vendor/doctrine/doctrine-bundle/DependencyInjection/DoctrineExtension.php line 394

  1. <?php
  2. namespace Doctrine\Bundle\DoctrineBundle\DependencyInjection;
  3. use Doctrine\Bundle\DoctrineBundle\Attribute\AsDoctrineListener;
  4. use Doctrine\Bundle\DoctrineBundle\Attribute\AsEntityListener;
  5. use Doctrine\Bundle\DoctrineBundle\Attribute\AsMiddleware;
  6. use Doctrine\Bundle\DoctrineBundle\CacheWarmer\DoctrineMetadataCacheWarmer;
  7. use Doctrine\Bundle\DoctrineBundle\Dbal\ManagerRegistryAwareConnectionProvider;
  8. use Doctrine\Bundle\DoctrineBundle\Dbal\RegexSchemaAssetFilter;
  9. use Doctrine\Bundle\DoctrineBundle\DependencyInjection\Compiler\IdGeneratorPass;
  10. use Doctrine\Bundle\DoctrineBundle\DependencyInjection\Compiler\ServiceRepositoryCompilerPass;
  11. use Doctrine\Bundle\DoctrineBundle\EventSubscriber\EventSubscriberInterface;
  12. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepositoryInterface;
  13. use Doctrine\Common\Annotations\Annotation;
  14. use Doctrine\DBAL\Connection;
  15. use Doctrine\DBAL\Connections\PrimaryReadReplicaConnection;
  16. use Doctrine\DBAL\Driver\Middleware as MiddlewareInterface;
  17. use Doctrine\ORM\Configuration as OrmConfiguration;
  18. use Doctrine\ORM\EntityManager;
  19. use Doctrine\ORM\EntityManagerInterface;
  20. use Doctrine\ORM\Id\AbstractIdGenerator;
  21. use Doctrine\ORM\Proxy\Autoloader;
  22. use Doctrine\ORM\Tools\Console\Command\ConvertMappingCommand;
  23. use Doctrine\ORM\Tools\Console\Command\EnsureProductionSettingsCommand;
  24. use Doctrine\ORM\Tools\Export\ClassMetadataExporter;
  25. use Doctrine\ORM\UnitOfWork;
  26. use Doctrine\Persistence\Reflection\RuntimeReflectionProperty;
  27. use InvalidArgumentException;
  28. use LogicException;
  29. use ReflectionMethod;
  30. use Symfony\Bridge\Doctrine\ArgumentResolver\EntityValueResolver;
  31. use Symfony\Bridge\Doctrine\Attribute\MapEntity;
  32. use Symfony\Bridge\Doctrine\DependencyInjection\AbstractDoctrineExtension;
  33. use Symfony\Bridge\Doctrine\IdGenerator\UlidGenerator;
  34. use Symfony\Bridge\Doctrine\IdGenerator\UuidGenerator;
  35. use Symfony\Bridge\Doctrine\PropertyInfo\DoctrineExtractor;
  36. use Symfony\Bridge\Doctrine\SchemaListener\PdoCacheAdapterDoctrineSchemaSubscriber;
  37. use Symfony\Bridge\Doctrine\Validator\DoctrineLoader;
  38. use Symfony\Component\Cache\Adapter\ArrayAdapter;
  39. use Symfony\Component\Cache\Adapter\PhpArrayAdapter;
  40. use Symfony\Component\Config\FileLocator;
  41. use Symfony\Component\DependencyInjection\Alias;
  42. use Symfony\Component\DependencyInjection\ChildDefinition;
  43. use Symfony\Component\DependencyInjection\ContainerBuilder;
  44. use Symfony\Component\DependencyInjection\Definition;
  45. use Symfony\Component\DependencyInjection\Loader\XmlFileLoader;
  46. use Symfony\Component\DependencyInjection\Reference;
  47. use Symfony\Component\ExpressionLanguage\ExpressionLanguage;
  48. use Symfony\Component\Form\AbstractType;
  49. use Symfony\Component\Messenger\Bridge\Doctrine\Transport\DoctrineTransportFactory;
  50. use Symfony\Component\Messenger\MessageBusInterface;
  51. use Symfony\Component\PropertyInfo\PropertyInfoExtractorInterface;
  52. use Symfony\Component\Validator\Mapping\Loader\LoaderInterface;
  53. use Symfony\Component\VarExporter\LazyGhostTrait;
  54. use function array_intersect_key;
  55. use function array_keys;
  56. use function class_exists;
  57. use function interface_exists;
  58. use function is_dir;
  59. use function method_exists;
  60. use function reset;
  61. use function sprintf;
  62. use function str_replace;
  63. use function trait_exists;
  64. /**
  65.  * DoctrineExtension is an extension for the Doctrine DBAL and ORM library.
  66.  */
  67. class DoctrineExtension extends AbstractDoctrineExtension
  68. {
  69.     private string $defaultConnection;
  70.     /**
  71.      * {@inheritDoc}
  72.      */
  73.     public function load(array $configsContainerBuilder $container)
  74.     {
  75.         $configuration $this->getConfiguration($configs$container);
  76.         $config        $this->processConfiguration($configuration$configs);
  77.         if (! empty($config['dbal'])) {
  78.             $this->dbalLoad($config['dbal'], $container);
  79.             $this->loadMessengerServices($container);
  80.         }
  81.         if (empty($config['orm'])) {
  82.             return;
  83.         }
  84.         if (empty($config['dbal'])) {
  85.             throw new LogicException('Configuring the ORM layer requires to configure the DBAL layer as well.');
  86.         }
  87.         $this->ormLoad($config['orm'], $container);
  88.     }
  89.     /**
  90.      * Loads the DBAL configuration.
  91.      *
  92.      * Usage example:
  93.      *
  94.      *      <doctrine:dbal id="myconn" dbname="sfweb" user="root" />
  95.      *
  96.      * @param array<string, mixed> $config    An array of configuration settings
  97.      * @param ContainerBuilder     $container A ContainerBuilder instance
  98.      */
  99.     protected function dbalLoad(array $configContainerBuilder $container)
  100.     {
  101.         $loader = new XmlFileLoader($container, new FileLocator(__DIR__ '/../Resources/config'));
  102.         $loader->load('dbal.xml');
  103.         if (empty($config['default_connection'])) {
  104.             $keys                         array_keys($config['connections']);
  105.             $config['default_connection'] = reset($keys);
  106.         }
  107.         $this->defaultConnection $config['default_connection'];
  108.         $container->setAlias('database_connection'sprintf('doctrine.dbal.%s_connection'$this->defaultConnection));
  109.         $container->getAlias('database_connection')->setPublic(true);
  110.         $container->setAlias('doctrine.dbal.event_manager', new Alias(sprintf('doctrine.dbal.%s_connection.event_manager'$this->defaultConnection), false));
  111.         $container->setParameter('doctrine.dbal.connection_factory.types'$config['types']);
  112.         $connections = [];
  113.         foreach (array_keys($config['connections']) as $name) {
  114.             $connections[$name] = sprintf('doctrine.dbal.%s_connection'$name);
  115.         }
  116.         $container->setParameter('doctrine.connections'$connections);
  117.         $container->setParameter('doctrine.default_connection'$this->defaultConnection);
  118.         $connWithLogging   = [];
  119.         $connWithProfiling = [];
  120.         $connWithBacktrace = [];
  121.         foreach ($config['connections'] as $name => $connection) {
  122.             if ($connection['logging']) {
  123.                 $connWithLogging[] = $name;
  124.             }
  125.             if ($connection['profiling']) {
  126.                 $connWithProfiling[] = $name;
  127.                 if ($connection['profiling_collect_backtrace']) {
  128.                     $connWithBacktrace[] = $name;
  129.                 }
  130.             }
  131.             $this->loadDbalConnection($name$connection$container);
  132.         }
  133.         $container->registerForAutoconfiguration(MiddlewareInterface::class)->addTag('doctrine.middleware');
  134.         $container->registerAttributeForAutoconfiguration(AsMiddleware::class, static function (ChildDefinition $definitionAsMiddleware $attribute) {
  135.             if ($attribute->connections === []) {
  136.                 $definition->addTag('doctrine.middleware');
  137.                 return;
  138.             }
  139.             foreach ($attribute->connections as $connName) {
  140.                 $definition->addTag('doctrine.middleware', ['connection' => $connName]);
  141.             }
  142.         });
  143.         $this->useMiddlewaresIfAvailable($container$connWithLogging$connWithProfiling$connWithBacktrace);
  144.     }
  145.     /**
  146.      * Loads a configured DBAL connection.
  147.      *
  148.      * @param string               $name       The name of the connection
  149.      * @param array<string, mixed> $connection A dbal connection configuration.
  150.      * @param ContainerBuilder     $container  A ContainerBuilder instance
  151.      */
  152.     protected function loadDbalConnection($name, array $connectionContainerBuilder $container)
  153.     {
  154.         $configuration $container->setDefinition(sprintf('doctrine.dbal.%s_connection.configuration'$name), new ChildDefinition('doctrine.dbal.connection.configuration'));
  155.         unset($connection['logging']);
  156.         $dataCollectorDefinition $container->getDefinition('data_collector.doctrine');
  157.         $dataCollectorDefinition->replaceArgument(1$connection['profiling_collect_schema_errors']);
  158.         unset(
  159.             $connection['profiling'],
  160.             $connection['profiling_collect_backtrace'],
  161.             $connection['profiling_collect_schema_errors']
  162.         );
  163.         if (isset($connection['auto_commit'])) {
  164.             $configuration->addMethodCall('setAutoCommit', [$connection['auto_commit']]);
  165.         }
  166.         unset($connection['auto_commit']);
  167.         if (isset($connection['schema_filter']) && $connection['schema_filter']) {
  168.             $definition = new Definition(RegexSchemaAssetFilter::class, [$connection['schema_filter']]);
  169.             $definition->addTag('doctrine.dbal.schema_filter', ['connection' => $name]);
  170.             $container->setDefinition(sprintf('doctrine.dbal.%s_regex_schema_filter'$name), $definition);
  171.         }
  172.         unset($connection['schema_filter']);
  173.         // event manager
  174.         $container->setDefinition(sprintf('doctrine.dbal.%s_connection.event_manager'$name), new ChildDefinition('doctrine.dbal.connection.event_manager'));
  175.         // connection
  176.         $options $this->getConnectionOptions($connection);
  177.         $connectionId sprintf('doctrine.dbal.%s_connection'$name);
  178.         $def $container
  179.             ->setDefinition($connectionId, new ChildDefinition('doctrine.dbal.connection'))
  180.             ->setPublic(true)
  181.             ->setArguments([
  182.                 $options,
  183.                 new Reference(sprintf('doctrine.dbal.%s_connection.configuration'$name)),
  184.                 new Reference(sprintf('doctrine.dbal.%s_connection.event_manager'$name)),
  185.                 $connection['mapping_types'],
  186.             ]);
  187.         $container
  188.             ->registerAliasForArgument($connectionIdConnection::class, sprintf('%sConnection'$name))
  189.             ->setPublic(false);
  190.         // Set class in case "wrapper_class" option was used to assist IDEs
  191.         if (isset($options['wrapperClass'])) {
  192.             $def->setClass($options['wrapperClass']);
  193.         }
  194.         if (! empty($connection['use_savepoints'])) {
  195.             $def->addMethodCall('setNestTransactionsWithSavepoints', [$connection['use_savepoints']]);
  196.         }
  197.         $container->setDefinition(
  198.             ManagerRegistryAwareConnectionProvider::class,
  199.             new Definition(ManagerRegistryAwareConnectionProvider::class, [$container->getDefinition('doctrine')])
  200.         );
  201.     }
  202.     /**
  203.      * @param array<string, mixed> $connection
  204.      *
  205.      * @return mixed[]
  206.      */
  207.     protected function getConnectionOptions(array $connection): array
  208.     {
  209.         $options $connection;
  210.         $connectionDefaults = [
  211.             'host' => 'localhost',
  212.             'port' => null,
  213.             'user' => 'root',
  214.             'password' => null,
  215.         ];
  216.         if ($options['override_url'] ?? false) {
  217.             $options['connection_override_options'] = array_intersect_key($options, ['dbname' => null] + $connectionDefaults);
  218.         }
  219.         unset($options['override_url']);
  220.         $options += $connectionDefaults;
  221.         foreach (['replicas''slaves'] as $connectionKey) {
  222.             foreach (array_keys($options[$connectionKey]) as $name) {
  223.                 $options[$connectionKey][$name] += $connectionDefaults;
  224.             }
  225.         }
  226.         if (isset($options['platform_service'])) {
  227.             $options['platform'] = new Reference($options['platform_service']);
  228.             unset($options['platform_service']);
  229.         }
  230.         unset($options['mapping_types']);
  231.         foreach (
  232.             [
  233.                 'options' => 'driverOptions',
  234.                 'driver_class' => 'driverClass',
  235.                 'wrapper_class' => 'wrapperClass',
  236.                 'keep_slave' => 'keepReplica',
  237.                 'keep_replica' => 'keepReplica',
  238.                 'replicas' => 'replica',
  239.                 'server_version' => 'serverVersion',
  240.                 'default_table_options' => 'defaultTableOptions',
  241.             ] as $old => $new
  242.         ) {
  243.             if (! isset($options[$old])) {
  244.                 continue;
  245.             }
  246.             $options[$new] = $options[$old];
  247.             unset($options[$old]);
  248.         }
  249.         foreach (['replica''slaves'] as $connectionKey) {
  250.             foreach ($options[$connectionKey] as $name => $value) {
  251.                 $driverOptions       $value['driverOptions'] ?? [];
  252.                 $parentDriverOptions $options['driverOptions'] ?? [];
  253.                 if ($driverOptions === [] && $parentDriverOptions === []) {
  254.                     continue;
  255.                 }
  256.                 $options[$connectionKey][$name]['driverOptions'] = $driverOptions $parentDriverOptions;
  257.             }
  258.         }
  259.         if (! empty($options['slaves']) || ! empty($options['replica'])) {
  260.             $nonRewrittenKeys = [
  261.                 'driver' => true,
  262.                 'driverClass' => true,
  263.                 'wrapperClass' => true,
  264.                 'keepSlave' => true,
  265.                 'keepReplica' => true,
  266.                 'platform' => true,
  267.                 'slaves' => true,
  268.                 'primary' => true,
  269.                 'replica' => true,
  270.                 'serverVersion' => true,
  271.                 'defaultTableOptions' => true,
  272.                 // included by safety but should have been unset already
  273.                 'logging' => true,
  274.                 'profiling' => true,
  275.                 'mapping_types' => true,
  276.                 'platform_service' => true,
  277.             ];
  278.             foreach ($options as $key => $value) {
  279.                 if (isset($nonRewrittenKeys[$key])) {
  280.                     continue;
  281.                 }
  282.                 $options['primary'][$key] = $value;
  283.                 unset($options[$key]);
  284.             }
  285.             if (empty($options['wrapperClass'])) {
  286.                 // Change the wrapper class only if user did not configure custom one.
  287.                 $options['wrapperClass'] = PrimaryReadReplicaConnection::class;
  288.             }
  289.         } else {
  290.             unset($options['slaves'], $options['replica']);
  291.         }
  292.         return $options;
  293.     }
  294.     /**
  295.      * Loads the Doctrine ORM configuration.
  296.      *
  297.      * Usage example:
  298.      *
  299.      *     <doctrine:orm id="mydm" connection="myconn" />
  300.      *
  301.      * @param array<string, mixed> $config    An array of configuration settings
  302.      * @param ContainerBuilder     $container A ContainerBuilder instance
  303.      */
  304.     protected function ormLoad(array $configContainerBuilder $container)
  305.     {
  306.         if (! class_exists(UnitOfWork::class)) {
  307.             throw new LogicException('To configure the ORM layer, you must first install the doctrine/orm package.');
  308.         }
  309.         $loader = new XmlFileLoader($container, new FileLocator(__DIR__ '/../Resources/config'));
  310.         $loader->load('orm.xml');
  311.         if (! (new ReflectionMethod(EntityManager::class, '__construct'))->isPublic()) {
  312.             $container->getDefinition('doctrine.orm.entity_manager.abstract')
  313.                 ->setFactory(['%doctrine.orm.entity_manager.class%''create']);
  314.         }
  315.         if (class_exists(AbstractType::class)) {
  316.             $container->getDefinition('form.type.entity')->addTag('kernel.reset', ['method' => 'reset']);
  317.         }
  318.         if (! class_exists(Annotation::class)) {
  319.             $container->removeAlias('doctrine.orm.metadata.annotation_reader');
  320.         }
  321.         // available in Symfony 5.1 and up to Symfony 5.4 (deprecated)
  322.         if (! class_exists(PdoCacheAdapterDoctrineSchemaSubscriber::class)) {
  323.             $container->removeDefinition('doctrine.orm.listeners.pdo_cache_adapter_doctrine_schema_subscriber');
  324.         }
  325.         if (! class_exists(UlidGenerator::class)) {
  326.             $container->removeDefinition('doctrine.ulid_generator');
  327.         }
  328.         if (! class_exists(UuidGenerator::class)) {
  329.             $container->removeDefinition('doctrine.uuid_generator');
  330.         }
  331.         // available in Symfony 6.2 and higher
  332.         if (! class_exists(EntityValueResolver::class)) {
  333.             $container->removeDefinition('doctrine.orm.entity_value_resolver');
  334.             $container->removeDefinition('doctrine.orm.entity_value_resolver.expression_language');
  335.         } else {
  336.             if (! class_exists(ExpressionLanguage::class)) {
  337.                 $container->removeDefinition('doctrine.orm.entity_value_resolver.expression_language');
  338.             }
  339.             $controllerResolverDefaults = [];
  340.             if (! $config['controller_resolver']['enabled']) {
  341.                 $controllerResolverDefaults['disabled'] = true;
  342.             }
  343.             if (! $config['controller_resolver']['auto_mapping']) {
  344.                 $controllerResolverDefaults['mapping'] = [];
  345.             }
  346.             if ($config['controller_resolver']['evict_cache']) {
  347.                 $controllerResolverDefaults['evict_cache'] = true;
  348.             }
  349.             if ($controllerResolverDefaults) {
  350.                 $container->getDefinition('doctrine.orm.entity_value_resolver')->setArgument(2, (new Definition(MapEntity::class))->setArguments([
  351.                     null,
  352.                     null,
  353.                     null,
  354.                     $controllerResolverDefaults['mapping'] ?? null,
  355.                     null,
  356.                     null,
  357.                     null,
  358.                     $controllerResolverDefaults['evict_cache'] ?? null,
  359.                     $controllerResolverDefaults['disabled'] ?? false,
  360.                 ]));
  361.             }
  362.         }
  363.         // not available in Doctrine ORM 3.0 and higher
  364.         if (! class_exists(ConvertMappingCommand::class)) {
  365.             $container->removeDefinition('doctrine.mapping_convert_command');
  366.         }
  367.         if (! class_exists(EnsureProductionSettingsCommand::class)) {
  368.             $container->removeDefinition('doctrine.ensure_production_settings_command');
  369.         }
  370.         if (! class_exists(ClassMetadataExporter::class)) {
  371.             $container->removeDefinition('doctrine.mapping_import_command');
  372.         }
  373.         $entityManagers = [];
  374.         foreach (array_keys($config['entity_managers']) as $name) {
  375.             $entityManagers[$name] = sprintf('doctrine.orm.%s_entity_manager'$name);
  376.         }
  377.         $container->setParameter('doctrine.entity_managers'$entityManagers);
  378.         if (empty($config['default_entity_manager'])) {
  379.             $tmp                              array_keys($entityManagers);
  380.             $config['default_entity_manager'] = reset($tmp);
  381.         }
  382.         $container->setParameter('doctrine.default_entity_manager'$config['default_entity_manager']);
  383.         if ($config['enable_lazy_ghost_objects'] ?? false) {
  384.             if (! method_exists(OrmConfiguration::class, 'setLazyGhostObjectEnabled')) {
  385.                 throw new LogicException(
  386.                     'Lazy ghost objects cannot be enabled because the "doctrine/orm" library'
  387.                     ' version 2.14 or higher is not installed. Please run "composer update doctrine/orm".'
  388.                 );
  389.             }
  390.             // available in Symfony 6.2 and higher
  391.             /** @psalm-suppress UndefinedClass */
  392.             if (! trait_exists(LazyGhostTrait::class)) {
  393.                 throw new LogicException(
  394.                     'Lazy ghost objects cannot be enabled because the "symfony/var-exporter" library'
  395.                     ' version 6.2 or higher is not installed. Please run "composer require symfony/var-exporter:^6.2".'
  396.                 );
  397.             }
  398.             if (! class_exists(RuntimeReflectionProperty::class)) {
  399.                 throw new LogicException(
  400.                     'Lazy ghost objects cannot be enabled because the "doctrine/persistence" library'
  401.                     ' version 3.1 or higher is not installed. Please run "composer update doctrine/persistence".'
  402.                 );
  403.             }
  404.         }
  405.         $options = ['auto_generate_proxy_classes''enable_lazy_ghost_objects''proxy_dir''proxy_namespace'];
  406.         foreach ($options as $key) {
  407.             $container->setParameter('doctrine.orm.' $key$config[$key]);
  408.         }
  409.         $container->setAlias('doctrine.orm.entity_manager'$defaultEntityManagerDefinitionId sprintf('doctrine.orm.%s_entity_manager'$config['default_entity_manager']));
  410.         $container->getAlias('doctrine.orm.entity_manager')->setPublic(true);
  411.         $config['entity_managers'] = $this->fixManagersAutoMappings($config['entity_managers'], $container->getParameter('kernel.bundles'));
  412.         foreach ($config['entity_managers'] as $name => $entityManager) {
  413.             $entityManager['name'] = $name;
  414.             $this->loadOrmEntityManager($entityManager$container);
  415.             if (interface_exists(PropertyInfoExtractorInterface::class)) {
  416.                 $this->loadPropertyInfoExtractor($name$container);
  417.             }
  418.             if (! interface_exists(LoaderInterface::class)) {
  419.                 continue;
  420.             }
  421.             $this->loadValidatorLoader($name$container);
  422.         }
  423.         if ($config['resolve_target_entities']) {
  424.             $def $container->findDefinition('doctrine.orm.listeners.resolve_target_entity');
  425.             foreach ($config['resolve_target_entities'] as $name => $implementation) {
  426.                 $def->addMethodCall('addResolveTargetEntity', [
  427.                     $name,
  428.                     $implementation,
  429.                     [],
  430.                 ]);
  431.             }
  432.             $def->addTag('doctrine.event_subscriber');
  433.         }
  434.         $container->registerForAutoconfiguration(ServiceEntityRepositoryInterface::class)
  435.             ->addTag(ServiceRepositoryCompilerPass::REPOSITORY_SERVICE_TAG);
  436.         $container->registerForAutoconfiguration(EventSubscriberInterface::class)
  437.             ->addTag('doctrine.event_subscriber');
  438.         $container->registerForAutoconfiguration(AbstractIdGenerator::class)
  439.             ->addTag(IdGeneratorPass::ID_GENERATOR_TAG);
  440.         $container->registerAttributeForAutoconfiguration(AsEntityListener::class, static function (ChildDefinition $definitionAsEntityListener $attribute) {
  441.             $definition->addTag('doctrine.orm.entity_listener', [
  442.                 'event'          => $attribute->event,
  443.                 'method'         => $attribute->method,
  444.                 'lazy'           => $attribute->lazy,
  445.                 'entity_manager' => $attribute->entityManager,
  446.                 'entity'         => $attribute->entity,
  447.             ]);
  448.         });
  449.         $container->registerAttributeForAutoconfiguration(AsDoctrineListener::class, static function (ChildDefinition $definitionAsDoctrineListener $attribute) {
  450.             $definition->addTag('doctrine.event_listener', [
  451.                 'event'      => $attribute->event,
  452.                 'priority'   => $attribute->priority,
  453.                 'connection' => $attribute->connection,
  454.             ]);
  455.         });
  456.         /** @see DoctrineBundle::boot() */
  457.         $container->getDefinition($defaultEntityManagerDefinitionId)
  458.             ->addTag('container.preload', [
  459.                 'class' => Autoloader::class,
  460.             ]);
  461.     }
  462.     /**
  463.      * Loads a configured ORM entity manager.
  464.      *
  465.      * @param array<string, mixed> $entityManager A configured ORM entity manager.
  466.      * @param ContainerBuilder     $container     A ContainerBuilder instance
  467.      */
  468.     protected function loadOrmEntityManager(array $entityManagerContainerBuilder $container)
  469.     {
  470.         $ormConfigDef $container->setDefinition(sprintf('doctrine.orm.%s_configuration'$entityManager['name']), new ChildDefinition('doctrine.orm.configuration'));
  471.         $ormConfigDef->addTag(IdGeneratorPass::CONFIGURATION_TAG);
  472.         $this->loadOrmEntityManagerMappingInformation($entityManager$ormConfigDef$container);
  473.         $this->loadOrmCacheDrivers($entityManager$container);
  474.         if (isset($entityManager['entity_listener_resolver']) && $entityManager['entity_listener_resolver']) {
  475.             $container->setAlias(sprintf('doctrine.orm.%s_entity_listener_resolver'$entityManager['name']), $entityManager['entity_listener_resolver']);
  476.         } else {
  477.             $definition = new Definition('%doctrine.orm.entity_listener_resolver.class%');
  478.             $definition->addArgument(new Reference('service_container'));
  479.             $container->setDefinition(sprintf('doctrine.orm.%s_entity_listener_resolver'$entityManager['name']), $definition);
  480.         }
  481.         $methods = [
  482.             'setMetadataCache' => new Reference(sprintf('doctrine.orm.%s_metadata_cache'$entityManager['name'])),
  483.             'setQueryCache' => new Reference(sprintf('doctrine.orm.%s_query_cache'$entityManager['name'])),
  484.             'setResultCache' => new Reference(sprintf('doctrine.orm.%s_result_cache'$entityManager['name'])),
  485.             'setMetadataDriverImpl' => new Reference('doctrine.orm.' $entityManager['name'] . '_metadata_driver'),
  486.             'setProxyDir' => '%doctrine.orm.proxy_dir%',
  487.             'setProxyNamespace' => '%doctrine.orm.proxy_namespace%',
  488.             'setAutoGenerateProxyClasses' => '%doctrine.orm.auto_generate_proxy_classes%',
  489.             'setSchemaIgnoreClasses' => $entityManager['schema_ignore_classes'],
  490.             'setClassMetadataFactoryName' => $entityManager['class_metadata_factory_name'],
  491.             'setDefaultRepositoryClassName' => $entityManager['default_repository_class'],
  492.             'setNamingStrategy' => new Reference($entityManager['naming_strategy']),
  493.             'setQuoteStrategy' => new Reference($entityManager['quote_strategy']),
  494.             'setEntityListenerResolver' => new Reference(sprintf('doctrine.orm.%s_entity_listener_resolver'$entityManager['name'])),
  495.             'setLazyGhostObjectEnabled' => '%doctrine.orm.enable_lazy_ghost_objects%',
  496.         ];
  497.         if (! method_exists(OrmConfiguration::class, 'setLazyGhostObjectEnabled')) {
  498.             unset($methods['setLazyGhostObjectEnabled']);
  499.         }
  500.         $listenerId        sprintf('doctrine.orm.%s_listeners.attach_entity_listeners'$entityManager['name']);
  501.         $listenerDef       $container->setDefinition($listenerId, new Definition('%doctrine.orm.listeners.attach_entity_listeners.class%'));
  502.         $listenerTagParams = ['event' => 'loadClassMetadata'];
  503.         if (isset($entityManager['connection'])) {
  504.             $listenerTagParams['connection'] = $entityManager['connection'];
  505.         }
  506.         $listenerDef->addTag('doctrine.event_listener'$listenerTagParams);
  507.         if (isset($entityManager['second_level_cache'])) {
  508.             $this->loadOrmSecondLevelCache($entityManager$ormConfigDef$container);
  509.         }
  510.         if ($entityManager['repository_factory']) {
  511.             $methods['setRepositoryFactory'] = new Reference($entityManager['repository_factory']);
  512.         }
  513.         foreach ($methods as $method => $arg) {
  514.             $ormConfigDef->addMethodCall($method, [$arg]);
  515.         }
  516.         foreach ($entityManager['hydrators'] as $name => $class) {
  517.             $ormConfigDef->addMethodCall('addCustomHydrationMode', [$name$class]);
  518.         }
  519.         if (! empty($entityManager['dql'])) {
  520.             foreach ($entityManager['dql']['string_functions'] as $name => $function) {
  521.                 $ormConfigDef->addMethodCall('addCustomStringFunction', [$name$function]);
  522.             }
  523.             foreach ($entityManager['dql']['numeric_functions'] as $name => $function) {
  524.                 $ormConfigDef->addMethodCall('addCustomNumericFunction', [$name$function]);
  525.             }
  526.             foreach ($entityManager['dql']['datetime_functions'] as $name => $function) {
  527.                 $ormConfigDef->addMethodCall('addCustomDatetimeFunction', [$name$function]);
  528.             }
  529.         }
  530.         $enabledFilters    = [];
  531.         $filtersParameters = [];
  532.         foreach ($entityManager['filters'] as $name => $filter) {
  533.             $ormConfigDef->addMethodCall('addFilter', [$name$filter['class']]);
  534.             if ($filter['enabled']) {
  535.                 $enabledFilters[] = $name;
  536.             }
  537.             if (! $filter['parameters']) {
  538.                 continue;
  539.             }
  540.             $filtersParameters[$name] = $filter['parameters'];
  541.         }
  542.         $managerConfiguratorName sprintf('doctrine.orm.%s_manager_configurator'$entityManager['name']);
  543.         $container
  544.             ->setDefinition($managerConfiguratorName, new ChildDefinition('doctrine.orm.manager_configurator.abstract'))
  545.             ->replaceArgument(0$enabledFilters)
  546.             ->replaceArgument(1$filtersParameters);
  547.         if (! isset($entityManager['connection'])) {
  548.             $entityManager['connection'] = $this->defaultConnection;
  549.         }
  550.         $entityManagerId sprintf('doctrine.orm.%s_entity_manager'$entityManager['name']);
  551.         $container
  552.             ->setDefinition($entityManagerId, new ChildDefinition('doctrine.orm.entity_manager.abstract'))
  553.             ->setPublic(true)
  554.             ->setArguments([
  555.                 new Reference(sprintf('doctrine.dbal.%s_connection'$entityManager['connection'])),
  556.                 new Reference(sprintf('doctrine.orm.%s_configuration'$entityManager['name'])),
  557.             ])
  558.             ->setConfigurator([new Reference($managerConfiguratorName), 'configure']);
  559.         $container
  560.             ->registerAliasForArgument($entityManagerIdEntityManagerInterface::class, sprintf('%sEntityManager'$entityManager['name']))
  561.             ->setPublic(false);
  562.         $container->setAlias(
  563.             sprintf('doctrine.orm.%s_entity_manager.event_manager'$entityManager['name']),
  564.             new Alias(sprintf('doctrine.dbal.%s_connection.event_manager'$entityManager['connection']), false)
  565.         );
  566.         if (! isset($entityManager['entity_listeners'])) {
  567.             return;
  568.         }
  569.         $entities $entityManager['entity_listeners']['entities'];
  570.         foreach ($entities as $entityListenerClass => $entity) {
  571.             foreach ($entity['listeners'] as $listenerClass => $listener) {
  572.                 foreach ($listener['events'] as $listenerEvent) {
  573.                     $listenerEventName $listenerEvent['type'];
  574.                     $listenerMethod    $listenerEvent['method'];
  575.                     $listenerDef->addMethodCall('addEntityListener', [
  576.                         $entityListenerClass,
  577.                         $listenerClass,
  578.                         $listenerEventName,
  579.                         $listenerMethod,
  580.                     ]);
  581.                 }
  582.             }
  583.         }
  584.     }
  585.     /**
  586.      * Loads an ORM entity managers bundle mapping information.
  587.      *
  588.      * There are two distinct configuration possibilities for mapping information:
  589.      *
  590.      * 1. Specify a bundle and optionally details where the entity and mapping information reside.
  591.      * 2. Specify an arbitrary mapping location.
  592.      *
  593.      * @param array<string, mixed> $entityManager A configured ORM entity manager
  594.      * @param Definition           $ormConfigDef  A Definition instance
  595.      * @param ContainerBuilder     $container     A ContainerBuilder instance
  596.      *
  597.      * @example
  598.      *
  599.      *  doctrine.orm:
  600.      *     mappings:
  601.      *         MyBundle1: ~
  602.      *         MyBundle2: yml
  603.      *         MyBundle3: { type: annotation, dir: Entities/ }
  604.      *         MyBundle4: { type: xml, dir: Resources/config/doctrine/mapping }
  605.      *         MyBundle5: { type: attribute, dir: Entities/ }
  606.      *         MyBundle6:
  607.      *             type: yml
  608.      *             dir: bundle-mappings/
  609.      *             alias: BundleAlias
  610.      *         arbitrary_key:
  611.      *             type: xml
  612.      *             dir: %kernel.project_dir%/src/vendor/DoctrineExtensions/lib/DoctrineExtensions/Entities
  613.      *             prefix: DoctrineExtensions\Entities\
  614.      *             alias: DExt
  615.      *
  616.      * In the case of bundles everything is really optional (which leads to autodetection for this bundle) but
  617.      * in the mappings key everything except alias is a required argument.
  618.      */
  619.     protected function loadOrmEntityManagerMappingInformation(array $entityManagerDefinition $ormConfigDefContainerBuilder $container)
  620.     {
  621.         // reset state of drivers and alias map. They are only used by this methods and children.
  622.         $this->drivers  = [];
  623.         $this->aliasMap = [];
  624.         $this->loadMappingInformation($entityManager$container);
  625.         $this->registerMappingDrivers($entityManager$container);
  626.         $ormConfigDef->addMethodCall('setEntityNamespaces', [$this->aliasMap]);
  627.     }
  628.     /**
  629.      * Loads an ORM second level cache bundle mapping information.
  630.      *
  631.      * @param array<string, mixed> $entityManager A configured ORM entity manager
  632.      * @param Definition           $ormConfigDef  A Definition instance
  633.      * @param ContainerBuilder     $container     A ContainerBuilder instance
  634.      *
  635.      * @example
  636.      *  entity_managers:
  637.      *      default:
  638.      *          second_level_cache:
  639.      *              region_lifetime: 3600
  640.      *              region_lock_lifetime: 60
  641.      *              region_cache_driver: apc
  642.      *              log_enabled: true
  643.      *              regions:
  644.      *                  my_service_region:
  645.      *                      type: service
  646.      *                      service : "my_service_region"
  647.      *
  648.      *                  my_query_region:
  649.      *                      lifetime: 300
  650.      *                      cache_driver: array
  651.      *                      type: filelock
  652.      *
  653.      *                  my_entity_region:
  654.      *                      lifetime: 600
  655.      *                      cache_driver:
  656.      *                          type: apc
  657.      */
  658.     protected function loadOrmSecondLevelCache(array $entityManagerDefinition $ormConfigDefContainerBuilder $container)
  659.     {
  660.         $driverId null;
  661.         $enabled  $entityManager['second_level_cache']['enabled'];
  662.         if (isset($entityManager['second_level_cache']['region_cache_driver'])) {
  663.             $driverName 'second_level_cache.region_cache_driver';
  664.             $driverMap  $entityManager['second_level_cache']['region_cache_driver'];
  665.             $driverId   $this->loadCacheDriver($driverName$entityManager['name'], $driverMap$container);
  666.         }
  667.         $configId   sprintf('doctrine.orm.%s_second_level_cache.cache_configuration'$entityManager['name']);
  668.         $regionsId  sprintf('doctrine.orm.%s_second_level_cache.regions_configuration'$entityManager['name']);
  669.         $driverId   $driverId ?: sprintf('doctrine.orm.%s_second_level_cache.region_cache_driver'$entityManager['name']);
  670.         $configDef  $container->setDefinition($configId, new Definition('%doctrine.orm.second_level_cache.cache_configuration.class%'));
  671.         $regionsDef $container
  672.             ->setDefinition($regionsId, new Definition('%doctrine.orm.second_level_cache.regions_configuration.class%'))
  673.             ->setArguments([$entityManager['second_level_cache']['region_lifetime'], $entityManager['second_level_cache']['region_lock_lifetime']]);
  674.         $slcFactoryId sprintf('doctrine.orm.%s_second_level_cache.default_cache_factory'$entityManager['name']);
  675.         $factoryClass $entityManager['second_level_cache']['factory'] ?? '%doctrine.orm.second_level_cache.default_cache_factory.class%';
  676.         $definition = new Definition($factoryClass, [new Reference($regionsId), new Reference($driverId)]);
  677.         $slcFactoryDef $container
  678.             ->setDefinition($slcFactoryId$definition);
  679.         if (isset($entityManager['second_level_cache']['regions'])) {
  680.             foreach ($entityManager['second_level_cache']['regions'] as $name => $region) {
  681.                 $regionRef  null;
  682.                 $regionType $region['type'];
  683.                 if ($regionType === 'service') {
  684.                     $regionId  sprintf('doctrine.orm.%s_second_level_cache.region.%s'$entityManager['name'], $name);
  685.                     $regionRef = new Reference($region['service']);
  686.                     $container->setAlias($regionId, new Alias($region['service'], false));
  687.                 }
  688.                 if ($regionType === 'default' || $regionType === 'filelock') {
  689.                     $regionId   sprintf('doctrine.orm.%s_second_level_cache.region.%s'$entityManager['name'], $name);
  690.                     $driverName sprintf('second_level_cache.region.%s_driver'$name);
  691.                     $driverMap  $region['cache_driver'];
  692.                     $driverId   $this->loadCacheDriver($driverName$entityManager['name'], $driverMap$container);
  693.                     $regionRef  = new Reference($regionId);
  694.                     $container
  695.                         ->setDefinition($regionId, new Definition('%doctrine.orm.second_level_cache.default_region.class%'))
  696.                         ->setArguments([$name, new Reference($driverId), $region['lifetime']]);
  697.                 }
  698.                 if ($regionType === 'filelock') {
  699.                     $regionId sprintf('doctrine.orm.%s_second_level_cache.region.%s_filelock'$entityManager['name'], $name);
  700.                     $container
  701.                         ->setDefinition($regionId, new Definition('%doctrine.orm.second_level_cache.filelock_region.class%'))
  702.                         ->setArguments([$regionRef$region['lock_path'], $region['lock_lifetime']]);
  703.                     $regionRef = new Reference($regionId);
  704.                     $regionsDef->addMethodCall('getLockLifetime', [$name$region['lock_lifetime']]);
  705.                 }
  706.                 $regionsDef->addMethodCall('setLifetime', [$name$region['lifetime']]);
  707.                 $slcFactoryDef->addMethodCall('setRegion', [$regionRef]);
  708.             }
  709.         }
  710.         if ($entityManager['second_level_cache']['log_enabled']) {
  711.             $loggerChainId   sprintf('doctrine.orm.%s_second_level_cache.logger_chain'$entityManager['name']);
  712.             $loggerStatsId   sprintf('doctrine.orm.%s_second_level_cache.logger_statistics'$entityManager['name']);
  713.             $loggerChaingDef $container->setDefinition($loggerChainId, new Definition('%doctrine.orm.second_level_cache.logger_chain.class%'));
  714.             $loggerStatsDef  $container->setDefinition($loggerStatsId, new Definition('%doctrine.orm.second_level_cache.logger_statistics.class%'));
  715.             $loggerChaingDef->addMethodCall('setLogger', ['statistics'$loggerStatsDef]);
  716.             $configDef->addMethodCall('setCacheLogger', [$loggerChaingDef]);
  717.             foreach ($entityManager['second_level_cache']['loggers'] as $name => $logger) {
  718.                 $loggerId  sprintf('doctrine.orm.%s_second_level_cache.logger.%s'$entityManager['name'], $name);
  719.                 $loggerRef = new Reference($logger['service']);
  720.                 $container->setAlias($loggerId, new Alias($logger['service'], false));
  721.                 $loggerChaingDef->addMethodCall('setLogger', [$name$loggerRef]);
  722.             }
  723.         }
  724.         $configDef->addMethodCall('setCacheFactory', [$slcFactoryDef]);
  725.         $configDef->addMethodCall('setRegionsConfiguration', [$regionsDef]);
  726.         $ormConfigDef->addMethodCall('setSecondLevelCacheEnabled', [$enabled]);
  727.         $ormConfigDef->addMethodCall('setSecondLevelCacheConfiguration', [$configDef]);
  728.     }
  729.     /**
  730.      * {@inheritDoc}
  731.      */
  732.     protected function getObjectManagerElementName($name): string
  733.     {
  734.         return 'doctrine.orm.' $name;
  735.     }
  736.     protected function getMappingObjectDefaultName(): string
  737.     {
  738.         return 'Entity';
  739.     }
  740.     protected function getMappingResourceConfigDirectory(?string $bundleDir null): string
  741.     {
  742.         if ($bundleDir !== null && is_dir($bundleDir '/config/doctrine')) {
  743.             return 'config/doctrine';
  744.         }
  745.         return 'Resources/config/doctrine';
  746.     }
  747.     protected function getMappingResourceExtension(): string
  748.     {
  749.         return 'orm';
  750.     }
  751.     /**
  752.      * {@inheritDoc}
  753.      */
  754.     protected function loadCacheDriver($cacheName$objectManagerName, array $cacheDriverContainerBuilder $container): string
  755.     {
  756.         $aliasId $this->getObjectManagerElementName(sprintf('%s_%s'$objectManagerName$cacheName));
  757.         switch ($cacheDriver['type'] ?? 'pool') {
  758.             case 'service':
  759.                 $serviceId $cacheDriver['id'];
  760.                 break;
  761.             case 'pool':
  762.                 $serviceId $cacheDriver['pool'] ?? $this->createArrayAdapterCachePool($container$objectManagerName$cacheName);
  763.                 break;
  764.             default:
  765.                 throw new InvalidArgumentException(sprintf(
  766.                     'Unknown cache of type "%s" configured for cache "%s" in entity manager "%s".',
  767.                     $cacheDriver['type'],
  768.                     $cacheName,
  769.                     $objectManagerName
  770.                 ));
  771.         }
  772.         $container->setAlias($aliasId, new Alias($serviceIdfalse));
  773.         return $aliasId;
  774.     }
  775.     /**
  776.      * Loads a configured entity managers cache drivers.
  777.      *
  778.      * @param array<string, mixed> $entityManager A configured ORM entity manager.
  779.      */
  780.     protected function loadOrmCacheDrivers(array $entityManagerContainerBuilder $container)
  781.     {
  782.         if (isset($entityManager['metadata_cache_driver'])) {
  783.             $this->loadCacheDriver('metadata_cache'$entityManager['name'], $entityManager['metadata_cache_driver'], $container);
  784.         } else {
  785.             $this->createMetadataCache($entityManager['name'], $container);
  786.         }
  787.         $this->loadCacheDriver('result_cache'$entityManager['name'], $entityManager['result_cache_driver'], $container);
  788.         $this->loadCacheDriver('query_cache'$entityManager['name'], $entityManager['query_cache_driver'], $container);
  789.     }
  790.     private function createMetadataCache(string $objectManagerNameContainerBuilder $container): void
  791.     {
  792.         $aliasId $this->getObjectManagerElementName(sprintf('%s_%s'$objectManagerName'metadata_cache'));
  793.         $cacheId sprintf('cache.doctrine.orm.%s.%s'$objectManagerName'metadata');
  794.         $cache = new Definition(ArrayAdapter::class);
  795.         if (! $container->getParameter('kernel.debug')) {
  796.             $phpArrayFile         '%kernel.cache_dir%' sprintf('/doctrine/orm/%s_metadata.php'$objectManagerName);
  797.             $cacheWarmerServiceId $this->getObjectManagerElementName(sprintf('%s_%s'$objectManagerName'metadata_cache_warmer'));
  798.             $container->register($cacheWarmerServiceIdDoctrineMetadataCacheWarmer::class)
  799.                 ->setArguments([new Reference(sprintf('doctrine.orm.%s_entity_manager'$objectManagerName)), $phpArrayFile])
  800.                 ->addTag('kernel.cache_warmer', ['priority' => 1000]); // priority should be higher than ProxyCacheWarmer
  801.             $cache = new Definition(PhpArrayAdapter::class, [$phpArrayFile$cache]);
  802.         }
  803.         $container->setDefinition($cacheId$cache);
  804.         $container->setAlias($aliasId$cacheId);
  805.     }
  806.     /**
  807.      * Loads a property info extractor for each defined entity manager.
  808.      */
  809.     private function loadPropertyInfoExtractor(string $entityManagerNameContainerBuilder $container): void
  810.     {
  811.         $propertyExtractorDefinition $container->register(sprintf('doctrine.orm.%s_entity_manager.property_info_extractor'$entityManagerName), DoctrineExtractor::class);
  812.         $argumentId                  sprintf('doctrine.orm.%s_entity_manager'$entityManagerName);
  813.         $propertyExtractorDefinition->addArgument(new Reference($argumentId));
  814.         $propertyExtractorDefinition->addTag('property_info.list_extractor', ['priority' => -1001]);
  815.         $propertyExtractorDefinition->addTag('property_info.type_extractor', ['priority' => -999]);
  816.         $propertyExtractorDefinition->addTag('property_info.access_extractor', ['priority' => -999]);
  817.     }
  818.     /**
  819.      * Loads a validator loader for each defined entity manager.
  820.      */
  821.     private function loadValidatorLoader(string $entityManagerNameContainerBuilder $container): void
  822.     {
  823.         $validatorLoaderDefinition $container->register(sprintf('doctrine.orm.%s_entity_manager.validator_loader'$entityManagerName), DoctrineLoader::class);
  824.         $validatorLoaderDefinition->addArgument(new Reference(sprintf('doctrine.orm.%s_entity_manager'$entityManagerName)));
  825.         $validatorLoaderDefinition->addTag('validator.auto_mapper', ['priority' => -100]);
  826.     }
  827.     /**
  828.      * @param array<string, mixed> $objectManager
  829.      * @param string               $cacheName
  830.      *
  831.      * @psalm-suppress MoreSpecificImplementedParamType
  832.      */
  833.     public function loadObjectManagerCacheDriver(array $objectManagerContainerBuilder $container$cacheName)
  834.     {
  835.         $this->loadCacheDriver($cacheName$objectManager['name'], $objectManager[$cacheName '_driver'], $container);
  836.     }
  837.     public function getXsdValidationBasePath(): string
  838.     {
  839.         return __DIR__ '/../Resources/config/schema';
  840.     }
  841.     public function getNamespace(): string
  842.     {
  843.         return 'http://symfony.com/schema/dic/doctrine';
  844.     }
  845.     /**
  846.      * {@inheritDoc}
  847.      */
  848.     public function getConfiguration(array $configContainerBuilder $container): Configuration
  849.     {
  850.         return new Configuration((bool) $container->getParameter('kernel.debug'));
  851.     }
  852.     protected function getMetadataDriverClass(string $driverType): string
  853.     {
  854.         return '%' $this->getObjectManagerElementName('metadata.' $driverType '.class') . '%';
  855.     }
  856.     private function loadMessengerServices(ContainerBuilder $container): void
  857.     {
  858.         // If the Messenger component is installed, wire it:
  859.         /** @psalm-suppress UndefinedClass Optional dependency */
  860.         if (! interface_exists(MessageBusInterface::class)) {
  861.             return;
  862.         }
  863.         $loader = new XmlFileLoader($container, new FileLocator(__DIR__ '/../Resources/config'));
  864.         $loader->load('messenger.xml');
  865.         /**
  866.          * The Doctrine transport component (symfony/doctrine-messenger) is optional.
  867.          * Remove service definition, if it is not available
  868.          */
  869.         if (class_exists(DoctrineTransportFactory::class)) {
  870.             return;
  871.         }
  872.         $container->removeDefinition('messenger.transport.doctrine.factory');
  873.     }
  874.     private function createArrayAdapterCachePool(ContainerBuilder $containerstring $objectManagerNamestring $cacheName): string
  875.     {
  876.         $id sprintf('cache.doctrine.orm.%s.%s'$objectManagerNamestr_replace('_cache'''$cacheName));
  877.         $poolDefinition $container->register($idArrayAdapter::class);
  878.         $poolDefinition->addTag('cache.pool');
  879.         $container->setDefinition($id$poolDefinition);
  880.         return $id;
  881.     }
  882.     /**
  883.      * @param string[] $connWithLogging
  884.      * @param string[] $connWithProfiling
  885.      * @param string[] $connWithBacktrace
  886.      */
  887.     private function useMiddlewaresIfAvailable(
  888.         ContainerBuilder $container,
  889.         array $connWithLogging,
  890.         array $connWithProfiling,
  891.         array $connWithBacktrace
  892.     ): void {
  893.         $loader = new XmlFileLoader($container, new FileLocator(__DIR__ '/../Resources/config'));
  894.         $loader->load('middlewares.xml');
  895.         $loggingMiddlewareAbstractDef $container->getDefinition('doctrine.dbal.logging_middleware');
  896.         foreach ($connWithLogging as $connName) {
  897.             $loggingMiddlewareAbstractDef->addTag('doctrine.middleware', ['connection' => $connName]);
  898.         }
  899.         $container->getDefinition('doctrine.debug_data_holder')->replaceArgument(0$connWithBacktrace);
  900.         $debugMiddlewareAbstractDef $container->getDefinition('doctrine.dbal.debug_middleware');
  901.         foreach ($connWithProfiling as $connName) {
  902.             $debugMiddlewareAbstractDef
  903.                 ->addTag('doctrine.middleware', ['connection' => $connName]);
  904.         }
  905.     }
  906. }