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

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 Doctrine\Deprecations\Deprecation;
  10. use PDO;
  11. use PDOException;
  12. use PDOStatement;
  14. use function assert;
  16. /**
  17.  * PDO implementation of the Connection interface.
  18.  * Used by all PDO-based drivers.
  19.  *
  20.  * @deprecated Use {@link Connection} instead
  21.  */
  22. class PDOConnection extends PDO implements ConnectionInterface, ServerInfoAwareConnection
  23. {
  24.     use PDOQueryImplementation;
  26.     /**
  27.      * @internal The connection can be only instantiated by its driver.
  28.      *
  29.      * @param string       $dsn
  30.      * @param string|null  $user
  31.      * @param string|null  $password
  32.      * @param mixed[]|null $options
  33.      *
  34.      * @throws PDOException In case of an error.
  35.      */
  36.     public function __construct($dsn, $user = null, $password = null, ?array $options = null)
  37.     {
  38.         try {
  39.             parent::__construct($dsn, (string) $user, (string) $password, (array) $options);
  40.             $this->setAttribute(PDO::ATTR_STATEMENT_CLASS, [Statement::class, []]);
  41.             $this->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  42.         } catch (PDOException $exception) {
  43.             throw Exception::new($exception);
  44.         }
  45.     }
  47.     /**
  48.      * {@inheritdoc}
  49.      */
  50.     public function exec($sql)
  51.     {
  52.         try {
  53.             $result = parent::exec($sql);
  54.             assert($result !== false);
  56.             return $result;
  57.         } catch (PDOException $exception) {
  58.             throw Exception::new($exception);
  59.         }
  60.     }
  62.     /**
  63.      * {@inheritdoc}
  64.      */
  65.     public function getServerVersion()
  66.     {
  67.         return PDO::getAttribute(PDO::ATTR_SERVER_VERSION);
  68.     }
  70.     /**
  71.      * @param string          $sql
  72.      * @param array<int, int> $driverOptions
  73.      *
  74.      * @return PDOStatement
  75.      */
  76.     public function prepare($sql, $driverOptions = [])
  77.     {
  78.         try {
  79.             $statement = parent::prepare($sql, $driverOptions);
  80.             assert($statement instanceof PDOStatement);
  82.             return $statement;
  83.         } catch (PDOException $exception) {
  84.             throw Exception::new($exception);
  85.         }
  86.     }
  88.     /**
  89.      * {@inheritdoc}
  90.      */
  91.     public function quote($value, $type = ParameterType::STRING)
  92.     {
  93.         return parent::quote($value, $type);
  94.     }
  96.     /**
  97.      * {@inheritdoc}
  98.      */
  99.     public function lastInsertId($name = null)
  100.     {
  101.         try {
  102.             if ($name === null) {
  103.                 return parent::lastInsertId();
  104.             }
  106.             return parent::lastInsertId($name);
  107.         } catch (PDOException $exception) {
  108.             throw Exception::new($exception);
  109.         }
  110.     }
  112.     /**
  113.      * {@inheritdoc}
  114.      */
  115.     public function requiresQueryForServerVersion()
  116.     {
  117.         Deprecation::triggerIfCalledFromOutside(
  118.             'doctrine/dbal',
  119.             'https://github.com/doctrine/dbal/pull/4114',
  120.             'ServerInfoAwareConnection::requiresQueryForServerVersion() is deprecated and removed in DBAL 3.'
  121.         );
  123.         return false;
  124.     }
  126.     /**
  127.      * @param mixed ...$args
  128.      */
  129.     private function doQuery(...$args): PDOStatement
  130.     {
  131.         try {
  132.             $stmt = parent::query(...$args);
  133.         } catch (PDOException $exception) {
  134.             throw Exception::new($exception);
  135.         }
  137.         assert($stmt instanceof PDOStatement);
  139.         return $stmt;
  140.     }
  141. }