symfony
diff --git a/‎src/Symfony/Component/Messenger/Bridge/Doctrine/Tests/Transport/PostgreSqlConnectionTest.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Doctrine/Tests/Transport/PostgreSqlConnectionTest.php
+2-8Lines changed: 2 additions & 8 deletions b/‎src/Symfony/Component/Messenger/Bridge/Doctrine/Tests/Transport/PostgreSqlConnectionTest.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Doctrine/Tests/Transport/PostgreSqlConnectionTest.php
+2-8Lines changed: 2 additions & 8 deletions
diff --git a/‎src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php
-2Lines changed: 0 additions & 2 deletions b/‎src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php
-2Lines changed: 0 additions & 2 deletions
@@ -51,16 +51,10 @@ public function testGetExtraSetupSql()
         $table->addOption('_symfony_messenger_table_name', 'queue_table');
         $sql = implode("\n", $connection->getExtraSetupSqlForTable($table));
 
-        /*
-         * We need to start a transaction for the following commands to work properly:
-         * doctrine:schema:create
-         * messenger:setup-transports
-         * doctrine:migrations:diff and doctrine:migrations:migrate
-         */
-        $this->assertStringContainsString('BEGIN;', $sql);
         $this->assertStringContainsString('CREATE TRIGGER', $sql);
 
-        // We MUST NOT commit, that will mess with the PDO in PHP 8
+        // We MUST NOT use transaction, that will mess with the PDO in PHP 8
+        $this->assertStringNotContainsString('BEGIN;', $sql);
         $this->assertStringNotContainsString('COMMIT;', $sql);
     }
 
 
@@ -109,8 +109,6 @@ public function getExtraSetupSqlForTable(Table $createdTable): array
     private function getTriggerSql(): array
     {
         return [
-            'BEGIN;',
-            sprintf('LOCK TABLE %s;', $this->configuration['table_name']),
             // create trigger function
             sprintf(<<<'SQL'
 CREATE OR REPLACE FUNCTION notify_%1$s() RETURNS TRIGGER AS $$