conn = db2_pconnect($params['dbname'], $username, $password, $driverOptions); } else { $this->conn = db2_connect($params['dbname'], $username, $password, $driverOptions); } if (! $this->conn) { throw new DB2Exception(db2_conn_errormsg()); } } /** * {@inheritdoc} */ public function getServerVersion() { /** @var stdClass $serverInfo */ $serverInfo = db2_server_info($this->conn); return $serverInfo->DBMS_VER; } /** * {@inheritdoc} */ public function requiresQueryForServerVersion() { return false; } /** * {@inheritdoc} */ public function prepare($sql) { $stmt = @db2_prepare($this->conn, $sql); if (! $stmt) { throw new DB2Exception(db2_stmt_errormsg()); } return new DB2Statement($stmt); } /** * {@inheritdoc} */ public function query() { $args = func_get_args(); $sql = $args[0]; $stmt = $this->prepare($sql); $stmt->execute(); return $stmt; } /** * {@inheritdoc} */ public function quote($input, $type = ParameterType::STRING) { $input = db2_escape_string($input); if ($type === ParameterType::INTEGER) { return $input; } return "'" . $input . "'"; } /** * {@inheritdoc} */ public function exec($statement) { $stmt = @db2_exec($this->conn, $statement); if ($stmt === false) { throw new DB2Exception(db2_stmt_errormsg()); } return db2_num_rows($stmt); } /** * {@inheritdoc} */ public function lastInsertId($name = null) { return db2_last_insert_id($this->conn); } /** * {@inheritdoc} */ public function beginTransaction() { db2_autocommit($this->conn, DB2_AUTOCOMMIT_OFF); } /** * {@inheritdoc} */ public function commit() { if (! db2_commit($this->conn)) { throw new DB2Exception(db2_conn_errormsg($this->conn)); } db2_autocommit($this->conn, DB2_AUTOCOMMIT_ON); } /** * {@inheritdoc} */ public function rollBack() { if (! db2_rollback($this->conn)) { throw new DB2Exception(db2_conn_errormsg($this->conn)); } db2_autocommit($this->conn, DB2_AUTOCOMMIT_ON); } /** * {@inheritdoc} */ public function errorCode() { return db2_conn_error($this->conn); } /** * {@inheritdoc} */ public function errorInfo() { return [ 0 => db2_conn_errormsg($this->conn), 1 => $this->errorCode(), ]; } }