123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183 |
- <?php
- namespace Doctrine\DBAL\Driver\IBMDB2;
- use Doctrine\DBAL\Driver\Connection;
- use Doctrine\DBAL\Driver\ServerInfoAwareConnection;
- use Doctrine\DBAL\ParameterType;
- use stdClass;
- use const DB2_AUTOCOMMIT_OFF;
- use const DB2_AUTOCOMMIT_ON;
- use function db2_autocommit;
- use function db2_commit;
- use function db2_conn_error;
- use function db2_conn_errormsg;
- use function db2_connect;
- use function db2_escape_string;
- use function db2_exec;
- use function db2_last_insert_id;
- use function db2_num_rows;
- use function db2_pconnect;
- use function db2_prepare;
- use function db2_rollback;
- use function db2_server_info;
- use function db2_stmt_errormsg;
- use function func_get_args;
- class DB2Connection implements Connection, ServerInfoAwareConnection
- {
- /** @var resource */
- private $conn = null;
- /**
- * @param mixed[] $params
- * @param string $username
- * @param string $password
- * @param mixed[] $driverOptions
- *
- * @throws DB2Exception
- */
- public function __construct(array $params, $username, $password, $driverOptions = [])
- {
- $isPersistent = (isset($params['persistent']) && $params['persistent'] === true);
- if ($isPersistent) {
- $this->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(),
- ];
- }
- }
|