Commit 37cc936e authored by Vladislav Vlastovskiy's avatar Vladislav Vlastovskiy Committed by Benjamin Eberlei

Fixed logic error

parent 2addbddb
...@@ -80,7 +80,7 @@ class PoolingShardManager implements ShardManager ...@@ -80,7 +80,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