变更

2023-02-07 15:17:08 +08:00
parent 728b253c0b
commit 603e0a41fc
1 changed files with 5 additions and 3 deletions
@@ -63,11 +63,13 @@ class DatabasesProviders extends Providers
 				return;
 			}

-			$min = Config::get('databases.pool.min', 5);
-
 			$connection = Kiri::getDi()->get(PoolConnection::class);
 			foreach ($databases as $database) {
-				$connection->flush($database['cds'], $min);
+				$connection->flush($database['cds'] . 'master', $database['pool']['min'] ?? 1);
+
+				$slaveCds = ($database['slaveConfig']['cds'] ?? $database['cds']) . 'slave';
+
+				$connection->flush($slaveCds, $database['pool']['min'] ?? 1);
 			}

 			$this->logger->warning("database tick clear.");