将集合加入到现有的聚合查询 mongodb

Question

我的 mongodb 数据库中有以下集合结构。

订单

[  
   {  
      "_id":"order_abcd",
      "name":"Order 1"
   },
   {  
      "_id":"order_defg",
      "name":"Order 2"
   }
]

会话

{  
   "_id":"session_abcd"
   "orders": [ ObjectId("order_abcd"), ObjectId("order_defg") ]
}

交易

{  
   "_id":"transaction_abcd"
   "id_session" : ObjectId("session_abcd")
}

我想要实现的是一个与此类似的数据集

[  
   {  
      "_id":"order_abcd",
      "name":"Order 1",
      "transaction":"transaction_abcd"
   },
   {  
      "_id":"order_defg",
      "name":"Order 2",
      "transaction":"transaction_abcd"
   }
]

除了将用于过滤订单的start date 和end date 之外，我没有任何输入数据，该查询主要用于报告目的，因此实际上我正在尝试生成一个查询以获取所有订单在给定的时间段之间，并将每个订单的交易 ID 附加到它。

Answer 1

我们可以在每个阶段使用一对$lookup（类似于在SQL 中连接2 个表）和$unwind，最终$project 得到所需的键值对。

db.Session.aggregate([
  {
    $lookup: {
      from: "Transactions",
      localField: "_id",
      foreignField: "id_session",
      as: "transaction_info"
    }
  },
  { $unwind: "$transaction_info" },
  {
    $lookup: {
      from: "Orders",
      localField: "orders",
      foreignField: "_id",
      as: "order_info"
    }
  },
  { $unwind: "$order_info" },
  {$project:{
    _id:"$order_info._id",
    name:"$order_info.name",
    transaction:"$transaction_info._id"
  }}
]).pretty();

给出输出：

{
    "_id" : "order_abcd",
    "name" : "Order 1",
    "transaction" : "transaction_abcd"
},
{
    "_id" : "order_defg",
    "name" : "Order 2",
    "transaction" : "transaction_abcd"
}

展开阶段用于展开查找，然后在最终项目阶段挑选字段。

++更新++

另一个可能有助于减少第二阶段查找记录的选项，因为$match 日期为Orders 可用于传递过滤后的文档以供下一阶段使用。

db.Session.aggregate([
  {
    $lookup: {
      from: "Orders",
      localField: "orders",
      foreignField: "_id",
      as: "order_info"
    }
  },
  { $unwind: "$order_info" },
  {
    $match: {} //filter on "order_info.property" (i:e; date,name,id)
  },
  {
    $lookup: {
      from: "Transactions",
      localField: "_id",
      foreignField: "id_session",
      as: "transaction_info"
    }
  },
  { $unwind: "$transaction_info" },
  {
    $project: {
      _id: "$order_info._id",
      name: "$order_info.name",
      transaction: "$transaction_info._id"
    }
  }
]).pretty();