devbox
笔触狂放9
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

通过java代码实现ES中的常用搜索_java es搜索引擎

作者：笔触狂放9 | 2024-02-08 10:15:50

赞

踩

java es搜索引擎

目录

测试环境准备

在指定索引下搜索全部（可以指定字段）

通过ids进行搜索

对搜索结果进行分页

match分词搜索

不分词模糊搜索：wildcardQuery与matchPhraseQuery

term 搜索（精确匹配）

multi_match搜索

bool搜索 多条件匹配

filter过滤搜索

sort排序搜索

后续待补充：queryStringQuery，minimumShouldMatch，对检索结果中的关键词进行高亮

测试环境准备

测试环境：

  1. <dependency>
  2.     <groupId>org.springframework.boot</groupId>
  3.     <artifactId>spring-boot-starter</artifactId>
  4.     <version>2.0.6.RELEASE</version>
  5. </dependency>
  6. <dependency>
  7.     <groupId>org.springframework.boot</groupId>
  8.     <artifactId>spring-boot-starter-test</artifactId>
  9.     <scope>test</scope>
  10.     <version>2.0.6.RELEASE</version>
  11. </dependency>
  12. <dependency>
  13.     <groupId>org.elasticsearch.client</groupId>
  14.     <artifactId>elasticsearch-rest-high-level-client</artifactId>
  15.     <version>7.3.0</version>
  16.     <exclusions>
  17.         <exclusion>
  18.             <groupId>org.elasticsearch</groupId>
  19.             <artifactId>elasticsearch</artifactId>
  20.         </exclusion>
  21.     </exclusions>
  22. </dependency>
  23. <dependency>
  24.     <groupId>org.elasticsearch</groupId>
  25.     <artifactId>elasticsearch</artifactId>
  26.     <version>7.3.0</version>
  27. </dependency>

2配置 application.yml

  1. spring:
  2.   application:
  3.     name: service-search
  4. eslearn:
  5.   elasticsearch:
  6.     hostlist: 127.0.0.1:9200 #多个结点中间用逗号分隔

 3主类代码

  1. @SpringBootApplication
  2. public class SearchApplication {
  3.     public static void main(String[] args) {
  4.         SpringApplication.run(SearchApplication.class,args);
  5.     }
  6. }

配置类：

  1. package com.learn.es.cofig;
  2.  
  3. import org.apache.http.HttpHost;
  4. import org.elasticsearch.client.RestClient;
  5. import org.elasticsearch.client.RestHighLevelClient;
  6. import org.springframework.beans.factory.annotation.Value;
  7. import org.springframework.context.annotation.Bean;
  8. import org.springframework.context.annotation.Configuration;
  9.  
  10. /**
  11.  * @author LJM
  12.  * @create 2022/12/10
  13.  */
  14. @Configuration
  15. public class ElasticSearchConfig {
  16.     
  17.     @Value("${eslearn.elasticsearch.hostlist}")
  18.     private String hostList;
  19.     
  20.     @Bean(destroyMethod = "close") //表示连接使用完成后需要关闭
  21.     public RestHighLevelClient restHighLevelClient(){
  22.         String[] split = hostList.split(",");
  23.         //这种写法是考虑到可能会配置多个es节点
  24.         HttpHost[] httpHosts = new HttpHost[split.length];
  25.         for (int i = 0; i < split.length; i++) {
  26.             String item = split[i];
  27.             httpHosts[i] = new HttpHost(item.split(":")[0],Integer.parseInt(item.split(":")[1]),"http");
  28.         }
  29.  
  30.         return new RestHighLevelClient(RestClient.builder(httpHosts));
  31.     }
  32.     
  33. }

