上一节讲述了 SpringBoot 实现 elasticsearch 索引操作,这一章节讲述 SpringBoot 实现 elasticsearch 查询操作。

1. 环境准备

案例用到的索引库结构

PUT /hotel
{"mappings": {"properties": {"id": {"type": "keyword"},"name":{"type": "text","analyzer": "ik_max_word","copy_to": "all"},"address":{"type": "keyword","index": false},"price":{"type": "integer"},"score":{"type": "integer"},"brand":{"type": "keyword","copy_to": "all"},"city":{"type": "keyword","copy_to": "all"},"starName":{"type": "keyword"},"business":{"type": "keyword"},"location":{"type": "geo_point"},"pic":{"type": "keyword","index": false},"all":{"type": "text","analyzer": "ik_max_word"}}}
}

1. 查询全部

@GetMapping("/searchAll")
public List<HotelDoc> searchAll() throws Exception {//1.创建请求语义对象SearchRequest searchRequest = new SearchRequest("索引名称");// QueryBuilders: 构建查询类型searchRequest.source().query(QueryBuilders.matchAllQuery());SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);return handleResponse(searchResponse);
}

2. 根据 name 查询 match 分词查询

 @GetMapping("/searchByName/{name}")
public List<HotelDoc> searchByName(@PathVariable("name") String name) throws Exception {//1.创建请求语义对象SearchRequest searchRequest = new SearchRequest("索引名称");// QueryBuilders: 构建查询类型searchRequest.source().query(QueryBuilders.matchQuery("name", name));SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);return handleResponse(searchResponse);
}

3. 根据 name 和 品牌查询 multiMatch 分词查询

@GetMapping("/searchByNameAndBrand/{name}")
public List<HotelDoc> searchByNameAndBrand(@PathVariable("name") String name) throws Exception {//1.创建请求语义对象SearchRequest searchRequest = new SearchRequest("索引名称");// QueryBuilders: 构建查询类型searchRequest.source().query(QueryBuilders.multiMatchQuery(name,"name","brand"));SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);return handleResponse(searchResponse);
}

4. 根据 brand 查询 match 分词查询

@GetMapping("/searchByBrand/{name}")
public List<HotelDoc> searchByBrand(@PathVariable("name") String name) throws Exception {//1.创建请求语义对象SearchRequest searchRequest = new SearchRequest("索引名称");// QueryBuilders: 构建查询类型searchRequest.source().query(QueryBuilders.matchQuery("brand", name));SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);return handleResponse(searchResponse);
}

5. 按照价格 范围查询

 @GetMapping("/searchByPrice/{low}/{high}")
public List<HotelDoc> searchByPrice(@PathVariable("low") String low, @PathVariable("high") String high) throws Exception {//1.创建请求语义对象SearchRequest searchRequest = new SearchRequest("索引名称");// QueryBuilders: 构建查询类型searchRequest.source().query(QueryBuilders.rangeQuery("price").gte(low).lte(high));SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);return handleResponse(searchResponse);
}

6. 精确查询

@GetMapping("/termQueryCity/{city}")
public List<HotelDoc> termQueryCity(@PathVariable("city") String city) throws Exception {//1.创建请求语义对象SearchRequest searchRequest = new SearchRequest("索引名称");// QueryBuilders: 构建查询类型SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();//searchSourceBuilder.query(QueryBuilders.termQuery("city", city)); 这行有点小问题//	https://zhuanlan.zhihu.com/p/270426807 参考searchSourceBuilder.query(QueryBuilders.termQuery("city.keyword", city));searchRequest.source(searchSourceBuilder);SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);return handleResponse(searchResponse);
}

7. boolQuery

@GetMapping("/testBool")
public List<HotelDoc> testBool() throws Exception {// 1.准备RequestSearchRequest request = new SearchRequest("索引名称");// 2.准备DSL// 2.1.准备BooleanQueryBoolQueryBuilder boolQuery = QueryBuilders.boolQuery();// 2.2.添加termboolQuery.must(QueryBuilders.termQuery("city.keyword", "杭州"));// 2.3.添加rangeboolQuery.filter(QueryBuilders.rangeQuery("price").lte(250));request.source().query(boolQuery);// 3.发送请求SearchResponse response = client.search(request, RequestOptions.DEFAULT);// 4.解析响应return handleResponse(response);
}

8. 分页

 @GetMapping("/testPageAndSort/{currentPage}/{pageSize}")
public List<HotelDoc> testPageAndSort(@PathVariable("currentPage") Integer currentPage, @PathVariable("pageSize") Integer pageSize) throws Exception {// 页码，每页大小// 1.准备RequestSearchRequest request = new SearchRequest("索引名称");// 2.准备DSL// 2.1.queryrequest.source().query(QueryBuilders.matchAllQuery());// 2.2.排序 sortrequest.source().sort("price", SortOrder.ASC);// 2.3.分页 from、sizerequest.source().from((currentPage - 1) * pageSize).size(pageSize);// 3.发送请求SearchResponse response = client.search(request, RequestOptions.DEFAULT);// 4.解析响应return handleResponse(response);
}

9. 高亮查询

 @GetMapping("/testHighlight/{name}")
void testHighlight(@PathVariable("name") String name) throws Exception {// 1.准备RequestSearchRequest request = new SearchRequest("索引名称");// 2.准备DSL// 2.1.queryrequest.source().query(QueryBuilders.matchQuery("name", name));// 2.2.高亮request.source().highlighter(new HighlightBuilder().field("name").requireFieldMatch(false));// 3.发送请求SearchResponse response = client.search(request, RequestOptions.DEFAULT);// 4.解析响应handleResponse2(response);
}

9. 公共解析

private List<HotelDoc> handleResponse(SearchResponse response) throws Exception {// 获取命中的所有内容SearchHits searchHits = response.getHits();// 获取命中的总条数long count = searchHits.getTotalHits().value;System.out.println("命中的条数为: "+ count);// 获取命中的文档对象数组SearchHit[] hits = searchHits.getHits();List<HotelDoc> docList = new ArrayList<>();for (SearchHit hit : hits) {// 解析每一个hit对象得到对应的文档数据String json = hit.getSourceAsString();//  HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);docList.add(JSON.parseObject(json, HotelDoc.class));}//destroy();return docList;
}private void handleResponse2(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) {// 获取文档sourceString 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);}
}