我想使用
对字段求和pipeline := []bson.M{
bson.M{"$group": bson.M{
"_id": "",
"count": bson.M{ "$sum": 1}}}
}
ctx, _ := context.WithTimeout(context.Background(), 5*time.Second)
result, err := collection.Aggregate(ctx, pipeline)
但它总是返回
"Current": null
有什么解决办法吗?
最佳答案
首先,Collection.Aggregate()
返回 mongo.Cursor
,而不是“直接”结果。您必须迭代光标才能获取结果文档(例如使用 Cursor.Next()
和 Cursor.Decode()
),或使用 Cursor.All()
一步获取所有结果文档。
接下来,您没有指定要求和的字段。您所拥有的是一个简单的“计数”,它将返回已处理的文档数量。要真正对字段求和,您可以使用
"sum": bson.M{"$sum": "$fieldName"}
让我们看一个例子。假设数据库 "example"
集合 "checks"
中有以下文档:
{ "_id" : ObjectId("5dd6f24742be9bfe54b298cb"), "payment" : 10 }
{ "_id" : ObjectId("5dd6f24942be9bfe54b298cc"), "payment" : 20 }
{ "_id" : ObjectId("5dd6f48842be9bfe54b298cd"), "payment" : 4 }
这就是我们计算支票并对付款求和的方式(付款
字段):
c := client.Database("example").Collection("checks")
pipe := []bson.M{
{"$group": bson.M{
"_id": "",
"sum": bson.M{"$sum": "$payment"},
"count": bson.M{"$sum": 1},
}},
}
cursor, err := c.Aggregate(ctx, pipe)
if err != nil {
panic(err)
}
var results []bson.M
if err = cursor.All(ctx, &results); err != nil {
panic(err)
}
if err := cursor.Close(ctx); err != nil {
panic(err)
}
fmt.Println(results)
这将输出:
[map[_id: count:3 sum:34]]
结果是一个只有一个元素的 slice ,显示已处理 3
个文档,并且(付款)总和为 34
。
关于mongodb - mongo-go-driver聚合查询总是返回 "Current": null,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/58981825/