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

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