MongoDB聚合查询通过管道阶段组合的方式，能够完成多集合关联、字段处理、数据过滤等复杂操作，其中多集合深度关联和数据类型转换是业务开发中非常常见的需求，比如订单集合关联用户集合、商品集合，同时需要将字符串格式的订单金额转为数值类型做统计。
多集合深度关联的实现方式
MongoDB聚合查询中使用$lookup阶段实现集合关联，对于多集合深度关联的场景，可以通过嵌套$lookup或者多次使用$lookup阶段来完成。
基础单集合关联示例
首先看单个集合关联的基础用法，假设存在orders订单集合和users用户集合，订单中存储了user_id字段，需要关联查询用户的基础信息：
// 订单集合示例文档
{
"_id": ObjectId("650a1b2c3d4e5f6a7b8c9d0e"),
"order_no": "ORD20240501001",
"user_id": "1001",
"amount": "199.9",
"create_time": ISODate("2024-05-01T10:00:00Z")
}
// 用户集合示例文档
{
"_id": ObjectId("650a1b2c3d4e5f6a7b8c9d0f"),
"user_id": "1001",
"user_name": "张三",
"age": 25
}
// 聚合关联查询代码
db.orders.aggregate([
{
$lookup: {
from: "users", // 要关联的目标集合
localField: "user_id", // 当前集合的关联字段
foreignField: "user_id", // 目标集合的关联字段
as: "user_info" // 关联结果存放的字段名
}
}
])
多集合嵌套关联示例
如果需要同时关联users用户集合和products商品集合，可以在第一次$lookup的结果上再做第二次关联，实现深度关联：
// 商品集合示例文档
{
"_id": ObjectId("650a1b2c3d4e5f6a7b8c9d10"),
"product_id": "P001",
"product_name": "无线耳机",
"price": 199.9
}
// 订单中包含商品id字段product_id
{
"_id": ObjectId("650a1b2c3d4e5f6a7b8c9d0e"),
"order_no": "ORD20240501001",
"user_id": "1001",
"product_id": "P001",
"amount": "199.9",
"create_time": ISODate("2024-05-01T10:00:00Z")
}
// 多集合关联聚合代码
db.orders.aggregate([
{
// 第一步关联用户集合
$lookup: {
from: "users",
localField: "user_id",
foreignField: "user_id",
as: "user_info"
}
},
{
// 第二步关联商品集合
$lookup: {
from: "products",
localField: "product_id",
foreignField: "product_id",
as: "product_info"
}
},
{
// 将关联后的数组字段转为对象，方便后续处理
$addFields: {
user_info: { $arrayElemAt: ["$user_info", 0] },
product_info: { $arrayElemAt: ["$product_info", 0] }
}
}
])
数据类型转换的常用操作
聚合查询中提供了多个类型转换操作符，常用的包括$toInt、$toDouble、$toString、$toDate等，可以在$addFields或者$project阶段完成类型转换。
基础类型转换示例
还是以上面的订单集合为例，amount字段存储的是字符串类型，需要转为双精度数值类型做求和统计：
db.orders.aggregate([
{
$addFields: {
// 将字符串类型的amount转为双精度数值
amount_double: { $toDouble: "$amount" },
// 将user_id转为整数类型
user_id_int: { $toInt: "$user_id" }
}
}
])
关联后结合类型转换的完整示例
将多集合关联和类型转换组合使用，实现查询订单关联的用户和商品信息，同时转换金额类型并统计总金额：
db.orders.aggregate([
{
$lookup: {
from: "users",
localField: "user_id",
foreignField: "user_id",
as: "user_info"
}
},
{
$lookup: {
from: "products",
localField: "product_id",
foreignField: "product_id",
as: "product_info"
}
},
{
$addFields: {
user_info: { $arrayElemAt: ["$user_info", 0] },
product_info: { $arrayElemAt: ["$product_info", 0] },
// 转换金额类型
amount_num: { $toDouble: "$amount" }
}
},
{
// 按用户分组统计总金额
$group: {
_id: "$user_id",
user_name: { $first: "$user_info.user_name" },
total_amount: { $sum: "$amount_num" },
order_count: { $sum: 1 }
}
}
])
注意事项
$lookup关联时，目标集合必须在同一个数据库中，跨库关联需要额外处理。- 类型转换时如果字段值不符合转换规则，会抛出错误，可以使用
$convert操作符配置错误处理策略，比如转换失败时设置默认值。 - 多集合关联会产生较多的临时数据，建议配合
$match阶段在关联前先过滤数据，提升查询性能。
通过上述方法，就可以灵活实现MongoDB聚合查询中的多集合深度关联和数据类型转换需求，适配各类复杂业务场景的数据处理要求。