devbox
我家自动化
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Elasticsearch概述和DSL查询总结_查询dsl

作者：我家自动化 | 2024-05-07 04:19:05

赞

踩

查询dsl

目录

Elasticsearch概述

1. 什么是Elasticsearch

2. 作用

3. 特点

DSL（Domain Specifit Language）特定领域语言：

概念和作用

查询代码总结

最后附项目准备

1.创建搜索工程（maven工程）

 2.配置文件 application.yml

3.配置类

4.启动类

测试类代码实现

创建索引、添加、查询、删除、更新文档

DSL查询测试类

Elasticsearch概述

1. 什么是Elasticsearch

Elasticsearch是基于Lucene的搜索服务器，它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口。Elasticsearch是用java开发的，开源，是当前流行的企业级搜索引擎。

2. 作用

 Elasticsearch具有极快的搜索速度，可以在几乎实时的时间内对大规模数据进行搜索和查询；它利用倒排索引和分布式搜索技术，使搜索操作变得高效，并能够多种查询方式进行全文搜索、短语匹配、模糊搜索等。

3. 特点

能够实时搜索，稳定，可靠，快速并且安装使用方便。
分布式和可扩展性：Elasticsearch基于分布式架构，可以将数据分布在多台服务器上，实现数据的水平分片和复制。这使得它能够处理海量数据，并具有高可用性和容错能力。通过添加或删除节点，可以轻松地扩展集群的容量和性能。

DSL（Domain Specifit Language）特定领域语言：

概念和作用

DSL查询是一种基于JSON的查询语言，用于构建复杂的查询和过滤条件，以检索和过滤文档。DSL查询提供了丰富的查询语法和灵活的组合方式，可以根据用户需求构建定制化的查询逻辑。

查询代码总结

  1. @Autowired   //注入客户端
  2.     RestHighLevelClient client; 
  3. SearchRequest searchRequest = new SearchRequest("abc");  //参数为索引名
  4. searchRequest.types("doc");  //参数为类型
  5. SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();  //创建查找源构造器
  6. SearchResponse searchResponse = client.search(searchRequest);  
  7.  
  8. 一、分页查询
  9. //分页查询，设置起始下标，从0开始 
  10. searchSourceBuilder.from(0); //工作中可以套公式计算出起始值(page-1)*size
  11. //每页显示个数 
  12. searchSourceBuilder.size(10); 
  13.  
  14. 二、Term精准查询
  15. searchSourceBuilder.query(QueryBuilders.termQuery("name","spring")); 
  16.  
  17. 三、根据id精准匹配
  18. searchSourceBuilder.query(QueryBuilders.termsQuery("_id", idList)); 
  19.  
  20. 四、match全文检索
  21. 先将搜索字符串分词，再使用各个词条从索引中搜索。
  22. searchSourceBuilder.query(
  23.     QueryBuilders.matchQuery("description", "spring开发")
  24.         .operator(Operator.OR));
  25.  
  26. 五、multi一次匹配多个字段
  27. 单项匹配是在一个field中去匹配，多项匹配是拿关键字去多个Field中匹配。
  28. MultiMatchQueryBuilder multiMatchQueryBuilder = QueryBuilders.multiMatchQuery("spring框架", "name", "description") .minimumShouldMatch("50%"); 
  29. multiMatchQueryBuilder.field("name",10);//提升boost显示级别
  30.  
  31. //设置过滤字段
  32. searchSourceBuilder.fetchSource(new String[]{"name","studymodel","description"},new String[]{});
  33.  
  34.  
  35. 六、布尔查询
  36. must：文档必须匹配must所包括的查询条件，相当于 “AND”。 表示必须，多个查询条件必须都满足。
  37. should：文档应该匹配should所包括的查询条件其中的一个或多个，相当于 "OR" 。表示或者，多个查询条件只要有一个满足即可。
  38. must_not：文档不能匹配must_not所包括的该查询条件，相当于 “NOT”。表示非。
  39. boolQueryBuilder.must(multiMatchQueryBuilder); //且的关系用must，或的关系用should
  40. searchSourceBuilder.query(boolQueryBuilder);//放入构造器中，否则不起作用
  41.  
  42. 七、filter过滤器
  43. boolQueryBuilder.filter(QueryBuilders.termQuery("studymodel", "201001")); 
  44. boolQueryBuilder.filter(QueryBuilders.rangeQuery("price").gte(60).lte(100)); 
  45.  
  46. 八、sort排序
  47. searchSourceBuilder.sort(new FieldSortBuilder("price").order(SortOrder.ASC)); 
  48.  
  49. 九、高亮显示
  50. //高亮设置
  51. HighlightBuilder highlightBuilder = new HighlightBuilder();
  52. highlightBuilder.preTags("<tag>");//设置前缀
  53. highlightBuilder.postTags("</tag>");//设置后缀
  54. // 设置高亮字段
  55. highlightBuilder.fields().add(new HighlightBuilder.Field("name"));//选择想要高亮的字段
  56. searchSourceBuilder.highlighter(highlightBuilder);//放入构造器中，否则不起作用
  57.  
  58. //取出高亮字段内容
  59. HighlightField nameField = highlightFields.get("name");
  60. Text[] fragments = nameField.getFragments();
  61.

