modify plugin name

2022-06-08 14:43:23 +08:00
parent b8542f6a70
commit 9ce43895b1
1 changed files with 2 additions and 4 deletions
@@ -87,8 +87,6 @@ class Connection extends Component

 	/**
 	 * @return void
-	 * @throws ContainerExceptionInterface
-	 * @throws NotFoundExceptionInterface
 	 * @throws Exception
 	 */
 	public function init()
@@ -120,10 +118,10 @@ class Connection extends Component
 	{
 		$connections = $this->connections();
 		$pool = Config::get('databases.pool.max', 10);
-
-		$connections->initConnections('Mysql:' . $this->cds, $pool);
 		if (!empty($this->slaveConfig) && $this->cds != $this->slaveConfig['cds']) {
 			$connections->initConnections('Mysql:' . $this->slaveConfig['cds'], $pool);
+		} else {
+			$connections->initConnections('Mysql:' . $this->cds, $pool);
 		}
 	}