MongoDB基于多个查询字段的聚合计数-(多个字段计数)

Question

我的集合是这样的，

{
    "_id" : ObjectId("55c8bd1d85b83e06dc54c0eb"),
    "name" : "xxx",
    "salary" : 10000,
    "type" : "type1"
}
{
    "_id" : ObjectId("55c8bd1d85b83e06dc54c0eb"),
    "name" : "aaa",
    "salary" : 10000,
    "type" : "type2"
}
{
    "_id" : ObjectId("55c8bd1d85b83e06dc54c0eb"),
    "name" : "ccc",
    "salary" : 10000,
    "type" : "type2"
}

我的查询参数将作为，

{工资= 10000,type = type2}

所以基于查询，我需要获取上述查询参数的计数

结果应该是这样的，

{类别:'type1'，计数:500}{类别:'type2'，计数:200}{类别:'name'，计数:100}

现在我通过点击三个不同的查询并构造结果(或)服务器端迭代来获得计数，我可以获得结果。

谁能建议或提供我好的方法来获得以上结果

Answer 1

您的问题不是很清楚地提出，但似乎您想在这里做的是计算字段中数据的出现次数，可选地通过匹配标准的值过滤这些字段。

这里 $cond 运算符允许您将逻辑条件转换为值:

db.collection.aggregate([
    { "$group": {
        "_id": null,
        "name": { "$sum": 1 },
        "salary": { 
            "$sum": { 
                "$cond": [
                    { "$gte": [ "$salary", 1000 ] },
                    1,
                    0
                ]
            }
        },
        "type": { 
            "$sum": { 
                "$cond": [
                    { "$eq": [ "$type", "type2" ] },
                    1,
                    0
                ]
            }
        }
    }}
])

所有值都在同一个文档中，在这里将它们分开是没有任何意义的，因为这是管道中的额外工作。

{ "_id" : null, "name" : 3, "salary" : 3, "type" : 2 }

否则，在长格式中，由于需要为每个键创建每个文档的副本，因此性能不是很好，看起来像这样:

db.collection.aggregate([
  { "$project": {
    "name": 1,
    "salary": 1,
    "type": 1,
    "category": { "$literal": ["name","salary","type"] }
  }},
  { "$unwind": "$category" },
  { "$group": {
    "_id": "$category",
    "count": {
      "$sum": {
        "$cond": [
          { "$and": [ 
            { "$eq": [ "$category", "name"] },
            { "$ifNull": [ "$name", false ] }
          ]},
          1,
          { "$cond": [
            { "$and": [
              { "$eq": [ "$category", "salary" ] },
              { "$gte": [ "$salary", 1000 ] }
            ]},
            1,
            { "$cond": [
              { "$and": [
                { "$eq": [ "$category", "type" ] },
                { "$eq": [ "$type", "type2" ] }
              ]},
              1,
              0
            ]}
          ]}
        ]
      }
    }
  }}
])

输出:

{ "_id" : "type",   "count" : 2 }
{ "_id" : "salary", "count" : 3 }
{ "_id" : "name",   "count" : 3 }

如果您的文档没有统一的键名，或者无法在管道条件中指定每个键，则使用mapReduce代替:

db.collection.mapReduce(
    function() {
        var doc = this;
        delete doc._id;
        Object.keys(this).forEach(function(key) {
          var value = (( key == "salary") && ( doc[key] < 1000 ))
              ? 0
              : (( key == "type" ) && ( doc[key] != "type2" ))
              ? 0
              : 1;
          emit(key,value);
        });
    },
    function(key,values) {
        return Array.sum(values);
    },
    {
        "out": { "inline": 1 }
    }
);

输出:

    "results" : [
            {
                    "_id" : "name",
                    "value" : 3
            },
            {
                    "_id" : "salary",
                    "value" : 3
            },
            {
                    "_id" : "type",
                    "value" : 2
            }
    ]

这与条件计数基本相同，除了您只指定所需条件的"反向"，并且仅针对您想要过滤条件的字段。当然，这种输出格式很容易作为单独的文档发出。

同样的方法适用于在您想要条件的字段上测试条件是否满足，并返回满足条件的1或不满足条件的0，用于计数求和。

Answer 2

您可以在以下查询中使用聚合:

db.collection.aggregate({
        $match: {
            salary: 10000,
            //add any other condition here
        }
    }, {
        $group: {
            _id: "$type",
            "count": {
                $sum: 1
            }
        }
    }, {
        $project: {
            "category": "$_id",
            "count": 1,
            _id: 0
        }
    }