symfony
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
+1-3Lines changed: 1 addition & 3 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
+1-3Lines changed: 1 addition & 3 deletions
@@ -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;',
         ];
     }
Original file line number	Diff line number	Diff line change
`@@ -87,7 +87,7 @@ public function setup(): void`
`87`	`87`	`{`
`88`	`88`	`parent::setup();`
`89`	`89`
`90`		`- $this->executeStatement(implode("\n", $this->getTriggerSql()));`
	`90`	`+ $this->executeStatement('BEGIN;'.implode("\n", $this->getTriggerSql()).'COMMIT;');`
`91`	`91`	`}`
`92`	`92`
`93`	`93`	`/**`
`@@ -109,7 +109,6 @@ public function getExtraSetupSqlForTable(Table $createdTable): array`
`109`	`109`	`private function getTriggerSql(): array`
`110`	`110`	`{`
`111`	`111`	`return [`
`112`		`- 'BEGIN;',`
`113`	`112`	`sprintf('LOCK TABLE %s;', $this->configuration['table_name']),`
`114`	`113`	`// create trigger function`
`115`	`114`	`sprintf(<<<'SQL'`
`@@ -124,7 +123,6 @@ private function getTriggerSql(): array`
`124`	`123`	`// register trigger`
`125`	`124`	`sprintf('DROP TRIGGER IF EXISTS notify_trigger ON %s;', $this->configuration['table_name']),`
`126`	`125`	`sprintf('CREATE TRIGGER notify_trigger AFTER INSERT OR UPDATE ON %1$s FOR EACH ROW EXECUTE PROCEDURE notify_%1$s();', $this->configuration['table_name']),`
`127`		`- 'COMMIT;',`
`128`	`126`	`];`
`129`	`127`	`}`
`130`	`128`