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:
向林
2022-09-20 18:35:20 +08:00
parent 202852a95d
commit dbf33b6d7d
1 changed files with 8 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Connection.php
+8 -10
View File
@@ -277,11 +277,10 @@ class Connection extends Component
*/
public function clear_connection()
{
$this->connection->connection_clear($this->cds);
if (!isset($this->slaveConfig['cds']) || $this->cds == $this->slaveConfig['cds']) {
return;
}
$this->connection->connection_clear($this->slaveConfig['cds']);
$cds = $this->slaveConfig['cds'] ?? $this->cds;
$this->connection->connection_clear($cds.'master');
$this->connection->connection_clear($cds.'slave');
}
@@ -290,11 +289,10 @@ class Connection extends Component
*/
public function disconnect()
{
$this->connection->disconnect($this->cds);
if (!isset($this->slaveConfig['cds']) || $this->cds == $this->slaveConfig['cds']) {
return;
}
$this->connection->disconnect($this->slaveConfig['cds']);
$cds = $this->slaveConfig['cds'] ?? $this->cds;
$this->connection->connection_clear($cds.'master');
$this->connection->connection_clear($cds.'slave');
}
}