本文介绍如何在 Go 中借助 mgo.v2 驱动，利用 MongoDB 聚合管道（Aggregation Pipeline）高效执行 Sum + Delta本文介绍如何在 go 中借助 mgo.v2 驱动，利用 mongodb 聚合管道（aggregation pipeline）高效执行 `sum + delta
在 MongoDB 原生查询中，无法直接对多个字段做算术运算后进行比较（如
{"sum": {"$lt": 1000 - "$delta"}}是非法语法）。此时需借助聚合框架的$project阶段动态计算新字段（如total = sum + delta），再通过$match对该计算字段施加条件。以下是标准、可复用的实现方式：
pipe := c_marks.Pipe([]bson.M{ { "$project": bson.M{ "_id": 1, "name": 1, "sum": 1, "delta": 1, "total": bson.M{"$add": []interface{}{"$sum", "$delta"}}, // 注意：应使用 interface{} 类型切片，而非 string }, }, { "$match": bson.M{"total": bson.M{"$lt": 1000}}, }, }) var results []MarkModel err := pipe.All(&results) if err != nil { log.Fatal("聚合查询失败:", err) }⚠️ 关键注意事项：
$add操作符接收的是[]interface{}类型参数（非[]string），虽然"$$sum"和"$$delta"在旧版 mgo 中常被误写为字符串，但正确写法应为[]interface{}{"$sum", "$delta"}——$符号表示字段引用，类型必须为interface{}才能被 mgo 正确序列化为 BSON 字段路径。$project中显式列出所需字段（如_id,name,sum,delta）可控制输出结构；若需保留全部原始字段，可用"$add": []interface{}{"$sum", "$delta"}并省略其他字段，或使用$mergeObjects（高级场景）。mgo.v2已停止维护，生产环境建议迁移到官方驱动mongo-go-driver，其语法更清晰、类型更安全，且原生支持表达式（如bson.D{{"$expr", bson.D{{"$lt", bson.A{"$sum", "$delta", 1000}}}}}）。✅ 替代方案（推荐用于新项目）：
若已升级至官方 MongoDB Go Driver，可直接使用$expr查询（无需聚合管道）：filter := bson.M{"$expr": bson.M{"$lt": []interface{}{"$sum", "$delta", 1000}}} cursor, err := collection.Find(ctx, filter)综上，合理利用聚合管道的
$project + $match组合，是mgo.v2下实现字段运算过滤的最优解。它将计算与筛选下推至数据库层，显著减少网络传输与内存占用，大幅提升查询效率与系统可扩展性。
