JFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3Rbrparser = new Parser(false); } public function __destruct() { if (! isset($this->connection)) { return; } @pg_close($this->connection); } public function prepare(string $sql): Statement { $visitor = new ConvertParameters(); $this->parser->parse($sql, $visitor); $statementName = uniqid('dbal', true); if (@pg_send_prepare($this->connection, $statementName, $visitor->getSQL()) !== true) { throw new Exception(pg_last_error($this->connection)); } $result = @pg_get_result($this->connection); assert($result !== false); if ((bool) pg_result_error($result)) { throw Exception::fromResult($result); } return new Statement($this->connection, $statementName, $visitor->getParameterMap()); } public function query(string $sql): Result { if (@pg_send_query($this->connection, $sql) !== true) { throw new Exception(pg_last_error($this->connection)); } $result = @pg_get_result($this->connection); assert($result !== false); if ((bool) pg_result_error($result)) { throw Exception::fromResult($result); } return new Result($result); } /** {@inheritDoc} */ public function quote(string $value): string { $quotedValue = pg_escape_literal($this->connection, $value); assert($quotedValue !== false); return $quotedValue; } public function exec(string $sql): int { return $this->query($sql)->rowCount(); } /** {@inheritDoc} */ public function lastInsertId(): int|string { try { return $this->query('SELECT LASTVAL()')->fetchOne(); } catch (Exception $exception) { if ($exception->getSQLState() === '55000') { throw NoIdentityValue::new($exception); } throw $exception; } } public function beginTransaction(): void { $this->exec('BEGIN'); } public function commit(): void { $this->exec('COMMIT'); } public function rollBack(): void { $this->exec('ROLLBACK'); } public function getServerVersion(): string { return (string) pg_version($this->connection)['server']; } public function getNativeConnection(): PgSqlConnection { return $this->connection; } }