java - 增加插入嵌入式文档 MONGODB 的计数器

Question

我的文档结构是这样的

{
    "_id" : {
        "Owner" : 651668690,
        "WeekOfTheYear" : 2
    },
    "calldetails" : {
        "426743784" : {
           "TotalDuration" : 204,
            "count" : 4
        },
        "752982293" : {
            "TotalDuration" : 206,
            "count" : 6
        }
    },
    "totalDuration" : 410,
    "totalcalls" : 10,
    "totaluniquecallers" : 0
}

仅当在 calldetails 内创建新的子文档时，我才想增加totaluniquecallers 字段。我正在使用 mongodb java 驱动程序并且启用了 upsert。

我的查询看起来是这样的

    BasicDBObject Query = new BasicDBObject();
    Query.put("_id.Owner", id);
    Query.put("_id.WeekOfTheYear", week);

    //update
    BasicDBObject update = new BasicDBObject();
    BasicDBObject incrementFields = new BasicDBObject();
    incrementFields.put("totalDuration", logdetails.getInt("duration"));
    incrementFields.put("totalcalls",1);
     incrementFields.put("calldetails."+logdetails.get("Phonenumber")+".TotalDuration",logdetails.getInt("duration"));
    incrementFields.put("calldetails."+logdetails.get("Phonenumber")+".count",1);
    update.put("$inc", incrementFields);
    WriteResult result1 = collection3.update(Query, update, true, false);

我尝试了 $addToSet 或 $set，但似乎其中不允许增量。所以任何人都可以在这个用例中帮助我，在这个用例中我基本上需要文档内的子文档计数或“calldetails”内的总文档计数“字段；

请注意:我正在尝试进行预聚合，因此每次插入新记录时我都会更新插入/更新。所以我需要每次在“calldetails”文档中创建新条目时递增“totaluniquecallers”字段

Answer 1

问题

<小时/>

这里的整体逻辑有几个问题，所以让我们尝试运行一下它们:

其中之一是您的子文档实际上并不是数组，这就是为什么像 $addToSet 这样的运算符对您失败的原因。但这实际上对您来说是一件好事，因此您应该更改您的架构:

{
    "_id" : {
        "Owner" : 651668690,
        "WeekOfTheYear" : 2
    },
    "calldetails" : [
       { 
           "number": "426743784",
           "TotalDuration" : 204,
            "count" : 4
       },
       {
           "number": "752982293",
            "TotalDuration" : 206,
            "count" : 6
       }
    ],
    "totalDuration" : 410,
    "totalcalls" : 10,
    "totaluniquecallers" : 0
}

其次，由于“集合”的实际含义，$addToSet在这里总是会失败。因此，请考虑以下声明:

db.collection.update(
    {
        "_id" : {
            "Owner" : 651668690,
            "WeekOfTheYear" : 2
        }
    },
    {
        "$addToSet": { 
            "number": "426743784",
            "TotalDuration" : 204,
             "count" : 0
        }
    }
)

自然，这就是结果:

{
    "_id" : {
        "Owner" : 651668690,
        "WeekOfTheYear" : 2
    },
    "calldetails" : [
       { 
           "number": "426743784",
           "TotalDuration" : 204,
            "count" : 4
       },
       { 
           "number": "426743784",
           "TotalDuration" : 204,
            "count" : 0
       },
       {
           "number": "752982293",
            "TotalDuration" : 206,
            "count" : 6
       }
    ],
    "totalDuration" : 410,
    "totalcalls" : 10,
    "totaluniquecallers" : 0
}

因此，由于新的“集合成员”实际上与已有的成员不同，因此您会得到另一个条目。所以 $addToSet 不是这里的答案。

重新设计

<小时/>

本质上，这并不是真正适合嵌入式文档的模式设计。你真正想要的是这样的:

{
    "Owner" : 651668690,
    "time": ISODate("2014-04-18T10:44:22.366Z")
    "number": "426743784",
    "duration" : 60,
},
{
    "Owner" : 651668690,
    "time" : ISODate("2014-04-18T10:50:22.366Z")
    "number": "752982293",
    "duration" : 100,
},
{
    "Owner" : 651668690,
    "time": ISODate("2014-04-18T11:44:22.366Z")
    "number": "426743784",
    "duration" : 60,
},

为什么？现在让我们考虑您的 需求:

1. 所有插入都是原子的。这意味着您只需每次写入一次即可将新详细信息添加到集合中。因此，每个“调用”都只是记录其中的详细信息。无需“addToSet”，也无需增加计数器。

2. 使用聚合可以轻松地以您想要的形式调用数据。您可以实时执行此操作，也可以将其作为后台任务聚合到另一个集合

您可以像这样聚合详细信息:

db.calls.aggregate([
    { "$group": {
        "_id": {
            "Owner": "$Owner",
            "WeekOfTheYear": { "$week": "$time" },
            "number": "$number"
        },
        "TotalDuration": { "$sum": "$duration" },
        "count": { "$sum": 1 }
    }},
    { "$group": {
        "_id": {
            "Owner": "$_id.Owner",
            "WeekOfTheYear": "$_id.WeekOfTheYear"
        },
        "calldetails": { "$push": {
            "number": "$_id.number",
            "TotalDuration": "$TotalDuration",
            "count": "$count"
        }},
        "totalDuration": { "$sum": "$TotalDuration" },
        "totalcalls": { "$sum": "$count" },
        "totaluniquecallers": { "$sum": 1 }
    }}
])

两阶段分组会按照您想要的格式构建结果。当然，您想要做的是将第一个管道阶段添加到 $match您想要查看的日期范围而不是处理所有结果，并且如前所述，您最好将这些结果作为后台任务添加到另一个集合中。

结论

<小时/>

虽然乍一看，保留某种“预先收集”的表单并在新事物出现时更新项目似乎是合乎逻辑的，但这并不容易做到，而且您很快就会遇到并发问题。除此之外，这里维护数组条目的逻辑远比简单的更新复杂，需要大量的读取然后更新，这加剧了并发问题。

因此，将其分解为一个简单的“一次写入”集合并使用“后台聚合”可以通过引入简单的“仅插入”操作来添加详细信息来避免这些问题，并且后台任务不必在每个项目时发生已插入。

因此，虽然它不完全是“实时”，但通过仔细的均匀处理，您可以获得收集的详细信息“接近”实时结果，并保持非常快速的写入操作。

总的来说，这是获得您想要的最终结果的最佳架构。