<?php namespace Doctrine\DBAL\Driver; use Doctrine\DBAL\ParameterType; use PDO; use function assert; /** * PDO implementation of the Connection interface. * * Used by all PDO-based drivers. */ class PDOConnection implements Connection, ServerInfoAwareConnection { /** @var PDO */ private $connection; /** * @param string $dsn * @param string|null $user * @param string|null $password * @param mixed[]|null $options * * @throws PDOException In case of an error. */ public function __construct($dsn, $user = null, $password = null, ?array $options = null) { try { $this->connection = new PDO($dsn, (string) $user, (string) $password, (array) $options); $this->connection->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); } catch (\PDOException $exception) { throw new PDOException($exception); } } /** * {@inheritdoc} */ public function exec(string $statement) : int { try { return $this->connection->exec($statement); } catch (\PDOException $exception) { throw new PDOException($exception); } } /** * {@inheritdoc} */ public function getServerVersion() { return $this->connection->getAttribute(PDO::ATTR_SERVER_VERSION); } /** * {@inheritdoc} */ public function prepare(string $sql) : Statement { try { return $this->createStatement( $this->connection->prepare($sql) ); } catch (\PDOException $exception) { throw new PDOException($exception); } } /** * {@inheritdoc} */ public function query(string $sql) : ResultStatement { try { $stmt = $this->connection->query($sql); assert($stmt instanceof \PDOStatement); return $this->createStatement($stmt); } catch (\PDOException $exception) { throw new PDOException($exception); } } /** * {@inheritdoc} */ public function quote($input, $type = ParameterType::STRING) { return $this->connection->quote($input, $type); } /** * {@inheritdoc} */ public function lastInsertId($name = null) { try { if ($name === null) { return $this->connection->lastInsertId(); } return $this->connection->lastInsertId($name); } catch (\PDOException $exception) { throw new PDOException($exception); } } /** * {@inheritdoc} */ public function requiresQueryForServerVersion() { return false; } /** * Creates a wrapped statement */ protected function createStatement(\PDOStatement $stmt) : PDOStatement { return new PDOStatement($stmt); } /** * {@inheritDoc} */ public function beginTransaction() { return $this->connection->beginTransaction(); } /** * {@inheritDoc} */ public function commit() { return $this->connection->commit(); } /** * {@inheritDoc} */ public function rollBack() { return $this->connection->rollBack(); } /** * {@inheritDoc} */ public function errorCode() { return $this->connection->errorCode(); } /** * {@inheritDoc} */ public function errorInfo() { return $this->connection->errorInfo(); } public function getWrappedConnection() : PDO { return $this->connection; } }