diogo/symfony
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[Messenger] Fix Doctrine setup when using a migration

Browse Source
This commit is contained in:
Fabien Potencier 2021-02-01 15:36:03 +01:00
parent a07638b14a
commit 42eeb44f83
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Symfony/Component/Messenger/Bridge/Doctrine/Transport/PostgreSqlConnection.php
View File

@ -87,7 +87,7 @@ final class PostgreSqlConnection extends Connection
{ {
parent::setup(); parent::setup();
$this->executeStatement(implode("\n", $this->getTriggerSql())); $this->executeStatement('BEGIN;'.implode("\n", $this->getTriggerSql()).'COMMIT;');
} }
/** /**
@ -109,7 +109,6 @@ final class PostgreSqlConnection extends Connection
private function getTriggerSql(): array private function getTriggerSql(): array
{ {
return [ return [
'BEGIN;',
sprintf('LOCK TABLE %s;', $this->configuration['table_name']), sprintf('LOCK TABLE %s;', $this->configuration['table_name']),
// create trigger function // create trigger function
sprintf(<<<'SQL' sprintf(<<<'SQL'
@ -124,7 +123,6 @@ SQL
// register trigger // register trigger
sprintf('DROP TRIGGER IF EXISTS notify_trigger ON %s;', $this->configuration['table_name']), 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']), 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;',
]; ];
} }