List<String> ids = List.of(id);
NativeSearchQuery query = new NativeSearchQueryBuilder()
.withSourceFilter(new FetchSourceFilterBuilder().withIncludes(section).build())
.withIds(ids)
.build();
log.trace("query {}", query.toString());
SearchHits<Foo> searchHits = operations.search(query, Foo.class, index);
上面的代码片段生成了以下查询,但不清楚为什么它会获取所有Foo,因为我已经明确提到使用withIds(ids)
使用单个id
Sending request POST /foos/_search?typed_keys=true&max_concurrent_shard_requests=5&ignore_unavailable=false&expand_wildcards=open&allow_no_indices=true&ignore_throttled=true&search_type=dfs_query_then_fetch&batched_reduce_size=512&ccs_minimize_roundtrips=true with parameters:
Request body: {"from":0,"size":10000,"version":true,"_source":{"includes":["bp"],"excludes":[]}}
2021-01-15 10:12:45.075 TRACE 45572 --- [/O dispatcher 1] o.s.data.elasticsearch.client.WIRE : [6ba88ad6] Received raw response: 200 OK
2021-01-15 10:12:45.284 TRACE 45572 --- [nio-5555-exec-2] c.p.matrimony.service.BaseService : searchHitsConvertList input SearchHits{totalHits=235, totalHitsRelation=EQUAL_TO, maxScore=1.0, scrollId='null', searchHits={235 elements}, aggregations=null}
withIds()
在另一个上下文中使用(即通过_mget
按ID检索多个文档时(。
在您的情况下,您应该简单地进行一点不同的处理,即在_id
字段上使用terms
过滤器:
NativeSearchQuery query = new NativeSearchQueryBuilder()
.withSourceFilter(new FetchSourceFilterBuilder().withIncludes(section).build())
.withFilter(QueryBuilders.termsFilter("_id", ids))
.build();