2 回答

TA貢獻2036條經驗 獲得超8個贊
group :=[]bson.M{bson.M{
"$group": bson.M{
"_id":bson.M{
"field1": "$field1",
"field2": "$field2"
}
}
},
bson.M {
"$group": bson.M{
"_id":nil,
"count": bson.M{
"$sum":1
}
}
}
}
cursor, err := coll.Aggregate(context.Background(), mongo.Pipeline{group})
if err != nil {
log.Fatal(err)
}
嘗試上面的解決方案,它會起作用。

TA貢獻1797條經驗 獲得超6個贊
為了補充已接受的解決方案,我將共享帶有光標迭代和解碼的完整代碼。我將 更改"_id": nil為"_id": ""來接收字符串并能夠毫無問題地解碼為結構。
pipeline := []bson.M{
{
"$group": bson.M{"_id": bson.M{"field1": "$field1", "field2": "$field2"}},
},
{
"$group": bson.M{"_id": "", "count": bson.M{"$sum": 1}},
},
}
cursor, err := coll.Aggregate(ctx, pipeline)
if err != nil {
return err
}
type Result struct {
ID string `bson:"_id"`
Count int `bson:"count"`
}
var res Result
for cursor.Next(ctx) {
err := cursor.Decode(&res)
if err != nil {
return err
}
fmt.Printf("Element %v", res)
}
- 2 回答
- 0 關注
- 165 瀏覽
添加回答
舉報