vendor/doctrine/dbal/src/Driver/PDO/Connection.php line 71

Open in your IDE?
  1. <?php
  3. namespace Doctrine\DBAL\Driver\PDO;
  5. use Doctrine\DBAL\Driver\Result as ResultInterface;
  6. use Doctrine\DBAL\Driver\ServerInfoAwareConnection;
  7. use Doctrine\DBAL\Driver\Statement as StatementInterface;
  8. use Doctrine\DBAL\ParameterType;
  9. use Doctrine\Deprecations\Deprecation;
  10. use PDO;
  11. use PDOException;
  12. use PDOStatement;
  14. use function assert;
  16. final class Connection implements ServerInfoAwareConnection
  17. {
  18.     private PDO $connection;
  20.     /**
  21.      * @internal The connection can be only instantiated by its driver.
  22.      */
  23.     public function __construct(PDO $connection)
  24.     {
  25.         $connection->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  27.         $this->connection = $connection;
  28.     }
  30.     public function exec(string $sql): int
  31.     {
  32.         try {
  33.             $result = $this->connection->exec($sql);
  35.             assert($result !== false);
  37.             return $result;
  38.         } catch (PDOException $exception) {
  39.             throw Exception::new($exception);
  40.         }
  41.     }
  43.     /**
  44.      * {@inheritdoc}
  45.      */
  46.     public function getServerVersion()
  47.     {
  48.         return $this->connection->getAttribute(PDO::ATTR_SERVER_VERSION);
  49.     }
  51.     /**
  52.      * {@inheritDoc}
  53.      *
  54.      * @return Statement
  55.      */
  56.     public function prepare(string $sql): StatementInterface
  57.     {
  58.         try {
  59.             $stmt = $this->connection->prepare($sql);
  60.             assert($stmt instanceof PDOStatement);
  62.             return new Statement($stmt);
  63.         } catch (PDOException $exception) {
  64.             throw Exception::new($exception);
  65.         }
  66.     }
  68.     public function query(string $sql): ResultInterface
  69.     {
  70.         try {
  71.             $stmt = $this->connection->query($sql);
  72.             assert($stmt instanceof PDOStatement);
  74.             return new Result($stmt);
  75.         } catch (PDOException $exception) {
  76.             throw Exception::new($exception);
  77.         }
  78.     }
  80.     /**
  81.      * {@inheritdoc}
  82.      */
  83.     public function quote($value, $type = ParameterType::STRING)
  84.     {
  85.         return $this->connection->quote($value, $type);
  86.     }
  88.     /**
  89.      * {@inheritdoc}
  90.      */
  91.     public function lastInsertId($name = null)
  92.     {
  93.         try {
  94.             if ($name === null) {
  95.                 return $this->connection->lastInsertId();
  96.             }
  98.             Deprecation::triggerIfCalledFromOutside(
  99.                 'doctrine/dbal',
  100.                 'https://github.com/doctrine/dbal/issues/4687',
  101.                 'The usage of Connection::lastInsertId() with a sequence name is deprecated.'
  102.             );
  104.             return $this->connection->lastInsertId($name);
  105.         } catch (PDOException $exception) {
  106.             throw Exception::new($exception);
  107.         }
  108.     }
  110.     public function beginTransaction(): bool
  111.     {
  112.         return $this->connection->beginTransaction();
  113.     }
  115.     public function commit(): bool
  116.     {
  117.         return $this->connection->commit();
  118.     }
  120.     public function rollBack(): bool
  121.     {
  122.         return $this->connection->rollBack();
  123.     }
  125.     public function getNativeConnection(): PDO
  126.     {
  127.         return $this->connection;
  128.     }
  130.     /**
  131.      * @deprecated Call {@see getNativeConnection()} instead.
  132.      */
  133.     public function getWrappedConnection(): PDO
  134.     {
  135.         Deprecation::triggerIfCalledFromOutside(
  136.             'doctrine/dbal',
  137.             'https://github.com/doctrine/dbal/pull/5037',
  138.             '%s is deprecated, call getNativeConnection() instead.',
  139.             __METHOD__
  140.         );
  142.         return $this->getNativeConnection();
  143.     }
  144. }