MongoDB - 2 个文档之间的聚合,使用字符串数组的字段进行连接
MongoDB - aggregation between 2 documents with join using field that is array of strings
我的架构如下所示
批量收集:
{"_id":{"$oid":"61e82ed943389ffc5d277055"},
"name":"Batch ready to process",
"DocumentIDs":["61e82edb75d2841f2a8a023d"]}
文献集:
{"_id":{"$oid":"61e82edb75d2841f2a8a023d"},
"DocumentStatus":{"ActionId":"1","ActionType":"Type1","Status":"Status1"}
}
因此批处理集合具有文档 ID 数组。
我如何合并这两个集合?
我试图使用聚合查找,但它似乎不适用于这种情况,因为它的模式只允许比较单个简单字段,我需要检查文档 ID 是否存在于数组“DocumentIDs”中。
因此,我只需要包含文档集合中仅存在的 2 个字段的项目列表:“ActionType”和“Status”。我需要一个特定批次 ID 的列表 - 所以批次 ID 是一个过滤条件。
这是聚合查找的架构
/**
* from: The target collection.
* localField: The local join field.
* foreignField: The target join field.
* as: The name for the results.
* pipeline: The pipeline to run on the joined collection.
* let: Optional variables to use in the pipeline field stages.
*/
{
from: 'string',
localField: 'string',
foreignField: 'string',
as: 'string'
}
-亚采克
可能是这样的:
db.getCollection('batches').aggregate([
{$match: {_id : ObjectId('61e82ed943389ffc5d277055')}},
{$unwind : {"path" : "$DocumentIDs"}},
{$project: {
_id: 1,
"documentId" : {$toObjectId: "$DocumentIDs"}
}
},
{$lookup:
{
from: 'documents',
localField: "documentId",
foreignField: "_id",
as: "join_results"
}
},
{$unwind: {"path" : "$join_results"}},
{$project:
{
"_id" : 0,
"actionType" : "$join_results.DocumentStatus.ActionId",
"status" : "$join_results.DocumentStatus.Status",
}
}
])
我的架构如下所示
批量收集:
{"_id":{"$oid":"61e82ed943389ffc5d277055"},
"name":"Batch ready to process",
"DocumentIDs":["61e82edb75d2841f2a8a023d"]}
文献集:
{"_id":{"$oid":"61e82edb75d2841f2a8a023d"},
"DocumentStatus":{"ActionId":"1","ActionType":"Type1","Status":"Status1"}
}
因此批处理集合具有文档 ID 数组。 我如何合并这两个集合? 我试图使用聚合查找,但它似乎不适用于这种情况,因为它的模式只允许比较单个简单字段,我需要检查文档 ID 是否存在于数组“DocumentIDs”中。
因此,我只需要包含文档集合中仅存在的 2 个字段的项目列表:“ActionType”和“Status”。我需要一个特定批次 ID 的列表 - 所以批次 ID 是一个过滤条件。
这是聚合查找的架构
/**
* from: The target collection.
* localField: The local join field.
* foreignField: The target join field.
* as: The name for the results.
* pipeline: The pipeline to run on the joined collection.
* let: Optional variables to use in the pipeline field stages.
*/
{
from: 'string',
localField: 'string',
foreignField: 'string',
as: 'string'
}
-亚采克
可能是这样的:
db.getCollection('batches').aggregate([
{$match: {_id : ObjectId('61e82ed943389ffc5d277055')}},
{$unwind : {"path" : "$DocumentIDs"}},
{$project: {
_id: 1,
"documentId" : {$toObjectId: "$DocumentIDs"}
}
},
{$lookup:
{
from: 'documents',
localField: "documentId",
foreignField: "_id",
as: "join_results"
}
},
{$unwind: {"path" : "$join_results"}},
{$project:
{
"_id" : 0,
"actionType" : "$join_results.DocumentStatus.ActionId",
"status" : "$join_results.DocumentStatus.Status",
}
}
])