时间戳

首页 > 解决方案 > MongoDB在内部子集合上聚合组并获取计数

mongodb - MongoDB在内部子集合上聚合组并获取计数

问题描述

我有一个用户集合，它还有一个“用户订阅”集合，它还有一个“订阅>发布”。

我在 Mongo 中有以下用户集合

/* 1 */
{
    "_id" : 1,
    "UserSubscriptions" : [ 
    {
        "_id" : 1,
        "Subscription" : {
            "_id" : 1,
            "Publication" : {
                "_id" : 1,
                "Code" : "1MM",
            },
    },
    {
        "_id" : 2,
        "Subscription" : {
            "_id" : 2,
            "Publication" : {
                "_id" : 2,
                "Code" : "2MM",
            },      
    },
    {
        "_id" : 7,
        "Subscription" : {
            "_id" : 7,
            "Publication" : {
                "_id" : 1,
                "Code" : "1MM",
            },      
    }
]
}

/* 2 */
{
    "_id" : 2,
    "UserSubscriptions" : [ 
    {
        "_id" : 3,
        "Subscription" : {
            "_id" : 3,
            "Publication" : {
                "_id" : 1,
                "Code" : "1MM",
            }      
        }
    ]
}

/* 3 */
{
    "_id" : 3,
    "UserSubscriptions" : [ 
    {
        "_id" : 4,
        "Subscription" : {
            "_id" : 4,
            "Publication" : {
                "_id" : 1,
                "Code" : "1MM",
            }      
        }
    ]
}

/* 4 */
{
    "_id" : 4,
    "UserSubscriptions" : [ 
    {
        "_id" : 5,
        "Subscription" : {
            "_id" : 5,
            "Publication" : {
                "_id" : 2,
                "Code" : "2MM",
            }      
       }
   ]
}

我正在尝试获取所有“发布代码”和计数（用户订阅订阅计数）。所以从上面的集合中我想要这样的结果

 PublicationCode      Count (Number of users)
 1MM                  3
 2MM                  2

我尝试过 MongoDB 查询，但没有得到实际结果

db.runCommand(
{ aggregate : "User", pipeline : [
    {$match: { "UserSubscriptions.0": {$exists: true}} },
    {$group: {_id:"$UserSubscriptions.Subscription.Publication.Code", count:{$sum:1}}},
    {$project: {_id:1,count:1 } }
    ]}
);

请建议一些在子集合上使用组的方法

(Robo 3T 1.2.1) (MongoDB.Driver 2.4.4)

对应的 C# Mongo Driver 查询是

var unWind = new BsonDocument
        {
            { "$unwind", "$UserSubscriptions" }
        };
var group = new BsonDocument
            {{"$group",
                new BsonDocument
                {{ "_id", new BsonDocument {{"id", 
"$UserSubscriptions.Subscription.Publication.Code"}, }},
                {"Count",  new BsonDocument {{"$sum", 1}} }}
            }};

var pipeline = new[] { unWind, group };
var ff = _readOnlyAccess.GetDatabase(this._Database).GetCollection<T> 
(this._Collection).Aggregate<T>(pipeline);

导致错误

FormatException：无法从 BsonType 'Document' 反序列化 'Int32'。

标签： mongodbmongodb-queryaggregation-frameworkmongodb-.net-driver

解决方案

只需使用$unwind. 此外，没有必要使用它$match-$unwind默认情况下会跳过空数组。

db.getCollection('User').aggregate([
  {$unwind: '$UserSubscriptions'},
  {$group: {
    _id: '$UserSubscriptions.Subscription.Publication.Code',
    count: {$sum: 1}
  }}
])

编辑：上面将多次计算客户中的多个代码，所以这是一个更新版本：

db.getCollection('User').aggregate([
  {$unwind: '$UserSubscriptions'},
  {$group: {
    _id: '$_id',
    codes: {$addToSet: '$UserSubscriptions.Subscription.Publication.Code'}
  }},
  {$unwind: '$codes'},
  {$group: {
    _id: '$codes',
    count: {$sum: 1}
  }}
])

推荐阅读