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

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. private Connection $wrappedConnection;
  21. public function __construct(Connection $wrappedConnection)
  22. {
  23. $this->wrappedConnection = $wrappedConnection;
  24. }
  26. public function prepare(string $sql): Statement
  27. {
  28. return $this->wrappedConnection->prepare($sql);
  29. }
  31. public function query(string $sql): Result
  32. {
  33. return $this->wrappedConnection->query($sql);
  34. }
  36. /**
  37. * {@inheritDoc}
  38. */
  39. public function quote($value, $type = ParameterType::STRING)
  40. {
  41. return $this->wrappedConnection->quote($value, $type);
  42. }
  44. public function exec(string $sql): int
  45. {
  46. return $this->wrappedConnection->exec($sql);
  47. }
  49. /**
  50. * {@inheritDoc}
  51. */
  52. public function lastInsertId($name = null)
  53. {
  54. if ($name !== null) {
  55. Deprecation::triggerIfCalledFromOutside(
  56. 'doctrine/dbal',
  57. 'https://github.com/doctrine/dbal/issues/4687',
  58. 'The usage of Connection::lastInsertId() with a sequence name is deprecated.',
  59. );
  60. }
  62. return $this->wrappedConnection->lastInsertId($name);
  63. }
  65. /**
  66. * {@inheritDoc}
  67. */
  68. public function beginTransaction()
  69. {
  70. return $this->wrappedConnection->beginTransaction();
  71. }
  73. /**
  74. * {@inheritDoc}
  75. */
  76. public function commit()
  77. {
  78. return $this->wrappedConnection->commit();
  79. }
  81. /**
  82. * {@inheritDoc}
  83. */
  84. public function rollBack()
  85. {
  86. return $this->wrappedConnection->rollBack();
  87. }
  89. /**
  90. * {@inheritDoc}
  91. */
  92. public function getServerVersion()
  93. {
  94. if (! $this->wrappedConnection instanceof ServerInfoAwareConnection) {
  95. throw new LogicException('The underlying connection is not a ServerInfoAwareConnection');
  96. }
  98. return $this->wrappedConnection->getServerVersion();
  99. }
  101. /** @return resource|object */
  102. public function getNativeConnection()
  103. {
  104. if (! method_exists($this->wrappedConnection, 'getNativeConnection')) {
  105. throw new LogicException(sprintf(
  106. 'The driver connection %s does not support accessing the native connection.',
  107. get_class($this->wrappedConnection),
  108. ));
  109. }
  111. return $this->wrappedConnection->getNativeConnection();
  112. }
  113. }