Docs 菜单
Docs 主页
/ / /
Java Reactive Streams 驱动程序
/

Update Documents

在此页面上

  • Overview
  • 样本数据
  • 更新操作
  • 筛选器
  • 更新操作符
  • 更新一个文档
  • 更新多个文档
  • 自定义更新操作
  • 例子
  • 返回值
  • 更多信息
  • API 文档

在本指南中,您可以学习;了解如何使用Java Reactive Streams驾驶员通过执行更新操作来更新MongoDB集合中的文档。

更新操作可更新MongoDB集合中的一个或多个文档。 您可以使用 updateOne()updateMany()方法执行更新操作。

本指南中的示例使用 Atlas示例数据集sample_restaurants数据库中的restaurants集合。

要学习;了解如何创建免费的MongoDB Atlas 群集并加载示例数据集,请参阅入门教程。

重要

项目 Reactor 库

本指南使用 Project ReactorPublisher 库来使用Java Reactive Streams驾驶员方法返回的 实例。要学习;了解有关 Project Reactor 库及其使用方法的更多信息,请参阅 Reactor 文档中的“入门” 。要进一步学习;了解如何使用本指南中的 Project Reactor 库方法,请参阅“将数据写入MongoDB ”指南。

您可以使用以下方法在 MongoDB 中执行更新操作:

  • updateOne(),更新匹配搜索条件的第一个文档

  • updateMany(),更新与搜索条件匹配的所有文档

每种更新方法都需要以下参数:

  • 查询过滤文档,用于确定要更新的文档。 有关使用查询筛选器的更多信息,请参阅筛选器部分。

  • 更新文档,指定更新操作符(要执行的更新类型)以及要更改的字段和值。 有关更新操作符的更多信息,请参阅更新操作符部分。

每种更新方法都需要一个查询过滤,它指定了搜索条件,以确定选择哪些文档进行更新。 为了便于创建过滤对象,驾驶员提供了提供过滤条件辅助方法的Filters类。

要查看Filters 助手列表,请参阅 筛选器API文档 。有关查询筛选器的更多信息,请参阅MongoDB Server手册中的查询筛选器文档部分

要更改文档中的字段, MongoDB提供了更新操作符。 要使用更新操作符指定要执行的修改,请创建更新文档。 为了便于创建更新文档,驾驶员提供了包含过滤条件辅助方法的Updates辅助类。

重要

_id字段不可变,因此您无法更改文档中_id字段的值。

要学习;了解有关更新操作符的更多信息,请参阅服务器手册中的更新操作符

要更新MongoDB集合中的单个文档,请调用updateOne()方法并传递查询过滤和更新操作符。 然后,将updateOne() 结果传递给 中的静态Mono.from() Mono方法。Mono 是 Project Reactor 库中的一个类。在Java Reactive Streams 中,驾驶员方法会返回Publisher冷实例,这意味着除非您订阅返回的Publisher ,否则不会发生相应的操作。 本指南使用 Project Reactor 库来使用它们。 要学习;了解有关Mono 的更多信息,请参阅 Mono 在 Project Reactor 文档中。

以下示例使用updateOne()方法将匹配文档的name值从"Bagels N Buns"更新为"2 Bagels 2 Buns"

Publisher<UpdateResult> updatePublisher =
restaurants.updateOne(eq("name", "Bagels N Buns"),
set("name", "2 Bagels 2 Buns"));
Mono.from(updatePublisher).block();

要更新MongoDB集合中的多个文档,请调用updateMany()方法并传递查询过滤和更新操作符。 然后,将updateMany() 结果传递给 中的静态Mono.from() Mono方法。Mono 是 Project Reactor 库中的一个类。在Java Reactive Streams 中,驾驶员方法会返回Publisher冷实例,这意味着除非您订阅返回的Publisher ,否则不会发生相应的操作。 本指南使用 Project Reactor 库来使用它们。 要学习;了解有关Mono 的更多信息,请参阅 Mono 在 Project Reactor 文档中。

以下示例使用updateMany()方法将cuisine值为"Pizza"的所有文档更新为cuisine值为"Pasta"

Publisher<UpdateResult> updatePublisher =
restaurants.updateMany(eq("cuisine", "Pizza"),
set("cuisine", "Pasta"));
Mono.from(updatePublisher).block();

UpdateOptions类包含修改更新方法行为的方法。 要使用UpdateOptions类,请构造该类的新实例,然后调用其一个或多个方法来修改更新操作。 您可以将这些方法调用链接在一起。 要修改更新操作的行为,请将类实例和链式方法调用作为第三个参数传递给updateOne()updateMany()方法。

您可以使用UpdateOptions类中的以下可选方法来修改更新操作:

方法
说明
arrayFilters(List<? extends Bson> arrayFilters)
Specifies which array elements an update applies to.
bypassDocumentValidation(Boolean bypassDocumentValidation)
Specifies whether the update operation bypasses document validation. This lets you update documents that don't meet the schema validation requirements, if any exist. For more information about schema validation, see Schema Validation in the MongoDB Server manual.
collation(Collation collation)
Specifies the kind of language collation to use when sorting results. For more information, see Collation in the MongoDB Server manual.
comment(Bson comment)
Attaches a Bson comment to the operation. For more information, see the insert command fields guide in the MongoDB Server manual.
comment(String comment)
Attaches a String comment to the operation. For more information, see the insert command fields guide in the MongoDB Server manual.
hint(Bson hint)
Sets the index for the operation as a Bson value. For more information, see the hint statement in the MongoDB Server manual.
hint(String hint)
Sets the index for the operation as a String value. For more information, see the hint statement in the MongoDB Server manual.
let(Bson variables)
Specifies a map of parameter names and values. Values must be constant or closed expressions that don't reference document fields. For more information, see the let statement in the MongoDB Server manual.
upsert(Boolean upsert)
Specifies whether the update operation performs an upsert operation if no documents match the query filter. For more information, see the upsert statement in the MongoDB Server manual.

以下代码使用updateMany()方法查找borough字段值为"Manhattan"的所有文档。 然后,它将这些文档中的borough值更新为"Manhattan (north)" 。 由于upsert选项设立为true ,因此如果查询过滤与任何现有文档都不匹配, Java Reactive Streams驾驶员将插入一个新文档。

Publisher<UpdateResult> updatePublisher = restaurants.updateMany(
eq("borough", "Manhattan"),
set("borough", "Manhattan (north)"),
new UpdateOptions().upsert(true));
Mono.from(updatePublisher).block();

updateOne()updateMany()方法各自返回一个UpdateResult对象。 UpdateResult类型包含以下实例方法:

方法
说明
getMatchedCount()
The number of documents that matched the query filter, regardless of how many were updated.
getModifiedCount()
The number of documents modified by the update operation. If an updated document is identical to the original, it is not included in this count.
getUpsertedId()
The ID of the document that was upserted in the database, if the driver performed an upsert. Otherwise null.
wasAcknowledged()
Returns true if the update was acknowledged.

有关更新操作符的更多信息,请参阅MongoDB Server手册中的更新操作符

有关使用Java Reactive Streams驾驶员插入文档的可运行代码示例,请参阅Write Data to MongoDB指南。

要进一步了解本指南所讨论的任何方法或类型,请参阅以下 API 文档:

后退

Insert