conn = $conn; } /** * {@inheritdoc} */ public function getServerVersion() { $serverInfo = db2_server_info($this->conn); assert($serverInfo instanceof stdClass); return $serverInfo->DBMS_VER; } /** * {@inheritdoc} */ public function requiresQueryForServerVersion() { Deprecation::triggerIfCalledFromOutside( 'doctrine/dbal', 'https://github.com/doctrine/dbal/pull/4114', 'ServerInfoAwareConnection::requiresQueryForServerVersion() is deprecated and removed in DBAL 3.' ); return false; } /** * {@inheritdoc} */ public function prepare($sql) { $stmt = @db2_prepare($this->conn, $sql); if ($stmt === false) { throw PrepareFailed::new(error_get_last()); } return new Statement($stmt); } /** * {@inheritdoc} */ public function query() { $args = func_get_args(); $sql = $args[0]; $stmt = $this->prepare($sql); $stmt->execute(); return $stmt; } /** * {@inheritdoc} */ public function quote($value, $type = ParameterType::STRING) { $value = db2_escape_string($value); if ($type === ParameterType::INTEGER) { return $value; } return "'" . $value . "'"; } /** * {@inheritdoc} */ public function exec($sql) { $stmt = @db2_exec($this->conn, $sql); if ($stmt === false) { throw ConnectionError::new($this->conn); } return db2_num_rows($stmt); } /** * {@inheritdoc} */ public function lastInsertId($name = null) { return db2_last_insert_id($this->conn); } /** * {@inheritdoc} */ public function beginTransaction() { $result = db2_autocommit($this->conn, DB2_AUTOCOMMIT_OFF); assert(is_bool($result)); return $result; } /** * {@inheritdoc} */ public function commit() { if (! db2_commit($this->conn)) { throw ConnectionError::new($this->conn); } $result = db2_autocommit($this->conn, DB2_AUTOCOMMIT_ON); assert(is_bool($result)); return $result; } /** * {@inheritdoc} */ public function rollBack() { if (! db2_rollback($this->conn)) { throw ConnectionError::new($this->conn); } $result = db2_autocommit($this->conn, DB2_AUTOCOMMIT_ON); assert(is_bool($result)); return $result; } /** * {@inheritdoc} * * @deprecated The error information is available via exceptions. */ public function errorCode() { return db2_conn_error($this->conn); } /** * {@inheritdoc} * * @deprecated The error information is available via exceptions. */ public function errorInfo() { return [ 0 => db2_conn_errormsg($this->conn), 1 => $this->errorCode(), ]; } }