从java更新mongodb数组中的值

Question

我在 mongodb 中有几个文档如下：

{
"_id" : ObjectId("54901212f315dce7077204af"),
"Date" : ISODate("2014-10-20T04:00:00.000Z"),
"Type" : "Twitter",
"Entities" : [ 
    {
        "ID" : 4,
        "Name" : "test1",
        "Sentiment" : {
            "Value" : 20,
            "Neutral" : 1
        }
    },
    {
        "ID" : 5,
        "Name" : "test5",
        "Sentiment" : {
            "Value" : 10,
            "Neutral" : 1
        }
    }
]

}

现在我想通过添加 (Sentiment.Value+4)/2 来更新 Entities.ID=4 的文档，例如在更新后的示例中我们有 12。

我写了以下代码，但我卡在 if 语句中，如您所见：

 DBCollection collectionG;
   collectionG = db.getCollection("GraphDataCollection");
    int entityID = 4;
    String entityName = "test";
    BasicDBObject queryingObject = new BasicDBObject();
    queryingObject.put("Entities.ID", entityID);
    DBCursor cursor = collectionG.find(queryingObject);

    if (cursor.hasNext())
    {
        BasicDBObject existingDocument = new BasicDBObject("Entities.ID", entityID);
        //not sure how to update the sentiment.value for entityid=4
    }

首先，我认为我应该首先展开 Entities 数组以获得情绪值，但如果我这样做了，那么我该如何再次展开它们并使用与现在相同的格式但使用新的情绪值更新文档？

我也找到了这个链接： MongoDB - Update objects in a document's array (nested updating)

但我无法理解它，因为它不是用 java 查询编写的， 谁能解释我如何在 java 中做到这一点？

Answer 1

您需要分两步完成：

• 获取所有包含情感实体的记录_id 值4。
• 在find期间，仅投影具有 匹配查询，以便我们可以处理它以仅使用它的 Sentiment.Value。为此，请使用位置运算符 ($)。
• 而不是每次都访问数据库来更新每个匹配的 记录，使用Bulk API，将更新排队并执行 最后。

创建批量操作写入器：

    BulkWriteOperation bulk = col.initializeUnorderedBulkOperation();

在其Entities.ID 字段中查找包含值4 的所有记录。当您将文档与此查询匹配时，您将返回整个文档。但是我们不想要整个文档，我们希望只有文档的 _id，这样我们就可以使用它来更新同一个文档，以及文档中值为 4 的 Entity 元素。可能有n其他实体文件，但它们无关紧要。因此，为了只获取与查询匹配的实体元素，我们使用位置运算符$。

    DBObject find = new BasicDBObject("Entities.ID",4);
    DBObject project = new BasicDBObject("Entities.$",1);
    DBCursor cursor = col.find(find, project);

上面可能会返回例如下面的文档（因为我们的示例假设只有一个输入文档）。如果您注意到，它只包含一个与我们的查询匹配的 Entity 元素。

{
        "_id" : ObjectId("54901212f315dce7077204af"),
        "Entities" : [
                {
                        "ID" : 4,
                        "Name" : "test1",
                        "Sentiment" : {
                                "Value" : 12,
                                "Neutral" : 1
                        }
                }
        ]
}

迭代每条记录以排队等待更新：

    while(cursor.hasNext()){
        BasicDBObject doc = (BasicDBObject)cursor.next();
        int curVal = ((BasicDBObject)
                     ((BasicDBObject)((BasicDBList)doc.get("Entities")).
                     get(0)).get("Sentiment")).getInt("Value");
        int updatedValue = (curVal+4)/2;
        DBObject query = new BasicDBObject("_id",doc.get("_id"))
                         .append("Entities.ID",4);
        DBObject update = new BasicDBObject("$set",
                          new BasicDBObject("Entities.$.Sentiment.Value",
                                             updatedValue));
        bulk.find(query).update(update);
    }

终于更新了：

    bulk.execute();

您需要执行find() 和update() 而不仅仅是update，因为目前mongodb 不允许引用文档字段来检索其值、修改它并使用计算值更新它, 在单个更新查询中。