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

Open in your IDE?
  1. <?php
  3. namespace Doctrine\DBAL\Driver;
  5. use Doctrine\DBAL\Driver\Connection as ConnectionInterface;
  6. use Doctrine\DBAL\Driver\PDO\Exception;
  7. use Doctrine\DBAL\Driver\PDO\Statement;
  8. use Doctrine\DBAL\ParameterType;
  9. use PDO;
  10. use PDOException;
  11. use PDOStatement;
  13. use function assert;
  15. /**
  16.  * PDO implementation of the Connection interface.
  17.  * Used by all PDO-based drivers.
  18.  *
  19.  * @deprecated Use {@link Connection} instead
  20.  */
  21. class PDOConnection extends PDO implements ConnectionInterface, ServerInfoAwareConnection
  22. {
  23.     use PDOQueryImplementation;
  25.     /**
  26.      * @internal The connection can be only instantiated by its driver.
  27.      *
  28.      * @param string       $dsn
  29.      * @param string|null  $user
  30.      * @param string|null  $password
  31.      * @param mixed[]|null $options
  32.      *
  33.      * @throws PDOException In case of an error.
  34.      */
  35.     public function __construct($dsn, $user = null, $password = null, ?array $options = null)
  36.     {
  37.         try {
  38.             parent::__construct($dsn, (string) $user, (string) $password, (array) $options);
  39.             $this->setAttribute(PDO::ATTR_STATEMENT_CLASS, [Statement::class, []]);
  40.             $this->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  41.         } catch (PDOException $exception) {
  42.             throw Exception::new($exception);
  43.         }
  44.     }
  46.     /**
  47.      * {@inheritdoc}
  48.      */
  49.     public function exec($sql)
  50.     {
  51.         try {
  52.             $result = parent::exec($sql);
  53.             assert($result !== false);
  55.             return $result;
  56.         } catch (PDOException $exception) {
  57.             throw Exception::new($exception);
  58.         }
  59.     }
  61.     /**
  62.      * {@inheritdoc}
  63.      */
  64.     public function getServerVersion()
  65.     {
  66.         return PDO::getAttribute(PDO::ATTR_SERVER_VERSION);
  67.     }
  69.     /**
  70.      * @param string          $sql
  71.      * @param array<int, int> $driverOptions
  72.      *
  73.      * @return PDOStatement
  74.      */
  75.     public function prepare($sql, $driverOptions = [])
  76.     {
  77.         try {
  78.             $statement = parent::prepare($sql, $driverOptions);
  79.             assert($statement instanceof PDOStatement);
  81.             return $statement;
  82.         } catch (PDOException $exception) {
  83.             throw Exception::new($exception);
  84.         }
  85.     }
  87.     /**
  88.      * {@inheritdoc}
  89.      */
  90.     public function quote($value, $type = ParameterType::STRING)
  91.     {
  92.         return parent::quote($value, $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 Exception::new($exception);
  108.         }
  109.     }
  111.     /**
  112.      * {@inheritdoc}
  113.      */
  114.     public function requiresQueryForServerVersion()
  115.     {
  116.         return false;
  117.     }
  119.     /**
  120.      * @param mixed ...$args
  121.      */
  122.     private function doQuery(...$args): PDOStatement
  123.     {
  124.         try {
  125.             $stmt = parent::query(...$args);
  126.         } catch (PDOException $exception) {
  127.             throw Exception::new($exception);
  128.         }
  130.         assert($stmt instanceof PDOStatement);
  132.         return $stmt;
  133.     }
  134. }