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-10 10:56:19 +08:00
parent 17e51b7898
commit 97d8f8fac5
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Connection.php
+5 -6
View File
@@ -266,13 +266,12 @@ class Connection extends Component
public function release(PDO $pdo, bool $isMaster) public function release(PDO $pdo, bool $isMaster)
{ {
$connections = $this->connection; $connections = $this->connection;
$cds = ($this->slaveConfig['cds'] ?? $this->cds) . ($isMaster ? 'master' : 'slave'); if (!$isMaster) {
if ($isMaster) { $connections->addItem(($this->slaveConfig['cds'] ?? $this->cds) . 'slave', $pdo);
if (!$pdo->inTransaction()) {
$connections->addItem($cds, $pdo);
}
} else { } else {
$connections->addItem($cds, $pdo); if (!$pdo->inTransaction()) {
$connections->addItem($this->cds . 'master', $pdo);
}
} }
} }