Java修仙传之神奇的ES2（巧妙的查询及结果处理篇）

高亮的核心：关键字加标签

• 高亮是对关键字高亮，因此搜索条件必须带有关键字，而不能是范围这样的查询。
• 默认情况下，高亮的字段，必须与搜索指定的字段一致，否则无法高亮
• 如果要对非搜索字段高亮，则需要添加一个属性：required_field_match=false

GET /hotel/_search
{
  "query": {
    "match": {
      "FIELD": "TEXT" // 查询条件，高亮一定要使用全文检索查询
    }
  },
  "highlight": {
    "fields": { // 指定要高亮的字段
      "FIELD": {
        "pre_tags": "",  // 用来标记高亮字段的前置标签
        "post_tags": "" // 用来标记高亮字段的后置标签
      }
    }
  }
}

JAVA客户端查询并解析

查询全部matchAllQuery

1：组装查询，发起请求（）

1.1:request.source():根据需求点出来需要排序分页还是什么

2：根据结构，层层解析

2.1：根据结构解析

2.2：返回数据为json，可以转java类等操作

@Test
void testMatchAll() throws IOException {
    // 1.准备Request
    SearchRequest request = new SearchRequest("hotel");
    // 2.准备DSL
    request.source()
        .query(QueryBuilders.matchAllQuery());
    // 3.发送请求
    SearchResponse response = client.search(request, RequestOptions.DEFAULT);
 
    // 4.解析响应
    handleResponse(response);
}
 
private void handleResponse(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);
    }
}

match查询

    @Test
    void testMatch() throws IOException {
        SearchRequest request = new SearchRequest("hotel");
        //单字段查询
        request.source().query(QueryBuilders.matchQuery("all", "如家"));
        //多字段查询
//        request.source().query(QueryBuilders.multiMatchQuery("外滩", "name","brand","business"));
        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
        handleResponse(response);
    }

单字段查询

多字段查询

精确查询及范围查询

    @Test
    void termQuery() throws IOException {
        SearchRequest request = new SearchRequest("hotel");
        //精确查询
        //request.source().query(QueryBuilders.termQuery("city", "上海"));
        //范围查询
        request.source().query(QueryBuilders.rangeQuery("price").gte(0).lte(1000));
        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
        handleResponse(response);
    }

布尔查询

 //布尔查询
    @Test
    void boolQuery() throws IOException {
        SearchRequest request = new SearchRequest("hotel");
        //布尔查询
        request.source().query(QueryBuilders.boolQuery()
                //必须匹配,且参与算分。城市=上海
                .must(QueryBuilders.termQuery("city", "上海"))
                //必须不匹配 品牌 ！= 如家
                .mustNot(QueryBuilders.termQuery("brand", "如家"))
                //必须匹配,但不参与算分。价格>=0,<=1000
                .filter(QueryBuilders.rangeQuery("price").gte(0).lte(1000))
        );
        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
        handleResponse(response);
    }

分页，排序

   @Test
    void sortAndPage() throws IOException {
        // 页码，每页大小
        int page = 2, size = 5;
 
        //备注：这里什么查询条件都没写，所以会查询出所有数据。但是下文分，所以只会取5-10条数据
        SearchRequest request = new SearchRequest("hotel");
 
        //分页  这里是写死的  
        request.source().from((page - 1) * size).size(size);
 
        //排序  升序排序
        request.source().sort("price", SortOrder.ASC);
 
        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
 
        handleResponse(response);
    }

handleResponse

 private void handleResponse(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 highlightQuery() throws IOException {
        SearchRequest request = new SearchRequest("hotel");
 
        //拼装高亮信息
        HighlightBuilder hb = new HighlightBuilder();
        hb.field("name"); //高亮字段
        hb.preTags(""); // 字段前缀标签
        hb.postTags(""); // 字段后缀标签
        hb.requireFieldMatch(false); // 条件和高亮字段可以不一致
 
        //组装查询
        request.source().query(QueryBuilders.matchQuery("name", "北京"))
               .highlighter(hb);
 
        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
 
        //高亮解析
        highlightHandel(response);
    }

高亮解析

  private void highlightHandel(SearchResponse response) {
        // 4.解析响应
        SearchHits searchHits = response.getHits();
        //获取总条数
        Long total = searchHits.getTotalHits().value;
        //文档数组
        SearchHit[] hits = searchHits.getHits();
        //一条文档 hit
        for (SearchHit hit : hits) {
            //一条原始文档数据
            String json = hit.getSourceAsString();
            // 反序列化
            HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);
            //获取高亮结果 String = 字段名  HighlightField = 被高亮的结果
            //highlightFields = {name=[name], fragments[[<em>北京</em>希尔顿酒店]]}  多条这种数据
            Map<String, HighlightField> highlightFields = hit.getHighlightFields();
            //根据字段名称获取高亮结果
            if (!CollectionUtils.isEmpty(highlightFields)) {
                // 根据字段名获取高亮结果
                HighlightField highlightField = highlightFields.get("name");
                String result = highlightField.getFragments()[0].string();
                //result是所有高亮的信息,我们这里是业务需求，覆盖掉原文的非高亮部分
                hotelDoc.setName(result);
            }
        }
    }

详细解释：