diff --git a/src/Symfony/Component/Messenger/Bridge/Doctrine/Tests/Transport/PostgreSqlConnectionTest.php b/src/Symfony/Component/Messenger/Bridge/Doctrine/Tests/Transport/PostgreSqlConnectionTest.php index 7b17e41af8..9fc3f6b527 100644 --- a/src/Symfony/Component/Messenger/Bridge/Doctrine/Tests/Transport/PostgreSqlConnectionTest.php +++ b/src/Symfony/Component/Messenger/Bridge/Doctrine/Tests/Transport/PostgreSqlConnectionTest.php @@ -51,16 +51,10 @@ class PostgreSqlConnectionTest extends TestCase $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); } diff --git a/src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php b/src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php index eede0d9262..5be0ae9773 100644 --- a/src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php +++ b/src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php @@ -109,8 +109,6 @@ final class PostgreSqlConnection extends Connection 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 $$