Delete.php

<?php

/**
 * @license MIT
 * @license http://opensource.org/licenses/MIT
 */

namespace FaaPz\PDO\Statement;

use FaaPz\PDO\AdvancedStatement;
use FaaPz\PDO\Database;

class Delete extends AdvancedStatement implements DeleteInterface
{
    /** @var ?string|?array<string, string> $table */
    protected $table = null;


    /**
     * @param Database                       $dbh
     * @param ?string|?array<string, string> $table
     */
    public function __construct(Database $dbh, $table = null)
    {
        parent::__construct($dbh);

        if ($table != null) {
            $this->from($table);
        }
    }

    /**
     * @param string|array<string, string> $table
     *
     * @return self
     */
    public function from($table): self
    {
        $this->table = $table;

        return $this;
    }

    /**
     * @return string
     */
    protected function renderFrom(): string
    {
        if (empty($this->table)) {
            trigger_error('No table set for delete statement', E_USER_ERROR);
        }

        if (is_array($this->table)) {
            $table = reset($this->table);
            $alias = key($this->table);
            if (is_string($alias)) {
                $table .= " AS {$alias}";
            }
        } else {
            $table = $this->table;
        }

        return " FROM {$table}";
    }

    /**
     * @return array<int, mixed>
     */
    public function getValues(): array
    {
        $values = [];
        foreach ($this->join as $join) {
            $values = array_merge($values, $join->getValues());
        }

        if ($this->where != null) {
            $values = array_merge($values, $this->where->getValues());
        }

        if (!empty($this->orderBy)) {
            $values = array_merge($values, $this->orderBy);
        }

        if ($this->limit != null) {
            $values = array_merge($values, $this->limit->getValues());
        }

        return $values;
    }

    /**
     * @return string
     */
    public function __toString(): string
    {
        return 'DELETE'
            . $this->renderFrom()
            . $this->renderJoin()
            . $this->renderWhere()
            . $this->renderOrderBy()
            . $this->renderLimit();
    }
}