yf_db_driver_pdo_pgsql class

    public function auto_limit_one()
    {
        return false;
    }

    public function connect()
    {
        $dsn = 'pgsql:host=' . $this->params['host'];
        if ($this->params['port'] && $this->params['port'] != $this->DEF_PORT) {
            $dsn .= ';port=' . $this->params['port'];
        }
        $dsn .= ';dbname=' . (($this->params['name'] ?? null) ?: 'template1');
        $attrs = [];
        $attrs[PDO::ATTR_TIMEOUT] = 2;
        if ($this->params['persist']) {
            $attrs[PDO::ATTR_PERSISTENT] = true;
        }
        $this->db_connect_id = new PDO($dsn, $this->params['user'], $this->params['pswd'], $attrs);
        $pdo = &$this->db_connect_id;

        if ( ! $this->db_connect_id) {
            $this->_connect_error = 'cannot_connect_to_server';
            return $this->db_connect_id;
        }
        return $this->db_connect_id;
    }

    public function error()
    {
        $error = parent::error();
        if ($error && $this->db_connect_id) {
            $error['sqlstate'] = (string) ($this->db_connect_id->errorInfo()[0] ?? '');
        }
        return $error;
    }

    public function escape_key($data)
    {
        return '"' . str_replace('"', '""', trim($data, '"')) . '"';
    }

    public function escape_val($data)
    {
        if ($data === null) {
            return 'NULL';
        }
        if ($this->ESCAPE_BUILDER_VALUES) {
            if ($this->db_connect_id) {
                return $this->db_connect_id->quote((string) $data);
            }
            $data = str_replace('\'', '\'\'', $data);
        }
        return '\'' . $data . '\'';
    }

    public function is_follow_up_error($db_error)
    {
        return ($db_error['sqlstate'] ?? '') === '25P02';
    }

    public function is_reconnect_error($db_error, array $codes = [])
    {
        $sqlstate = (string) ($db_error['sqlstate'] ?? '');
        return substr($sqlstate, 0, 2) === '08' || in_array($sqlstate, ['57P01', '57P02', '57P03'], true);
    }

    public function limit($count, $offset)
    {
        if ($count > 0) {
            return 'LIMIT ' . $count . ($offset > 0 ? ' OFFSET ' . $offset : '');
        }
        return false;
    }

    public function no_cache_hint()
    {
        return '';
    }

    public function real_escape_string($string)
    {
        if ($string === null) {
            return 'NULL';
        }
        $quoted = $this->db_connect_id ? $this->db_connect_id->quote((string) $string) : false;
        if ($quoted !== false) {
            return substr($quoted, 1, -1);
        }
        // no connection, or PDO refused the bytes (invalid encoding): the server reports the encoding error
        return str_replace("'", "''", (string) $string);
    }

    public function repairable_error_codes()
    {
        return null;
    }

    public function supports_upsert()
    {
        return true;
    }

    public function __construct(array $params)
    {
        if ( ! extension_loaded('pdo_pgsql')) {
            throw new RuntimeException('YF PDO PgSQL db driver require missing php extension pdo_pgsql');
            return false;
        }
        $params['port'] = ($params['port'] ?? null) ?: 5432;
        $this->params = $params;
        $this->connect();
        return $this->db_connect_id;
    }