Don't attempt to rollback when connections are lost (#7240)

|      Q       |   A
|------------- | -----------
| Type         | bug

#### Summary

It's useless to try to perform a rollback when there's no active
connection, not to mention that the use of `NoActiveTransaction`
exceptions masks the real underlying issue.

This attempts to fix the problem by detecting connection issues and
bypassing rollbacks.

Signed-off-by: Luís Cobucci <lcobucci@gmail.com>

Author: lcobucci

src/Connection.php

@@ -964,8 +964,11 @@ public function transactional(Closure $func): mixed
             $res = $func($this);
 
             $successful = true;
+        } catch (ConnectionLost $connectionLost) {
+            // Catching here only to be able to prevent a rollback attempt
+            throw $connectionLost;
         } finally {
-            if (! $successful) {
+            if (! isset($connectionLost) && ! $successful) {
                 $this->rollBack();
             }
         }
@@ -981,6 +984,7 @@ public function transactional(Closure $func): mixed
                 || $t instanceof UniqueConstraintViolationException
                 || $t instanceof ForeignKeyConstraintViolationException
                 || $t instanceof DeadlockException
+                || $t instanceof ConnectionLost
             );
 
             throw $t;

tests/Functional/TransactionTest.php

@@ -48,6 +48,27 @@ public function testRollbackFailure(): void
         });
     }
 
+    public function testTransactionalFailureDuringCallback(): void
+    {
+        $this->connection->transactional(
+            function (): void {
+                $this->expectConnectionLoss(static function (Connection $connection): void {
+                    $connection->executeQuery($connection->getDatabasePlatform()->getDummySelectSQL());
+                });
+            },
+        );
+    }
+
+    public function testTransactionalFailureDuringCommit(): void
+    {
+        $this->connection->transactional(
+            function (): void {
+                $this->expectConnectionLoss(static function (Connection $connection): void {
+                });
+            },
+        );
+    }
+
     private function expectConnectionLoss(callable $scenario): void
     {
         $this->killCurrentSession();