使用Java更新MongoDB中的文档

debugcn 发表于 Dev

迈克·B。

我正在使用MongoDB 3.2和MongoDB Java驱动程序3.2。我想更新具有其ID的文档的值。为此，我尝试使用以下两种方法（可在Stackoverflow和MongoDB Blog中找到）：

方法1：

for(String docID : expiredDocsIDs) {
    Bson filter = Filters.eq("_id", docID);
    Bson updates = Updates.set("isExpired", true);

    dbCollection.findOneAndUpdate(filter, updates);
}

方法2：

expiredDocsIDs.stream()
    .forEach(docID -> {
        BasicDBObject searchQuery = new BasicDBObject("_id", docID);
        BasicDBObject updateFields = new BasicDBObject();
        updateFields.append("isExpired", true);
        updateFields.append("fetchStatus", "FETCHED");
        BasicDBObject setQuery = new BasicDBObject();
        setQuery.append("$set", updateFields);

        dbCollection.updateOne(searchQuery, setQuery);
});

这些方法都不行。它遍历文档ID列表，执行代码，但是在代码末尾，当我检查DB中的文档时，我尝试更新的文档字段中没有任何更改。

我的问题：
如何更新MongoDB中的特定文档？

迈克·B。

正如BlakesSeven正确指出的那样，问题出在_id领域的铸造上。原始代码发送此参数，String而正确的方法是发送ObjectId类型的参数。

正确且有效的代码形式MongoDB3.2：

this.trackedEpisodesReg.entrySet().stream()
    .filter(ep -> ep.getValue().isExpired())
    .forEach(ep -> {

        BasicDBObject updateFields = new BasicDBObject();
        updateFields.append("isExpired", true);

        BasicDBObject setQuery = new BasicDBObject();
        setQuery.append("$set", updateFields);

        BasicDBObject searchQuery = new BasicDBObject("_id", new ObjectId(ep.getValue().getEpisodeID()));

        dbCollection.updateOne(searchQuery, setQuery);
    });

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。