<?php namespace DBDiff\SQLGen\DiffToSQL;

use DBDiff\SQLGen\SQLGenInterface;
use DBDiff\SQLGen\Dialect\DialectRegistry;
use DBDiff\SQLGen\Dialect\SQLDialectInterface;
use DBDiff\DB\Data\BinaryValue;


class InsertDataSQL implements SQLGenInterface {

    protected $obj;
    protected SQLDialectInterface $dialect;

    public function __construct($obj, SQLDialectInterface $dialect = null) {
        $this->obj     = $obj;
        $this->dialect = $dialect ?? DialectRegistry::get();
    }
    
    public function getUp(): string {
        $t      = $this->dialect->quote($this->obj->table);
        $d      = $this->dialect;
        $row    = $this->obj->diff['diff']->getNewValue();
        $cols   = implode(',', array_map(fn($c) => $d->quote($c), array_keys($row)));
        $values = array_map(fn($el) => BinaryValue::formatSQL($el), $row);
        return "INSERT INTO $t ($cols) VALUES(" . implode(',', $values) . ");";
    }

    public function getDown(): string {
        $t    = $this->dialect->quote($this->obj->table);
        $d    = $this->dialect;
        $keys = $this->obj->diff['keys'];
        array_walk($keys, function (&$value, $column) use ($d) {
            $value = BinaryValue::formatCondition($d->quote($column), $value);
        });
        return "DELETE FROM $t WHERE " . implode(' AND ', $keys) . ';';
    }
}