变更
This commit is contained in:
@@ -90,7 +90,11 @@ class DatabasesProviders extends Providers
|
|||||||
if (!empty($databases)) {
|
if (!empty($databases)) {
|
||||||
$connection = Kiri::getDi()->get(PoolConnection::class);
|
$connection = Kiri::getDi()->get(PoolConnection::class);
|
||||||
foreach ($databases as $database) {
|
foreach ($databases as $database) {
|
||||||
$connection->disconnect($database['cds']);
|
$connection->disconnect($database['cds'] . 'master');
|
||||||
|
|
||||||
|
$slaveCds = ($database['slaveConfig']['cds'] ?? $database['cds']) . 'slave';
|
||||||
|
|
||||||
|
$connection->disconnect($slaveCds);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user