本文详解如何利用 mgo（MongoDB Go 驱动）的聚合管道，从嵌套数组字段（如 Requests）中高效筛选并投影指定 _id 的嵌入文档，避免全量加载与应用层过滤。
本文详解如何利用 mgo（mongodb go 驱动）的聚合管道，从嵌套数组字段（如 `requests`）中高效筛选并投影指定 `_id` 的嵌入文档，避免全量加载与应用层过滤。
在 MongoDB 中处理嵌套文档（如 Group.Requests 数组）时，若需仅提取满足条件的子文档（例如按 Requests._id 精确匹配多个 ID），直接使用 find 查询无法跨数组元素做高效筛选——必须借助聚合管道。核心思路是：解构数组 → 过滤匹配项 → 投影所需字段。
以下是基于 mgo（v2.0+，兼容旧版语法）的完整实现：
import (
"gopkg.in/mgo.v2"
"gopkg.in/mgo.v2/bson"
)
type Request struct {
ID int `bson:"_id" json:"_id"`
Name string `bson:"name" json:"name"`
}
func GetRequests(requestIDs []int) ([]Request, error) {
session := // 获取你的 mgo.Session（确保已建立连接）
defer session.Close()
collection := session.DB("your_db").C("Groups")
// 构建聚合管道
pipeline := []bson.M{
{"$unwind": "$Group.Requests"}, // 展开 Group.Requests 数组，每条记录生成一个文档
{"$match": bson.M{
"Group.Requests._id": bson.M{"$in": requestIDs}, // 匹配 Requests._id 在目标列表中
}},
{"$project": bson.M{
"_id": "$Group.Requests._id",
"name": "$Group.Requests.name",
"_id": 1, // 显式保留 _id 字段（注意：$project 中键名即输出字段名）
}},
}
var results []Request
err := collection.Pipe(pipeline).All(&results)
if err != nil {
return nil, err
}
return results, nil
}
⚠️ 关键注意事项：
- 字段路径必须精确：因数据结构为 { Group: { Requests: [...] } }，$unwind 和 $match 中需使用完整路径 "Group.Requests"，而非 "Requests"。
- $unwind 是必需步骤：它将每个 Requests 元素拆分为独立文档，使后续 $match 能对单个子文档生效。
- 类型一致性：示例中 requestIDs 为 []int，对应 BSON ObjectId 或整型 _id；若实际 _id 是 ObjectId，需转换为 bson.ObjectId 并使用 bson.ObjectIdHex() 解析字符串。
- 性能优化：该方案在数据库层完成过滤与投影，仅返回目标字段，显著减少网络传输和内存占用，优于应用层遍历+过滤。
- mgo 替代建议：mgo 已归档，生产环境推荐迁移至官方驱动 mongo-go-driver，其聚合语法更现代、维护更活跃。
通过此聚合流程，输入 [1,2,4] 将精准返回三个匹配的 Request 对象，结构清晰、执行高效，是处理嵌套数组查询的标准实践。