注意：设置完毕后一定要加入SearchSourceBuilder 构造器中

注意：设置完毕后一定要加入SearchSourceBuilder 构造器中

注意：设置完毕后一定要加入SearchSourceBuilder 构造器中

最后附项目准备

1.创建搜索工程（maven工程）

添加RestHighLevelClient依赖及junit依赖。

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <modelVersion>4.0.0</modelVersion>
  6.  
  7.     <parent>
  8.         <groupId>org.springframework.boot</groupId>
  9.         <artifactId>spring-boot-starter-parent</artifactId>
  10.         <version>2.1.3.RELEASE</version>
  11.     </parent>
  12.  
  13.     <groupId>cn.yh</groupId>
  14.     <artifactId>yh-service-search</artifactId>
  15.     <version>1.0-SNAPSHOT</version>
  16.  
  17.     <properties>
  18.         <maven.compiler.source>8</maven.compiler.source>
  19.         <maven.compiler.target>8</maven.compiler.target>
  20.     </properties>
  21.  
  22.     <dependencies>
  23.         <dependency>
  24.             <groupId>org.springframework.boot</groupId>
  25.             <artifactId>spring-boot-starter-web</artifactId>
  26.         </dependency>
  27.         <!--elasticsearch-->
  28.         <dependency>
  29.             <groupId>org.elasticsearch.client</groupId>
  30.             <artifactId>elasticsearch-rest-high-level-client</artifactId>
  31.             <version>6.2.1</version>
  32.             <exclusions>
  33.                 <exclusion>
  34.                     <groupId>org.elasticsearch.client</groupId>
  35.                     <artifactId>elasticsearch-rest-client</artifactId>
  36.                 </exclusion>
  37.             </exclusions>
  38.         </dependency>
  39.         <dependency>
  40.             <groupId>org.elasticsearch.client</groupId>
  41.             <artifactId>elasticsearch-rest-client</artifactId>
  42.             <version>6.2.1</version>
  43.         </dependency>
  44.         <dependency>
  45.             <groupId>org.elasticsearch</groupId>
  46.             <artifactId>elasticsearch</artifactId>
  47.             <version>6.2.1</version>
  48.         </dependency>
  49.         <!--junit-->
  50.         <dependency>
  51.             <groupId>org.springframework.boot</groupId>
  52.             <artifactId>spring-boot-starter-test</artifactId>
  53.             <scope>test</scope>
  54.         </dependency>
  55.     </dependencies>
  56. </project>

 2.配置文件 application.yml

  1. server:
  2.   port: 8080
  3. spring:
  4.   application:
  5.     name: yh-search-service
  6. yh:
  7.   elasticsearch:
  8.     hostlist: ${eshostlist:127.0.0.1:9200} #多个结点中间用逗号分隔

3.配置类

