如何在Elasticsearch查询中仅获取指定字段（Java实现）

要实现类似SQL的Select column_one, column_two from table的字段过滤效果，你可以通过NativeSearchQueryBuilder的withFetchSource()方法来指定需要返回的字段，具体修改如下：

1. 修改findAll方法，支持传入指定字段 #

将原findAll方法新增字段列表参数，在构建查询时添加字段过滤逻辑：

protected List<T> findAll(final BoolQueryBuilder query, String... includeFields) {
    NativeSearchQueryBuilder queryBuilder = new NativeSearchQueryBuilder().withQuery(query);
    // 指定要返回的字段
    if (includeFields != null && includeFields.length > 0) {
        queryBuilder.withFetchSource(includeFields, null);
    }
    Query searchQuery = queryBuilder.build();
    SearchHits<T> searchHits = this.elasticsearchRestTemplate.search(
        searchQuery, 
        this.getClazz(), 
        this.elasticsearchRestTemplate.getIndexCoordinatesFor(this.getClazz())
    );
    return (List)SearchHitSupport.unwrapSearchHits(searchHits);
}

• withFetchSource(includeFields, null)：第一个参数是要包含的字段数组，第二个参数是要排除的字段（这里设为null表示不排除任何字段）。如果需要排除某些字段，可以把第二个参数设为对应的字段数组。

2. 调用修改后的findAll方法 #

在原查询代码中，传入需要返回的字段名即可：

BoolQueryBuilder query = boolQuery();
query.must(wildcardQuery("value", value + "*"));
// 指定要返回column_one和column_two字段
return findAll(query, "column_one", "column_two");

补充说明 #

如果你不需要修改原findAll方法，也可以直接调整查询构建逻辑，核心都是通过withFetchSource或withSourceFilter（Spring Data Elasticsearch 4.x+支持）控制返回字段。比如用withSourceFilter的写法：

SourceFilter sourceFilter = new FetchSourceFilter(new String[]{"column_one", "column_two"}, null);
queryBuilder.withSourceFilter(sourceFilter);

内容的提问来源于stack exchange，提问作者EleXorZ