vendor/dama/doctrine-test-bundle/src/DAMA/DoctrineTestBundle/Doctrine/DBAL/StaticDriver.php line 37

Open in your IDE?
  1. <?php
  3. namespace DAMA\DoctrineTestBundle\Doctrine\DBAL;
  5. use Doctrine\DBAL\Driver;
  6. use Doctrine\DBAL\Driver\API\ExceptionConverter;
  7. use Doctrine\DBAL\Driver\Connection;
  8. use Doctrine\DBAL\Driver\Connection as DriverConnection;
  9. use Doctrine\DBAL\Platforms\AbstractPlatform;
  10. use Doctrine\DBAL\Schema\AbstractSchemaManager;
  12. class StaticDriver implements Driver
  13. {
  14.     /**
  15.      * @var Connection[]
  16.      */
  17.     protected static $connections = [];
  19.     /**
  20.      * @var bool
  21.      */
  22.     protected static $keepStaticConnections = false;
  24.     /**
  25.      * @var Driver
  26.      */
  27.     protected $underlyingDriver;
  29.     public function __construct(Driver $underlyingDriver)
  30.     {
  31.         $this->underlyingDriver = $underlyingDriver;
  32.     }
  34.     public function connect(array $params): DriverConnection
  35.     {
  36.         if (!self::$keepStaticConnections) {
  37.             return $this->underlyingDriver->connect($params);
  38.         }
  40.         $key = sha1(json_encode($params));
  42.         if (!isset(self::$connections[$key])) {
  43.             self::$connections[$key] = $this->underlyingDriver->connect($params);
  44.             self::$connections[$key]->beginTransaction();
  45.         }
  47.         return new StaticConnection(self::$connections[$key]);
  48.     }
  50.     public function getSchemaManager(\Doctrine\DBAL\Connection $conn, AbstractPlatform $platform): AbstractSchemaManager
  51.     {
  52.         return $this->underlyingDriver->getSchemaManager($conn, $platform);
  53.     }
  55.     public function getExceptionConverter(): ExceptionConverter
  56.     {
  57.         return $this->underlyingDriver->getExceptionConverter();
  58.     }
  60.     public function getDatabasePlatform(): AbstractPlatform
  61.     {
  62.         return $this->underlyingDriver->getDatabasePlatform();
  63.     }
  65.     public static function setKeepStaticConnections(bool $keepStaticConnections): void
  66.     {
  67.         self::$keepStaticConnections = $keepStaticConnections;
  68.     }
  70.     public static function isKeepStaticConnections(): bool
  71.     {
  72.         return self::$keepStaticConnections;
  73.     }
  75.     public static function beginTransaction(): void
  76.     {
  77.         foreach (self::$connections as $con) {
  78.             $con->beginTransaction();
  79.         }
  80.     }
  82.     public static function rollBack(): void
  83.     {
  84.         foreach (self::$connections as $con) {
  85.             $con->rollBack();
  86.         }
  87.     }
  89.     public static function commit(): void
  90.     {
  91.         foreach (self::$connections as $con) {
  92.             $con->commit();
  93.         }
  94.     }
  95. }