RestClient查询文档

快速入门：

编辑

match_all查询：

//match_all查询
    @Test
    void testMatchAll() throws IOException {
        String index  = "tb_disable_date_diary";
        //1.准备Request
        SearchRequest request = new SearchRequest(index);
        //2.准备DSL
        request.source().query(QueryBuilders.matchAllQuery());
        //3.发送请求
        SearchResponse response = client.search(request,RequestOptions.DEFAULT);

        //解析响应
        handleResponce(response);

        System.out.println(response);
    }

    //解析响应
    private void handleResponce(SearchResponse response) {
        //4.解析响应
        SearchHits searchHits = response.getHits();
        //4.1获取总条数
        long total = searchHits.getTotalHits().value;
        System.out.println("共搜索到"+total+"条数据");
        //4.2文档数据
        SearchHit[] hits = searchHits.getHits();
        //4.3遍历
        for(SearchHit hit : hits){
            //获取文档source
            String json = hit.getSourceAsString();
            //反序列化
            Diary diary = JSON.parseObject(json,Diary.class);
            System.out.println("diary = "+diary);
        }
    }

//分页和排序
   @Test
   void restPageAndSort() throws IOException {
       //页码，每页大小
       int page = 2,size = 5;

       //1.准备Request
       SearchRequest request = new SearchRequest("hotel");
       //2.准备DSL
       //2.1 query
       request.source().query(QueryBuilders.matchAllQuery());
       //2.2 排序 sort
       request.source().sort("price", SortOrder.ASC);
       //2.3 分页from，size
       request.source().from((page - 1) * size).size(5);

       //3.发送请求
       SearchResponse response = client.search(request,RequestOptions.DEFAULT);

       handleResponce(response);

       System.out.println(response);
   }

   private void handleResponce(SearchResponse response) {
       //4.解析响应
       SearchHits searchHits = response.getHits();
       //4.1获取总条数
       long total = searchHits.getTotalHits().value;
       System.out.println("共搜索到"+total+"条数据");
       //4.2文档数据
       SearchHit[] hits = searchHits.getHits();
       //4.3遍历
       for(SearchHit hit : hits){
           //获取文档source
           String json = hit.getSourceAsString();
           //反序列化
           HotelDoc hotelDoc = JSON.parseObject(json,HotelDoc.class);
           System.out.println("hotelDoc = "+hotelDoc);
       }
   }

高亮

//高亮
    @Test
    void testHighlight() throws IOException {
        //1.准备Request
        SearchRequest request = new SearchRequest("hotel");
        //2.准备DSL
        //2.1 query
        request.source().query(QueryBuilders.matchQuery("all","如家"));
        //2.2 高亮
        request.source().highlighter(new HighlightBuilder().field("name").requireFieldMatch(false));

        //3.发送请求
        SearchResponse response = client.search(request,RequestOptions.DEFAULT);

        handleResponce1(response);

        System.out.println(response);
    }

    private void handleResponce1(SearchResponse response) {
        //4.解析响应
        SearchHits searchHits = response.getHits();
        //4.1获取总条数
        long total = searchHits.getTotalHits().value;
        System.out.println("共搜索到"+total+"条数据");
        //4.2文档数组
        SearchHit[] hits = searchHits.getHits();
        //4.3遍历
        for(SearchHit hit : hits){
            //获取文档source
            String json = hit.getSourceAsString();
            //反序列化
            HotelDoc hotelDoc = JSON.parseObject(json,HotelDoc.class);

            //获取高亮结果
            Map<String, HighlightField> highlightFields = hit.getHighlightFields();
            if(!CollectionUtils.isEmpty(highlightFields)){
                //根据各字段名获取高亮结果
                HighlightField highlightField = highlightFields.get("name");
                if(highlightField != null){
                    //获取高亮
                    String name = highlightField.getFragments()[0].string();
                    //覆盖非高亮结果
                    hotelDoc.setName(name);
                }
            }

            System.out.println("hotelDoc = "+hotelDoc);
        }
    }