创建 com.yh.search.config 包在其下

  1. package cn.yh.es.config;
  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. @Configuration
  11. public class ElasticsearchConfig {
  12.     @Value("${yh.elasticsearch.hostlist}")
  13.     private String hostlist;
  14.  
  15.     @Bean
  16.     public RestHighLevelClient restHighLevelClient() {
  17.         //解析hostlist配置信息
  18.         String[] split = hostlist.split(",");
  19.         //创建HttpHost数组，其中存放es主机和端口的配置信息
  20.         HttpHost[] httpHostArray = new HttpHost[split.length];
  21.         for (int i = 0; i < split.length; i++) {
  22.             String item = split[i];
  23.             httpHostArray[i] =
  24.                     new HttpHost(item.split(":")[0], Integer.parseInt(item.split(":")[1]), "http");
  25.         }
  26.         //创建RestHighLevelClient客户端
  27.         return new RestHighLevelClient(RestClient.builder(httpHostArray));
  28.     }
  29.  
  30.     //项目主要使用RestHighLevelClient，对于低级的客户端暂时不用
  31.     @Bean
  32.     public RestClient restClient() {
  33.         //解析hostlist配置信息
  34.         String[] split = hostlist.split(",");
  35.         //创建HttpHost数组，其中存放es主机和端口的配置信息
  36.         HttpHost[] httpHostArray = new HttpHost[split.length];
  37.         for (int i = 0; i < split.length; i++) {
  38.             String item = split[i];
  39.             httpHostArray[i] =
  40.                     new HttpHost(item.split(":")[0], Integer.parseInt(item.split(":")[1]), "http");
  41.         }
  42.         return RestClient.builder(httpHostArray).build();
  43.     }
  44. }

4.启动类

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

测试类代码实现

创建索引、添加、查询、删除、更新文档

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class EsTest {
  4.  
  5.     @Autowired
  6.     private RestHighLevelClient client;
  7.  
  8.     @Autowired
  9.     private RestClient restClient;
  10.  
  11.     /**
  12.      * 创建索引库(数据库)，创建映射Mapping(字段)
  13.      * @throws IOException
  14.      */
  15.     @Test
  16.     public void creatIndex() throws IOException {
  17.  
  18.         CreateIndexRequest createIndexRequest = new CreateIndexRequest("yh_test");
  19.  
  20.         //1.创建索引的客户端
  21.         IndicesClient indices = client.indices();
  22.         //3.1设置索引参数
  23.         createIndexRequest.settings(Settings.builder().put("number_of_shards",1).
  24.                 put("number_of_replicas",0).build());
  25.         //3.2创建映射
  26.         createIndexRequest.mapping("doc","{\n" +
  27.                 "    \"properties\": {  \n" +
  28.                 "        \"name\": {\n" +
  29.                 "            \"type\": \"text\",\n" +
  30.                 "            \"analyzer\":\"ik_max_word\",\n" +
  31.                 "            \"search_analyzer\":\"ik_smart\"\n" +
  32.                 "        },\n" +
  33.                 "        \"description\": {\n" +
  34.                 "            \"type\": \"text\",\n" +
  35.                 "            \"analyzer\":\"ik_max_word\",\n" +
  36.                 "            \"search_analyzer\":\"ik_smart\"\n" +
  37.                 "        },\n" +
  38.                 "        \"studymodel\": {\n" +
  39.                 "            \"type\": \"keyword\"\n" +
  40.                 "        },\n" +
  41.                 "        \"price\": {\n" +
  42.                 "            \"type\": \"float\"\n" +
  43.                 "        },\n" +
  44.                 "        \"timestamp\": {\n" +
  45.                 "            \"type\":   \"date\",  \n" +
  46.                 "            \"format\": \"yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||epoch_millis\"\n" +
  47.                 "        }\n" +
  48.                 "    }\n" +
  49.                 "}", XContentType.JSON);
  50.  
  51.         //2.创建响应对象
  52.         CreateIndexResponse response = indices.create(createIndexRequest);
  53.         //得到响应对象
  54.         boolean responseAcknowledged = response.isAcknowledged();
  55.         System.out.println(responseAcknowledged);
  56.  
  57.     }
  58.  
  59.  
  60.     /**
  61.      * 添加文档(向表doc中添加记录)
  62.      * @throws IOException
  63.      */
  64.     @Test
  65.     public void addDoc() throws IOException {
  66.         //准备json数据
  67.         Map<String, Object> jsonMap = new HashMap<>();
  68.         jsonMap.put("name", "spring MVC开源框架1");
  69.         jsonMap.put("description", "本课程主要从四个章节进行讲解： 1.微服务架构入门 2.spring cloud基础入门 3.实战Spring Boot 4.注册中心eureka。");
  70.         jsonMap.put("studymodel", "201001");
  71.         SimpleDateFormat dateFormat =new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  72.         jsonMap.put("timestamp", dateFormat.format(new Date()));
  73.         jsonMap.put("price", 5.6f);
  74.  
  75.         //获取索引对象
  76.         IndexRequest indexRequest = new IndexRequest("yh_test","doc","6");
  77.  
  78.         //向索引中添加数据
  79.         indexRequest.source(jsonMap);
  80.  
  81.         //客户端添加索引
  82.         IndexResponse index = client.index(indexRequest);
  83.         System.out.println(index.getResult());
  84.  
  85.  
  86.     }
  87.  
  88.  
  89.     /**
  90.      * 查询文档
  91.      * @throws IOException
  92.      */
  93.     @Test
  94.     public void searchDoc() throws IOException {
  95.         GetRequest getRequest = new GetRequest("yh_test","doc","N7gytIkBjqFbH1htibgh");
  96.  
  97.         GetResponse response = client.get(getRequest);
  98.         System.out.println(response);
  99.  
  100.         boolean exists = response.isExists();
  101.         System.out.println(exists);
  102.         Map<String, Object> sourceAsMap = response.getSourceAsMap();
  103.         System.out.println(sourceAsMap);
  104.     }
  105.  
  106.  
  107.     /**
  108.      * 更新文档
  109.      */
  110.     @Test
  111.     public void updateDoc() throws IOException {
  112.         UpdateRequest updateRequest = new UpdateRequest("yh_test","doc","N7gytIkBjqFbH1htibgh");
  113.  
  114.         Map<String, String> map = new HashMap<>();
  115.         map.put("name","spring boot");
  116.         updateRequest.doc(map); //将修改内容放到对象中
  117.         UpdateResponse update = client.update(updateRequest);
  118.         System.out.println(update);
  119.     }
  120.  
  121.  
  122.     /**
  123.      * 删除文档
  124.      */
  125.     @Test
  126.     public void deleteDoc() throws IOException {
  127.         //获取文档id
  128.         String id = "N7gytIkBjqFbH1htibgh";
  129.         DeleteRequest deleteRequest = new DeleteRequest("yh_test","doc","1"); //id为记录id
  130.         DeleteResponse delete = client.delete(deleteRequest);
  131.         System.out.println(delete);
  132.     }
  133.  
  134.  
  135.  
  136.  
  137.  
  138.  
  139. }

