文章目录

• 前言
• • Elasticsearch - SpringBoot 查询 es
  • • 1. ES 整合
    • 2. 示例-简单匹配查询
    • 3. 示例-简单范围查询
    • 4. 示例-布尔查询-分页查询-match 查询
    • 5. 示例-布尔查询-分页查询-term查询

前言

  如果您觉得有用的话，记得给博主点个赞，评论，收藏一键三连啊，写作不易啊^ _ ^。
  而且听说点赞的人每天的运气都不会太差，实在白嫖的话，那欢迎常来啊!!!

Elasticsearch - SpringBoot 查询 es

1. ES 整合

yml:

es:   ip: 192.168.79.1   port: 9200   user: yzy   passWord: yzy 

pom:

                     org.elasticsearch             elasticsearch             7.6.2                               org.elasticsearch.client             elasticsearch-rest-high-level-client             7.6.2          

RestHighLevelClient 是 Elasticsearch 客户端，用于执行搜索、索引、删除等操作。

我们这次的demo都是基于RestHighLevelClient 来写的。

注入bean:

package org.example.config;  import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.apache.http.HttpHost; import org.elasticsearch.client.RequestOptions; import org.elasticsearch.client.RestClient; import org.elasticsearch.client.RestClientBuilder; import org.elasticsearch.client.RestHighLevelClient; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import cn.hutool.core.util.ObjectUtil; import sun.misc.BASE64Encoder;  /** * @description: TODO * @author 杨镇宇 * @date 2024/8/29 17:02 * @version 1.0 */ @Configuration @Slf4j public class EsConfig {      @Value("${es.ip}")     private String esIp;     @Value("${es.port}")     private String esPort;     @Value("${es.user}")     private String esUser;     @Value("${es.passWord}")     private String esPassWord;           @Bean     public RestHighLevelClient getHighLevelClient(){         RestHighLevelClient restHighLevelClient = null;         if (ObjectUtil.isNotEmpty(esIp) && ObjectUtil.isNotEmpty(esPort)){             RestClientBuilder builder = RestClient.builder(new HttpHost(esIp,Integer.parseInt(esPort),"http"));             restHighLevelClient = new RestHighLevelClient(builder);             log.info("Created RestHighLevelClient: {}", restHighLevelClient);          }         return restHighLevelClient;     }      @Bean     public RequestOptions getRequestOptions(){         RequestOptions.Builder builder = RequestOptions.DEFAULT.toBuilder();         return builder.build();     }  }  

2. 示例-简单匹配查询

GET /blog_new/_search {   "query": {     "match": {       "author": "糖炒栗子"     }   },   "size": 1000 } 