测试项目结构：

 在kibana中把数据插入es中：

  1. delete book   //先删除索引
  2.  
  3. PUT /book    //往索引中插入数据进行测试,后面在api实现搜索的小节,可以使用从数据库中读取数据 然后把数据插入es库指定的索引
  4.  
  5. PUT /book/_doc/1
  6. {
  7. "name": "Bootstrap开发",
  8. "description": "Bootstrap是由Twitter推出的一个前台页面开发css框架，是一个非常流行的开发框架，此框架集成了多种页面效果。此开发框架包含了大量的CSS、JS程序代码，可以帮助开发者（尤其是不擅长css页面开发的程序人员）轻松的实现一个css，不受浏览器限制的精美界面css效果。",
  9. "studymodel": "201002",
  10. "price":38.6,
  11. "timestamp":"2019-08-25 19:11:35",
  12. "pic":"group1/M00/00/00/wKhlQFs6RCeAY0pHAAJx5ZjNDEM428.jpg",
  13. "tags": [ "bootstrap", "dev"]
  14. }
  15.  
  16.  
  17. PUT /book/_doc/2
  18. {
  19. "name": "java编程思想",
  20. "description": "java语言是世界第一编程语言，在软件开发领域使用人数最多。",
  21. "studymodel": "201001",
  22. "price":68.6,
  23. "timestamp":"2019-08-25 19:11:35",
  24. "pic":"group1/M00/00/00/wKhlQFs6RCeAY0pHAAJx5ZjNDEM428.jpg",
  25. "tags": [ "java", "dev"]
  26. }
  27.  
  28.  
  29.  
  30.  
  31. PUT /book/_doc/3
  32. {
  33. "name": "spring开发基础",
  34. "description": "spring 在java领域非常流行，java程序员都在用。",
  35. "studymodel": "201001",
  36. "price":88.6,
  37. "timestamp":"2019-08-24 19:11:35",
  38. "pic":"group1/M00/00/00/wKhlQFs6RCeAY0pHAAJx5ZjNDEM428.jpg",
  39. "tags": [ "spring", "java"]
  40. }

测试类代码结构： 

  1. /**
  2.  * @author LJM
  3.  * @create 2022/12/13
  4.  * 测试使用java代码实现es的各种搜索
  5.  */
  6. @SpringBootTest(classes = SearchApplication.class)
  7. @RunWith(SpringRunner.class)
  8. public class TestSearch {
  9.     @Autowired
  10.     RestHighLevelClient client;
  11.  
  12. // 后面的测试方法会全部写在这个类中 .....
  13.  
  14. }

在指定索引下搜索全部（可以指定字段）

在kibana中 GET /book/_search 先获取一下本地es库中的book索引下有多少数据。

  1. /**
  2.      *     搜索全部
  3.      *       GET book/_search
  4.      *       {
  5.      *         "query": {
  6.      *          "match_all": {}
  7.      *          }
  8.      *       }
  9.      * @throws IOException
  10.      */
  11.     @Test
  12.     public void testSearchAll() throws IOException {
  13.  
  14.         //1构建搜索请求  实际生产环境中这个索引名称的获取:①把这个索引名称写在枚举类中,然后从枚举类中获取②从配置文件中获取
  15.         SearchRequest searchRequest = new SearchRequest("book");
  16.  
  17.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  18.         searchSourceBuilder.query(QueryBuilders.matchAllQuery());
  19.  
  20.         //获取某些字段
  21.         searchSourceBuilder.fetchSource(new String[]{"name"}, new String[]{});
  22.  
  23.         searchRequest.source(searchSourceBuilder);
  24.  
  25.         //2执行搜索
  26.         SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
  27.  
  28.         //3获取结果
  29.         SearchHits hits = searchResponse.getHits();
  30.  
  31.         //数据数据
  32.         SearchHit[] searchHits = hits.getHits();
  33.         System.out.println("--------------------------");
  34.         for (SearchHit hit : searchHits) {
  35.             String id = hit.getId();
  36.             float score = hit.getScore();
  37.             //这个source里面就是我们存储的数据
  38.             Map<String, Object> sourceAsMap = hit.getSourceAsMap();
  39.             String name = (String) sourceAsMap.get("name");
  40.             String description = (String) sourceAsMap.get("description");
  41.             Double price = (Double) sourceAsMap.get("price");
  42.             System.out.println("id:" + id);
  43.             System.out.println("score:" + score);
  44.             System.out.println("name:" + name);
  45.             System.out.println("description:" + description);
  46.             System.out.println("price:" + price);
  47.             System.out.println("==========================");
  48.  
  49.         }
  50.     }

