Handle lost connection during commit

src/Connection.php

@@ -1238,6 +1238,8 @@ public function commit(): void
 
             try {
                 $connection->commit();
+            } catch (Driver\Exception $e) {
+                throw $this->convertException($e);
             } finally {
                 $logger->stopQuery();
             }
@@ -1299,6 +1301,8 @@ public function rollBack(): void
 
             try {
                 $connection->rollBack();
+            } catch (Driver\Exception $e) {
+                throw $this->convertException($e);
             } finally {
                 $this->isRollbackOnly = false;
                 $logger->stopQuery();

src/Driver/PDO/Connection.php

@@ -112,12 +112,20 @@ public function beginTransaction(): void
 
     public function commit(): void
     {
-        $this->connection->commit();
+        try {
+            $this->connection->commit();
+        } catch (PDOException $exception) {
+            throw Exception::new($exception);
+        }
     }
 
     public function rollBack(): void
     {
-        $this->connection->rollBack();
+        try {
+            $this->connection->rollBack();
+        } catch (PDOException $exception) {
+            throw Exception::new($exception);
+        }
     }
 
     public function getWrappedConnection(): PDO

tests/Functional/TransactionTest.php

@@ -0,0 +1,44 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Doctrine\DBAL\Tests\Functional;
+
+use Doctrine\DBAL\Exception\ConnectionLost;
+use Doctrine\DBAL\Platforms\MySQLPlatform;
+use Doctrine\DBAL\Tests\FunctionalTestCase;
+
+use function sleep;
+
+use const E_ALL;
+use const E_WARNING;
+
+class TransactionTest extends FunctionalTestCase
+{
+    protected function setUp(): void
+    {
+        parent::setUp();
+
+        if ($this->connection->getDatabasePlatform() instanceof MySQLPlatform) {
+            return;
+        }
+
+        self::markTestSkipped('Restricted to MySQL.');
+    }
+
+    public function testCommitFailure(): void
+    {
+        $this->connection->executeStatement('SET SESSION wait_timeout=1');
+
+        $this->connection->beginTransaction();
+
+        // during the sleep MySQL will close the connection
+        sleep(2);
+
+        // prevent the PHPUnit error handler from handling the "MySQL server has gone away" warning
+        $this->iniSet('error_reporting', (string) (E_ALL & ~E_WARNING));
+
+        $this->expectException(ConnectionLost::class);
+        $this->connection->commit();
+    }
+}