使用Spring数据elasticsearch中的Elasticsearch模板获取ID的计数和列表

Question

我正在为一个项目使用spring-data-elasticsearch来为其提供全文搜索功能。我们将真实数据保存在关系数据库中，将相关元数据以及相应的id保存在elasticsearch中。因此，对于搜索结果，只需要id字段，因为实际数据将从关系数据库中检索。

我正在根据搜索条件构建搜索查询，然后执行queryForIds（）：

    SearchQuery searchQuery = new NativeSearchQueryBuilder()
            .withIndices(indexName)
            .withTypes(typeName)
            .withQuery(getQueryBuilder(searchParams))
            .withPageable(pageable)
            .build();

    return elasticsearchTemplate.queryForIds(searchQuery);

如果我还需要特定搜索查询的总数，我可以做另一个elasticsearchTemplate。count（searchQuery）调用，但据我所知，这是多余的。我认为有一种方法可以通过使用类似elasticsearchTemplate的东西来获取id列表和总计数。queryformage（）在单个调用中。

此外，我可以在queryformage（SearchQuery查询，class）中使用自定义类吗

Answer 1

也可以考虑使用AggregatedPage

SearchQuery searchQuery = new NativeSearchQueryBuilder().withIndices(indexName)
        .withTypes(typeName)
        .withQuery(queryBuilder)
        .withPageable(pageable)
        .build();

AggregatedPage<ElasticDTO> queryResult = elasticsearchTemplate.queryForPage(searchQuery , ElasticDTO.class);

Answer 2

如果您想防止两次调用elasticsearch，我建议您编写一个自定义ResultExtractor：

SearchQuery searchQuery = new NativeSearchQueryBuilder().withIndices(indexName)
        .withTypes(typeName)
        .withQuery(queryBuilder)
        .withPageable(pageable)
        .build();
SearchResult result = template.query(searchQuery, new ResultsExtractor<SearchResult>() {

    @Override
    public SearchResult extract(SearchResponse response) {
        long totalHits = response.getHits()
                .totalHits();
        List<String> ids = new ArrayList<String>();
        for (SearchHit hit : response.getHits()) {
            if (hit != null) {
                ids.add(hit.getId());
            }
        }
        return new SearchResult(ids, totalHits);
    }
});
System.out.println(result.getIds());
System.out.println(result.getCount());

其中SearchResult是自定义类：

public class SearchResult {

    List<String> ids;
    long count;

    //getter and setter
}

这样，您可以从elasticsearch获得所需的信息。

关于你的第二个问题：据我所知，当调用queryForPage（SearchQuery查询，Class