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