fix aggregation match bug

baxiry · Sep 12, 2024 · 71a87cd · 71a87cd
1 parent 8e5c906
commit 71a87cd
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/engine/aggregate.go b/engine/aggregate.go
@@ -81,6 +81,9 @@ func aggrigate(query gjson.Result) string {
 	if err != nil {
 		return err.Error()
 	}
+	if len(data) == 0 {
+		return "[]"
+	}
 
 	group := query.Get("group")
 	if _id := group.Get("_id"); !_id.Exists() {

diff --git a/engine/coreFuncs.go b/engine/coreFuncs.go
@@ -35,10 +35,9 @@ func getData(query gjson.Result) (data []string, err error) {
 	}
 	defer rows.Close()
 
-	record := ""
-
 	isMatch := query.Get("match")
 
+	record := ""
 	for rows.Next() {
 
 		if limit == 0 {

diff --git a/store/store.go b/store/store.go
@@ -166,4 +166,7 @@ func (db *Database) Close() error {
 	}
 	clear(db.Collections)
 	return nil
+
 }
+
+// end
-Original file line number
+Diff line change
@@ Expand Up / @@ -166,4 +166,7 @@ func (db *Database) Close() error { @@
     	}
     	clear(db.Collections)
     	return nil
     }
+    // end