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:33:03 +08:00
parent 145970316f
commit 72cfba6a5d
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Connection.php
+4 -4
View File
@@ -199,7 +199,7 @@ class Connection extends Component
public function getPdo(): PDO
{
if (!Context::hasContext('master:client')) {
Context::setContext('master:client', $this->getMasterClient());
Context::setContext('master:client', $this->getMasterClient());
}
return Context::getContext('master:client');
}
@@ -260,14 +260,14 @@ class Connection extends Component
* 回收链接
* @throws
*/
public function release(PDO $pdo, $isMaster)
public function release(PDO $pdo, bool $isMaster)
{
$connections = $this->connection;
$cds = ($this->slaveConfig['cds'] ?? $this->cds) . ($isMaster ? 'master' : 'slave');
if (!$isMaster) {
$cds = $this->slaveConfig['cds'] ?? $this->cds;
$connections->addItem($cds, $pdo);
} else if (!$pdo->inTransaction()) {
$connections->addItem($this->cds, $pdo);
$connections->addItem($cds, $pdo);
}
}