如何从内部数组中找到总值的总和？

Question

{ 
    "_id" : ObjectId("56fb04fd2e6bb8bc059287c9"), 
    "BillNo" : "Bill_001", 
    "DateP" : "12-12-2015", 
    "Type" : "Cash", 
    "Items" : [
        {
            "id" : NumberInt(1), 
            "ItemName" : "cement", 
            "Qty" : "100", 
            "Rate" : "10", 
            "Total" : "1000"
        }, 
        {
            "id" : NumberInt(2), 
            "ItemName" : "steel", 
            "Qty" : "10", 
            "Rate" : "50", 
            "Total" : "500"
        }, 
        {
            "id" : NumberInt(3), 
            "ItemName" : "sand", 
            "Qty" : "1", 
            "Rate" : "1500", 
            "Total" : "1500"
        }
    ]
}
{ 
    "_id" : ObjectId("56fb05382e6bb8bc059287ca"), 
    "BillNo" : "Bill_002", 
    "DateP" : "12-10-2015", 
    "Type" : "Cash", 
    "Items" : [
        {
            "id" : NumberInt(1), 
            "ItemName" : "Paint", 
            "Qty" : "50", 
            "Rate" : "100", 
            "Total" : "5000"
        }, 
        {
            "id" : NumberInt(2), 
            "ItemName" : "Brush", 
            "Qty" : "5", 
            "Rate" : "10", 
            "Total" : "50"
        }
    ]
}

在上面的集合中，将所有购买细节存储在主文档中，并将其项目细节存储为主项目的内部数组。我需要使用 mongodb 得到如下结果；如何从 mongodb 中的内部数组中查找总数。

Bill_001     1500
Bill_002     5050

Answer 1

理想情况下，在 MongoDB 中，您可以使用 $map 和 $sum 作为 $group 累加器，并且它是添加所提供数组成员的新角色：

db.collection.aggregate({
   { "$group": {
       "_id": "$BillNo",
       "Total": {
           "$sum": {
               "$sum": {
                  "$map": {
                     "input": "$Items",
                     "as": "item",
                     "in": "$$item.Total"
                  }
               }
           }
       }
   }}
})

或者只是每个文档：

db.collection.aggregate({
   { "$group": {
       "_id": "$_id",
       "BillNo": { "$first": "$BillNo" },
       "DateP": { "$first" "$DateP" },
       "Type": { "$first": "$Type" }
       "Total": {
           "$sum": {
               "$sum": {
                  "$map": {
                     "input": "$Items",
                     "as": "item",
                     "in": "$$item.Total"
                  }
               }
           }
       }
   }}
})

使用$first 的另一个累加器。当然，你真的可以只用 $project 使用 MongoDB 3.2：

db.collection.aggregate({
   { "$project": {
       "BillNo": 1,
       "DateP": 1,
       "Type": 1,
       "Total": {
           "$sum": {
              "$map": {
                 "input": "$Items",
                 "as": "item",
                 "in": "$$item.Total"
              }
           }
       }
   }}
})

在旧版本中，您仍然需要先在阵列上使用$unwind：

db.collection.aggregate([
    { "$unwind": "$Items" },
    { "$group": {
       "_id": "$BillNo",
       "Total": {
           "$sum": "$Items.Total"
       }
    }}
])

或者，如果您只添加每个文档：

db.collection.aggregate([
    { "$unwind": "$Items" },
    { "$group": {
       "_id": "_id",
       "BillNo": { "$first": "$BillNo" },
       "DateP": { "$first": "$DateP" },
       "Type": { "$first": "$Type" },
       "Total": {
           "$sum": "$Items.Total"
       }
    }}
])

当然，只有在您实际将字符串固定为数值时。

理想情况下，您可以这样修复它：

var ops = [];

db.collection.find().forEach(function(doc) {
    doc.Items.forEach(function(item) {
        ops.push({
            "updateOne": {
                "filter": { "_id": doc._id, "Items.id": item.id },
                "update": {
                    "$set": {
                        "Items.$.Qty": parseInt(item.Qty),
                        "Items.$.Rate": parseInt(item.Rate),
                        "Items.$Total": parseInt(item.Total)
                    }
                }
            }        
        });

        // Send batch of updates
        if ( ops.length == 1000 ) {
            db.collection.bulkWrite(ops);
            ops = [];
        }
    })
});

// Clear any unprocessed updates
if ( ops.length > 0 ) {
    db.collection.bulkWrite(ops);
}