Asa*_*af 5 aggregation mongodb mongodb-query
我正在使用 MongoDB,我尝试使用许多管道步骤来完成它,但找不到方法。
我有一个玩家集合,每个玩家包含一个items
数组
{
"_id": ObjectId("5fba17c1c4566e57fafdcd7e"),
"username": "moshe",
"items": [
{
"_id": ObjectId("5fbb5ac178045a985690b5fd"),
"equipped": false,
"itemId": "5fbb5ab778045a985690b5fc"
}
]
}
Run Code Online (Sandbox Code Playgroud)
我有一个项目集合,其中包含有关播放器items
数组中每个项目的更多信息。
{
"_id": ObjectId("5fbb5ab778045a985690b5fc"),
"name": "Axe",
"damage": 4,
"defense": 6
}
Run Code Online (Sandbox Code Playgroud)
我的目标是拥有一个玩家文档,其中包含有关其items
数组中项目的所有信息,因此它看起来像这样:
{
"_id": ObjectId("5fba17c1c4566e57fafdcd7e"),
"username": "moshe",
"items": [
{
"_id": ObjectId("5fbb5ac178045a985690b5fd"),
"equipped": false,
"itemId": "5fbb5ab778045a985690b5fc",
"name": "Axe",
"damage": 4,
"defense": 6
}
]
}
Run Code Online (Sandbox Code Playgroud)
tur*_*hal 16
$unwind
解构items
数组$lookup
要加入items
集合,请itemsId
在使用$toObjectId
和传递items
对象将其转换为对象 id 后传递给 let,
$match
itemId
状况$mergeObject
合并items
对象和$$ROOT
对象并替换为根使用$replaceRoot
$group
再次重建items
数组,分组_id
并获取第一个username
并构造items
数组db.players.aggregate([
{ $unwind: "$items" },
{
$lookup: {
from: "items",
let: {
itemId: { $toObjectId: "$items.itemId" },
items: "$items"
},
pipeline: [
{ $match: { $expr: { $eq: ["$_id", "$$itemId" ] } } },
{ $replaceRoot: { newRoot: { $mergeObjects: ["$$items", "$$ROOT"] } } }
],
as: "items"
}
},
{
$group: {
_id: "$_id",
username: { $first: "$username" },
items: { $push: { $first: "$items" } }
}
}
])
Run Code Online (Sandbox Code Playgroud)
第二个选项使用$map
, 和不使用$unwind
,
$addFields
使用and将字符串items
转换为对象类型 iditemId
$toObjectId
$map
$lookup
加入items
收藏$project
显示必填字段,合并items
数组并itemsCollection
使用$map
迭代项目数组循环$filter
来获取匹配itemId
并$first
从返回结果中获取第一个对象,$mergeObject
合并当前对象和返回的对象$first
db.players.aggregate([
{
$addFields: {
items: {
$map: {
input: "$items",
in: {
$mergeObjects: ["$$this", { itemId: { $toObjectId: "$$this.itemId" } }]
}
}
}
}
},
{
$lookup: {
from: "items",
localField: "items.itemId",
foreignField: "_id",
as: "itemsCollection"
}
},
{
$project: {
username: 1,
items: {
$map: {
input: "$items",
as: "i",
in: {
$mergeObjects: [
"$$i",
{
$first: {
$filter: {
input: "$itemsCollection",
cond: { $eq: ["$$this._id", "$$i.itemId"] }
}
}
}
]
}
}
}
}
}
])
Run Code Online (Sandbox Code Playgroud)
首先,我强烈建议您应该存储items.itemId
asObjectId
而不是字符串。
那么另一个简单的解决方案可以是:
db.players.aggregate([
{
$lookup: {
from: "items",
localField: "items.itemId",
foreignField: "_id",
as: "itemsDocuments",
},
},
{
$addFields: {
items: {
$map: {
input: { $zip: { inputs: ["$items", "$itemsDocuments"] } },
in: { $mergeObjects: "$$this" },
},
},
},
},
{ $unset: "itemsDocuments" },
])
Run Code Online (Sandbox Code Playgroud)
归档时间: |
|
查看次数: |
1527 次 |
最近记录: |