通过ids进行搜索

  1.  /**
  2.      * 通过ids进行搜索  有的就查询出来,没有的也不会报错
  3.      *     GET /book/_search
  4.      *     {
  5.      *         "query": {
  6.      *            "ids" : {
  7.      *              "values" : ["1", "2", "6"]
  8.      *              }
  9.      *         }
  10.      *     }
  11.      * @throws IOException
  12.      */
  13.     @Test
  14.     public void testSearchIds() throws IOException {
  15.  
  16.         //1构建搜索请求
  17.         SearchRequest searchRequest = new SearchRequest("book");
  18.  
  19.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  20.         searchSourceBuilder.query(QueryBuilders.idsQuery().addIds("1","2","6"));
  21.  
  22.         searchRequest.source(searchSourceBuilder);
  23.  
  24.         //2执行搜索
  25.         SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
  26.  
  27.         //3获取结果
  28.         SearchHits hits = searchResponse.getHits();
  29.  
  30.         //数据数据
  31.         SearchHit[] searchHits = hits.getHits();
  32.         System.out.println("--------------------------");
  33.         for (SearchHit hit : searchHits) {
  34.             String id = hit.getId();
  35.             float score = hit.getScore();
  36.             //这个source里面就是我们存储的数据
  37.             Map<String, Object> sourceAsMap = hit.getSourceAsMap();
  38.             String name = (String) sourceAsMap.get("name");
  39.             String description = (String) sourceAsMap.get("description");
  40.             Double price = (Double) sourceAsMap.get("price");
  41.             System.out.println("id:" + id);
  42.             System.out.println("name:" + name);
  43.             System.out.println("description:" + description);
  44.             System.out.println("price:" + price);
  45.             System.out.println("==========================");
  46.  
  47.         }
  48.     }

对搜索结果进行分页

  1.     /**
  2.      *     对搜索结果进行分页
  3.      *         GET book/_search
  4.      *         {
  5.      *             "query": {
  6.      *               "match_all": {}
  7.      *            },
  8.      *             "from": 0,
  9.      *             "size": 2
  10.      *         }
  11.      */
  12.     @Test
  13.     public void testSearchPage() throws IOException {
  14.         //1构建搜索请求
  15.         SearchRequest searchRequest = new SearchRequest("book");
  16.  
  17.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  18.         searchSourceBuilder.query(QueryBuilders.matchAllQuery());
  19.  
  20.         //搜索第几页的数据
  21.         int page=1;
  22.         //每页展示几个数据
  23.         //int size=2;  //因为本地es一共就插入了三条数据进行测试,所以可以把大小分别设置为2和3看一下输出效果
  24.         int size=3;
  25.         //下标计算
  26.         int from = (page-1) / size;
  27.  
  28.         searchSourceBuilder.from(from);
  29.         searchSourceBuilder.size(size);
  30.  
  31.         searchRequest.source(searchSourceBuilder);
  32.  
  33.         //2执行搜索
  34.         SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
  35.  
  36.         //3获取结果
  37.         SearchHits hits = searchResponse.getHits();
  38.  
  39.         //数据数据
  40.         SearchHit[] searchHits = hits.getHits();
  41.         System.out.println("--------------------------");
  42.         for (SearchHit hit : searchHits) {
  43.             String id = hit.getId();
  44.             float score = hit.getScore();
  45.             //这个source里面就是我们存储的数据
  46.             Map<String, Object> sourceAsMap = hit.getSourceAsMap();
  47.             String name = (String) sourceAsMap.get("name");
  48.             String description = (String) sourceAsMap.get("description");
  49.             Double price = (Double) sourceAsMap.get("price");
  50.             System.out.println("id:" + id);
  51.             System.out.println("name:" + name);
  52.             System.out.println("description:" + description);
  53.             System.out.println("price:" + price);
  54.             System.out.println("==========================");
  55.  
  56.         }
  57.     }

