快速入门（POJO 示例）

先决条件

您必须设置以下组件才能运行本指南中的代码示例：

• 在 MongoDB 默认端口 ( 27017 ) 上运行的 MongoDB 服务器

• 项目中安装的驱动程序依赖项

• 以下 import 语句：

  import com.mongodb.client.result.InsertOneResult;
  import com.mongodb.client.result.InsertManyResult;
  import com.mongodb.client.result.DeleteResult;
  import com.mongodb.client.result.UpdateResult;
  import com.mongodb.reactivestreams.client.MongoClient;
  import com.mongodb.reactivestreams.client.MongoClients;
  import com.mongodb.reactivestreams.client.MongoCollection;
  import com.mongodb.reactivestreams.client.MongoDatabase;
  import org.bson.codecs.configuration.CodecRegistry;
  import org.bson.codecs.pojo.PojoCodecProvider;
  import java.util.List;
  import static com.mongodb.client.model.Filters.*;
  import static com.mongodb.client.model.Updates.*;
  import static java.util.Arrays.asList;
  import static org.bson.codecs.configuration.CodecRegistries.fromProviders;
  import static org.bson.codecs.configuration.CodecRegistries.fromRegistries;

• POJO 类定义。 从Github上的驱动程序源代码存储库复制 Person 和 Address POJO 的完整代码：

  • Person 类

  • 地址类

创建自定义 CodecRegistry

在将 POJO 与驱动程序一起使用之前，您需要配置CodecRegistry以包含一个编解码器，该编解码器可以处理 POJO 与 BSON 之间的转换。最简单的方法是使用PojoCodecProvider.builder()方法创建和配置CodecProvider 。

以下示例将默认编解码器注册表与配置的PojoCodecProvider相结合，以自动创建 POJO Codec实例：

CodecRegistry pojoCodecRegistry = fromRegistries(
    MongoClientSettings.getDefaultCodecRegistry(),
    fromProviders(PojoCodecProvider.builder().automatic(true).build())
);

将 POJO 插入 MongoDB

编解码器注册表会自动尝试为未知类创建 POJO Codec 。这允许您开箱即用 POJO，无需任何额外配置。

在将 POJO 插入 MongoDB 之前，请先创建一个配置有 POJO 类的MongoCollection实例：

MongoCollection<Person> collection = database.getCollection("people", Person.class);

Person ada = new Person("Ada Byron", 20, new Address("St James Square", "London", "W1"));
collection.insertOne(ada).subscribe(new OperationSubscriber<InsertOneResult>());

List<Person> people = asList(
    new Person("Charles Babbage", 45, new Address("5 Devonshire Street", "London", "W11")),
    new Person("Alan Turing", 28, new Address("Bletchley Hall", "Bletchley Park", "MK12")),
    new Person("Timothy Berners-Lee", 61, new Address("Colehill", "Wimborne", null))
);
collection.insertMany(people).subscribe(new OperationSubscriber<InsertManyResult>());

查询集合

要查询集合，可以使用find()方法。

Person以下示例将打印collection中的所有实例：

collection.find().subscribe(new PrintToStringSubscriber<>());

指定查询筛选器

要查询匹配特定条件的Person实例，请将筛选器对象传递给find()方法。 为了便于创建筛选器对象，驱动程序提供了Filters辅助方法。

collection.find(eq("address.city", "Wimborne"))
    .first()
    .subscribe(new PrintToStringSubscriber<>());

collection.find(gt("age", 30)).subscribe(new PrintToStringSubscriber<>());

更新文档

要更新集合中的文档，可以使用集合的updateOne()和updateMany()方法。

将以下参数传递给这些方法：

• 筛选对象以确定要更新的一个或多个文档。 要指定空过滤器并匹配所有Person实例，请使用空Document对象。

• 更新指定修改的文档。 要查看可用操作符的列表，请参阅 MongoDB Server手册中的 更新操作符 。

更新方法返回UpdateResult类型，其中提供有关操作的信息，包括更新修改的文档数量。

collection.updateOne(
    eq("name", "Ada Byron"),
    combine(set("age", 23), set("name", "Ada Lovelace"))
).subscribe(new OperationSubscriber<>());

collection.updateMany(not(eq("zip", null)), set("zip", null))
         .subscribe(new OperationSubscriber<>());

collection.replaceOne(eq("name", "Ada Lovelace"), ada)
    .subscribe(new OperationSubscriber<>());

删除文档

要从集合中删除文档，可以使用集合的deleteOne()和deleteMany()方法。

传递筛选器对象以匹配要删除的一个或多个文档。要指定空筛选器，请使用空Document对象。

删除方法返回DeleteResult类型，其中提供有关操作的信息，包括删除的文档数。

collection.deleteOne(eq("address.city", "Wimborne"))
    .subscribe(new OperationSubscriber<>());

collection.deleteMany(eq("address.city", "London"))
    .subscribe(new OperationSubscriber<>());