support count('*') (#238)

Signed-off-by: shanghaikid <[email protected]>

milvus/grpc/Data.ts

@@ -709,13 +709,8 @@ export class Data extends Collection {
  offset = { offset: data.offset };
  }
 
- // check expr or filter
- if (!data.filter && !data.expr) {
- throw new Error(ERROR_REASONS.FILTER_EXPR_REQUIRED);
- }
-
- // filter > expr
- data.expr = data.filter || data.expr;
+ // filter > expr or empty
+ data.expr = data.filter || data.expr || '';
 
  // Execute the query and get the results
  const promise: QueryRes = await promisify(
@@ -728,9 +723,8 @@ export class Data extends Collection {
  data.timeout || this.timeout
  );
 
- // compatible with milvus before v2.2.9
- const output_fields =
- promise.output_fields || promise.fields_data.map(f => f.field_name);
+ // always get output_fields from fields_data
+ const output_fields = promise.fields_data.map(f => f.field_name);
 
  // Initialize an array to hold the query results
  let results: { [x: string]: any }[] = [];

package.json

@@ -1,7 +1,7 @@
 {
  "name": "@zilliz/milvus2-sdk-node",
  "author": "[email protected]",
- "version": "2.3.0",
+ "version": "2.3.1",
  "milvusVersion": "v2.3.0",
  "main": "dist/milvus",
  "files": [

test/Data.spec.ts

@@ -437,6 +437,16 @@ describe(`Data.API`, () => {
  expect(res.data.length).toBe(3);
  });
 
+ it(`Query with count(*)`, async () => {
+ const queryString = 'count(*)';
+ const res = await milvusClient.query({
+ collection_name: COLLECTION_NAME,
+ output_fields: [queryString],
+ });
+
+ expect(res.data.length).toEqual(1);
+ });
+
  it(`Query with data limit only`, async () => {
  const expr = 'age > 0';
  const res = await milvusClient.query({