Cavemanon/piratepoet
8
Fork 0
Code Pull Requests Actions Releases 16 Activity

Update Migration_20230831_143755_Db to work properly with multi query

Browse Source 
STOMAIL-7397
This commit is contained in:
Rostislav Wolny
2025-04-25 15:05:38 +02:00
committed by Aschepikov
parent 0898ed7b56
commit 1faf5822a2
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
mailpoet/lib/Migrations/Db/Migration_20230831_143755_Db.php
View File

@@ -115,7 +115,7 @@ class Migration_20230831_143755_Db extends DbMigration {
$stepId = strval($item['step_id']); $stepId = strval($item['step_id']);
$stepKey = strval($steps[$stepId]['key'] ?? 'unknown'); $stepKey = strval($steps[$stepId]['key'] ?? 'unknown');
$triggerId = $steps['root']['next_steps'][0]['id']; $triggerId = $steps['root']['next_steps'][0]['id'];
$triggerKey = $steps['root']['next_steps'][0]['key']; $triggerKey = $steps['root']['next_steps'][0]['key'] ?? 'unknown';
$queries[] = "UPDATE {$logsTable} SET step_key = '{$stepKey}' WHERE id = {$id}"; $queries[] = "UPDATE {$logsTable} SET step_key = '{$stepKey}' WHERE id = {$id}";
@@ -132,7 +132,16 @@ class Migration_20230831_143755_Db extends DbMigration {
} }
} }
$this->connection->executeStatement(implode(';', $queries)); $nativeConnection = $this->connection->getNativeConnection();
// If the connection is a mysqli object, we can use the multi_query method
if (is_object($nativeConnection) && get_class($nativeConnection) === 'mysqli') {
$query = implode(';', $queries);
$nativeConnection->multi_query($query);
} else { // Otherwise, we need to execute each query individually (e.g. PDO or SQLite)
foreach ($queries as $query) {
$this->connection->executeStatement($query);
}
}
} }
} }
} }