我有以下数据:
{
"make" : "Toyota",
"name" : "Corolla",
"year" : "2012"
"color" : "Blue"
}
{
"make" : "Toyota",
"name" : "Camry",
"year" : "2016"
"color" : "Blue"
}
{
"make" : "Toyota",
"name" : "Prius",
"year" : "2012"
"color" : "Black"
}
{
"make" : "Nissan",
"name" : "PathFinder",
"year" : 2012.0
"color" : "Black"
}
{
"make" : "Nissan",
"name" : "Qashqai",
"year" : 2011.0
"color" : "Black"
}
{
"make" : "Nissan",
"name" : "X-Trail",
"year" : 2009.0
"color" : "Blue"
}
Run Code Online (Sandbox Code Playgroud)
我想通过写汇总查询到组make,然后由color该内make组。
所以我想要的结果摘录如下
[{
_id: "Toyota"
colors: [
{
_id: "Black"
cars: [{
"make" : "Toyota",
"name" : "Prius",
"year" : "2012"
"color" : "Black"
}]
},
{
_id: "Blue"
cars:[{
"make" : "Toyota",
"name" : "Corolla",
"year" : "2012"
"color" : "Blue"
},
{
"make" : "Toyota",
"name" : "Camry",
"year" : "2016"
"color" : "Blue"
}]
}
]
},
{
.... Nissan cars
}]
Run Code Online (Sandbox Code Playgroud)
我已经尝试了以下管道,但与我期望的结果有些接近,但这并不理想
db.Cars.aggregate(
// Pipeline
[
// Stage 1
{
$group: {
_id: {make: '$make', color: '$color'},
cars: {$push: '$$CURRENT'}
}
},
// Stage 2
{
$group: {
_id: '$_id.make',
colors: {$push: '$$CURRENT'}
}
},
]
);
Run Code Online (Sandbox Code Playgroud)
结果如下(注意_id颜色字段):
[{
"_id" : "Toyota",
"colors" : [
{
"_id" : {
"make" : "Toyota",
"color" : "Black"
},
"cars" : [
{
"make" : "Toyota",
"name" : "Prius",
"year" : "2012",
"color" : "Black"
}
]
},
{
"_id" : {
"make" : "Toyota",
"color" : "Blue"
},
"cars" : [
{
"make" : "Toyota",
"name" : "Corolla",
"year" : "2012",
"color" : "Blue"
},
{
"make" : "Toyota",
"name" : "Camry",
"year" : "2016",
"color" : "Blue"
}
]
}
]
}
...
]
Run Code Online (Sandbox Code Playgroud)
编写查询以使输出更接近所需结果的任何帮助都很好
添加一个$project或$addFields阶段到$map colors._idfromcolors._id.color
管道
db.cars.aggregate(
[
{
$group: {
_id: {make: '$make', color: '$color'},
cars: {$push: '$$CURRENT'}
}
},
{
$group: {
_id: '$_id.make',
colors: {$push: '$$CURRENT'}
}
},
{$project : {colors : {$map : {input : "$colors", as : "color", in : { "_id" : "$$color._id.color", cars : "$$color.cars" }}}}}
]
).pretty()
Run Code Online (Sandbox Code Playgroud)
输出
>db.cars.aggregate( [ {$project : {_id : 0}}, { $group: { _id: {make: '$make', color: '$color'}, cars: {$push: '$$CURRENT'} } }, { $group: { _id: '$_id.make', colors: {$push: '$$CURRENT'} } }, {$project : {colors : {$map : {input : "$colors", as : "color", in : { "_id" : "$$color._id.color", cars : "$$color.cars" }}}}} ] ).pretty()
{
"_id" : "Toyota",
"colors" : [
{
"_id" : "Black",
"cars" : [
{
"make" : "Toyota",
"name" : "Prius",
"year" : "2012",
"color" : "Black"
}
]
},
{
"_id" : "Blue",
"cars" : [
{
"make" : "Toyota",
"name" : "Corolla",
"year" : "2012",
"color" : "Blue"
},
{
"make" : "Toyota",
"name" : "Camry",
"year" : "2016",
"color" : "Blue"
}
]
}
]
}
....//output omitted
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
105 次 |
| 最近记录: |