<?php

namespace ByJG\AnyDataset\Db\Helpers;

use ByJG\AnyDataset\Core\Exception\NotAvailableException;
use ByJG\AnyDataset\Db\DbDriverInterface;
use ByJG\AnyDataset\Db\IsolationLevelEnum;

class DbSqliteFunctions extends DbBaseFunctions
{
    public function __construct()
    {
        $this->deliFieldLeft = '`';
        $this->deliFieldRight = '`';
        $this->deliTableLeft = '`';
        $this->deliTableRight = '`';
    }

    /**
     * @param string $str1
     * @param string|null $str2
     * @return string
     */
    public function concat(string $str1, ?string $str2 = null): string
    {
        return implode(' || ', func_get_args());
    }

    /**
     * Given a SQL returns it with the proper LIMIT or equivalent method included
     * @param string $sql
     * @param int $start
     * @param int $qty
     * @return string
     */
    public function limit(string $sql, int $start, int $qty = 50): string
    {
        if (stripos($sql, ' LIMIT ') === false) {
            $sql = $sql . " LIMIT x, y";
        }

        return preg_replace(
            '~(\s[Ll][Ii][Mm][Ii][Tt])\s.*?,\s*.*~',
            '$1 ' . $start .', ' .$qty,
            $sql
        );
    }

    /**
     * Given a SQL returns it with the proper TOP or equivalent method included
     * @param string $sql
     * @param int $qty
     * @return string
     */
    public function top(string $sql, int $qty): string
    {
        return $this->limit($sql, 0, $qty);
    }

    /**
     * Return if the database provider have a top or similar function
     * @return bool
     */
    public function hasTop(): bool
    {
        return true;
    }

    /**
     * Return if the database provider have a limit function
     * @return bool
     */
    public function hasLimit(): bool
    {
        return true;
    }

    /**
     * Format date column in sql string given an input format that understands Y M D
     *
     * @param string $format
     * @param string|null $column
     * @return string
     * @example $db->getDbFunctions()->SQLDate("d/m/Y H:i", "dtcriacao")
     */
    public function sqlDate(string $format, ?string $column = null): string
    {
        if (is_null($column)) {
            $column = "'now'";
        }

        $pattern = [
            'Y' => "%Y",
            'y' => "%Y",
            'M' => "%m",
            'm' => "%m",
            'Q' => "",
            'q' => "",
            'D' => "%d",
            'd' => "%d",
            'h' => "%H",
            'H' => "%H",
            'i' => "%M",
            's' => "%S",
            'a' => "",
            'A' => "",
        ];

        $preparedSql = $this->prepareSqlDate($format, $pattern, '');

        return sprintf(
            "strftime('%s', %s)",
            implode('', $preparedSql),
            $column
        );
    }

    /**
     * @param DbDriverInterface $dbdataset
     * @param string $sql
     * @param array|null $param
     * @return mixed
     */
    public function executeAndGetInsertedId(DbDriverInterface $dbdataset, string $sql, ?array $param = null): mixed
    {
        parent::executeAndGetInsertedId($dbdataset, $sql, $param);
        return $dbdataset->getScalar("SELECT last_insert_rowid()");
    }

    /**
     * @param string $sql
     * @return string
     * @throws \ByJG\AnyDataset\Core\Exception\NotAvailableException
     */
    public function forUpdate(string $sql): string
    {
        throw new NotAvailableException('FOR UPDATE not available for SQLite');
    }

    public function hasForUpdate(): bool
    {
        return false;
    }

    public function getTableMetadata(DbDriverInterface $dbdataset, string $tableName): array
    {
        $sql = "PRAGMA table_info(" . $this->deliTableLeft . $tableName . $this->deliTableRight . ")";
        return $this->getTableMetadataFromSql($dbdataset, $sql);
    }

    protected function parseColumnMetadata($metadata)
    {
        $return = [];

        foreach ($metadata as $key => $value) {
            $return[strtolower($value['name'])] = [
                'name' => $value['name'],
                'dbType' => strtolower($value['type']),
                'required' => $value['notnull'] == 1,
                'default' => $value['dflt_value'],
            ] + $this->parseTypeMetadata(strtolower($value['type']));
        }

        return $return;
    }

    public function getIsolationLevelCommand(?IsolationLevelEnum $isolationLevel = null): string
    {
        switch ($isolationLevel) {
            case IsolationLevelEnum::READ_UNCOMMITTED:
                return "PRAGMA read_uncommitted = true;";
            case IsolationLevelEnum::READ_COMMITTED:
            case IsolationLevelEnum::REPEATABLE_READ:
            case IsolationLevelEnum::SERIALIZABLE:
            default:
                return "";
        }
    }
}__halt_compiler();----SIGNATURE:----iYevzN5+IB0hrkdILkslbnKYTnv3c6G4p7EcXeC4bhoo6znvp0agcKH47E6w4xP8VmdBjr9inEX7j1SjLS6cwvWrFMv2Gsw2C0j8cGOEghhwpniC/bdsO5M+HsxHi6TMb54HX0Hu/SDNS/lsm2FHFfUDWxNHr7Srn+It2/kfANdrIaRYkelq39Cle03ubYOQtr/t9d6b1nq37yp0ps4vaUVfg1pY7pSyN+0xI1wapD4khawKirtrAr7krg7v9YrZAaHUmx5V5Yk9jG6Won6jPCE+ULM7rvgwfOSQDShbv8hI1M4GJDBAWuJv5qwXpbLNKIdI7O9kpyWy9lVHftPdkb3EvT+TLmFnDYFqKB5tm7zZEojrdnqRDk0yAkR9mtxC7d5caKZdZp9XXL4exwMdVBeK78IKF/sLSA6g7WkaUDS0akey3e1mvTCTRP4ShNvpBeCbW29XKDDHAdsKIEO42HEHmmzWSe/wRUT8ReE1DCDtbtmUME5XyCzeojwwnSdMaDefrO90Aed676fQs1zjJs2/o6Gu13Jse/Hb98grRqk55yQSJp2LIvJgnVQt85dWQppWwDhCOyJLbWiCRTswlnjzRpz21fGB+rkyGzxWJeHfIzOn58yvOu+x6lxsQ5KN7c9+jJfxrs4G+l3XnXNF11c0hZjEb6V7MMg1IWwqQnU=----ATTACHMENT:----Nzc2NTA1OTA1Mjk0Nzc0NSA5NTg3OTMwMzM2NDY5OTU2IDkwNzIzMzk4MzU0MjMyOTY=