vendor/doctrine/doctrine-bundle/ConnectionFactory.php line 63

Open in your IDE?
  1. <?php
  3. namespace Doctrine\Bundle\DoctrineBundle;
  5. use Doctrine\Common\EventManager;
  6. use Doctrine\DBAL\Configuration;
  7. use Doctrine\DBAL\Connection;
  8. use Doctrine\DBAL\DBALException;
  9. use Doctrine\DBAL\DriverManager;
  10. use Doctrine\DBAL\Exception\DriverException;
  11. use Doctrine\DBAL\Platforms\AbstractPlatform;
  12. use Doctrine\DBAL\Types\Type;
  14. /**
  15.  * Connection
  16.  */
  17. class ConnectionFactory
  18. {
  19.     /** @var mixed[][] */
  20.     private $typesConfig = [];
  22.     /** @var string[] */
  23.     private $commentedTypes = [];
  25.     /** @var bool */
  26.     private $initialized = false;
  28.     /**
  29.      * Construct.
  30.      *
  31.      * @param mixed[][] $typesConfig
  32.      */
  33.     public function __construct(array $typesConfig)
  34.     {
  35.         $this->typesConfig = $typesConfig;
  36.     }
  38.     /**
  39.      * Create a connection by name.
  40.      *
  41.      * @param mixed[]         $params
  42.      * @param string[]|Type[] $mappingTypes
  43.      *
  44.      * @return Connection
  45.      */
  46.     public function createConnection(array $params, Configuration $config = null, EventManager $eventManager = null, array $mappingTypes = [])
  47.     {
  48.         if (! $this->initialized) {
  49.             $this->initializeTypes();
  50.         }
  52.         $connection = DriverManager::getConnection($params, $config, $eventManager);
  54.         if (! empty($mappingTypes)) {
  55.             $platform = $this->getDatabasePlatform($connection);
  56.             foreach ($mappingTypes as $dbType => $doctrineType) {
  57.                 $platform->registerDoctrineTypeMapping($dbType, $doctrineType);
  58.             }
  59.         }
  60.         if (! empty($this->commentedTypes)) {
  61.             $platform = $this->getDatabasePlatform($connection);
  62.             foreach ($this->commentedTypes as $type) {
  63.                 $platform->markDoctrineTypeCommented(Type::getType($type));
  64.             }
  65.         }
  67.         return $connection;
  68.     }
  70.     /**
  71.      * Try to get the database platform.
  72.      *
  73.      * This could fail if types should be registered to an predefined/unused connection
  74.      * and the platform version is unknown.
  75.      * For details have a look at DoctrineBundle issue #673.
  76.      *
  77.      * @return AbstractPlatform
  78.      *
  79.      * @throws DBALException
  80.      */
  81.     private function getDatabasePlatform(Connection $connection)
  82.     {
  83.         try {
  84.             return $connection->getDatabasePlatform();
  85.         } catch (DriverException $driverException) {
  86.             throw new DBALException(
  87.                 'An exception occured while establishing a connection to figure out your platform version.' . PHP_EOL .
  88.                 "You can circumvent this by setting a 'server_version' configuration value" . PHP_EOL . PHP_EOL .
  89.                 'For further information have a look at:' . PHP_EOL .
  90.                 'https://github.com/doctrine/DoctrineBundle/issues/673',
  91.                 0,
  92.                 $driverException
  93.             );
  94.         }
  95.     }
  97.     /**
  98.      * initialize the types
  99.      */
  100.     private function initializeTypes()
  101.     {
  102.         foreach ($this->typesConfig as $type => $typeConfig) {
  103.             if (Type::hasType($type)) {
  104.                 Type::overrideType($type, $typeConfig['class']);
  105.             } else {
  106.                 Type::addType($type, $typeConfig['class']);
  107.             }
  108.             if (! $typeConfig['commented']) {
  109.                 continue;
  110.             }
  112.             $this->commentedTypes[] = $type;
  113.         }
  114.         $this->initialized = true;
  115.     }
  116. }