蒙戈总结：总和计数数组重复值田间

Question

我的文档巨大的一堆这样：

{ 
    _id: '1', 
    colors: [ 
    { value: 'red', count: 2 }, 
    { value: 'blue', count: 3} 
    ] 
    shapes: [ 
    { value: 'cube', type: '3d' }, 
    { value: 'square', type: '2d'} 
    ] 
},  
{ 
    _id: '2', 
    colors: [ 
    { value: 'red', count: 7 }, 
    { value: 'blue', count: 34}, 
    { value: 'yellow', count: 12} 
    ] 
    shapes: [ 
    { value: 'prism', type: '3d' }, 
    { value: 'triangle', type: '2d'} 
    ] 
} 

通过使用$unwind和$addToSet，因为这样的：

db.getCollection('coll').aggregate([{$unwind:"$colors"},{$unwind:"$shapes"},{$group:{_id:null,colors:{$addToSet:"$colors"},shapes:{$addToSet:"$shapes"}]) 

我能得到如下：

{ 
    "_id" : null, 
    "colors" : [ 
     { "value" : "red", "count" : 2 }, 
     { "value" : "blue", "count" : 3 }, 
     { "value" : "red", "count" : 7 }, 
     { "value" : "blue", "count" : 34 }, 
     { "value" : "yellow", "count" : 12 } 
    ] 
    "shapes" : [ 
     { value: 'cube', type: '3d' }, 
     { value: 'square', type: '2d'} 
     { value: 'prism', type: '3d' }, 
     { value: 'triangle', type: '2d'} 
    ] 
} 

然而我想要的是判断重复的唯一的领域“值”，并总结“计数”字段重复，即

{ 
    "_id" : null, 
    "colors" : [ 
     { "value" : "red", "count" : 9 }, 
     { "value" : "blue", "count" : 37 }, 
     { "value" : "yellow", "count" : 12 } 
    ] 
    "shapes" : [ 
     { value: 'cube', type: '3d' }, 
     { value: 'square', type: '2d'} 
     { value: 'prism', type: '3d' }, 
     { value: 'triangle', type: '2d'} 
    ] 
} 

这question表明我可以使用$colors.value作为_id字段和$sum与总的count。然而，因为我有第二个数组$unwind和聚合/ $group，我不确定最好的方式去做这件事。

Answer 1

尝试运行以下聚合管道：

pipeline = [ 
    {"$unwind": "$colors"}, 
    { 
     "$group": { 
      "_id": "$colors.value", 
      "count": { "$sum": "$colors.count" }, 
      "shapes": { "$first": "$shapes" } 
     } 
    }, 
    {"$unwind": "$shapes"}, 
    { 
     "$group": { 
      "_id": null, 
      "colors": { 
       "$addToSet": { 
        "value": "$_id", 
        "count": "$count" 
       } 
      }, 
      "shapes": { "$addToSet": "$shapes" }    
     } 
    } 
]; 
db.getCollection('coll').aggregate(pipeline) 

样本输出

{ 
    "result" : [ 
     { 
      "_id" : null, 
      "colors" : [ 
       { 
        "value" : "red", 
        "count" : 9 
       }, 
       { 
        "value" : "blue", 
        "count" : 37 
       }, 
       { 
        "value" : "yellow", 
        "count" : 12 
       } 
      ], 
      "shapes" : [ 
       { 
        "value" : "square", 
        "type" : "2d" 
       }, 
       { 
        "value" : "cube", 
        "type" : "3d" 
       }, 
       { 
        "value" : "triangle", 
        "type" : "2d" 
       }, 
       { 
        "value" : "prism", 
        "type" : "3d" 
       } 
      ] 
     } 
    ], 
    "ok" : 1 
} 

注意文件的计数值是一个字符串，在聚合中它将被打折为0，因为$sum运算符有效地聚合数值，否则字符串值会被累计为零默认值。

---

里面$group管道，你现在通过$colors.value场分组扁平的颜色排列的文件，然后使用蓄能器返回的分组文件所需的聚集。累积器运算符$first用于此分组操作，因为它在文档处于已定义顺序时为每个组返回第一个文档的值，在这种情况下，您希望返回形状字段，因为当所有文档都是分组。维护管道内文档的顺序更是一种窍门。

在这里需要注意的一件事是执行一个管道时，MongoDB将管道操作符互相管道。这里的“管道”采用Linux的含义：操作员的输出成为后面的操作员的输入。每个操作员的结果都是一个新的文档集合。所以蒙戈执行以前的管道如下：

collection | $unwind | $group | $unwind | $group => result 

因此$first有必要从以前的管道输送到下一个获得形状领域。

Answer 2

所以，你需要重写你的插入，或将字符串转换为计数值的整数。

这里是插入：

db.so.insert([{ 
    _id: '1', 
    colors: [ 
    { value: 'red', count: 2 }, 
    { value: 'blue', count: 3} 
    ] 
},  
{ 
    _id: '2', 
    colors: [ 
    { value: 'red', count: 7 }, 
    { value: 'blue', count: 34}, 
    { value: 'yellow', count: 12} 
    ] 
}]); 

要做到现有表的转换，可以look at this SO。

然后你就可以做一个简单的两个步骤汇总查询：

db.so.aggregate(
    [ 
    { 
     $unwind: "$colors" 
    }, 
    { 
     $group: { 
     _id : { color : "$colors.value"}, 
     count : { $sum: "$colors.count"}, 
     simple : { $sum: 1} 
     } 
    } 
    ] 
);