paw*_*392 5 mongodb node.js aggregation-framework
我有一个MongoDB查询,例如
// Get scoreboard of challenge
response.aggregate = await ScoreBoardModel.aggregate([
{ $match: { challenge_id: mongoose.Types.ObjectId(req.body.challenge_id) } },
{ $group: { _id: '$user_id', value: { $sum: '$value' } } },
]);
Run Code Online (Sandbox Code Playgroud)
哪个输出像
[
{
"_id": "5b762887b6e3a91c60c01718",
"value": 4300
},
{
"_id": "5b8b41f10186400163d0df83",
"value": 6800
},
{
"_id": "5b762590b6e3a91c60c01713",
"value": 2023
}
]
Run Code Online (Sandbox Code Playgroud)
但我想执行此查询,如下所示:
response.aggregate = await ScoreBoardModel.aggregate([
{ $match: { challenge_id: mongoose.Types.ObjectId(req.body.challenge_id) } },
{ $lookup: {
from: 'appusers',
let: { 'user_id': '$user_id' },
pipeline: [{ $match: { $expr: { $eq: [ '$_id', '$$user_id' ] } } },],
as: 'user'
} },
{ $group: { _id: '$user_id', value: { $sum: '$value' } } },
]);
Run Code Online (Sandbox Code Playgroud)
我想$lookup在appusers得到的每一个细节appusers。我怎么做?
您需要使用$first聚合运算符来返回应用阶段后的第一个文档$group。
ScoreBoardModel.aggregate([
{ "$match": { challenge_id: mongoose.Types.ObjectId(req.body.challenge_id) } },
{ "$lookup": {
"from": "appusers",
"let": { "user_id": "$user_id" },
"pipeline": [{ "$match": { "$expr": { "$eq": [ "$_id", "$$user_id" ] } } }],
"as": "user"
}},
{ "$group": {
"_id": "$user_id",
"value": { "$sum": "$value" },
"appusers": { "$first": "$user" },
}}
])
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
181 次 |
| 最近记录: |