vendor/sentry/sentry-symfony/src/Tracing/Doctrine/DBAL/TracingDriverConnectionFactoryForV2V3.php line 48

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Sentry\SentryBundle\Tracing\Doctrine\DBAL;
  7. use Doctrine\DBAL\Driver\Connection;
  8. use Doctrine\DBAL\Driver\ServerInfoAwareConnection;
  9. use Doctrine\DBAL\Platforms\AbstractMySQLPlatform;
  10. use Doctrine\DBAL\Platforms\AbstractPlatform;
  11. use Doctrine\DBAL\Platforms\DB2Platform;
  12. use Doctrine\DBAL\Platforms\OraclePlatform;
  13. use Doctrine\DBAL\Platforms\PostgreSQLPlatform;
  14. use Doctrine\DBAL\Platforms\SqlitePlatform;
  15. use Doctrine\DBAL\Platforms\SQLServerPlatform;
  16. use Sentry\State\HubInterface;
  18. /**
  19.  * @internal
  20.  */
  21. final class TracingDriverConnectionFactoryForV2V3 implements TracingDriverConnectionFactoryInterface
  22. {
  23.     /**
  24.      * @var HubInterface The current hub
  25.      */
  26.     private $hub;
  28.     /**
  29.      * @var bool Whether prepare spans should be ignored
  30.      */
  31.     private $ignorePrepareSpans;
  33.     /**
  34.      * Constructor.
  35.      *
  36.      * @param HubInterface $hub                The current hub
  37.      * @param bool         $ignorePrepareSpans Whether prepare spans should be ignored
  38.      */
  39.     public function __construct(HubInterface $hub, bool $ignorePrepareSpans = false)
  40.     {
  41.         $this->hub = $hub;
  42.         $this->ignorePrepareSpans = $ignorePrepareSpans;
  43.     }
  45.     /**
  46.      * {@inheritdoc}
  47.      */
  48.     public function create(Connection $connection, AbstractPlatform $databasePlatform, array $params): TracingDriverConnectionInterface
  49.     {
  50.         $tracingDriverConnection = new TracingDriverConnection(
  51.             $this->hub,
  52.             $connection,
  53.             $this->getDatabasePlatform($databasePlatform),
  54.             $params,
  55.             $this->ignorePrepareSpans
  56.         );
  58.         if ($connection instanceof ServerInfoAwareConnection) {
  59.             $tracingDriverConnection = new TracingServerInfoAwareDriverConnection($tracingDriverConnection);
  60.         }
  62.         return $tracingDriverConnection;
  63.     }
  65.     private function getDatabasePlatform(AbstractPlatform $databasePlatform): string
  66.     {
  67.         // https://github.com/open-telemetry/opentelemetry-specification/blob/33113489fb5a1b6da563abb4ffa541447b87f515/specification/trace/semantic_conventions/database.md#connection-level-attributes
  68.         switch (true) {
  69.             case $databasePlatform instanceof AbstractMySQLPlatform:
  70.                 return 'mysql';
  72.             case $databasePlatform instanceof DB2Platform:
  73.                 return 'db2';
  75.             case $databasePlatform instanceof OraclePlatform:
  76.                 return 'oracle';
  78.             case $databasePlatform instanceof PostgreSQLPlatform:
  79.                 return 'postgresql';
  81.             case $databasePlatform instanceof SqlitePlatform:
  82.                 return 'sqlite';
  84.             case $databasePlatform instanceof SQLServerPlatform:
  85.                 return 'mssql';
  87.             default:
  88.                 return 'other_sql';
  89.         }
  90.     }
  91. }