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.      * {@inheritdoc}
  57.      */
  58.     public function prepare($prepareString, $driverOptions = [])
  59.     {
  60.         try {
  61.             return parent::prepare($prepareString, $driverOptions);
  62.         } catch (\PDOException $exception) {
  63.             throw new PDOException($exception);
  64.         }
  65.     }
  67.     /**
  68.      * {@inheritdoc}
  69.      */
  70.     public function query()
  71.     {
  72.         $args = func_get_args();
  74.         try {
  75.             $stmt = parent::query(...$args);
  76.             assert($stmt instanceof \PDOStatement);
  78.             return $stmt;
  79.         } catch (\PDOException $exception) {
  80.             throw new PDOException($exception);
  81.         }
  82.     }
  84.     /**
  85.      * {@inheritdoc}
  86.      */
  87.     public function quote($input, $type = ParameterType::STRING)
  88.     {
  89.         return parent::quote($input, $type);
  90.     }
  92.     /**
  93.      * {@inheritdoc}
  94.      */
  95.     public function lastInsertId($name = null)
  96.     {
  97.         try {
  98.             if ($name === null) {
  99.                 return parent::lastInsertId();
  100.             }
  102.             return parent::lastInsertId($name);
  103.         } catch (\PDOException $exception) {
  104.             throw new PDOException($exception);
  105.         }
  106.     }
  108.     /**
  109.      * {@inheritdoc}
  110.      */
  111.     public function requiresQueryForServerVersion()
  112.     {
  113.         return false;
  114.     }
  115. }