Go 语言使用官方驱动进行 MongoDB 聚合查询详解

准备条件：环境搭建与数据初始化

在开始编写聚合代码前，需要确保本地或服务器已运行 MongoDB 实例，并在 Go 项目中安装官方驱动。

1. 启动 MongoDB 服务。
2. 使用 Go Modules 引入依赖：go get go.mongodb.org/mongo-driver/mongo。
3. 连接到数据库并使用 shell 或程序插入测试数据。

demo> db.student.insert({"field": "score", "num": [12, 23, 34, 45, 56, 67, 78, 89]})

核心概念：BSON 类型映射

MongoDB 基于 BSON（二进制 JSON），在 Go 中构建查询参数时，主要使用以下结构：

• bson.D{{...}}：有序文档，对顺序敏感的指令（如聚合阶段）必须使用此类型。
• bson.M{}：无序 Map，用于常规筛选条件。
• bson.A{}：有序数组。
• bson.E{Key:"", Value: nil}：表示一个键值对元素。

实现步骤：翻译聚合管道到 Go 代码

第一步：建立数据库连接

配置连接 URI 并验证连通性，获取目标集合（Collection）引用。

import (
    "context"
    "log"
    "go.mongodb.org/mongo-driver/mongo"
    "go.mongodb.org/mongo-driver/mongo/options"
)

clientOptions := options.Client().ApplyURI("mongodb://admin:123456@localhost:27017")
client, err := mongo.Connect(context.TODO(), clientOptions)
if err != nil { log.Fatal(err) }
collection := client.Database("demo").Collection("student")

第二步：定义聚合管道（Pipeline）

聚合是将多个处理阶段串联的过程。我们需要为每个 MongoDB 命令创建对应的 bson.D 结构体：

1. $unwind：展开数组字段。bson.D{{"$unwind", "$num"}}
2. $project：提取并重命名字段。bson.D{{"$project", bson.D{{"value", "$num"}}}}
3. $match：过滤数值区间（例如 40~90 之间）。bson.D{{"$match", bson.D{{"value", bson.D{{"$gte", 40}, {"$lt", 90}}}}}}
4. $group：按指定键分组并统计数量。bson.D{{"$group", bson.D{{"_id", nil}, {"count", bson.D{{"$sum", 1}}}}}}

第三步：执行 Aggregate 操作

将定义的 BSON 切片作为 Pipeline 传入 collection.Aggregate 方法，并遍历游标输出结果：

pipeline := mongo.Pipeline{unwindStage, projectStage, matchStage, groupStage}
cursor, err := collection.Aggregate(context.TODO(), pipeline)

var results []map[string]interface{}
cursor.All(context.TODO(), &results)
for _, res := range results {
    fmt.Println(res) // 输出: map[_id:<nil> count:5]
}

注意事项

• 顺序敏感：MongoDB 的聚合阶段是有序的，因此在 Go 中必须使用 bson.D 而非无序的 bson.M。
• 内存开销：若数据量极大，建议使用 cursor.Next() 逐条读取，而非一次性加载所有结果到内存。

以上就是 Golang 对 mongodb 进行聚合查询详解的详细内容，更多关于 Golang mongodb 聚合查询的资料请关注本站其它相关文章！