Elasticsearch查询文档--常见API篇（附详细代码和案例图文）

2023-08-21 22:19

短信预约 -IT技能 免费直播动态提醒

前言：大家好，我是小威，24届毕业生，在一家满意的公司实习。本篇文章将介绍Elasticsearch在Java中的几种API的使用，这块内容不作为面试中的重点。
如果文章有什么需要改进的地方还请大佬不吝赐教👏👏。
小威在此先感谢各位大佬啦~~🤞🤞
在这里插入图片描述

🏠个人主页：小威要向诸佬学习呀
🧑个人简介：大家好，我是小威，一个想要与大家共同进步的男人😉😉
目前状况🎉：24届毕业生，在一家满意的公司实习👏👏

💕欢迎大家：这里是CSDN，我总结知识的地方，欢迎来到我的博客，我亲爱的大佬😘

在这里插入图片描述

Java中API查询文档

Elasticsearch在网页端查询文档对应的DSL语句如下：

GET /hotel/_search{  "query": {    "match": {      "all": "如家"    }  },  "highlight": {    "fields": {      "name": {        "require_field_match": "false"      }    }  }}

执行上述语句打印结果如下：

在这里插入图片描述

在Java代码中我们需要准备request，DSL语句以及发送请求

    private RestHighLevelClient client;    @Test    void testMatchAll() throws IOException {        //准备request        SearchRequest request = new SearchRequest("hotel");//hotel为我们之前文章中所建立的索引库        //准备DSL语句，查询所有文档        request.source().query(QueryBuilders.matchAllQuery());        //发送请求        SearchResponse response = client.search(request, RequestOptions.DEFAULT);        //打印结果        System.out.println(response);    }    @BeforeEach    void setUp() {        client = new RestHighLevelClient(RestClient.builder(                HttpHost.create("http://192.168.220.***:9200")        ));    }    @AfterEach    void tearDown() throws IOException {        client.close();    }}

如下图所示，打印除开的结果为String类型，可以优化为HotelDoc对象类型。
在这里插入图片描述
其对应的Java代码改进后如下，以下的步骤是根据上面网页端响应出来的结果由外到内逐层解析出来的，相关详细注释如下：

    @Test    void testMatchAll() throws IOException {        //准备request        SearchRequest request = new SearchRequest("hotel");        //准备DSL语句        request.source().query(QueryBuilders.matchAllQuery());        //发送请求        SearchResponse response = client.search(request, RequestOptions.DEFAULT);        //解析响应结果，对于网页端的hits,参考json解析结果由外到内逐层解析        SearchHits searchHits = response.getHits();        //获取命中的总条数        TotalHits total = searchHits.getTotalHits();        //打印搜索出多少条数据        System.out.println("共搜索出"+total+"条数据");        //搜索出的文档数组        SearchHit[] hits = searchHits.getHits();        //遍历文档数组        for (SearchHit hit : hits) {            //获取文档source            String json = hit.getSourceAsString();            //反序列为HotelDoc对象            HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);            //打印输出            System.out.println(hotelDoc);        }

执行上述代码所得结果如下，已反序列化为HotelDoc对象：
在这里插入图片描述

部分小结：

RestAPI其中构建DSL是通过RestHighLevelClient的source（）方法实现的，如同我们浏览器中json中写的方法，其包含很多功能，如排序，分页，高亮等：
在这里插入图片描述
RestAPI中构建查询条件的核心部分是由QueryBuilders工具类提供的，其中包含了很多种查询方法。

全文查询

全文检索查询的match和multi_match查询与match_all的API基本一致，主要就是query部分的查询条件不一致，例如：

//这里的all是整合了需要查询的组合字段，在建立索引库时候添加的request.source().query(QueryBuilders.matchQuery("all", "如家"));

除了此处不一致以外，其他代码均与上面一致
在这里插入图片描述

精确查询

精确查询常见的有term查询和range查询，可以使用QueryBuilders工具类来实现。
例如基于词条查询和范围查询的DSL语句如下：

# 词条查询GET /hotel/_search{  "query": {    "term": {      "city": "上海"    }  }}# 范围查询GET /hotel/_search{  "query": {    "range": {      "price": {        "gte": 100,        "lte": 200      }    }  }}

使用QueryBuilders工具类来实现的代码如下：

request.source().query(QueryBuilders.termQuery("city","上海"));

request.source().query(QueryBuilders.rangeQuery("price").gt(150).lt(200));

复合查询

例如使用term查询和range查询组合到一起来进行组合查询，在DSL中的语句为：

GET /hotel/_search{  "query": {    "bool": {      "must": [        {          "term": {            "city": {              "value": "上海"            }          }        }      ],      "filter": [        {          "range": {            "price": {              "gte": 150,              "lte": 200            }          }        }      ]    }  }}

将其转化为Java语言中的代码，如下：

//准备DSL语句BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();boolQuery.must(QueryBuilders.termQuery("city","上海"));boolQuery.filter(QueryBuilders.rangeQuery("price").gt(150).lt(200));request.source().query(boolQuery);

执行代码得到以下结果：
在这里插入图片描述

排序和分页

对搜索的结果进行排序和分页，是与query同级的参数，由以下的DSL语句可以看出：

GET /hotel/_search{  "query": {    "match_all": {}  },  "from": 0,  "size": 5  , "sort": [    {      "price": {        "order": "desc"      }    }  ]}

上面DSL对于的Java代码如下，query和sort等为同级结构：

//准备DSL语句request.source().query(QueryBuilders.matchAllQuery());request.source().from(0).size(5);//查询结果显示五条数据request.source().sort("price", SortOrder.ASC);//按照升序的顺序排列

执行结果如下：

在这里插入图片描述

高亮显示

高亮API包括请求DSL构建和结果解析两部分，DSL语句如下：

GET /hotel/_search{  "query": {    "match": {      "all": "如家"    }  },  "highlight": {    "fields": {      "name": {        "require_field_match": "false"      }    }  }}

网页端高亮显示结果如下图所示：
在这里插入图片描述

Java代码如下：

    @Test    void testHighLighter() throws IOException {        //准备request        SearchRequest request = new SearchRequest("hotel");        //准备DSL语句        request.source().query(QueryBuilders.matchQuery("name","如家"));        request.source().highlighter(new HighlightBuilder().field("name").requireFieldMatch(false));        //发送请求        SearchResponse response = client.search(request, RequestOptions.DEFAULT);        //解析响应结果，对于网页端的hits,参考json解析结果由外到内逐层解析        handleResponse(response);    }     private void handleResponse(SearchResponse response) {        //解析响应结果，对于网页端的hits,参考json解析结果由外到内逐层解析        SearchHits searchHits = response.getHits();        //获取命中的总条数        TotalHits total = searchHits.getTotalHits();        //打印搜索出多少条数据        System.out.println("共搜索出" + total + "条数据");        //搜索出的文档数组        SearchHit[] hits = searchHits.getHits();        //遍历文档数组        for (SearchHit hit : hits) {            //获取文档source            String json = hit.getSourceAsString();            //反序列为HotelDoc对象            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);        }    }