match分词搜索

  1.  /**
  2.      * match搜索  这个是会进行分词搜索的
  3.      *     GET /book/_search
  4.      *     {
  5.      *         "query": {
  6.      *            "match": {
  7.      *             "description": "java程序员"
  8.      *         }
  9.      *       }
  10.      *     }
  11.      * @throws IOException
  12.      */
  13.     @Test
  14.     public void testSearchMatch() throws IOException {
  15.         //1构建搜索请求
  16.         SearchRequest searchRequest = new SearchRequest("book");
  17.  
  18.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  19.         searchSourceBuilder.query(QueryBuilders.matchQuery("description", "java程序员"));
  20.  
  21.  
  22.         searchRequest.source(searchSourceBuilder);
  23.  
  24.         //2执行搜索
  25.         SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
  26.  
  27.         //3获取结果
  28.         SearchHits hits = searchResponse.getHits();
  29.  
  30.         //数据数据
  31.         SearchHit[] searchHits = hits.getHits();
  32.         System.out.println("--------------------------");
  33.         for (SearchHit hit : searchHits) {
  34.             String id = hit.getId();
  35.             float score = hit.getScore();
  36.             //这个source里面就是我们存储的数据
  37.             Map<String, Object> sourceAsMap = hit.getSourceAsMap();
  38.             String name = (String) sourceAsMap.get("name");
  39.             String description = (String) sourceAsMap.get("description");
  40.             Double price = (Double) sourceAsMap.get("price");
  41.             System.out.println("id:" + id);
  42.             System.out.println("name:" + name);
  43.             System.out.println("description:" + description);
  44.             System.out.println("price:" + price);
  45.             System.out.println("==========================");
  46.  
  47.         }
  48.     }

不分词模糊搜索：wildcardQuery与matchPhraseQuery

  1.     /**
  2.      * 不分词模糊搜索   like '%检索词%'
  3.      * @throws IOException
  4.      */
  5.     @Test
  6.     public void testSearchLike() throws IOException {
  7.         //1构建搜索请求
  8.         SearchRequest searchRequest = new SearchRequest("book");
  9.  
  10.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  11.         //使用matchPhraseQuery 需要对检索的关键词的前后加 * 否则不是完全的模糊匹配  可以对检索的结果中的检索关键词进行高亮
  12.         searchSourceBuilder.query(QueryBuilders.matchPhraseQuery("description", "*"+"程序员"+"*"));
  13.  
  14.         //还可以使用wildcardQuery 但是这种就会导致检索的结果不能高亮(这个不太确定,但是我自己试的时候,这样确实是不能对检索结果中的检索词进行高亮)
  15.         //需要在检索的字段名后拼接 ".keyword"  并且也需要对检索词前后添加 *
  16. //        searchSourceBuilder.query(QueryBuilders.wildcardQuery("description"+".keyword","*"+"程序员"+"*"));
  17.  
  18.  
  19.  
  20.         searchRequest.source(searchSourceBuilder);
  21.  
  22.         //2执行搜索
  23.         SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
  24.  
  25.         //3获取结果
  26.         SearchHits hits = searchResponse.getHits();
  27.  
  28.         //数据数据
  29.         SearchHit[] searchHits = hits.getHits();
  30.         System.out.println("--------------------------");
  31.         for (SearchHit hit : searchHits) {
  32.             String id = hit.getId();
  33.             float score = hit.getScore();
  34.             //这个source里面就是我们存储的数据
  35.             Map<String, Object> sourceAsMap = hit.getSourceAsMap();
  36.             String name = (String) sourceAsMap.get("name");
  37.             String description = (String) sourceAsMap.get("description");
  38.             Double price = (Double) sourceAsMap.get("price");
  39.             System.out.println("id:" + id);
  40.             System.out.println("name:" + name);
  41.             System.out.println("description:" + description);
  42.             System.out.println("price:" + price);
  43.             System.out.println("==========================");
  44.  
  45.         }
  46.     }

