[Messenger] Fix Doctrine setup when using a migration

symfony · fabpot · Feb 1, 2021 · Feb 1, 2021 · Feb 1, 2021 · 42eeb44f8326ea3efb951df1c2308a338715a3f9
commit 42eeb44f8326ea3efb951df1c2308a338715a3f9
diff --git a/src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php b/src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php
@@ -87,7 +87,7 @@ public function setup(): void
    {
        parent::setup();

-        $this->executeStatement(implode("\n", $this->getTriggerSql()));
+        $this->executeStatement('BEGIN;'.implode("\n", $this->getTriggerSql()).'COMMIT;');
    }

    /**
@@ -109,7 +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'
@@ -124,7 +123,6 @@ private function getTriggerSql(): array
            // register trigger
            sprintf('DROP TRIGGER IF EXISTS notify_trigger ON %s;', $this->configuration['table_name']),
            sprintf('CREATE TRIGGER notify_trigger AFTER INSERT OR UPDATE ON %1$s FOR EACH ROW EXECUTE PROCEDURE notify_%1$s();', $this->configuration['table_name']),
-            'COMMIT;',
        ];
    }