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

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\Driver\AbstractMySQLDriver;
  10. use Doctrine\DBAL\DriverManager;
  11. use Doctrine\DBAL\Exception\DriverException;
  12. use Doctrine\DBAL\Platforms\AbstractPlatform;
  13. use Doctrine\DBAL\Types\Type;
  14. use function is_subclass_of;
  16. class ConnectionFactory
  17. {
  18.     /** @var mixed[][] */
  19.     private $typesConfig = [];
  21.     /** @var bool */
  22.     private $initialized = false;
  24.     /**
  25.      * @param mixed[][] $typesConfig
  26.      */
  27.     public function __construct(array $typesConfig)
  28.     {
  29.         $this->typesConfig = $typesConfig;
  30.     }
  32.     /**
  33.      * Create a connection by name.
  34.      *
  35.      * @param mixed[]         $params
  36.      * @param string[]|Type[] $mappingTypes
  37.      *
  38.      * @return Connection
  39.      */
  40.     public function createConnection(array $params, Configuration $config = null, EventManager $eventManager = null, array $mappingTypes = [])
  41.     {
  42.         if (! $this->initialized) {
  43.             $this->initializeTypes();
  44.         }
  46.         if (! isset($params['pdo']) && ! isset($params['charset'])) {
  47.             $wrapperClass = null;
  48.             if (isset($params['wrapperClass'])) {
  49.                 if (! is_subclass_of($params['wrapperClass'], Connection::class)) {
  50.                     throw DBALException::invalidWrapperClass($params['wrapperClass']);
  51.                 }
  53.                 $wrapperClass           = $params['wrapperClass'];
  54.                 $params['wrapperClass'] = null;
  55.             }
  57.             $connection = DriverManager::getConnection($params, $config, $eventManager);
  58.             $params     = $connection->getParams();
  59.             $driver     = $connection->getDriver();
  61.             if ($driver instanceof AbstractMySQLDriver) {
  62.                 $params['charset'] = 'utf8mb4';
  64.                 if (! isset($params['defaultTableOptions']['collate'])) {
  65.                     $params['defaultTableOptions']['collate'] = 'utf8mb4_unicode_ci';
  66.                 }
  67.             } else {
  68.                 $params['charset'] = 'utf8';
  69.             }
  71.             if ($wrapperClass !== null) {
  72.                 $params['wrapperClass'] = $wrapperClass;
  73.             } else {
  74.                 $wrapperClass = Connection::class;
  75.             }
  77.             $connection = new $wrapperClass($params, $driver, $config, $eventManager);
  78.         } else {
  79.             $connection = DriverManager::getConnection($params, $config, $eventManager);
  80.         }
  82.         if (! empty($mappingTypes)) {
  83.             $platform = $this->getDatabasePlatform($connection);
  84.             foreach ($mappingTypes as $dbType => $doctrineType) {
  85.                 $platform->registerDoctrineTypeMapping($dbType, $doctrineType);
  86.             }
  87.         }
  89.         return $connection;
  90.     }
  92.     /**
  93.      * Try to get the database platform.
  94.      *
  95.      * This could fail if types should be registered to an predefined/unused connection
  96.      * and the platform version is unknown.
  97.      * For details have a look at DoctrineBundle issue #673.
  98.      *
  99.      * @throws DBALException
  100.      */
  101.     private function getDatabasePlatform(Connection $connection) : AbstractPlatform
  102.     {
  103.         try {
  104.             return $connection->getDatabasePlatform();
  105.         } catch (DriverException $driverException) {
  106.             throw new DBALException(
  107.                 'An exception occured while establishing a connection to figure out your platform version.' . PHP_EOL .
  108.                 "You can circumvent this by setting a 'server_version' configuration value" . PHP_EOL . PHP_EOL .
  109.                 'For further information have a look at:' . PHP_EOL .
  110.                 'https://github.com/doctrine/DoctrineBundle/issues/673',
  111.                 0,
  112.                 $driverException
  113.             );
  114.         }
  115.     }
  117.     /**
  118.      * initialize the types
  119.      */
  120.     private function initializeTypes() : void
  121.     {
  122.         foreach ($this->typesConfig as $typeName => $typeConfig) {
  123.             if (Type::hasType($typeName)) {
  124.                 Type::overrideType($typeName, $typeConfig['class']);
  125.             } else {
  126.                 Type::addType($typeName, $typeConfig['class']);
  127.             }
  128.         }
  130.         $this->initialized = true;
  131.     }
  132. }