POJO CRUD操作示例

先决条件

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

• 在 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.find().subscribe(new PrintToStringSubscriber<>());

Person{id='...', name='Ada Byron', age=20, address=Address{street='St James Square', city='London', zip='W1'}}
Person{id='...', name='Charles Babbage', age=45, address=Address{street='5 Devonshire Street', city='London', zip='W11'}}
Person{id='...', name='Alan Turing', age=28, address=Address{street='Bletchley Hall', city='Bletchley Park', zip='MK12'}}
Person{id='...', name='Timothy Berners-Lee', age=61, address=Address{street='Colehill', city='Wimborne', zip='null'}}

指定查询筛选器

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

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

Person{id='591dbc2550852fa685b3ad1a', name='Timothy Berners-Lee', age=61, address=Address{street='Colehill', city='Wimborne', zip='null'}}

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

Update Documents

要更新集合中的文档，可以使用集合的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<>());

Delete Documents

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

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

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

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

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