Comments fix

milvus-io · Jul 13, 2024 · 4d71943 · 4d71943
1 parent 3bb279b
commit 4d71943
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/Milvus.Client/MilvusCollection.Entity.cs b/Milvus.Client/MilvusCollection.Entity.cs
@@ -567,13 +567,16 @@ public async IAsyncEnumerable<IReadOnlyList<FieldData>> QueryWithIteratorAsync(
                     Value = Math.Min(batchSize, leftItemsCount).ToString(CultureInfo.InvariantCulture)
                 });
 
-            string nextExpression = pkField.DataType == DataType.VarChar
-                ? $"{pkField.Name} > '{pkLastValue}'"
-                : $"{pkField.Name} > {pkLastValue}";
+            string nextExpression = pkField.DataType switch
+            {
+                DataType.VarChar => $"{pkField.Name} > '{pkLastValue}'",
+                DataType.Int8 or DataType.Int16 or DataType.Int32 or DataType.Int64 => $"{pkField.Name} > '{pkLastValue}'",
+                _ => throw new MilvusException("Unsupported data type for primary key field")
+            };
 
             if (!string.IsNullOrWhiteSpace(userExpression))
             {
-                nextExpression += $" and {userExpression}";
+                nextExpression += $" and ({userExpression})";
             }
 
             request.Expr = nextExpression;