Java驱动：如何使用Mongodb的updateFirst方法获取更新对象的objectId

Question

我正在尝试获取我已更新的对象的 objectId - 这是我使用 java 驱动程序的 java 代码：

    Query query = new Query();
    query.addCriteria(Criteria.where("color").is("pink"));
    Update update = new Update();
    update.set("name", name);
    WriteResult writeResult = mongoTemplate.updateFirst(query, update, Colors.class);

    Log.e("object id", writeResult.getUpsertedId().toString());

日志消息返回 null。我在 mongolab 上使用 mongo server 3.0，因为我在免费层上，所以它不应该返回 null。我的 mongo shell 也是：

MongoDB shell 版本：3.0.7

有没有一种简单的方法可以返回我刚刚更新的文档的对象 ID？如果我无法返回 upsertedId，那么 getUpsertedId() 方法的意义何在？

要做我想做的事，我目前必须发出两个非常麻烦的查询：

    //1st query - updating the object first
    Query query = new Query();
    query.addCriteria(Criteria.where("color").is("pink"));
    Update update = new Update();
    update.set("name", name);
    WriteResult writeResult = mongoTemplate.updateFirst(query, update, Colors.class);
    //2nd query - find the object so that I can get its objectid
    Query queryColor = new Query();
    queryColor.addCriteria(Criteria.where("color").is("pink"));
    queryColor.addCriteria(Criteria.where("name").is(name));
    Color color = mongoTemplate.findOne(queryColor, Color.class);
    Log.e("ColorId", color.getId());

根据大卫的回答，我什至尝试了他的建议，宁愿在模板上使用 upsert，所以我将代码更改为下面的代码，它仍然不起作用：

    Query query = new Query();
    query.addCriteria(Criteria.where("color").is("pink"));
    Update update = new Update();
    update.set("name", name);
    WriteResult writeResult = mongoTemplate.upsert(query, update, Colors.class);

    Log.e("object id", writeResult.getUpsertedId().toString());

Answer 1

Simon，我认为它可以在一个查询中实现。您需要的是一种不同的方法，称为 findAndModify()。

在 mongoDB 的 java 驱动程序中，它有一个名为 findOneAndUpdate(filter, update, options) 的方法。

此方法返回已更新的文档。根据您为该方法指定的选项，这将是更新前的文档或更新后的文档。如果没有与查询过滤器匹配的文档，则将返回 null。它不需要传递选项，在这种情况下它将返回在应用更新操作之前更新的文档。

在这里快速浏览一下 mongoTemplate java 驱动程序文档：http://docs.spring.io/spring-data/mongodb/docs/current/api/org/springframework/data/mongodb/core/FindAndModifyOptions.html 告诉我你可以使用方法调用：

public <T> T findAndModify(Query query,
                           Update update,
                           FindAndModifyOptions options,
                           Class<T> entityClass)

如果在查询中未找到该项目，您还可以更改 FindAndModifyOptions 类以采用“更新插入”。如果找到，则仅修改该对象。

Answer 2

Upsert 仅适用于两者

1. 更新选项已更新
2. 实际创建了一个新文档。

您的查询既没有启用 upsert，也没有创建新文档。因此，getUpsertedId() 在此处返回 null 是完全合理的。

不幸的是，使用当前 API 一次调用无法获得您想要的；你需要把它分成两个电话。 WriteResults 的 Mongo shell API 进一步表明了这一点：

由 upsert 插入的文档的 _id。 仅在以下情况下返回 upsert 导致插入。

Answer 3

这是在 Scala 中使用 findOneAndUpdate(filter,update,options) 执行此操作的示例：

val findOneAndUpdateOptions = new FindOneAndUpdateOptions
findOneAndUpdateOptions.returnDocument(ReturnDocument.AFTER)
val filter = Document.parse("{\"idContrato\":\"12345\"}")
val update = Document.parse("{ $set: {\"descripcion\": \"New Description\" } }")
val response = collection.findOneAndUpdate(filter,update,findOneAndUpdateOptions)
println(response)