一、概念说明
3、search after深分页
二、curl命令操作
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()));
}
}