Golang对mongodb进行聚合查询详解

我们来详细讲解一下“Golang对mongodb进行聚合查询”的完整攻略。首先我们需要了解一下什么是聚合查询。

聚合查询就是将多个文档（document）合并成一个结果文档的操作，它可以用于统计、求和、分组等操作。在mongodb中，聚合查询使用聚合管道（pipeline）来实现。

接下来，我们将结合两个示例来详细说明如何使用Golang来对mongodb进行聚合查询。

示例一：统计某个集合中各个“age”字段的平均值

pipeline := bson.A{
    bson.M{"$group": bson.M{
        "_id":   "$age",
        "count": bson.M{"$sum": 1},
    }},
    bson.M{"$sort": bson.M{"_id": 1}},
}

cursor, err := collection.Aggregate(context.Background(), pipeline)
if err != nil {
    log.Fatal(err)
}
defer cursor.Close(context.Background())

for cursor.Next(context.Background()) {
    var result bson.M
    err := cursor.Decode(&result)
    if err != nil {
        log.Fatal(err)
    }

    fmt.Printf("Age: %v, Count: %v\n", result["_id"], result["count"])
}

这段代码中，我们首先定义了一个pipeline，其中包含了两个stage：

1. 使用$group stage将集合中的文档按照“age”字段进行分组，然后使用$sum操作符对每个分组的文档数量进行统计，并将结果保存到count字段中。
2. 使用$sort操作符对结果文档按照“age”字段进行升序排序。

然后我们使用collection.Aggregate函数执行聚合查询，并将结果保存到cursor中。

最后我们使用cursor.Next函数遍历查询结果，并使用cursor.Decode函数将每个文档中的数据解码到bson.M类型的result变量中。然后我们可以从result中获取“age”字段和“count”字段的值，并输出到控制台中。

示例二：获取某个集合中年龄最大的文档

pipeline := bson.A{
    bson.M{"$sort": bson.M{"age": -1}},
    bson.M{"$limit": 1},
}

cursor, err := collection.Aggregate(context.Background(), pipeline)
if err != nil {
    log.Fatal(err)
}
defer cursor.Close(context.Background())

for cursor.Next(context.Background()) {
    var result bson.M
    err := cursor.Decode(&result)
    if err != nil {
        log.Fatal(err)
    }

    fmt.Println(result)
}

这段代码中，我们定义了一个pipeline，其中包含了两个stage：

1. 使用$sort操作符将集合中的文档按照“age”字段进行降序排序。
2. 使用$limit操作符将结果文档数量限制为1个。

然后我们使用collection.Aggregate函数执行聚合查询，并将结果保存到cursor中。

最后我们使用cursor.Next函数遍历查询结果，并使用cursor.Decode函数将结果文档解码到bson.M类型的result变量中，然后输出到控制台中即可。

希望这两个示例可以帮助大家更好地了解如何使用Golang来对mongodb进行聚合查询。