JFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3Rbrstmt->param_count; $this->types = str_repeat(self::PARAMETER_TYPE_STRING, $paramCount); $this->boundValues = array_fill(1, $paramCount, null); } public function bindValue(int|string $param, mixed $value, ParameterType $type): void { assert(is_int($param)); $this->types[$param - 1] = $this->convertParameterType($type); $this->values[$param] = $value; $this->boundValues[$param] =& $this->values[$param]; } public function execute(): Result { if (count($this->boundValues) > 0) { $this->bindParameters(); } try { if (! $this->stmt->execute()) { throw StatementError::new($this->stmt); } } catch (mysqli_sql_exception $e) { throw StatementError::upcast($e); } return new Result($this->stmt); } /** * Binds parameters with known types previously bound to the statement * * @throws Exception */ private function bindParameters(): void { $streams = $values = []; $types = $this->types; foreach ($this->boundValues as $parameter => $value) { assert(is_int($parameter)); if (! isset($types[$parameter - 1])) { $types[$parameter - 1] = self::PARAMETER_TYPE_STRING; } if ($types[$parameter - 1] === self::PARAMETER_TYPE_BINARY) { if (is_resource($value)) { if (get_resource_type($value) !== 'stream') { throw NonStreamResourceUsedAsLargeObject::new($parameter); } $streams[$parameter] = $value; $values[$parameter] = null; continue; } $types[$parameter - 1] = self::PARAMETER_TYPE_STRING; } $values[$parameter] = $value; } if (! $this->stmt->bind_param($types, ...$values)) { throw StatementError::new($this->stmt); } $this->sendLongData($streams); } /** * Handle $this->_longData after regular query parameters have been bound * * @param array $streams * * @throws Exception */ private function sendLongData(array $streams): void { foreach ($streams as $paramNr => $stream) { while (! feof($stream)) { $chunk = fread($stream, 8192); if ($chunk === false) { throw FailedReadingStreamOffset::new($paramNr); } if (! $this->stmt->send_long_data($paramNr - 1, $chunk)) { throw StatementError::new($this->stmt); } } } } private function convertParameterType(ParameterType $type): string { return match ($type) { ParameterType::NULL, ParameterType::STRING, ParameterType::ASCII, ParameterType::BINARY => self::PARAMETER_TYPE_STRING, ParameterType::INTEGER, ParameterType::BOOLEAN => self::PARAMETER_TYPE_INTEGER, ParameterType::LARGE_OBJECT => self::PARAMETER_TYPE_BINARY, }; } }