Commit 4f7656ed authored by Vladislav Vlastovskiy's avatar Vladislav Vlastovskiy

Fixed logic error

parent 8f119eea
...@@ -115,7 +115,7 @@ class PoolingShardManager implements ShardManager ...@@ -115,7 +115,7 @@ class PoolingShardManager implements ShardManager
$oldDistribution = $this->getCurrentDistributionValue(); $oldDistribution = $this->getCurrentDistributionValue();
foreach ($shards as $shard) { foreach ($shards as $shard) {
$this->selectShard($shard['id']); $this->conn->connect($shard['id']);
foreach ($this->conn->fetchAll($sql, $params, $types) as $row) { foreach ($this->conn->fetchAll($sql, $params, $types) as $row) {
$result[] = $row; $result[] = $row;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment