二十七、RestClient查询文档

目录

一、MatchALL查询

二、Match查询

三、bool查询

四、排序和分页

五、高亮

---

一、MatchALL查询

    @Testvoid testMatchAll() throws IOException {
//      准备Request对象SearchRequest request = new SearchRequest("hotel");
//      准备DSLrequest.source().query(QueryBuilders.matchAllQuery());
//      发送请求SearchResponse response = client.search(request, RequestOptions.DEFAULT);
//      解析响应SearchHits searchHits = response.getHits();
//      获取总条数long value = searchHits.getTotalHits().value;System.out.println("共搜索到"+value+"条数据!");
//      获取文档数组SearchHit[] hits = searchHits.getHits();
//      遍历for (SearchHit hit : hits) {
//          获取文档sourceString json = hit.getSourceAsString();
//          反序列化HotelDoc object = JSON.parseObject(json, HotelDoc.class);System.out.println("object = " + object);}}

二、Match查询

    @Testvoid testMatch() throws IOException {
//      准备Request对象SearchRequest request = new SearchRequest("hotel");
//      准备DSLrequest.source().query(QueryBuilders.matchQuery("name","连锁"));
//      发送请求SearchResponse response = client.search(request, RequestOptions.DEFAULT);
//      解析响应SearchHits searchHits = response.getHits();
//      获取总条数long value = searchHits.getTotalHits().value;System.out.println("共搜索到"+value+"条数据!");
//      获取文档数组SearchHit[] hits = searchHits.getHits();
//      遍历for (SearchHit hit : hits) {
//          获取文档sourceString json = hit.getSourceAsString();
//          反序列化HotelDoc object = JSON.parseObject(json, HotelDoc.class);System.out.println("object = " + object);}}

三、bool查询

    @Testvoid testBool() throws IOException {
//      准备Request对象SearchRequest request = new SearchRequest("hotel");
//      准备DSLBoolQueryBuilder boolQuery = QueryBuilders.boolQuery();boolQuery.must(QueryBuilders.termQuery("city","杭州"));boolQuery.filter(QueryBuilders.rangeQuery("price").lte(250));request.source().query(boolQuery);
//      发送请求SearchResponse response = client.search(request, RequestOptions.DEFAULT);extracted(response);}

四、排序和分页

    @Testvoid testMatchAll() throws IOException {
//      准备Request对象SearchRequest request = new SearchRequest("hotel");
//      准备DSLrequest.source().query(QueryBuilders.matchAllQuery());
//      分页request.source().from(0).size(5);
//      排序request.source().sort("price", SortOrder.ASC);
//      发送请求SearchResponse response = client.search(request, RequestOptions.DEFAULT);
//      解析响应extracted(response);}

五、高亮

所有搜索DSL的构建，记住一个API    :   SearchRequest的source()方法。

高亮结果解析是参考JSON结果，逐层解析

     @Testvoid testHighLight() throws IOException {
//      准备Request对象SearchRequest request = new SearchRequest("hotel");
//      准备DSLrequest.source().query(QueryBuilders.matchQuery("name", "连锁"));request.source().highlighter(new HighlightBuilder().field("name").requireFieldMatch(false));
//      发送请求SearchResponse response = client.search(request, RequestOptions.DEFAULT);extracted(response);}   private void extracted(SearchResponse response) {
//      解析响应SearchHits searchHits = response.getHits();
//      获取总条数long value = searchHits.getTotalHits().value;System.out.println("共搜索到" + value + "条数据!");
//      获取文档数组SearchHit[] hits = searchHits.getHits();
//      遍历for (SearchHit hit : hits) {
//          获取文档sourceString json = hit.getSourceAsString();
//          反序列化HotelDoc object = JSON.parseObject(json, HotelDoc.class);
//          获取高亮结果Map<String, HighlightField> highlightFields = hit.getHighlightFields();if (!CollectionUtils.isEmpty(highlightFields)){
//              根据字段名获取高亮结果HighlightField highlightField = highlightFields.get("name");if (highlightFields != null){
//                  获取高亮值String name = highlightField.getFragments()[0].string();
//                  覆盖非高亮结果object.setName(name);}}System.out.println("object = " + object);}}