Docs 主页

/ /

开始体验

Docs 主页

/ /

Java Reactive Streams 驱动程序

Java Reactive Streams 驱动程序

开始体验

快速入门

本指南中的代码示例来自驱动程序源代码 GitHub 存储库中的 QuickTour.java 文件。

注意

有关如何安装Java Reactive Streams驱动程序的说明，请参阅安装指南。

重要

本指南使用 Subscriber实现，如快速入门入门中所述。

先决条件

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

在 MongoDB 默认端口 ( 27017 ) 上运行的 MongoDB 服务器
项目中安装的驱动程序依赖项

以下 import 语句：

import com.mongodb.bulk.BulkWriteResult;
import com.mongodb.client.model.BulkWriteOptions;
import com.mongodb.client.model.DeleteOneModel;
import com.mongodb.client.model.InsertOneModel;
import com.mongodb.client.model.ReplaceOneModel;
import com.mongodb.client.model.UpdateOneModel;
import com.mongodb.client.model.WriteModel;
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.Document;
import java.util.ArrayList;
import java.util.List;
import static com.mongodb.client.model.Accumulators.*;
import static com.mongodb.client.model.Aggregates.*;
import static com.mongodb.client.model.Filters.*;
import static com.mongodb.client.model.Projections.*;
import static com.mongodb.client.model.Sorts.*;
import static com.mongodb.client.model.Updates.*;
import static java.util.Arrays.asList;
import static java.util.Collections.singletonList;

建立连接

使用MongoClients.create()方法连接到正在运行的 MongoDB 部署。

MongoClient实例表示数据库的连接池。即使使用并发操作线程，也只需要一个MongoClient实例。

重要

通常，您仅为给定 MongoDB 部署（例如独立部署、副本集或分片集群）仅创建一个MongoClient实例，并在整个应用程序中使用该客户端。但是，如果您确实创建了多个实例，请记住以下几点：

所有资源使用限制（例如最大连接数）均适用于每个MongoClient实例。
要丢弃实例，请调用MongoClient.close()方法来清理资源。

连接到单个 MongoDB 部署

以下示例展示了连接到单个 MongoDB 部署的几种方法。

您可以通过以下方式连接到单个MongoDB 部署：

实例化一个不带任何参数的MongoClient对象，以连接到在本地主机上运行的 MongoDB 服务器的端口27017 ：
```
MongoClient mongoClient = MongoClients.create();
```

显式指定hostname以连接到在指定主机的端口27017上运行的 MongoDB 实例：

MongoClient mongoClient = MongoClients.create(
   MongoClientSettings.builder()
       .applyToClusterSettings(builder ->
           builder.hosts(Arrays.asList(new ServerAddress("hostOne"))))
       .build());

显式指定hostname和port ：

MongoClient mongoClient = MongoClients.create(
   MongoClientSettings.builder()
       .applyToClusterSettings(builder ->
           builder.hosts(Arrays.asList(new ServerAddress("hostOne", 27018))))
       .build());

指定ConnectionString ：
```
MongoClient mongoClient = MongoClients.create("mongodb://hostOne:27017");
```

访问数据库

将MongoClient实例连接到 MongoDB 部署后，使用MongoClient.getDatabase()方法访问数据库。

为getDatabase()方法指定数据库的名称。如果数据库不存在，MongoDB 会在您首次为该数据库存储数据时创建该数据库。

以下示例将访问mydb数据库：

MongoDatabase database = mongoClient.getDatabase("mydb");

MongoDatabase 实例不可变。

访问集合