term 搜索（精确匹配）

  1.  /**
  2.      * term 搜索  如果字段为keyword那么【存储】和【搜索】都不分词。 搜索的时候相当于在使用 = 符号进行搜索
  3.      *        GET / book / _search
  4.      *         {
  5.      *             "query":{
  6.      *                 "term":{
  7.      *                     "description":"java程序员"
  8.      *                 }
  9.      *             }
  10.      *         }
  11.      * @throws IOException
  12.      */
  13.     @Test
  14.     public void testSearchTerm() throws IOException {
  15.  
  16.         //1构建搜索请求
  17.         SearchRequest searchRequest = new SearchRequest("book");
  18.  
  19.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  20.         //如果字段的映射是text但是也想要精确匹配,可以这样操作：QueryBuilders.termQuery("description" + ".keyword","java程序员")
  21.         searchSourceBuilder.query(QueryBuilders.termQuery("description", "java语言"));
  22.  
  23.         searchRequest.source(searchSourceBuilder);
  24.  
  25.         //2执行搜索
  26.         SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
  27.  
  28.         //3获取结果
  29.         SearchHits hits = searchResponse.getHits();
  30.  
  31.         //数据数据
  32.         SearchHit[] searchHits = hits.getHits();
  33.         System.out.println("--------------------------");
  34.         for (SearchHit hit : searchHits) {
  35.             String id = hit.getId();
  36.             float score = hit.getScore();
  37.             //这个source里面就是我们存储的数据
  38.             Map<String, Object> sourceAsMap = hit.getSourceAsMap();
  39.             String name = (String) sourceAsMap.get("name");
  40.             String description = (String) sourceAsMap.get("description");
  41.             Double price = (Double) sourceAsMap.get("price");
  42.             System.out.println("id:" + id);
  43.             System.out.println("name:" + name);
  44.             System.out.println("description:" + description);
  45.             System.out.println("price:" + price);
  46.             System.out.println("==========================");
  47.  
  48.         }
  49.     }

multi_match搜索

  1.     /**
  2.      * multi_match搜索
  3.      *     GET /book/_search
  4.      *     {
  5.      *         "query": {
  6.      *           "multi_match": {
  7.      *             "query": "java程序员",
  8.      *             "fields": ["name", "description"]
  9.      *         }
  10.      *       }
  11.      *     }
  12.      * @throws IOException
  13.      */
  14.     @Test
  15.     public void testSearchMultiMatch() throws IOException {
  16.  
  17.         //1构建搜索请求
  18.         SearchRequest searchRequest = new SearchRequest("book");
  19.  
  20.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  21.         //第二个参数才是 字段  第一个参数是匹配的内容
  22.         searchSourceBuilder.query(QueryBuilders.multiMatchQuery("java程序员","name","description"));
  23.  
  24.         searchRequest.source(searchSourceBuilder);
  25.  
  26.         //2执行搜索
  27.         SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
  28.  
  29.         //3获取结果
  30.         SearchHits hits = searchResponse.getHits();
  31.  
  32.         //数据数据
  33.         SearchHit[] searchHits = hits.getHits();
  34.         System.out.println("--------------------------");
  35.         for (SearchHit hit : searchHits) {
  36.             String id = hit.getId();
  37.             float score = hit.getScore();
  38.             //这个source里面就是我们存储的数据
  39.             Map<String, Object> sourceAsMap = hit.getSourceAsMap();
  40.             String name = (String) sourceAsMap.get("name");
  41.             String description = (String) sourceAsMap.get("description");
  42.             Double price = (Double) sourceAsMap.get("price");
  43.             System.out.println("id:" + id);
  44.             System.out.println("name:" + name);
  45.             System.out.println("description:" + description);
  46.             System.out.println("price:" + price);
  47.             System.out.println("==========================");
  48.  
  49.         }
  50.     }

