diff --git a/DatabasesProviders.php b/DatabasesProviders.php index 070c295..6b6298b 100644 --- a/DatabasesProviders.php +++ b/DatabasesProviders.php @@ -90,7 +90,11 @@ class DatabasesProviders extends Providers if (!empty($databases)) { $connection = Kiri::getDi()->get(PoolConnection::class); foreach ($databases as $database) { - $connection->disconnect($database['cds']); + $connection->disconnect($database['cds'] . 'master'); + + $slaveCds = ($database['slaveConfig']['cds'] ?? $database['cds']) . 'slave'; + + $connection->disconnect($slaveCds); } } }