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

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