<?php

namespace ByJG\AnyDataset\Db\Helpers;

use ByJG\AnyDataset\Db\DbDriverInterface;

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

    public function concat($str1, $str2 = null)
    {
        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($sql, $start, $qty = null)
    {
        if (is_null($qty)) {
            $qty = 50;
        }

        if (stripos($sql, ' LIMIT ') === false) {
            $sql = $sql . " LIMIT x OFFSET y";
        }

        return preg_replace(
            '~(\s[Ll][Ii][Mm][Ii][Tt])\s.*?\s([Oo][Ff][Ff][Ss][Ee][Tt])\s.*~',
            '$1 ' . $qty .' $2 ' .$start,
            $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($sql, $qty)
    {
        return $this->limit($sql, 0, $qty);
    }

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

    /**
     * Return if the database provider have a limit function
     * @return bool
     */
    public function hasLimit()
    {
        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($format, $column = null)
    {
        if (is_null($column)) {
            $column = 'current_timestamp';
        }

        $pattern = [
            'Y' => "YYYY",
            'y' => "YY",
            'M' => "Mon",
            'm' => "MM",
            'Q' => "Q",
            'q' => "Q",
            'D' => "DD",
            'd' => "DD",
            'h' => "HH",
            'H' => "HH24",
            'i' => "MI",
            's' => "SS",
            'a' => "AM",
            'A' => "AM",
        ];

        return sprintf(
            "TO_CHAR(%s,'%s')",
            $column,
            implode('', $this->prepareSqlDate($format, $pattern, ''))
        );
    }

    /**
     * @param DbDriverInterface $dbdataset
     * @param string $sql
     * @param array $param
     * @return int
     */
    public function executeAndGetInsertedId(DbDriverInterface $dbdataset, $sql, $param)
    {
        parent::executeAndGetInsertedId($dbdataset, $sql, $param);
        return $dbdataset->getScalar('select lastval()');
    }

    public function hasForUpdate()
    {
        return true;
    }
}
__halt_compiler();----SIGNATURE:----D4aBvzcHJHHYJuqUmkH8xGF8OyjJEYGQi3nvf3pf+Gdnkxo4y9/LokUMfz8jrp85IQ+SOvJVEnA2d/dEW+40LizFeDr7U+Dn6Xcbh1sU6M1bNOT10zjgHrwFWMJF15+25I9FZ1w6kbgGMZYYMVkvO46YvGgEG9CcwtpPAlBzT2mb7DBaGUpKmYME4+wqdXyh5D+A5o3cCeNDiF93KjIhRvqiEXDfCBJxzjS2ASkYvoOOJ3HP0ky/Wb8HaPeA+6TA5MeRZ06ojvbaEG8GSOW+BXnvz8U6qy+h3VEUa73NGqnNv7NRyeCzbFgVfdhPl1/lgO1fsP0QH7WiWPvL+APoiG7dEoVRfsrM4LFVsxb34Dhgw8oT/FHTiV6oHoYlf+AcRgmaGB7haZPTeoKgftJMnxRWfGJ8NBlqbLSj1MU43YymsYSb21mPI2qXR3L0f999bqusFr8nf0ad8G7C4DX+ptMgF3KMZiC7aOS7R/sHucvJzF2Gx/Ls7x/SFjtPuGE7NUyaunJfPgi2EA59UaKxwlY3ay1k7lonIHOybPM1/wPFoeJn8XNw+t+ceeapoqt8y1WjgHGUHBDFWDPjCKtYfFUztU8DVFAVmMTpXlUlVGJcPDYsIsXHFtE+mdhWNOFGCp5GFDx87iuU5Ib0vBOJDnPRwp7EpL6nl9oXEA+a29E=----ATTACHMENT:----MzUxMzQxOTM2NTExODQ4OSAxMTU4NTAwNDg4NDk4NDAxIDUwNDczOTI2MzAyODg4MjM=