Fixed Oracle SQL queries with IN condition and more than 1000 params

framework/CHANGELOG.md

@@ -84,6 +84,7 @@ Yii Framework 2 Change Log
 - Enh #13981: `yii\caching\Cache::getOrSet()` now supports both `Closure` and `callable` (silverfire)
 - Enh #13911: Significantly enhanced MSSQL schema reading performance (paulzi, WebdevMerlion)
 - Enh #14059: Removed unused AR instantiating for calling of static methods (ElisDN)
+- Bug #10305: Oracle SQL queries with `IN` condition and more than 1000 parameters are working now (silverfire)
 
 2.0.11.2 February 08, 2017
 --------------------------

framework/db/oci/QueryBuilder.php

@@ -331,4 +331,59 @@ public function buildLikeCondition($operator, $operands, &$params)
         }
         return parent::buildLikeCondition($operator, $operands, $params);
     }
+
+    /**
+     * @inheritdoc
+     */
+    public function buildInCondition($operator, $operands, &$params)
+    {
+        $splitCondition = $this->splitInCondition($operator, $operands, $params);
+        if ($splitCondition !== null) {
+            return $splitCondition;
+        }
+
+        return parent::buildInCondition($operator, $operands, $params);
+    }
+
+    /**
+     * Oracle DBMS does not support more than 1000 parameters in `IN` condition.
+     * This method splits long `IN` condition into series of smaller ones.
+     *
+     * @param string $operator
+     * @param array $operands
+     * @param array $params
+     * @return null|string null when split is not required. Otherwise - built SQL condition.
+     * @throws Exception
+     * @since 2.0.12
+     */
+    protected function splitInCondition($operator, $operands, &$params)
+    {
+        if (!isset($operands[0], $operands[1])) {
+            throw new Exception("Operator '$operator' requires two operands.");
+        }
+
+        list($column, $values) = $operands;
+
+        if ($values instanceof \Traversable) {
+            $values = iterator_to_array($values);
+        }
+
+        if (!is_array($values)) {
+            return null;
+        }
+
+        $maxParameters = 1000;
+        $count = count($values);
+        if ($count <= $maxParameters) {
+            return null;
+        }
+
+        $condition = [($operator === 'IN') ? 'OR' : 'AND'];
+        for ($i = 0; $i < $count; $i += $maxParameters) {
+            $condition[] = [$operator, $column, array_slice($values, $i, $maxParameters)];
+        }
+
+        return $this->buildCondition(['AND', $condition], $params);
+    }
+
 }

tests/framework/db/mssql/QueryBuilderTest.php

@@ -2,8 +2,6 @@
 
 namespace yiiunit\framework\db\mssql;
 
-use yii\db\Expression;
-use yii\db\mssql\Schema;
 use yii\db\Query;
 
 /**

tests/framework/db/oci/QueryBuilderTest.php

@@ -3,6 +3,7 @@
 namespace yiiunit\framework\db\oci;
 
 use yii\db\oci\Schema;
+use yiiunit\data\base\TraversableObject;
 
 /**
  * @group db
@@ -86,4 +87,52 @@ public function likeConditionProvider()
         $this->likeParameterReplacements[$encodedBackslash] = '\\';
         return parent::likeConditionProvider();
     }
+
+    public function conditionProvider()
+    {
+        return array_merge(parent::conditionProvider(), [
+            [
+                ['in', 'id', range(0, 2500)],
+
+                ' ('
+                . '([[id]] IN (' . implode(', ', $this->generateSprintfSeries(':qp%d', 0, 999)) . '))'
+                . ' OR ([[id]] IN (' . implode(', ', $this->generateSprintfSeries(':qp%d', 1000, 1999)) . '))'
+                . ' OR ([[id]] IN (' . implode(', ', $this->generateSprintfSeries(':qp%d', 2000, 2500)) .'))'
+                . ')',
+
+                array_flip($this->generateSprintfSeries(':qp%d', 0, 2500))
+            ],
+            [
+                ['not in', 'id', range(0, 2500)],
+
+                '('
+                . '([[id]] NOT IN (' . implode(', ', $this->generateSprintfSeries(':qp%d', 0, 999)) . '))'
+                . ' AND ([[id]] NOT IN (' . implode(', ', $this->generateSprintfSeries(':qp%d', 1000, 1999)) . '))'
+                . ' AND ([[id]] NOT IN (' . implode(', ', $this->generateSprintfSeries(':qp%d', 2000, 2500)) .'))'
+                . ')',
+
+                array_flip($this->generateSprintfSeries(':qp%d', 0, 2500))
+            ],
+            [
+                ['not in', 'id', new TraversableObject(range(0, 2500))],
+
+                '('
+                . '([[id]] NOT IN (' . implode(', ', $this->generateSprintfSeries(':qp%d', 0, 999)) . '))'
+                . ' AND ([[id]] NOT IN (' . implode(', ', $this->generateSprintfSeries(':qp%d', 1000, 1999)) . '))'
+                . ' AND ([[id]] NOT IN (' . implode(', ', $this->generateSprintfSeries(':qp%d', 2000, 2500)) .'))'
+                . ')',
+
+                array_flip($this->generateSprintfSeries(':qp%d', 0, 2500))
+            ],
+        ]);
+    }
+
+    protected function generateSprintfSeries ($pattern, $from, $to) {
+        $items = [];
+        for ($i = $from; $i <= $to; $i++) {
+            $items[] = sprintf($pattern, $i);
+        }
+
+        return $items;
+    }
 }