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

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.     /** @internal The connection can be only instantiated by its driver. */
  21.     public function __construct(PDO $connection)
  22.     {
  23.         $connection->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
  25.         $this->connection = $connection;
  26.     }
  28.     public function exec(string $sql): int
  29.     {
  30.         try {
  31.             $result = $this->connection->exec($sql);
  33.             assert($result !== false);
  35.             return $result;
  36.         } catch (PDOException $exception) {
  37.             throw Exception::new($exception);
  38.         }
  39.     }
  41.     /**
  42.      * {@inheritdoc}
  43.      */
  44.     public function getServerVersion()
  45.     {
  46.         return $this->connection->getAttribute(PDO::ATTR_SERVER_VERSION);
  47.     }
  49.     /**
  50.      * {@inheritDoc}
  51.      *
  52.      * @return Statement
  53.      */
  54.     public function prepare(string $sql): StatementInterface
  55.     {
  56.         try {
  57.             $stmt = $this->connection->prepare($sql);
  58.             assert($stmt instanceof PDOStatement);
  60.             return new Statement($stmt);
  61.         } catch (PDOException $exception) {
  62.             throw Exception::new($exception);
  63.         }
  64.     }
  66.     public function query(string $sql): ResultInterface
  67.     {
  68.         try {
  69.             $stmt = $this->connection->query($sql);
  70.             assert($stmt instanceof PDOStatement);
  72.             return new Result($stmt);
  73.         } catch (PDOException $exception) {
  74.             throw Exception::new($exception);
  75.         }
  76.     }
  78.     /**
  79.      * {@inheritdoc}
  80.      */
  81.     public function quote($value, $type = ParameterType::STRING)
  82.     {
  83.         return $this->connection->quote($value, $type);
  84.     }
  86.     /**
  87.      * {@inheritdoc}
  88.      */
  89.     public function lastInsertId($name = null)
  90.     {
  91.         try {
  92.             if ($name === null) {
  93.                 return $this->connection->lastInsertId();
  94.             }
  96.             Deprecation::triggerIfCalledFromOutside(
  97.                 'doctrine/dbal',
  98.                 'https://github.com/doctrine/dbal/issues/4687',
  99.                 'The usage of Connection::lastInsertId() with a sequence name is deprecated.',
  100.             );
  102.             return $this->connection->lastInsertId($name);
  103.         } catch (PDOException $exception) {
  104.             throw Exception::new($exception);
  105.         }
  106.     }
  108.     public function beginTransaction(): bool
  109.     {
  110.         return $this->connection->beginTransaction();
  111.     }
  113.     public function commit(): bool
  114.     {
  115.         return $this->connection->commit();
  116.     }
  118.     public function rollBack(): bool
  119.     {
  120.         return $this->connection->rollBack();
  121.     }
  123.     public function getNativeConnection(): PDO
  124.     {
  125.         return $this->connection;
  126.     }
  128.     /** @deprecated Call {@see getNativeConnection()} instead. */
  129.     public function getWrappedConnection(): PDO
  130.     {
  131.         Deprecation::triggerIfCalledFromOutside(
  132.             'doctrine/dbal',
  133.             'https://github.com/doctrine/dbal/pull/5037',
  134.             '%s is deprecated, call getNativeConnection() instead.',
  135.             __METHOD__,
  136.         );
  138.         return $this->getNativeConnection();
  139.     }
  140. }