vendor/doctrine/dbal/src/Driver/Middleware/AbstractConnectionMiddleware.php line 34

Open in your IDE?
  1. <?php
  3. namespace Doctrine\DBAL\Driver\Middleware;
  5. use Doctrine\DBAL\Driver\Connection;
  6. use Doctrine\DBAL\Driver\Result;
  7. use Doctrine\DBAL\Driver\ServerInfoAwareConnection;
  8. use Doctrine\DBAL\Driver\Statement;
  9. use Doctrine\DBAL\ParameterType;
  10. use Doctrine\Deprecations\Deprecation;
  11. use LogicException;
  13. use function get_class;
  14. use function method_exists;
  15. use function sprintf;
  17. abstract class AbstractConnectionMiddleware implements ServerInfoAwareConnection
  18. {
  19.     /** @var Connection */
  20.     private $wrappedConnection;
  22.     public function __construct(Connection $wrappedConnection)
  23.     {
  24.         $this->wrappedConnection = $wrappedConnection;
  25.     }
  27.     public function prepare(string $sql): Statement
  28.     {
  29.         return $this->wrappedConnection->prepare($sql);
  30.     }
  32.     public function query(string $sql): Result
  33.     {
  34.         return $this->wrappedConnection->query($sql);
  35.     }
  37.     /**
  38.      * {@inheritdoc}
  39.      */
  40.     public function quote($value, $type = ParameterType::STRING)
  41.     {
  42.         return $this->wrappedConnection->quote($value, $type);
  43.     }
  45.     public function exec(string $sql): int
  46.     {
  47.         return $this->wrappedConnection->exec($sql);
  48.     }
  50.     /**
  51.      * {@inheritdoc}
  52.      */
  53.     public function lastInsertId($name = null)
  54.     {
  55.         if ($name !== null) {
  56.             Deprecation::triggerIfCalledFromOutside(
  57.                 'doctrine/dbal',
  58.                 'https://github.com/doctrine/dbal/issues/4687',
  59.                 'The usage of Connection::lastInsertId() with a sequence name is deprecated.'
  60.             );
  61.         }
  63.         return $this->wrappedConnection->lastInsertId($name);
  64.     }
  66.     /**
  67.      * {@inheritdoc}
  68.      */
  69.     public function beginTransaction()
  70.     {
  71.         return $this->wrappedConnection->beginTransaction();
  72.     }
  74.     /**
  75.      * {@inheritdoc}
  76.      */
  77.     public function commit()
  78.     {
  79.         return $this->wrappedConnection->commit();
  80.     }
  82.     /**
  83.      * {@inheritdoc}
  84.      */
  85.     public function rollBack()
  86.     {
  87.         return $this->wrappedConnection->rollBack();
  88.     }
  90.     /**
  91.      * {@inheritdoc}
  92.      */
  93.     public function getServerVersion()
  94.     {
  95.         if (! $this->wrappedConnection instanceof ServerInfoAwareConnection) {
  96.             throw new LogicException('The underlying connection is not a ServerInfoAwareConnection');
  97.         }
  99.         return $this->wrappedConnection->getServerVersion();
  100.     }
  102.     /**
  103.      * @return resource|object
  104.      */
  105.     public function getNativeConnection()
  106.     {
  107.         if (! method_exists($this->wrappedConnection, 'getNativeConnection')) {
  108.             throw new LogicException(sprintf(
  109.                 'The driver connection %s does not support accessing the native connection.',
  110.                 get_class($this->wrappedConnection)
  111.             ));
  112.         }
  114.         return $this->wrappedConnection->getNativeConnection();
  115.     }
  116. }