0
点赞
收藏
分享

微信扫一扫

java实现es的search after查询(三种方式详解)

沈芏 2022-03-17 阅读 71

一、概念说明

1、form size查询

2、scroll深分页

3、search after深分页

二、curl命令操作

1、form size

2、scroll

3、search after

三、代码实现

1、form size

2、scroll

3、search after

//第一次请求获取数据
@Test
public void test01() throws IOException {
    SearchRequest searchRequest = new SearchRequest();
    SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
    TermQueryBuilder queryBuilder = QueryBuilders.termQuery("age", 24);
    searchRequest.indices("person");
    searchSourceBuilder.query(queryBuilder).sort("id",SortOrder.ASC);
    searchSourceBuilder.from(0).size(3);
    searchRequest.source(searchSourceBuilder);
    SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
    //处理数据获取最后一条的sortid
    SearchHit[] hits = searchResponse.getHits().getHits();
    Object[] sortValues1 = hits[hits.length - 1].getSortValues();
    System.out.println("最后一条数据sort_id为:"+Arrays.toString(sortValues1));
    for (SearchHit hit : searchResponse.getHits().getHits()) {
        Object[] sortValues = hit.getSortValues();
        System.out.println(Arrays.toString(sortValues));
        System.out.println(hit.getSourceAsString());
    }
}


代码执行返回值:
最后一条数据sort_id为:[14]
[7]
{"nama":"牛二","age":"24","id":7}
[13]
{"nama":"李彬","age":"24","id":13}
[14]
{"nama":"菠萝","age":"24","id":14}


//往后的每次请求都携带上一次的sort_id进行访问。
@Test
public void test02() throws IOException {
    TermQueryBuilder queryBuilder = QueryBuilders.termQuery("age", 24);
    Object[] objects= new Object[]{"14"};
    //第二次请求,携带sortid进行查询。
    SearchRequest searchRequest = new SearchRequest();
    searchRequest.indices("person");
    SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
    searchSourceBuilder.query(queryBuilder).sort("id",SortOrder.ASC).searchAfter(objects);
    searchSourceBuilder.from(0).size(3);
    searchRequest.source(searchSourceBuilder);
    SearchResponse search = client.search(searchRequest, RequestOptions.DEFAULT);
    for (SearchHit hit : search.getHits().getHits()) {
        System.out.println(Arrays.toString(hit.getSortValues()));
    }
}
举报

相关推荐

0 条评论