JFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3Rbr */ private array $parameters = []; /** @psalm-var array */ private array $parameterTypes = []; /** @param array $parameterMap */ public function __construct( private readonly PgSqlConnection $connection, private readonly string $name, private readonly array $parameterMap, ) { } public function __destruct() { if (! isset($this->connection)) { return; } @pg_query( $this->connection, 'DEALLOCATE ' . pg_escape_identifier($this->connection, $this->name), ); } /** {@inheritDoc} */ public function bindValue(int|string $param, mixed $value, ParameterType $type = ParameterType::STRING): void { if (! isset($this->parameterMap[$param])) { throw UnknownParameter::new((string) $param); } $this->parameters[$this->parameterMap[$param]] = $value; $this->parameterTypes[$this->parameterMap[$param]] = $type; } /** {@inheritDoc} */ public function execute(): Result { ksort($this->parameters); $escapedParameters = []; foreach ($this->parameters as $parameter => $value) { $escapedParameters[] = match ($this->parameterTypes[$parameter]) { ParameterType::BINARY, ParameterType::LARGE_OBJECT => $value === null ? null : pg_escape_bytea($this->connection, is_resource($value) ? stream_get_contents($value) : $value), default => $value, }; } if (@pg_send_execute($this->connection, $this->name, $escapedParameters) !== 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); } }