Overview
在本指南中,您可以学习;了解如何使用Java Reactive Streams驾驶员对集合运行MongoDB Search 查询。 MongoDB Search 使您能够对MongoDB集合执行全文搜索。 MongoDB Search 索引指定搜索行为以及要索引的字段。
样本数据
moviessample_mflix本指南中的示例使用Atlas示例数据集的 数据库中的 集合。要学习;了解如何创建免费的MongoDB 部署并加载示例数据集,请参阅MongoDB入门指南。要学习;了解有关聚合操作和构建者的更多信息,请参阅聚合框架指南。
运行MongoDB搜索查询
本节展示如何创建聚合管道,以对集合运行 MongoDB Search 查询。 您可以使用 Aggregates.search() 构建器方法来创建 $search 管道阶段,该阶段指定搜索条件。然后,调用 aggregate() 方法,并将您的管道作为参数传递。
注意
Atlas和 Community Edition 版本要求
$search 聚合管道操作符仅适用于在运行 MongoDB v4.2 或更高版本的MongoDB Atlas集群上托管的集合,或者运行 MongoDB v8.2 或更高版本的MongoDB Community Edition集群上托管的集合。集合必须包含在MongoDB 搜索索引中。要了解有关此操作符所需设置和功能的更多信息,请参阅MongoDB 搜索文档。
在运行MongoDB Search查询之前,您必须在集合上创建MongoDB Search索引。要学习;了解如何以编程方式创建MongoDB Search索引,请参阅索引指南中的MongoDB Search 索引管理部分。
MongoDB搜索示例
此示例通过执行以下操作来运行MongoDB 搜索查询:
使用
Aggregates.project()构建者方法构造$project阶段,指示驱动程序在查询结果中包含title字段将管道阶段传递到
aggregate()方法并打印结果
Publisher<Document> publisher = collection.aggregate( List.of( Aggregates.search(SearchOperator.text( SearchPath.fieldPath("title"), "Alabama")), Aggregates.project(Projections.include("title")) ) ); Flux.from(publisher) .doOnNext(doc -> System.out.println(doc.toJson())) .blockLast();
{"_id": {"$oid": "..."}, "title": "Alabama Moon"} {"_id": {"$oid": "..."}, "title": "Crazy in Alabama"} {"_id": {"$oid": "..."}, "title": "Sweet Home Alabama"}
MongoDB搜索元数据
使用Aggregates.searchMeta() 方法创建 $searchMeta管道阶段,该阶段仅返回MongoDB搜索结果的元数据。
注意
Atlas和 Community Edition 版本要求
此聚合管道操作符符仅适用于运行 MongoDB v4.4.11 及更高版本的MongoDB Atlas集群,或者运行 MongoDB v8.2 或更高版本的MongoDB Community Edition集群。有关版本可用性的详细列表,请参阅 $searchMeta 上的MongoDB Atlas文档。
以下示例显示了MongoDB Search聚合阶段的 near 元元数据,该阶段返回 2010 的 1 年内具有 year字段值的文档数量:
Aggregates.searchMeta( SearchOperator.near(2010, 1, fieldPath("year")));
Document{{count=Document{{lowerBound=21326}}}}
要学习;了解有关此辅助方法的更多信息,请参阅 searchMeta() API文档。
创建管道搜索阶段
Java Reactive Streams驱动程序为以下操作符提供了辅助方法:
Operator | 说明 |
|---|---|
从不完整输入字符串中搜索包含字符序列的单词或短语。 | |
将两个或多个操作符组合到一个查询中。 | |
检查字段是否与您指定的值匹配。映射到 | |
测试指定索引字段名称的路径在文档中是否存在。 | |
在给定路径搜索由BSON数字、日期、布尔值、ObjectId、uuid 或字符串值组成的大量,并返回该字段的值等于指定大量中任意值的文档。 | |
返回与输入文档类似的文档。 | |
支持对数字、日期和GeoJSON point值进行查询和评分。 | |
使用索引配置中指定的分析器搜索包含有序术语序列的文档。 | |
支持查询索引字段和值的组合。 | |
支持对数字、日期和字符串值进行查询和评分。 映射到 | |
将查询字段解释为正则表达式。 | |
使用在索引配置中指定的分析器执行全文搜索。 | |
启用在搜索字符串中使用可匹配任何字符的特殊字符的查询。 |
管道搜索阶段示例
在运行此示例之前,您必须在具有以下定义的 movies 集合上创建 MongoDB 搜索索引:
{ "mappings": { "dynamic": true, "fields": { "title": { "analyzer": "lucene.keyword", "type": "string" }, "genres": { "normalizer": "lowercase", "type": "token" } } } }
要了解有关创建 MongoDB 搜索索引的更多信息,请参阅索引指南中MongoDB 搜索索引管理部分。
以下代码创建具有以下规范的 $search 阶段:
检查
genres大量是否包含"Comedy"在
fullplot字段中搜索字段"new york"匹配介于
1950和2000(含)之间的year值搜索以术语
"Love"开头的title值
List<Bson> pipeline = List.of( Aggregates.search( SearchOperator.compound() .filter( List.of( SearchOperator.in(fieldPath("genres"), List.of("Comedy")), SearchOperator.phrase(fieldPath("fullplot"), "new york"), SearchOperator.numberRange(fieldPath("year")).gtLt(1950, 2000), SearchOperator.wildcard(fieldPath("title"), "Love *") ))), Aggregates.project( Projections.include("title", "year", "genres") )); Publisher<Document> publisher = collection.aggregate(pipeline); Flux.from(publisher) .doOnNext(doc -> System.out.println(doc.toJson())) .blockLast();
{"_id": ..., "genres": ["Comedy", "Romance"], "title": "Love at First Bite", "year": 1979} {"_id": ..., "genres": ["Comedy", "Drama"], "title": "Love Affair", "year": 1994}
要学习有关MongoDB 搜索辅助程序方法的更多信息,请参阅驱动程序 Core API 文档中的SearchOperator接口参考。
更多信息
要学习有关MongoDB Search 的更多信息,请参阅Atlas文档中的MongoDB Search。
API 文档
要学习;了解有关本指南中提到的方法的更多信息,请参阅以下API文档: