conn = $conn; $this->lastInsertId = new LastInsertId(); } /** * {@inheritdoc} */ public function getServerVersion() { $serverInfo = sqlsrv_server_info($this->conn); return $serverInfo['SQLServerVersion']; } /** * {@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) { return new Statement($this->conn, $sql, $this->lastInsertId); } /** * {@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) { if (is_int($value)) { return $value; } if (is_float($value)) { return sprintf('%F', $value); } return "'" . str_replace("'", "''", $value) . "'"; } /** * {@inheritDoc} */ public function exec($sql) { $stmt = sqlsrv_query($this->conn, $sql); if ($stmt === false) { throw Error::new(); } $rowsAffected = sqlsrv_rows_affected($stmt); if ($rowsAffected === false) { throw Error::new(); } return $rowsAffected; } /** * {@inheritDoc} */ public function lastInsertId($name = null) { if ($name !== null) { $stmt = $this->prepare('SELECT CONVERT(VARCHAR(MAX), current_value) FROM sys.sequences WHERE name = ?'); $stmt->execute([$name]); } else { $stmt = $this->query('SELECT @@IDENTITY'); } if ($stmt instanceof Result) { return $stmt->fetchOne(); } return $stmt->fetchColumn(); } /** * {@inheritDoc} */ public function beginTransaction() { if (! sqlsrv_begin_transaction($this->conn)) { throw Error::new(); } return true; } /** * {@inheritDoc} */ public function commit() { if (! sqlsrv_commit($this->conn)) { throw Error::new(); } return true; } /** * {@inheritDoc} */ public function rollBack() { if (! sqlsrv_rollback($this->conn)) { throw Error::new(); } return true; } /** * {@inheritDoc} * * @deprecated The error information is available via exceptions. */ public function errorCode() { $errors = sqlsrv_errors(SQLSRV_ERR_ERRORS); if ($errors) { return $errors[0]['code']; } return null; } /** * {@inheritDoc} * * @deprecated The error information is available via exceptions. */ public function errorInfo() { return (array) sqlsrv_errors(SQLSRV_ERR_ERRORS); } }