说明：如何使用rest高级客户端和Spring实现分页？

Question

我在从传输客户端迁移到Rest高级客户端时遇到问题。下面的代码不适用于RestHighLevelClient，我想使用它来获取类类型的聚合页面的响应。

elasticsearchTemplate.queryForPage(searchQuery, Class.class)

我们也欢迎任何用其他方法实现同样目标的建议。

Answer 1

这对我有用

public Page<T> search(){
           Query query;
            SearchHits<T> t;
            Criteria nameCriteria = new Criteria("name").is(text).and(new 
            Criteria("jsonNode").in(String ...)); //This can be any Aggregator
            query = new CriteriaQuery(nameCriteria).setPageable(paging);
            searchHits = elasticsearchOperations.search(query, T.class);
            return (Page) SearchHitSupport.searchPageFor(searchHits, query.getPageable());;
}
 

Answer 2

我在不使用Spring data elasticsearch的情况下使用restHighLevelClient的解决方案包含在以下代码中（这不是解决方案，但可能对您的解决方案有所帮助）：

        BoolQueryBuilder criteriaQuerySpecification = getCriteriaQuerySpecification(transactionFilter);

        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        sourceBuilder.sort(new FieldSortBuilder("operation_created_at").order(SortOrder.DESC));
        sourceBuilder.query(criteriaQuerySpecification);

        SearchRequest searchRequest = generateSearchRequest(totalElementsInt, pageNumberInt, sourceBuilder);
        SearchResponse search = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);

        List<OperationDto > operations = Arrays.asList(hits).stream().map(hit -> {
            hit.getSourceAsString();
         // get operation is a method mapping from hit to your dto using  Map<String, Object> sourceAsMap = hit.getSourceAsMap();
         OperationDto operation = getOperationDto(hit);

            //convert hit to OperationDto
          return operation;
        }).collect(Collectors.toList());


private SearchRequest generateSearchRequest(Integer totalElementsInt, Integer pageNumberInt, SearchSourceBuilder sourceBuilder) {
    SearchRequest searchRequest = new SearchRequest("operation-index").types("operation");
    int  offset = pageNumberInt *totalElementsInt;
    sourceBuilder.from(offset);
    sourceBuilder.size(totalElementsInt);
    sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));
    searchRequest.source(sourceBuilder);
    return searchRequest;
}