vendor/sentry/sentry-symfony/src/Tracing/Doctrine/DBAL/TracingDriverForV2.php line 51

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Sentry\SentryBundle\Tracing\Doctrine\DBAL;
  7. use Doctrine\DBAL\Connection;
  8. use Doctrine\DBAL\Driver;
  9. use Doctrine\DBAL\Driver\DriverException;
  10. use Doctrine\DBAL\Driver\ExceptionConverterDriver;
  11. use Doctrine\DBAL\Exception\DriverException as DBALDriverException;
  12. use Doctrine\DBAL\Platforms\AbstractPlatform;
  13. use Doctrine\DBAL\Schema\AbstractSchemaManager;
  14. use Doctrine\DBAL\VersionAwarePlatformDriver;
  16. /**
  17.  * This is a simple implementation of the {@see Driver} interface that decorates
  18.  * an existing driver to support distributed tracing capabilities. This implementation
  19.  * is compatible only with DBAL version < 3.0.
  20.  *
  21.  * @internal
  22.  */
  23. final class TracingDriverForV2 implements Driver, VersionAwarePlatformDriver, ExceptionConverterDriver
  24. {
  25.     /**
  26.      * @var TracingDriverConnectionFactoryInterface
  27.      */
  28.     private $connectionFactory;
  30.     /**
  31.      * @var Driver|VersionAwarePlatformDriver|ExceptionConverterDriver The instance of the decorated driver
  32.      */
  33.     private $decoratedDriver;
  35.     /**
  36.      * @param TracingDriverConnectionFactoryInterface $connectionFactory The connection factory
  37.      * @param Driver                                  $decoratedDriver   The instance of the driver to decorate
  38.      */
  39.     public function __construct(TracingDriverConnectionFactoryInterface $connectionFactory, Driver $decoratedDriver)
  40.     {
  41.         $this->decoratedDriver = $decoratedDriver;
  42.         $this->connectionFactory = $connectionFactory;
  43.     }
  45.     /**
  46.      * {@inheritdoc}
  47.      */
  48.     public function connect(array $params, $username = null, $password = null, array $driverOptions = []): TracingDriverConnectionInterface
  49.     {
  50.         return $this->connectionFactory->create(
  51.             $this->decoratedDriver->connect($params, $username, $password, $driverOptions),
  52.             $this->decoratedDriver->getDatabasePlatform(),
  53.             $params
  54.         );
  55.     }
  57.     /**
  58.      * {@inheritdoc}
  59.      */
  60.     public function getDatabasePlatform(): AbstractPlatform
  61.     {
  62.         return $this->decoratedDriver->getDatabasePlatform();
  63.     }
  65.     /**
  66.      * {@inheritdoc}
  67.      */
  68.     public function getSchemaManager(Connection $conn, ?AbstractPlatform $platform = null): AbstractSchemaManager
  69.     {
  70.         return $this->decoratedDriver->getSchemaManager($conn, $platform);
  71.     }
  73.     /**
  74.      * {@inheritdoc}
  75.      */
  76.     public function getName(): string
  77.     {
  78.         return $this->decoratedDriver->getName();
  79.     }
  81.     /**
  82.      * {@inheritdoc}
  83.      */
  84.     public function getDatabase(Connection $conn): ?string
  85.     {
  86.         return $this->decoratedDriver->getDatabase($conn);
  87.     }
  89.     /**
  90.      * {@inheritdoc}
  91.      */
  92.     public function createDatabasePlatformForVersion($version): AbstractPlatform
  93.     {
  94.         if ($this->decoratedDriver instanceof VersionAwarePlatformDriver) {
  95.             return $this->decoratedDriver->createDatabasePlatformForVersion($version);
  96.         }
  98.         return $this->getDatabasePlatform();
  99.     }
  101.     /**
  102.      * {@inheritdoc}
  103.      */
  104.     public function convertException($message, DriverException $exception): DBALDriverException
  105.     {
  106.         if ($this->decoratedDriver instanceof ExceptionConverterDriver) {
  107.             return $this->decoratedDriver->convertException($message, $exception);
  108.         }
  110.         return new DBALDriverException($message, $exception);
  111.     }
  112. }