对应的java代码

    private final RestHighLevelClient client;     @Resource     private final RequestOptions requestOptions;     /**      * 匹配查询      * @return      */     @GetMapping("/api/find_a")     public void getA() {         try {             // 创建 SearchRequest 对象，指定索引名称             SearchRequest searchRequest = new SearchRequest("blog_new");              // 构建查询条件             SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();             searchSourceBuilder.query(QueryBuilders.matchQuery("author", "糖炒栗子"));             searchSourceBuilder.size(1000);  // 设置返回结果数量             // 将查询条件添加到 SearchRequest 对象中             searchRequest.source(searchSourceBuilder);              // 通过 esIndexUtils 工具类执行查询，假设你想使用默认的 ES 客户端             SearchResponse response = client.search(searchRequest, requestOptions).queryRequest(searchRequest, "default");              // 处理查询响应             if (response != null && response.getHits().getTotalHits().value > 0) {                 response.getHits().forEach(hit -> {                     log.info(hit.getSourceAsString()); // 打印每个文档的内容                 });             } else {                 log.info("No results found.");             }          }catch (Exception e){             log.error("错误",e);          }     } 

3. 示例-简单范围查询

GET /blog_new/_search {     "query": {     "range": {         "content": {             "gte": 100,              "lte": 120         }     } },     "size": 1000 }  

对应的java代码:

    private final RestHighLevelClient client;     @Resource     private final RequestOptions requestOptions;  @GetMapping("/api/find_b")     public void getB() {         try {             // 创建 SearchRequest 对象，指定索引名称             SearchRequest searchRequest = new SearchRequest("blog_new");              // 构建查询条件             SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();             searchSourceBuilder.query(QueryBuilders.rangeQuery("content").gte(100).lte(120));             searchSourceBuilder.size(1000);             // 将查询条件添加到 SearchRequest 对象中             searchRequest.source(searchSourceBuilder);              // 通过 esIndexUtils 工具类执行查询，假设你想使用默认的 ES 客户端             SearchResponse response = client.search(searchRequest, requestOptions).queryRequest(searchRequest, "default");              // 处理查询响应             if (response != null && response.getHits().getTotalHits().value > 0) {                 response.getHits().forEach(hit -> {                     log.info(hit.getSourceAsString()); // 打印每个文档的内容                 });             } else {                 log.info("No results found.");             }          }catch (Exception e){             log.error("错误",e);          }     } 

4. 示例-布尔查询-分页查询-match 查询

match 查询：用于全文检索。match 查询会对搜索词进行分析（如分词、标准化），并与文档中经过分析的字段内容进行匹配。

分页查询:
如果您想要获取第一页的结果，每页返回10个文档，您可以将"from"设置为0，
"size"设置为10。如果想获取第二页的结果，您可以将"from"设置为10，"size"设置为10，以此类推。

GET /blog_new/_search {   "query": {     "bool": {       "must": [         { "match": { "title": "jstat命令查看jvm的GC信息2"  }},         { "range": { "publish_date": { "gte": "2022-01-01" }}}       ],       "must_not": [         { "range": { "content": { "gte": "300" }}}       ],       "should": [         { "match": { "author": "yangzhenyu" }}       ],       "minimum_should_match": 1     }   },   "from":0,   "size": 1000 } 

含义:

must: 查询条件必须满足：  title字段必须包含“jstat命令查看jvm的GC信息2”。 publish_date字段的日期必须在2022年1月1日或之后。 must_not: 查询条件不能满足：  content字段的值不能大于等于300。 should: 满足以下条件将提高文档的相关性：  author字段如果包含“yangzhenyu”。 minimum_should_match: 至少需要满足一个should条件。  from: 从结果的第0条开始返回。  size: 返回的文档数量限制为1000条。 

对应的java代码:

    private final RestHighLevelClient client;     @Resource     private final RequestOptions requestOptions;    @GetMapping("/api/find_c")     public void getC() {         try {             // 创建 SearchRequest 对象，指定索引名称             SearchRequest searchRequest = new SearchRequest("blog_new");              // 构建查询条件             BoolQueryBuilder boolQuery = QueryBuilders.boolQuery()                     .must(QueryBuilders.matchQuery("title", "jstat命令查看jvm的GC信息2"))                     .must(QueryBuilders.rangeQuery("publish_date").gte("2022-01-01"))                     .mustNot(QueryBuilders.rangeQuery("content").gte(300))                     .should(QueryBuilders.matchQuery("author", "yangzhenyu"))                     .minimumShouldMatch(1);              // 构建 SearchSourceBuilder             SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();             searchSourceBuilder.query(boolQuery);             searchSourceBuilder.from(0);             searchSourceBuilder.size(1000);             searchRequest.source(searchSourceBuilder);              // 通过 esIndexUtils 工具类执行查询，假设你想使用默认的 ES 客户端             SearchResponse response = client.search(searchRequest, requestOptions).queryRequest(searchRequest, "default");              // 处理查询响应             if (response != null && response.getHits().getTotalHits().value > 0) {                 response.getHits().forEach(hit -> {                     log.info(hit.getSourceAsString()); // 打印每个文档的内容                 });             } else {                 log.info("No results found.");             }          }catch (Exception e){             log.error("错误",e);          }     } 

5. 示例-布尔查询-分页查询-term查询

term 精确匹配：term 查询用于精确匹配字段的内容，不进行分词。它适用于关键词或精确值的匹配，比如数值、日期、布尔值或者不需要分词的字符串（如ID、邮政编码）。
用途：用于精确匹配。在搜索时，term 查询会查找完全与提供的值匹配的文档。通常用于 keyword 类型的字段或者数值字段。

分页查询:
如果您想要获取第一页的结果，每页返回10个文档，您可以将"from"设置为0，"size"设置为10。如果想获取第二页的结果，您可以将"from"设置为10，"size"设置为10，以此类推。

GET /blog_new/_search {    "query": {      "bool": {        "must": [          { "term": { "title.keyword": "jstat命令查看jvm的GC信息2" }},          { "range": { "publish_date": { "gte": "2022-01-01" }}}        ],        "must_not": [          { "range": { "content": { "gte": 300 }}}        ],        "should": [          { "term": { "author.keyword": "yangzhenyu" }}        ],        "minimum_should_match": 1      }    },    "from": 0,    "size": 1000  }  

含义:

 must: 查询条件必须满足：   title字段必须包含“jstat命令查看jvm的GC信息2”。  publish_date字段的日期必须在2022年1月1日或之后。  must_not: 查询条件不能满足：   content字段的值不能大于等于300。  should: 满足以下条件将提高文档的相关性：   author字段如果包含“yangzhenyu”。  minimum_should_match: 至少需要满足一个should条件。   from: 从结果的第0条开始返回。   size: 返回的文档数量限制为1000条。 

对应的java代码:

    @Resource     private final RestHighLevelClient client;     @Resource     private final RequestOptions requestOptions;     @GetMapping("/api/find_d")     public void getD() {         try {             // 创建 SearchRequest 对象，指定索引名称             SearchRequest searchRequest = new SearchRequest("blog_new");              // 构建查询条件             BoolQueryBuilder boolQuery = QueryBuilders.boolQuery()                     .must(QueryBuilders.termQuery("title.keyword", "jstat命令查看jvm的GC信息2"))                     .must(QueryBuilders.rangeQuery("publish_date").gte("2022-01-01"))                     .mustNot(QueryBuilders.rangeQuery("content").gte(300))                     .should(QueryBuilders.termQuery("author.keyword", "yangzhenyu"))                     .minimumShouldMatch(1);              // 构建 SearchSourceBuilder             SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();             searchSourceBuilder.query(boolQuery);             searchSourceBuilder.from(0);             searchSourceBuilder.size(1000);             searchRequest.source(searchSourceBuilder);              // 通过 esIndexUtils 工具类执行查询，假设你想使用默认的 ES 客户端             SearchResponse response = client.search(searchRequest, requestOptions).queryRequest(searchRequest, "default");              // 处理查询响应             if (response != null && response.getHits().getTotalHits().value > 0) {                 response.getHits().forEach(hit -> {                     log.info(hit.getSourceAsString()); // 打印每个文档的内容                 });             } else {                 log.info("No results found.");             }          }catch (Exception e){             log.error("错误",e);          }     }