vendor/doctrine/dbal/lib/Doctrine/DBAL/Driver/PDOConnection.php line 31

Open in your IDE?
  1. <?php
  3. namespace Doctrine\DBAL\Driver;
  5. use Doctrine\DBAL\ParameterType;
  6. use PDO;
  7. use function assert;
  8. use function func_get_args;
  10. /**
  11.  * PDO implementation of the Connection interface.
  12.  * Used by all PDO-based drivers.
  13.  */
  14. class PDOConnection extends PDO implements Connection, ServerInfoAwareConnection
  15. {
  16.     /**
  17.      * @param string       $dsn
  18.      * @param string|null  $user
  19.      * @param string|null  $password
  20.      * @param mixed[]|null $options
  21.      *
  22.      * @throws PDOException In case of an error.
  23.      */
  24.     public function __construct($dsn, $user = null, $password = null, ?array $options = null)
  25.     {
  26.         try {
  27.             parent::__construct($dsn, (string) $user, (string) $password, (array) $options);
  28.             $this->setAttribute(PDO::ATTR_STATEMENT_CLASS, [PDOStatement::class, []]);
  29.             $this->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  30.         } catch (\PDOException $exception) {
  31.             throw new PDOException($exception);
  32.         }
  33.     }
  35.     /**
  36.      * {@inheritdoc}
  37.      */
  38.     public function exec($statement)
  39.     {
  40.         try {
  41.             return parent::exec($statement);
  42.         } catch (\PDOException $exception) {
  43.             throw new PDOException($exception);
  44.         }
  45.     }
  47.     /**
  48.      * {@inheritdoc}
  49.      */
  50.     public function getServerVersion()
  51.     {
  52.         return PDO::getAttribute(PDO::ATTR_SERVER_VERSION);
  53.     }
  55.     /**
  56.      * @param string          $prepareString
  57.      * @param array<int, int> $driverOptions
  58.      *
  59.      * @return Statement
  60.      */
  61.     public function prepare($prepareString, $driverOptions = [])
  62.     {
  63.         try {
  64.             return parent::prepare($prepareString, $driverOptions);
  65.         } catch (\PDOException $exception) {
  66.             throw new PDOException($exception);
  67.         }
  68.     }
  70.     /**
  71.      * {@inheritdoc}
  72.      */
  73.     public function query()
  74.     {
  75.         $args = func_get_args();
  77.         try {
  78.             $stmt = parent::query(...$args);
  79.             assert($stmt instanceof \PDOStatement);
  81.             return $stmt;
  82.         } catch (\PDOException $exception) {
  83.             throw new PDOException($exception);
  84.         }
  85.     }
  87.     /**
  88.      * {@inheritdoc}
  89.      */
  90.     public function quote($input, $type = ParameterType::STRING)
  91.     {
  92.         return parent::quote($input, $type);
  93.     }
  95.     /**
  96.      * {@inheritdoc}
  97.      */
  98.     public function lastInsertId($name = null)
  99.     {
  100.         try {
  101.             if ($name === null) {
  102.                 return parent::lastInsertId();
  103.             }
  105.             return parent::lastInsertId($name);
  106.         } catch (\PDOException $exception) {
  107.             throw new PDOException($exception);
  108.         }
  109.     }
  111.     /**
  112.      * {@inheritdoc}
  113.      */
  114.     public function requiresQueryForServerVersion()
  115.     {
  116.         return false;
  117.     }
  118. }