修复：IN操作

dxkite · Jul 17, 2019 · 78e8649 · 78e8649
1 parent ff61668
commit 78e8649
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/suda/src/database/statement/PrepareTrait.php b/suda/src/database/statement/PrepareTrait.php
@@ -63,7 +63,7 @@ protected function prepareWhere(array $where)
     private function getQueryForArray(string $name, $value)
     {
         if ($value instanceof IteratorAggregate) {
-            return $this->prepareIn($name, $value);
+            return $this->prepareIn($name, 'IN', $value);
         } elseif (is_array($value)) {
             list($op, $val) = $value;
             $op = trim($op);
@@ -90,7 +90,7 @@ private function createQueryOperation(string $name, string $operation, $value, s
             return new Query("`{$name}` {$operation} (".$value->getQuery().')', $value->getBinder());
         }
         if ($value instanceof IteratorAggregate || is_array($value)) {
-            return $this->prepareIn($name, $value);
+            return $this->prepareIn($name, $operation, $value);
         }
         if (strlen($indexName) === 0) {
             $indexName = Binder::index($name);
@@ -145,13 +145,13 @@ protected function prepareWhereString(string $where, array $whereBinder)
      * @return Query
      * @throws SQLException
      */
-    protected function prepareIn(string $name, $values)
+    protected function prepareIn(string $name, string $operation, $values)
     {
         if ($values instanceof Query || $values instanceof Statement) {
             return $this->createQueryOperation($name, 'in', $values);
         }
         list($inSQL, $binders) = $this->prepareInParameter($values, $name);
-        $sql = '`'.$name.'` IN ('.$inSQL.')';
+        $sql = '`'.$name.'` '.strtoupper($operation).' ('.$inSQL.')';
         return new Query($sql, $binders);
     }
 
@@ -187,7 +187,7 @@ private function count($value)
         }
         return iterator_count($value);
     }
-    
+
     /**
      * 准备更新
      *