Skip to content

Commit 92b31d7

Browse files
committed
support multiple connection pools
1 parent e4f4ed3 commit 92b31d7

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

src/Model/Logic/MigrateLogic.php

+7-2
Original file line numberDiff line numberDiff line change
@@ -525,9 +525,14 @@ private function groupByPoolMigrates(array $mathMigrateNames): array
525525
continue;
526526
}
527527
$time = $config['time'];
528-
$pool = $config['pool'];
529528

530-
$poolMigrates[$pool][] = compact('time', 'name');
529+
// support multiple connection pools
530+
$pools = $config['pool'];
531+
$params = compact('time', 'name');
532+
533+
foreach (explode(',', $pools) as $pools) {
534+
$poolMigrates[$pools][] = $params;
535+
}
531536
}
532537

533538
return $poolMigrates;

0 commit comments

Comments
 (0)