long running process doctrine connection listener

DependencyInjection/DoctrineExtension.php

@@ -537,6 +537,10 @@ protected function ormLoad(array $config, ContainerBuilder $container)
             $container->removeDefinition('doctrine.mapping_import_command');
         }
 
+        if (!$container->hasParameter('kernel.runtime_mode') || !$container->hasParameter('kernel.runtime_mode.worker')) {
+            $container->removeDefinition('doctrine.dbal.connection_middleware');
+        }
+
         $entityManagers = [];
         foreach (array_keys($config['entity_managers']) as $name) {
             /** @psalm-suppress InvalidArrayOffset */

Resources/config/middlewares.xml

@@ -17,5 +17,10 @@
             <argument type="service" id="doctrine.debug_data_holder" />
             <argument type="service" id="debug.stopwatch" on-invalid="null" />
         </service>
+        <service id="doctrine.dbal.connection_middleware" class="Symfony\Bridge\Doctrine\Middleware\DoctrineConnectionMiddleware">
+            <argument type="service" id="doctrine" />
+            <argument type="service" id="service_container"  />
+            <tag name="doctrine.middleware" />
+        </service>
     </services>
 </container>

Tests/DoctrineConnectionMiddlewareTest.php

@@ -0,0 +1,120 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Doctrine\Bundle\DoctrineBundle\Tests;
+
+use Doctrine\DBAL\Connection;
+use Doctrine\DBAL\Driver;
+use Doctrine\DBAL\Exception as DBALException;
+use Doctrine\DBAL\Platforms\AbstractPlatform;
+use Doctrine\DBAL\Result;
+use Doctrine\ORM\EntityManagerInterface;
+use Doctrine\Persistence\ManagerRegistry;
+use PHPUnit\Framework\TestCase;
+use Symfony\Bridge\Doctrine\Middleware\DoctrineConnectionDriver;
+use Symfony\Bridge\Doctrine\Middleware\DoctrineConnectionMiddleware;
+use Symfony\Component\DependencyInjection\Container;
+
+/**
+ * Based on https://github.com/Baldinof/roadrunner-bundle/blob/3.x/src/Integration/Doctrine/DoctrineORMMiddleware.php
+ */
+class DoctrineConnectionMiddlewareTest extends TestCase
+{
+    public const CONNECTION_NAME = 'doctrine.connection';
+    public const MANAGER_NAME    = 'doctrine.manager';
+
+    private $managerRegistryMock;
+    private $connectionMock;
+    private $container;
+    private $driver;
+    private $doctrineConnectionDriver;
+
+    public function setUp(): void
+    {
+        $platform = $this->createMock(AbstractPlatform::class);
+        $platform->method('getDummySelectSQL')->willReturn('SELECT 1');
+
+        $this->managerRegistryMock = $this->createMock(ManagerRegistry::class);
+        $this->connectionMock = $this->createMock(Connection::class);
+        $this->connectionDriverMock = $this->createMock(Driver\Connection::class);
+        $this->connectionMock->method('getDatabasePlatform')->willReturn($platform);
+
+        $this->container = new Container();
+        $this->container->set(self::CONNECTION_NAME, $this->connectionMock);
+
+        $this->managerRegistryMock->method('getConnectionNames')->willReturn([self::CONNECTION_NAME]);
+        $this->managerRegistryMock->method('getManagerNames')->willReturn([self::MANAGER_NAME]);
+
+        $this->driver = $this->createMock(Driver::class);
+        $this->driver->method('connect')->willReturn($this->connectionDriverMock);
+
+        $this->doctrineConnectionDriver = new DoctrineConnectionDriver($this->driver, $this->managerRegistryMock, $this->container);
+    }
+
+    public function testSkipNotInitializedConnections()
+    {
+        $this->container->set(self::CONNECTION_NAME, null);
+
+        $this->connectionMock->expects($this->never())->method('isConnected');
+        $this->connectionMock->expects($this->never())->method('executeQuery');
+        $this->connectionMock->expects($this->never())->method('close');
+        $this->connectionMock->expects($this->never())->method('connect');
+
+        $this->doctrineConnectionDriver->connect([]);
+    }
+
+    public function testSkipWhenNotConnected(): void
+    {
+        $this->connectionMock->method('isConnected')->willReturn(false);
+        $this->connectionMock->expects($this->never())->method('executeQuery');
+        $this->connectionMock->expects($this->never())->method('close');
+        $this->connectionMock->expects($this->never())->method('connect');
+
+        $this->doctrineConnectionDriver->connect([]);
+    }
+
+    public function testItClosesNotPingableConnection(): void
+    {
+        $this->connectionMock->expects($this->exactly(2))->method('executeQuery')
+            ->willReturnCallback(function () {
+                static $counter = 0;
+
+                if (1 === ++$counter) {
+                    throw $this->createMock(DBALException::class);
+                }
+
+                return $this->createMock(Result::class);
+            });
+
+        $this->connectionMock->method('isConnected')->willReturn(true);
+        $this->connectionMock->expects($this->once())->method('close');
+        $this->connectionMock->expects($this->never())->method('connect');
+
+        $this->doctrineConnectionDriver->connect([]);
+    }
+
+    public function testItDoesNotClosePingableConnection(): void
+    {
+        $this->connectionMock->expects($this->once())->method('executeQuery');
+        $this->connectionMock->method('isConnected')->willReturn(true);
+        $this->connectionMock->expects($this->never())->method('close');
+        $this->connectionMock->expects($this->never())->method('connect');
+
+        $this->doctrineConnectionDriver->connect([]);
+    }
+
+    public function testItForcesRebootOnClosedManagerWhenMissingProxySupport()
+    {
+        $manager = $this->createMock(EntityManagerInterface::class);
+        $this->container->set(self::MANAGER_NAME, $manager);
+
+        $manager->expects($this->once())->method('isOpen')->willReturn(false);
+        $this->managerRegistryMock->expects($this->once())
+            ->method('resetManager')
+            ->with(self::MANAGER_NAME)
+        ;
+
+        $this->doctrineConnectionDriver->connect([]);
+    }
+}