DSL查询测试类

  1. @RunWith(SpringRunner.class)
  2. @SpringBootTest
  3. public class EsDSLSearchTest {
  4.  
  5.     @Autowired
  6.     private RestHighLevelClient client;
  7.  
  8.     @Autowired
  9.     private RestClient restClient;
  10.  
  11.     /**
  12.      * 自定义打印输出方法
  13.      * @param search
  14.      * @throws IOException
  15.      */
  16.     public void myPrint(SearchResponse search)  {
  17.         SearchHits hits = search.getHits();
  18.         for (SearchHit hit : hits) {
  19.             Map<String, Object> sourceAsMap = hit.getSourceAsMap();
  20.             float score = hit.getScore();
  21.             Double price = (Double)sourceAsMap.get("price");
  22.             String name = (String) sourceAsMap.get("name");
  23.             String studymodel = (String) sourceAsMap.get("studymodel");
  24.             String description = (String) sourceAsMap.get("description");
  25.             System.out.println("name:"+name+",studymodel:"+studymodel+",score:"
  26.                     +score+",price:"+price+",description:"+description);
  27.         }
  28.     }
  29.  
  30.  
  31.  
  32.     /**
  33.      * 一：查询文档，所有记录，指定字段
  34.      */
  35.     @Test
  36.     public void selectDocBy() throws IOException {
  37.         //2.
  38.         SearchRequest searchRequest = new SearchRequest("yh_test");
  39.         searchRequest.types("doc");
  40.         //4.查找源构造器
  41.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  42.         //ctrl+h查看接口实现类列表
  43.         //查询所有
  44.         searchSourceBuilder.query(QueryBuilders.matchAllQuery());
  45.         //source源字段过滤
  46.         searchSourceBuilder.fetchSource(new String[]{"name", "studymodel"}, new String[]{});
  47.         //3.
  48.         searchRequest.source(searchSourceBuilder);
  49.         //1.
  50.         SearchResponse search = client.search(searchRequest);
  51.  
  52.         //输出
  53.         this.myPrint(search);
  54.     }
  55.  
  56.  
  57. //    /**
  58. //     * 查所有记录DSL
  59. //     */
  60. //    @Test
  61. //    public void selectAll() throws IOException {
  62. //        SearchRequest searchRequest = new SearchRequest("yh_test");
  63. //        searchRequest.types("doc");
  64. //        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  65. //        searchSourceBuilder.query(QueryBuilders.matchAllQuery());
  66. //        searchSourceBuilder.fetchSource(new String[] {"name"},new String[]{} ); //exclude排除
  67. //        searchRequest.source(searchSourceBuilder);
  68. //
  69. //        SearchResponse search = client.search(searchRequest);
  70. //
  71. //        //输出
  72. //        SearchHits hits = search.getHits();
  73. //        for (SearchHit hit : hits) {
  74. //            String index = hit.getIndex();
  75. //            float score = hit.getScore();
  76. //            String id = hit.getId();
  77. //            String type = hit.getType();
  78. //            Map<String, Object> sourceAsMap = hit.getSourceAsMap(); //获取_source集合，该集合是上面过滤的字段
  79. //            System.out.println(sourceAsMap);
  80. //        }
  81. //    }
  82.  
  83.  
  84.     /**
  85.      * 二：分页查询
  86.      */
  87.     @Test
  88.     public void splitPageSearch() throws IOException {
  89.  
  90.         SearchRequest searchRequest = new SearchRequest("yh_test");
  91.         searchRequest.types("doc");
  92.  
  93.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  94.         //分页
  95.         searchSourceBuilder.from(0);
  96.         searchSourceBuilder.size(2);
  97.         //限制输出字段
  98.         searchSourceBuilder.query(QueryBuilders.matchAllQuery());
  99.         searchSourceBuilder.fetchSource(new String[]{"name"}, new String[]{});
  100.  
  101.  
  102.         searchRequest.source(searchSourceBuilder);
  103.         SearchResponse search = client.search(searchRequest);
  104.  
  105.         //打印输出
  106.         this.myPrint(search);
  107.  
  108.  
  109.     }
  110.  
  111.  
  112.     /**
  113.      * 三：term精准查询
  114.      * {
  115.      *     "query": {
  116.      *         "term" : {
  117.      *             "name": "spring"
  118.      *         }
  119.      *     },
  120.      *     "_source" : ["name","studymodel"]
  121.      * }
  122.      */
  123.     @Test
  124.     public void termQuery() throws IOException {
  125.         SearchRequest searchRequest = new SearchRequest("yh_test");
  126.         searchRequest.types("doc");
  127.  
  128.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  129.         //设置精准匹配字段
  130.         searchSourceBuilder.query(QueryBuilders.termQuery("name", "spring"));
  131.         //限制输出字段
  132.         searchSourceBuilder.fetchSource(new String[]{"name","studymodel","description"}, new String[]{});
  133.  
  134.  
  135.         searchRequest.source(searchSourceBuilder);
  136.         SearchResponse search = client.search(searchRequest);
  137.  
  138.         //输出
  139.         this.myPrint(search);
  140.  
  141.     }
  142.  
  143.  
  144.     /**
  145.      * 四：根据id精准匹配
  146.      * {
  147.      *     "query": {
  148.      *         "ids" : {
  149.      *             "type" : "doc",
  150.      *             "values" : ["3", "4", "100"]
  151.      *         }
  152.      *     }
  153.      * }
  154.      */
  155.     @Test
  156.     public void accurateQueryById() throws IOException {
  157.         SearchRequest searchRequest = new SearchRequest("yh_test");
  158.         searchRequest.types("doc");
  159.  
  160.         String[] ids = {"3", "4", "100"};
  161.         List<String> idsList = Arrays.asList(ids);  //将字符数组转换为集合
  162.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  163.         searchSourceBuilder.query(QueryBuilders.termsQuery("_id", idsList));
  164.  
  165.  
  166.         searchRequest.source(searchSourceBuilder);
  167.         SearchResponse search = client.search(searchRequest);
  168.  
  169.         //输出
  170.         this.myPrint(search);
  171.     }
  172.  
  173.  
  174.     /**
  175.      * 五：match全文检索
  176.      * 先将搜索字符串分词，再使用各个词条从索引中搜索
  177.      * {
  178.      *     "query": {
  179.      *         "match" : {
  180.      *             "description" : {
  181.      *                 "query" : "spring开发",
  182.      *                 "operator" : "or"
  183.      *             }
  184.      *         }
  185.      *     }
  186.      * }
  187.      */
  188.     @Test
  189.     public void matchQuery() throws IOException {
  190.         SearchRequest searchRequest = new SearchRequest("yh_test");
  191.         searchRequest.types("doc");
  192.  
  193.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  194.         //查询字段为name，name：spring的记录；   Operator.OR操作数意思是分词满足其中任一记录的都可以
  195.         searchSourceBuilder.query(QueryBuilders.matchQuery("name","spring").operator(Operator.OR));
  196.  
  197.         searchRequest.source(searchSourceBuilder);
  198.         SearchResponse search = client.search(searchRequest);
  199.  
  200.         //输出
  201.         this.myPrint(search);
  202.  
  203.     }
  204.  
  205.  
  206.     /**
  207.      * 六：multi关键字匹配多个字段
  208.      * 单项匹配是在一个field中去匹配，多项匹配是拿关键字去多个Field中匹配
  209.      * {
  210.      *     "query": {
  211.      *         "multi_match" : {
  212.      *             "query" : "spring css",
  213.      *             "minimum_should_match": "50%",
  214.      *             "fields": [ "name", "description" ]
  215.      *         }
  216.      *     }
  217.      * }
  218.      */
  219.     @Test
  220.     public void multiQuery() throws IOException {
  221.         SearchRequest searchRequest = new SearchRequest();
  222.  
  223.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  224.         searchSourceBuilder.query(QueryBuilders.multiMatchQuery
  225.                 //spring css匹配字段；  name、description匹配字段；   minimumShouldMatch匹配度50%，分次数*50%向下取整；  field提升优先级；
  226.                 ("spring css","name","description").minimumShouldMatch("50%").field("name",10));
  227.  
  228.  
  229.         searchRequest.source(searchSourceBuilder);
  230.         SearchResponse search = client.search(searchRequest);
  231.  
  232.         //输出
  233.         this.myPrint(search);
  234.  
  235.     }
  236.  
  237.  
  238.     /**
  239.      * 七：布尔查询
  240.      * 布尔查询对应于Lucene的BooleanQuery查询，实现将多个查询组合起来。
  241.      * 三个参数：
  242.      * must：文档必须匹配must所包括的查询条件，相当于 “AND”
  243.      * should：文档应该匹配should所包括的查询条件其中的一个或多个，相当于 "OR"
  244.      * must_not：文档不能匹配must_not所包括的该查询条件，相当于 “NOT”
  245.      * {
  246.      *     "_source" : [ "name", "studymodel", "description"],
  247.      *     "from" : 0, "size" : 1,
  248.      *     "query": {
  249.      *         "bool" : {
  250.      *             "must":[
  251.      *                 {
  252.      *                     "multi_match" : {
  253.      *                         "query" : "spring框架",
  254.      *                         "minimum_should_match": "50%",
  255.      *                         "fields": [ "name^10", "description" ]
  256.      *                     }
  257.      *                 },
  258.      *                 {
  259.      *                     "term":{
  260.      *                         "studymodel" : "201001"
  261.      *                     }
  262.      *                 }
  263.      *             ]
  264.      *         }
  265.      *     }
  266.      * }
  267.      */
  268.     @Test
  269.     public void boolQuery() throws IOException {
  270.         SearchRequest searchRequest = new SearchRequest();
  271.  
  272.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  273.         //查询一
  274.         MultiMatchQueryBuilder multiMatchQueryBuilder =QueryBuilders.multiMatchQuery
  275.                 ("spring框架","name","description").minimumShouldMatch("50%").field("name",10);
  276.  
  277.         //查询二
  278.         TermsQueryBuilder termsQuery = QueryBuilders.termsQuery("studymodel", "201001");
  279.  
  280.         //获取bool查询对象
  281.         BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
  282.         boolQueryBuilder.must(multiMatchQueryBuilder);
  283.         boolQueryBuilder.must(termsQuery);
  284.  
  285.         searchSourceBuilder.query(boolQueryBuilder);
  286.         //设置过滤字段
  287.         searchSourceBuilder.fetchSource(new String[]{"name","studymodel","description"},new String[]{});
  288.         //设置分页
  289.         searchSourceBuilder.from(0);
  290.         searchSourceBuilder.size(2);
  291.  
  292.  
  293.         searchRequest.source(searchSourceBuilder);
  294.         SearchResponse search = client.search(searchRequest);
  295.  
  296.         //输出
  297.         this.myPrint(search);
  298.     }
  299.  
  300.  
  301.     /**
  302.      * 八：filter过滤器
  303.      * 过滤是针对搜索的结果进行过滤，过滤器主要判断的是文档是否匹配，不去计算和判断文档的匹配度得分，所以过
  304.      * 虑器性能比查询要高，且方便缓存，推荐尽量使用过滤器去实现查询或者过滤器和查询共同使用。
  305.      */
  306.     @Test
  307.     public void filterQuery() throws IOException {
  308.         SearchRequest searchRequest = new SearchRequest();
  309.  
  310.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  311.         //查询一
  312.         MultiMatchQueryBuilder multiMatchQueryBuilder =QueryBuilders.multiMatchQuery
  313.                 ("spring框架","name","description").minimumShouldMatch("50%").field("name",10);
  314.  
  315.  
  316.         //获取bool查询对象
  317.         BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
  318.         boolQueryBuilder.must(multiMatchQueryBuilder);
  319.         //filter过滤器
  320.         boolQueryBuilder.filter(QueryBuilders.termsQuery("studymodel","201001"));
  321.         boolQueryBuilder.filter(QueryBuilders.rangeQuery("price").gte(60).lte(100));
  322.  
  323.         searchSourceBuilder.query(boolQueryBuilder);
  324.         //设置过滤字段
  325.         searchSourceBuilder.fetchSource(new String[]{"name","studymodel","price","description"},new String[]{});
  326.         //设置分页
  327.         searchSourceBuilder.from(0);
  328.         searchSourceBuilder.size(6);
  329.  
  330.  
  331.         searchRequest.source(searchSourceBuilder);
  332.         SearchResponse search = client.search(searchRequest);
  333.  
  334.         //输出
  335.         this.myPrint(search);
  336.  
  337.     }
  338.  
  339.  
  340.     /**
  341.      * 九：sort排序
  342.      */
  343.     @Test
  344.     public void sortQuery() throws IOException {
  345.         SearchRequest searchRequest = new SearchRequest();
  346.  
  347.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  348.         //查询一
  349.         MultiMatchQueryBuilder multiMatchQueryBuilder =QueryBuilders.multiMatchQuery
  350.                 ("spring框架","name","description").minimumShouldMatch("50%").field("name",10);
  351.  
  352.  
  353.         //获取bool查询对象
  354.         BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
  355.         boolQueryBuilder.must(multiMatchQueryBuilder);
  356.         //filter过滤器
  357.         boolQueryBuilder.filter(QueryBuilders.rangeQuery("price").gte(0).lte(100));
  358.  
  359.         searchSourceBuilder.query(boolQueryBuilder);
  360.  
  361.         //sort排序
  362.         searchSourceBuilder.sort("studymodel", SortOrder.DESC);
  363.         searchSourceBuilder.sort("price",SortOrder.ASC);
  364.  
  365.         //设置过滤字段
  366.         searchSourceBuilder.fetchSource(new String[]{"name","studymodel","price","description"},new String[]{});
  367.         //设置分页
  368.         searchSourceBuilder.from(0);
  369.         searchSourceBuilder.size(6);
  370.  
  371.  
  372.         searchRequest.source(searchSourceBuilder);
  373.         SearchResponse search = client.search(searchRequest);
  374.  
  375.         //输出
  376.         this.myPrint(search);
  377.  
  378.  
  379.     }
  380.  
  381.  
  382.     /**
  383.      * 十：高亮显示highlight
  384.      * {
  385.      *     "_source" : [ "name", "studymodel", "description","price"],
  386.      *     "query": {
  387.      *         "bool" : {
  388.      *             "must":[
  389.      *                 {
  390.      *                     "multi_match" : {
  391.      *                         "query" : "开发框架",
  392.      *                         "minimum_should_match": "50%",
  393.      *                         "fields": [ "name^10", "description" ],
  394.      *                         "type":"best_fields"
  395.      *                     }
  396.      *                 }
  397.      *             ],
  398.      *             "filter": [
  399.      *                 { "range": { "price": { "gte": 0 ,"lte" : 100}}}
  400.      *             ]
  401.      *         }
  402.      *     },
  403.      *     "sort" : [
  404.      *         {
  405.      *             "price" : "asc"
  406.      *         }
  407.      *     ],
  408.      *     "highlight": {
  409.      *         "pre_tags": ["<tag1>"],
  410.      *         "post_tags": ["</tag1>"],
  411.      *         "fields": {
  412.      *             "name": {},
  413.      *             "description":{}
  414.      *         }
  415.      *     }
  416.      * }
  417.      */
  418.     @Test
  419.     public void highLightQuery() throws IOException {
  420.         SearchRequest searchRequest = new SearchRequest("yh_test");
  421.         searchRequest.types("doc");
  422.  
  423.         SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  424.         //指定查询字段
  425.         searchSourceBuilder.fetchSource(new String[]{"name","studymodel","description","price"},new String[]{});
  426.  
  427.         //multi查询
  428.         MultiMatchQueryBuilder multiMatchQueryBuilder = QueryBuilders.multiMatchQuery(
  429.                 "开发","name","description").field("name",10).minimumShouldMatch("50%");
  430.         searchSourceBuilder.query(multiMatchQueryBuilder);  //给查询资源构造器传过去
  431.  
  432.         //布尔查询
  433.         BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
  434.         boolQueryBuilder.must(searchSourceBuilder.query());
  435.         //filter过滤器
  436.         boolQueryBuilder.filter(QueryBuilders.rangeQuery("price").gte(0).lte(100));
  437.  
  438.         //price升序排列
  439.         searchSourceBuilder.sort(new FieldSortBuilder("price").order(SortOrder.ASC));
  440.  
  441.         //高亮
  442.         HighlightBuilder highlighter =new HighlightBuilder();
  443.         highlighter.preTags("<tag1>");
  444.         highlighter.postTags("</tag1>");
  445.         //设置高光字段
  446.         highlighter.fields().add(new HighlightBuilder.Field("name"));
  447.         highlighter.fields().add(new HighlightBuilder.Field("description"));
  448.         searchSourceBuilder.highlighter(highlighter);   //给查询资源构造器传过去
  449.  
  450.         searchRequest.source(searchSourceBuilder);
  451.         SearchResponse search = client.search(searchRequest);
  452.  
  453.  
  454.  
  455.         //输出
  456.         SearchHits hits = search.getHits();
  457.         SearchHit[] searchHits = hits.getHits();
  458.         for (SearchHit hit : searchHits) {
  459.             Map<String, Object> sourceAsMap = hit.getSourceAsMap();
  460.             //名称
  461.             String name = (String) sourceAsMap.get("name");
  462.             //取出高亮字段内容
  463.             Map<String, HighlightField> highlightFields = hit.getHighlightFields();
  464.             if (highlightFields != null) {  //如果高光对象存在，获取一下name字段的高光内容
  465.                 HighlightField nameField = highlightFields.get("name");
  466. //                System.out.println("++++++++"+nameField+"++++++++++++++");
  467.                 if (nameField != null) {
  468.                     Text[] fragments = nameField.getFragments();  //得到片段数组
  469.                     StringBuffer stringBuffer = new StringBuffer();
  470.                     for (Text str : fragments) {
  471.                         stringBuffer.append(str.string());
  472.                     }
  473.                     name = stringBuffer.toString();
  474.                 }
  475.             }
  476.             String index = hit.getIndex();
  477.             String type = hit.getType();
  478.             String id = hit.getId();
  479.             float score = hit.getScore();
  480.             String sourceAsString = hit.getSourceAsString();
  481.             String studymodel = (String) sourceAsMap.get("studymodel");
  482.             String description = (String) sourceAsMap.get("description");
  483.             System.out.println(name);
  484.             System.out.println(studymodel);
  485.             System.out.println(description);
  486.         }
  487.  
  488.     }
  489.  
  490.  
  491. }

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

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

  

闽ICP备14008679号