FAQ
如果实现类似的sql的 join 功能呢?
查看官方文档
ask
- ask : 我在写在mongodb的相关内容, 有一个user collection ,还有一个comment collection,commment通过 userid 与user 进行了关联,,我在查询comment ,如何得到每个comment 里的user 的相关属性?
Answser
在 MongoDB 中，如果 comment 集合中的每个文档通过 userId 字段与 user 集合中的用户进行关联，并且你希望在查询 comment 时获取每个评论对应的 user 的相关属性，你可以使用 $lookup 聚合操作来实现联表查询。
示例数据结构
user 集合:
1{ 2 "_id": ObjectId("user1"), 3 "name": "Alice", 4 "email": "alice@example.com", 5 "age": 30 6}comment 集合:
1{ 2 "_id": ObjectId("comment1"), 3 "content": "This is a comment", 4 "userId": ObjectId("user1"), 5 "timestamp": ISODate("2024-12-09T10:00:00Z") 6}
使用 $lookup 进行联表查询
你可以使用聚合框架（aggregate()）结合 $lookup 来连接 comment 和 user 集合，并将每个评论对应的用户信息合并到评论数据中。
聚合查询示例
1db.comment.aggregate([
2 {
3 $lookup: {
4 from: "user", // 关联的集合是 "user"
5 localField: "userId", // 当前集合中关联字段是 "userId"
6 foreignField: "_id", // 关联到 "user" 集合中的 "_id" 字段
7 as: "userDetails" // 结果会放入 "userDetails" 数组字段
8 }
9 },
10 {
11 $unwind: "$userDetails" // 将 "userDetails" 数组展开成单个对象（如果每个评论只能有一个用户的话）
12 }
13])
查询结果
假设 comment 集合有一个文档，如下所示：
1{
2 "_id": ObjectId("comment1"),
3 "content": "This is a comment",
4 "userId": ObjectId("user1"),
5 "timestamp": ISODate("2024-12-09T10:00:00Z"),
6 "userDetails": {
7 "_id": ObjectId("user1"),
8 "name": "Alice",
9 "email": "alice@example.com",
10 "age": 30
11 }
12}
解析说明
$lookup: 在comment集合中的userId字段和user集合中的_id字段之间建立连接，将匹配到的用户信息加入到每个评论中，并存储在userDetails字段中。$unwind: 如果你确定每个评论只有一个对应的用户（即userId字段指向的是唯一用户），使用$unwind将userDetails数组拆解成单个对象。这样，你就可以直接在每个评论文档中获取到用户的属性。
如果一个评论可能有多个用户（例如评论可能有多个作者），你可以跳过 $unwind，这样每个评论的 userDetails 会是一个数组，包含匹配的所有用户。
其他改进
如果你只关心某些特定的用户字段，可以通过 $project 对返回的字段进行过滤，减少数据传输量。例如：
1db.comment.aggregate([
2 {
3 $lookup: {
4 from: "user",
5 localField: "userId",
6 foreignField: "_id",
7 as: "userDetails"
8 }
9 },
10 {
11 $unwind: "$userDetails"
12 },
13 {
14 $project: {
15 content: 1, // 只保留评论的内容
16 "userDetails.name": 1, // 只返回用户的名字
17 "userDetails.email": 1 // 只返回用户的邮箱
18 }
19 }
20])
这样，结果将只包含评论内容以及用户的名字和邮箱。
总结
使用 aggregate() 方法结合 $lookup 可以轻松地在查询评论时获取每个评论对应用户的详细信息。如果你只关心部分用户字段，可以使用 $project 来限制返回的字段，优化查询效率。