Convert driver exceptions when starting transactions

tests/Functional/TransactionTest.php

@@ -9,43 +9,40 @@
 use Doctrine\DBAL\Platforms\AbstractMySQLPlatform;
 use Doctrine\DBAL\Schema\Table;
 use Doctrine\DBAL\Tests\FunctionalTestCase;
+use Doctrine\DBAL\Tests\TestUtil;
 use Doctrine\DBAL\Types\Types;
 
 use function func_get_args;
 use function restore_error_handler;
 use function set_error_handler;
-use function sleep;
+use function sprintf;
 
 use const E_WARNING;
 
 class TransactionTest extends FunctionalTestCase
 {
     public function testCommitFailure(): void
     {
+        $this->markConnectionNotReusable();
+
         $this->expectConnectionLoss(static function (Connection $connection): void {
             $connection->commit();
         });
     }
 
     public function testRollbackFailure(): void
     {
+        $this->markConnectionNotReusable();
+
         $this->expectConnectionLoss(static function (Connection $connection): void {
             $connection->rollBack();
         });
     }
 
     private function expectConnectionLoss(callable $scenario): void
     {
-        if (! $this->connection->getDatabasePlatform() instanceof AbstractMySQLPlatform) {
-            self::markTestSkipped('Restricted to MySQL.');
-        }
-
-        $this->connection->executeStatement('SET SESSION wait_timeout=1');
         $this->connection->beginTransaction();
-
-        // during the sleep MySQL will close the connection
-        sleep(2);
-
+        $this->killCurrentSession();
         $this->expectException(ConnectionLost::class);
 
         // prevent the PHPUnit error handler from handling the "MySQL server has gone away" warning
@@ -65,6 +62,24 @@ private function expectConnectionLoss(callable $scenario): void
         }
     }
 
+    private function killCurrentSession(): void
+    {
+        $databasePlatform = $this->connection->getDatabasePlatform();
+
+        [$currentProcessQuery, $killProcessStatement] = match (true) {
+            $databasePlatform instanceof AbstractMySqlPlatform => ['SELECT CONNECTION_ID()', 'KILL %s'],
+            default => self::markTestSkipped('Unsupported test platform.'),
+        };
+
+        $privilegedConnection = TestUtil::getPrivilegedConnection();
+        $privilegedConnection->executeStatement(
+            sprintf(
+                $killProcessStatement,
+                $this->connection->executeQuery($currentProcessQuery)->fetchOne(),
+            ),
+        );
+    }
+
     public function testNestedTransactionWalkthrough(): void
     {
         if (! $this->connection->getDatabasePlatform()->supportsSavepoints()) {