as2252258/kiri-databases
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

变更

Browse Source
This commit is contained in:
向林
2023-02-07 16:46:13 +08:00
parent 603e0a41fc
commit 73561a8983
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Connection.php
+4 -1
View File
@@ -117,10 +117,13 @@ class Connection extends Component
*/ */
public function connectPoolInstance() public function connectPoolInstance()
{ {
$pool = Config::get('databases.pool.max', 10);
if (!empty($this->slaveConfig) && $this->cds != $this->slaveConfig['cds']) { if (!empty($this->slaveConfig) && $this->cds != $this->slaveConfig['cds']) {
$pool = $this->pool ?? ['max' => 10, 'min' => 1];
$this->connection->initConnections('Mysql:' . $this->slaveConfig['cds'], $pool); $this->connection->initConnections('Mysql:' . $this->slaveConfig['cds'], $pool);
} else { } else {
$pool = $this->slaveConfig['pool'] ?? ['max' => 10, 'min' => 1];
$this->connection->initConnections('Mysql:' . $this->cds, $pool); $this->connection->initConnections('Mysql:' . $this->cds, $pool);
} }
} }