Следующий запрос может дать нам ожидаемый результат:
db.collection.aggregate([
{
$unwind:"$list"
},
{
$group:{
"_id":"$list.uuid",
"list":{
$push:"$list"
}
}
},
{
$project:{
"merged":{
$reduce:{
"input":"$list",
"initialValue":{},
"in":{
$mergeObjects:["$$this","$$value"]
}
}
}
}
},
{
$group:{
"_id":null,
"list":{
$push: "$merged"
}
}
},
{
$project:{
"_id":0,
"storage" : "result",
"list":1
}
}
]).pretty()
Набор данных:
{
"_id" : ObjectId("5a1ea4a4a1a13eaecf571267"),
"storage" : "events",
"list" : [
{
"uuid" : "5a03c1e0e31a11e7b8c2e398bcd9f882",
"type" : "TYPE",
"desc" : "DESC",
"when" : 1513934100000,
"loc" : "LOC",
"schedule" : [ ]
},
{
"uuid" : "1b45a340e70911e7b8c2e398bcd9f882",
"type" : "TYPE1",
"desc" : "DESC1",
"when" : 1514624400000,
"loc" : "LOC1",
"schedule" : [ ]
}
]
}
{
"_id" : ObjectId("5a297001840b2aba87a5b1eb"),
"storage" : "control",
"list" : [
{
"uuid" : "5a03c1e0e31a11e7b8c2e398bcd9f882",
"missing" : [
{
"user" : "user",
"instrument" : "inst"
},
{
"user" : "user",
"instrument" : "inst"
}
],
"when" : 1513934100000
},
{
"uuid" : "1b45a340e70911e7b8c2e398bcd9f882",
"missing" : [
{
"user" : "user",
"instrument" : "inst"
},
{
"user" : "user",
"instrument" : "inst"
}
],
"when" : 1514624400000
}
]
}
Выход:
{
"list" : [
{
"uuid" : "1b45a340e70911e7b8c2e398bcd9f882",
"missing" : [
{
"user" : "user",
"instrument" : "inst"
},
{
"user" : "user",
"instrument" : "inst"
}
],
"when" : 1514624400000,
"type" : "TYPE1",
"desc" : "DESC1",
"loc" : "LOC1",
"schedule" : [ ]
},
{
"uuid" : "5a03c1e0e31a11e7b8c2e398bcd9f882",
"missing" : [
{
"user" : "user",
"instrument" : "inst"
},
{
"user" : "user",
"instrument" : "inst"
}
],
"when" : 1513934100000,
"type" : "TYPE",
"desc" : "DESC",
"loc" : "LOC",
"schedule" : [ ]
}
],
"storage" : "result"
}
Анализ запросов: Сначала мы раскручиваем массив list
, а затем группируем на основе list.uuid
.Каждая группа содержит набор всех элементов списка с одинаковым UUID.Позже элементы списка объединяются в один.