bool搜索 多条件匹配

  1.     /**
  2.      * bool搜索 多条件匹配  and or !=
  3.      *         GET / book / _search
  4.      *         {
  5.      *          "query":{
  6.      *             "bool":{
  7.      *                 "must": [
  8.      *                 {
  9.      *                     "multi_match":{
  10.      *                     "query":"java程序员",
  11.      *                             "fields": ["name", "description"]
  12.      *                     }
  13.      *                 }
  14.      *                 ],
  15.      *                 "should": [
  16.      *                     {
  17.      *                         "match":{
  18.      *                         "studymodel":"201001"
  19.      *                     }
  20.      *                 }
  21.      *                 ]
  22.      *             }
  23.      *         }
  24.      *       }
  25.      * @throws IOException
  26.      */
  27.     @Test
  28.     public void testSearchBool() throws IOException {
  29.  
  30.         //1构建搜索请求
  31.         SearchRequest searchRequest = new SearchRequest("book");
  32.  
  33.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  34.  
  35.         //构建multiMatch请求 第一个参数是检索内容 第二个参数是检索的字段
  36.         MultiMatchQueryBuilder multiMatchQueryBuilder = QueryBuilders.multiMatchQuery("java程序员", "name", "description");
  37.         //构建match请求
  38.         MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchQuery("name", "测试没有的字段");
  39.  
  40.         BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
  41.         boolQueryBuilder.must(multiMatchQueryBuilder);
  42.         boolQueryBuilder.should(matchQueryBuilder);
  43.         //        boolQueryBuilder.must(matchQueryBuilder); //把should改成must就相当于用 and进行了再一次的过滤 就会查询不到数据
  44.  
  45.         searchSourceBuilder.query(boolQueryBuilder);
  46.         searchRequest.source(searchSourceBuilder);
  47.  
  48.         //2执行搜索
  49.         SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
  50.  
  51.         //3获取结果
  52.         SearchHits hits = searchResponse.getHits();
  53.  
  54.         //数据数据
  55.         SearchHit[] searchHits = hits.getHits();
  56.         System.out.println("--------------------------");
  57.         for (SearchHit hit : searchHits) {
  58.             String id = hit.getId();
  59.             float score = hit.getScore();
  60.             //这个source里面就是我们存储的数据
  61.             Map<String, Object> sourceAsMap = hit.getSourceAsMap();
  62.             String name = (String) sourceAsMap.get("name");
  63.             String description = (String) sourceAsMap.get("description");
  64.             Double price = (Double) sourceAsMap.get("price");
  65.             System.out.println("id:" + id);
  66.             System.out.println("name:" + name);
  67.             System.out.println("description:" + description);
  68.             System.out.println("price:" + price);
  69.             System.out.println("==========================");
  70.  
  71.         }
  72.     }
  73.  
  74. }

filter过滤搜索

过滤搜索和范围搜索的区别：

filter，仅仅只是按照搜索条件过滤出需要的数据而已，不计算任何相关度分数，对相关度没有任何影响。

query，会去计算每个document相对于搜索条件的相关度，并按照相关度进行排序。

  1.     /**
  2.      * filter过滤搜索
  3.      *     GET /book/_search
  4.      *     {
  5.      *         "query": {
  6.      *           "bool": {
  7.      *             "must": [
  8.      *             {
  9.      *                 "multi_match": {
  10.      *                 "query": "java程序员",
  11.      *                         "fields": ["name","description"]
  12.      *                                      }
  13.      *             }
  14.      *       ],
  15.      *             "should": [
  16.      *             {
  17.      *                 "match": {
  18.      *                 "studymodel": "201001"
  19.      *             }
  20.      *             }
  21.      *           ],
  22.      *             "filter": {
  23.      *                 "range": {
  24.      *                     "price": {
  25.      *                         "gte": 50,
  26.      *                          "lte": 90
  27.      *                     }
  28.      *                 }
  29.      *
  30.      *             }
  31.      *         }
  32.      *     }
  33.      *  }
  34.      * @throws IOException
  35.      */
  36.     @Test
  37.     public void testSearchFilter() throws IOException {
  38.  
  39.         //1构建搜索请求
  40.         SearchRequest searchRequest = new SearchRequest("book");
  41.  
  42.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  43.  
  44.         //构建multiMatch请求
  45.         MultiMatchQueryBuilder multiMatchQueryBuilder = QueryBuilders.multiMatchQuery("java程序员", "name", "description");
  46.         //构建match请求
  47.         MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchQuery("studymodel", "201001");
  48.  
  49.         BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
  50.         boolQueryBuilder.must(multiMatchQueryBuilder);
  51.         boolQueryBuilder.should(matchQueryBuilder);
  52.  
  53.         boolQueryBuilder.filter(QueryBuilders.rangeQuery("price").gte(50).lte(90));
  54.  
  55.         searchSourceBuilder.query(boolQueryBuilder);
  56.  
  57.         searchRequest.source(searchSourceBuilder);
  58.  
  59.         //2执行搜索
  60.         SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
  61.  
  62.         //3获取结果
  63.         SearchHits hits = searchResponse.getHits();
  64.  
  65.         //数据数据
  66.         SearchHit[] searchHits = hits.getHits();
  67.         System.out.println("--------------------------");
  68.         for (SearchHit hit : searchHits) {
  69.             String id = hit.getId();
  70.             float score = hit.getScore();
  71.             //这个source里面就是我们存储的数据
  72.             Map<String, Object> sourceAsMap = hit.getSourceAsMap();
  73.             String name = (String) sourceAsMap.get("name");
  74.             String description = (String) sourceAsMap.get("description");
  75.             Double price = (Double) sourceAsMap.get("price");
  76.             System.out.println("id:" + id);
  77.             System.out.println("name:" + name);
  78.             System.out.println("description:" + description);
  79.             System.out.println("price:" + price);
  80.             System.out.println("==========================");
  81.  
  82.         }
  83.     }

