diff --git a/Connection.php b/Connection.php index c2e079c..b2da286 100644 --- a/Connection.php +++ b/Connection.php @@ -264,7 +264,11 @@ class Connection extends Component { $connections = $this->connection; $cds = ($this->slaveConfig['cds'] ?? $this->cds) . ($isMaster ? 'master' : 'slave'); - if ($isMaster && !$pdo->inTransaction()) { + if ($isMaster) { + if (!$pdo->inTransaction()) { + $connections->addItem($cds, $pdo); + } + } else { $connections->addItem($cds, $pdo); } }