检索不同字段值

在此页面上

Overview

样本数据
distinct() 方法
检索集合中的不同值
检索指定文档中的不同值
修改不同行为
更多信息
API 文档

Overview

在集合中，不同文档的单个字段可能包含不同值。示例， restaurant集合中的一个文档的borough值为"Manhattan" ，而另一文档的borough值为"Queens" 。借助Java Reactive Streams驾驶员，您可以检索集合中多个文档中某个字段包含的所有不同值。

样本数据

本指南中的示例使用 Atlas示例数据集中的sample_restaurants.restaurants集合。要学习；了解如何创建免费的MongoDB Atlas 群集并加载示例数据集，请参阅入门。

重要

项目 Reactor 库

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

`distinct()` 方法

要检索指定字段的非重复值，请调用distinct()方法并传入要查找非重复值的字段的名称。

检索集合中的不同值

以下示例检索restaurants集合中borough字段的非重复值：

DistinctPublisher<String> distinctPublisher = collection
        .distinct("borough", String.class);
Flux.from(distinctPublisher)
        .doOnNext(System.out::println)
        .blockLast();

Bronx
Brooklyn
Manhattan
Missing
Queens
Staten Island

结果显示集合中所有文档的borough字段中出现的每个不同值。尽管多个文档在borough字段中具有相同的值，但每个值仅在结果中出现一次。

检索指定文档中的不同值

您可以为distinct()方法提供查询筛选器，以查找集合中文档子集的不同字段值。查询筛选器是一个表达式，指定Atlas Search用于匹配操作中的文档的条件。有关创建查询筛选器的更多信息，请参阅指定查询。

以下示例检索cuisine字段值为"Italian"的所有文档的borough字段的非重复值：

Bson filter = Filters.eq("cuisine", "Italian");
DistinctPublisher<String> distinctPublisher = collection
        .distinct("borough", String.class)
        .filter(filter);
Flux.from(distinctPublisher)
        .doOnNext(System.out::println)
        .blockLast();

Bronx
Brooklyn
Manhattan
Queens
Staten Island

修改不同行为

可以通过将方法链接到distinct()方法调用来修改distinct()方法。如果不指定任何选项，驾驶员不会自定义操作。

下表描述了可用于自定义distinct()操作的一些方法：

方法	说明
`batchSize()`	Sets the number of documents to return per batch.
`collation()`	Specifies the kind of language collation to use when sorting results. For more information, see Collation in the MongoDB Server manual.
`comment()`	Specifies a comment to attach to the operation.
`filter()`	Sets the query filter to apply to the query.
`maxTime()`	Sets the maximum amount of time to allow the operation to run, in milliseconds.

有关可用于修改distinct() 方法的方法的完整列表，请参阅 DistinctPublisher API文档。

以下示例检索borough字段值为"Bronx"且cuisine字段值为"Pizza"的所有文档的name字段的非重复值。它还使用comment选项为操作添加注释。

Bson filter = Filters.and(
        Filters.eq("borough", "Bronx"),
        Filters.eq("cuisine", "Pizza")
);
DistinctPublisher<String> distinctPublisher = collection
        .distinct("name", String.class)
        .filter(filter)
        .comment("Bronx pizza restaurants");
Flux.from(distinctPublisher)
        .doOnNext(System.out::println)
        .blockLast();

$1.25 Pizza
18 East Gunhill Pizza
2 Bros
Aenos Pizza
Alitalia Pizza Restaurant
...