获得MongoDatabase实例后，使用getCollection()`方法访问权限集合。

为getCollection()方法指定集合的名称。如果集合不存在， MongoDB会在您首次存储该集合。

示例，以下声明使用数据库实例访问mydb数据库中名为test的集合：

MongoCollection<Document> collection = database.getCollection("test");

MongoCollection 实例不可变。

创建文档

要使用驱动程序创建文档，请使用 Document 类。

例如，考虑以下JSON document ：

{
   "name" : "MongoDB",
   "type" : "database",
   "count" : 1,
   "versions": [ "v3.2", "v3.0", "v2.6" ],
   "info" : { x : 203, y : 102 }
}

要使用驱动程序创建文档，请使用字段和值实例化Document对象，并使用其append()方法将其他字段和值包含到文档对象中。该值可以是另一个Document对象，用于指定嵌入式文档：

Document doc = new Document("name", "MongoDB")
    .append("type", "database")
    .append("count", 1)
    .append("versions", Arrays.asList("v3.2", "v3.0", "v2.6"))
    .append("info", new Document("x", 203).append("y", 102));

注意

数组的 BSON 类型对应于 Java 类型java.util.List 。有关BSON types和Java中相应类型的列表，请参阅 Document 映射。

插入文档

获得MongoCollection对象后，您可以将文档插入到集合中。

插入一个文档

要将单个文档插入集合，可以使用insertOne()方法。

var subscriber = new OperationSubscriber<InsertOneResult>();
collection.insertOne(doc).subscribe(subscriber);
// Wait for the insertOne operation to complete
subscriber.await();

注意

如果文档中没有指定顶级_id字段，MongoDB 会自动生成一个值并将该字段添加到插入的文档中。

重要

在 API 中，所有返回Publisher实例的方法都是冷流，这意味着在它们被订阅之前不会发生任何事情。

例如，以下示例不执行任何操作：

Publisher<InsertOneResult> publisher = collection.insertOne(doc);

该操作仅在订阅Publisher并请求数据时发生。

publisher.subscribe(new Subscriber<InsertOneResult>() {
    @Override
    public void onSubscribe(final Subscription s) {
        s.request(1);  // <--- Data requested and the insertion will now occur
    }
    @Override
    public void onNext(final InsertOneResult result) {
        System.out.println("Inserted: " + result);
    }
    @Override
    public void onError(final Throwable t) {
        System.out.println("Failed");
    }
    @Override
    public void onComplete() {
        System.out.println("Completed");
    }
});

插入文档后，系统会调用onNext()方法并打印Inserted: ，然后打印结果。最后， onComplete()方法会打印Completed 。如果由于任何原因出现错误， onError()方法将打印Failed 。

插入多个文档

要插入多个文档，可以使用集合的insertMany()方法，该方法获取要插入的文档列表。

以下示例按以下形式添加多个文档：

{ "i" : value }

在循环中创建文档并将它们添加到documents列表中：

List<Document> documents = new ArrayList<Document>();
for (int i = 0; i < 100; i++) {
    documents.add(new Document("i", i));
}

要将这些文档插入到集合中，请将文档列表传递给insertMany()方法：

var subscriber = new OperationSubscriber<InsertManyResult>();
collection.insertMany(documents).subscribe(subscriber);
// Wait for the insertMany operation to complete
subscriber.await();

上一个示例会在Publisher完成时阻塞。这可确保在运行下一个操作之前数据已存储在数据库中。

对集合中的文档进行计数

要计算集合中的文档数量，可以使用集合的countDocuments()方法。以下代码应打印101 ，描述使用insertMany() 100文档以及使用insertOne() 1插入的。

collection.count()
    .subscribe(new PrintSubscriber<Long>("total # of documents: %s"));

查询集合

要查询集合，可以使用集合的find()方法。您可以不带任何参数调用该方法来查询集合中的所有文档，也可以传递过滤来查询与过滤条件匹配的文档。

查找集合中的第一个文档

要返回集合中的第一个文档，请使用不带任何参数的find()方法，并链接first()方法。

提示

find().first()构造对于只应匹配单个文档的查询或仅对第一个匹配的文档感兴趣时非常有用。

以下示例打印在集合中找到的第一个文档：

collection.find().first().subscribe(new PrintDocumentSubscriber());

该示例应打印以下文档：

{
  "_id" : { "$oid" : "551582c558c7b4fbacf16735" },
  "name" : "MongoDB",
  "type" : "database",
  "count" : 1,
  "info" : { "x" : 203, "y" : 102 }
}

注意

_id元素已由MongoDB自动添加到您的文档中，您的值将与显示的不同。 MongoDB保留以_和$开头的字段名称供内部使用。

查找集合中的所有文档

要检索集合中的所有文档，请使用find()方法。 find()方法返回一个FindPublisher实例，该实例为链接或控制查找操作提供流畅的接口。以下代码检索并打印集合中的所有文档：

collection.find().subscribe(new PrintDocumentSubscriber());

指定查询筛选器

要查询匹配特定条件的文档，请将过滤器对象传递给 find() 方法。为了便于创建过滤器对象，驱动程序提供了 Filters 辅助工具方法。

获取与筛选器匹配的单个文档

要查找字段i的值为71的第一个文档，请传递eq()过滤定义以指定相等条件：

collection.find(eq("i", 71)).first().subscribe(new PrintDocumentSubscriber());

该示例打印一个文档：

{ "_id" : { "$oid" : "5515836e58c7b4fbc756320b" }, "i" : 71 }

获取与筛选器匹配的所有文档

以下示例返回并打印i值大于50的所有文档：

collection.find(gt("i", 50)).subscribe(new PrintDocumentSubscriber());

要为范围指定过滤器，例如50 < i <= 100 ，可以使用and()助手：

collection.find(and(gt("i", 50), lte("i", 100)))
    .subscribe(new PrintDocumentSubscriber());

Update Documents

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

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

过滤器对象以确定要更新的文档或多个文档。为了便于创建过滤器对象，驱动程序提供了 Filters 辅助工具方法。要指定空过滤器并匹配集合中的所有文档，请使用空 Document对象。
更新指定修改的文档。要查看可用操作符的列表，请参阅 MongoDB Server手册中的更新操作符。

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

更新单份文档

要更新单个文档，请使用updateOne()方法。

以下示例更新i为10的第一个文档，并将i的值设置为110 ：

collection.updateOne(eq("i", 10), set("i", 110))
    .subscribe(new PrintSubscriber<UpdateResult>("Update Result: %s"));

更新多个文档

要更新与查询筛选器匹配的所有文档，请使用updateMany()方法。

以下示例在值小于i 100的所有文档中将的值递增i 100：

UpdateResult updateResult = collection.updateMany(lt("i", 100), inc("i", 100))
    .subscribe(new PrintSubscriber<UpdateResult>("Update Result: %s"));

Delete Documents

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

传递一个过滤器对象以确定要删除的文档或多个文档。为了便于创建过滤器对象，驱动程序提供了 Filters 辅助工具方法。要指定空过滤器并匹配集合中的所有文档，请使用空 Document对象。

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

删除与筛选器匹配的单个文档

要删除与筛选器匹配的单个文档，请使用deleteOne()方法。

以下示例删除了i的值等于110的第一个文档：

collection.deleteOne(eq("i", 110))
    .subscribe(new PrintSubscriber<DeleteResult>("Delete Result: %s"));

删除与筛选器匹配的所有文档

要删除与过滤匹配的所有文档，请使用deleteMany()方法。

以下示例删除i值大于或等于100的所有文档：

DeleteResult deleteResult = collection.deleteMany(gte("i", 100))
    .subscribe(new PrintSubscriber<DeleteResult>("Delete Result: %s"));

createIndexes

要在一个或多个字段上创建索引，请将索引规范文档传递给createIndex()方法。索引键规范文档包含要索引的字段以及每个字段的索引类型，由以下文档建模：

new Document(<field1>, <type1>).append(<field2>, <type2>) ...

要创建升序索引类型，请为指定1 <type>。要创建降序索引类型，请为指定-1 <type>。

以下示例在i字段上创建一个升序索引：

collection.createIndex(new Document("i", 1))
    .subscribe(new PrintSubscriber<String>("Create Index Result: %s"));

要查看其他索引类型的列表，请参阅创建索引指南。

注意

重要

先决条件

建立连接

重要

连接到单个 MongoDB 部署

访问数据库

访问集合

创建文档

注意

插入文档

插入一个文档

注意

重要

插入多个文档

对集合中的文档进行计数

查询集合

查找集合中的第一个文档

提示

注意

查找集合中的所有文档

指定查询筛选器

获取与筛选器匹配的单个文档

获取与筛选器匹配的所有文档

Update Documents

更新单份文档

更新多个文档

Delete Documents

删除与筛选器匹配的单个文档

删除与筛选器匹配的所有文档

createIndexes

更多信息