sort排序搜索

  1.     /**
  2.      * sort排序搜索
  3.      *     GET /book/_search
  4.      *     {
  5.      *         "query": {
  6.      *         "bool": {
  7.      *             "must": [
  8.      *             {
  9.      *                 "multi_match": {
  10.      *                 "query": "java程序员",
  11.      *                         "fields": ["name","description"]
  12.      *             }
  13.      *             }
  14.      *       ],
  15.      *             "should": [
  16.      *             {
  17.      *                 "match": {
  18.      *                 "studymodel": "201001"
  19.      *             }
  20.      *             }
  21.      *       ],
  22.      *             "filter": {
  23.      *                 "range": {
  24.      *                     "price": {
  25.      *                         "gte": 50,
  26.      *                                 "lte": 90
  27.      *                     }
  28.      *                 }
  29.      *
  30.      *             }
  31.      *         }
  32.      *     },
  33.      *         "sort": [
  34.      *         {
  35.      *             "price": {
  36.      *             "order": "asc"
  37.      *         }
  38.      *         }
  39.      *   ]
  40.      *     }
  41.      * @throws IOException
  42.      */
  43.     @Test
  44.     public void testSearchSort() throws IOException {
  45.  
  46.         //1构建搜索请求
  47.         SearchRequest searchRequest = new SearchRequest("book");
  48.  
  49.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  50.  
  51.         //构建multiMatch请求
  52.         MultiMatchQueryBuilder multiMatchQueryBuilder = QueryBuilders.multiMatchQuery("java程序员", "name", "description");
  53.         //构建match请求
  54.         MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchQuery("studymodel", "201001");
  55.  
  56.         BoolQueryBuilder boolQueryBuilder=QueryBuilders.boolQuery();
  57.         boolQueryBuilder.must(multiMatchQueryBuilder);
  58.         boolQueryBuilder.should(matchQueryBuilder);
  59.  
  60.         boolQueryBuilder.filter(QueryBuilders.rangeQuery("price").gte(50).lte(90));
  61.  
  62.         searchSourceBuilder.query(boolQueryBuilder);
  63.  
  64.         //按照价格升序
  65.         searchSourceBuilder.sort("price", SortOrder.ASC);
  66.  
  67.  
  68.         searchRequest.source(searchSourceBuilder);
  69.  
  70.         //2执行搜索
  71.         SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
  72.  
  73.         //3获取结果
  74.         SearchHits hits = searchResponse.getHits();
  75.  
  76.         //数据数据
  77.         SearchHit[] searchHits = hits.getHits();
  78.         System.out.println("--------------------------");
  79.         for (SearchHit hit : searchHits) {
  80.             String id = hit.getId();
  81.             float score = hit.getScore();
  82.             //这个source里面就是我们存储的数据
  83.             Map<String, Object> sourceAsMap = hit.getSourceAsMap();
  84.             String name = (String) sourceAsMap.get("name");
  85.             String description = (String) sourceAsMap.get("description");
  86.             Double price = (Double) sourceAsMap.get("price");
  87.             System.out.println("id:" + id);
  88.             System.out.println("name:" + name);
  89.             System.out.println("description:" + description);
  90.             System.out.println("price:" + price);
  91.             System.out.println("==========================");
  92.         }
  93.     }

后续待补充：queryStringQuery，minimumShouldMatch，对检索结果中的关键词进行高亮

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/笔触狂放9/article/detail/68277
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号