ES QueryBuilder

https://blog.csdn.net/qq_42383787/article/details/89476236

public void test() throws IOException {

•  
  # 创建一个Search 对象
•  
  SearchRequest searchRequest = new SearchRequest();
•  
   
•  
  # 创建一个Builder 对象 对条件进行封装
•  
  SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
•  
   
•  
  # 查询条件: 字段名为text 内容含有19的数据
•  
  searchSourceBuilder.query(QueryBuilders.matchQuery("text", "19"));
•  
  # 查询条件: 在上面条件的基础上 加上字段 jiage 内容含有329的数据
•  
  searchSourceBuilder.query(QueryBuilders.matchQuery("jiage", "329"));
•  
   
•  
  # 从搜索结果中取第0条开始的10条数据，数据量最多不要超过10000 会报错，有解决方案百度
•  
  searchSourceBuilder.from(0);
•  
  searchSourceBuilder.size(10);
•  
   
•  
  # 排序根据字段id 按照正序排列
•  
  searchSourceBuilder.sort(new FieldSortBuilder("id").order(SortOrder.ASC));
•  
   
•  
  searchSourceBuilder.fetchSource(false);
•  
   
•  
  # 参数，用于是否需要过滤
•  
  String[] includeFields = new String[]{"id", "dizhi","text","jiage"};
•  
  # 第1个参数是 需要显示的字段，第2个参数是需要过滤的字段
•  
  searchSourceBuilder.fetchSource(includeFields, null);
•  
   
•  
  # 进行构建
•  
  searchRequest.source(searchSourceBuilder);
•  
  searchRequest.scroll(TimeValue.timeValueMinutes(1L));
•  
   
•  
  SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
•  
   
•  
  # 获取数据 数据可以是多种类型的
•  
  SearchHits hits = searchResponse.getHits();
•  
  SearchHit[] hits1 = hits.getHits();
•  
   
•  
  List list = new ArrayList();
•  
  for (SearchHit hit : hits1) {
•  
  list.add(hit.getSourceAsString());
•  
  }
•  
  System.out.println(list);
•  
  }
•  
  }
•  
   
•  
  SearchHit[] searchHits = hits.getHits();
•  
  for (SearchHit hit : searchHits) {
•  
  // 结果的Index
•  
  String index = hit.getIndex();
•  
  // 结果的type
•  
  String type = hit.getType();
•  
  // 结果的ID
•  
  String id = hit.getId();
•  
  // 结果的评分
•  
  float score = hit.getScore();
•  
  // 查询的结果 JSON字符串形式
•  
  String sourceAsString = hit.getSourceAsString();
•  
  // 查询的结果 Map的形式
•  
  Map<String, Object> sourceAsMap = hit.getSourceAsMap();
•  
  // Document的title
•  
  String documentTitle = (String) sourceAsMap.get("title");
•  
  // 结果中的某个List
•  
  List<Object> users = (List<Object>) sourceAsMap.get("user");
•  
  // 结果中的某个Map
•  
  Map<String, Object> innerObject = (Map<String, Object>)sourceAsMap.get("innerObject");
•  
  }

QueryBuilder  常用来配合 Search 查询来使用 

boolQuery() 布尔查询，可以用来组合多个查询条件 
fuzzyQuery() 相似度查询 
matchAllQuery() 查询所有数据 
regexpQuery() 正则表达式查询 
termQuery() 词条查询 
wildcardQuery() 模糊查询 
等等.....

1.matchQuery 匹配查询: 

    matchQuery可以简单理解为mysql中的like，但是我不知道我这么理解对不对，因为在elasticsearch中使用matchQuery查询时，他会对查询的field进行分词，打个比方，我们搜索"联想笔记本电脑"，他可能会将他拆分为：“联想”，“电脑”，“联想电脑”，那么如果一个filed中包括 联想 两个字就可以被搜出来。当然我们进行查询的这个field的mapping必须是text类型。（如果是中文分词的话，还需要配置中文分词器），他的查询语句和上边基本相似

1.  
   public void test() throws IOException {
2.  
   SearchRequest searchRequest = new SearchRequest();
3.  
   SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
4.  
    
5.  
   # matchQuery 匹配查询
6.  
   searchSourceBuilder.query(QueryBuilders.matchQuery("text", "19"));
7.  
    
8.  
    
9.  
   # multiMatchQuery(Object text, String... fieldNames) 多个字段匹配某一个值
10.  
    # 搜索name中或interest中包含有music的文档 (必须与music一致)
11.  
    public void test() throws IOException {
12.  
    SearchRequest searchRequest = new SearchRequest();
13.  
    SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
14.  
     
15.  
    searchSourceBuilder.query(QueryBuilders.multiMatchQuery("music", "name", "interest"));
16.  
    }
17.  
     
18.  
     
19.  
     
20.  
    # wildcardQuery()模糊查询，?匹配单个字符，*匹配多个字符
21.  
    # 搜索名字中含有jack文档 （name中只要包含jack即可）
22.  
    public void test() throws IOException {
23.  
    SearchRequest searchRequest = new SearchRequest();
24.  
    SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
25.  
     
26.  
    searchSourceBuilder.query(QueryBuilders.wildcardQuery("name","*jack?*"));
27.  
    }

2.matchAllQuery 查询所用

查询指定index和type中的所用记录，相当于sql：select * from sales 

1.  
   public void test() throws IOException {
2.  
   SearchRequest searchRequest = new SearchRequest();
3.  
   SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
4.  
   searchSourceBuilder.query(QueryBuilders.matchAllQuery());
5.  
   }

3.termQuery等值搜索

我们在数据库中进行查询的时候，sql：select sales from tvs where brand = ‘小米’，那么在elasticsearch中的javaapi怎么写呢？这里我们用到一个termQuery，他相当于sql语句中的“=”，使用这个搜索一般是对索引中keyword的mapping进行等值搜索      term query 属于过滤器查询，可以处理数字（numbers）、布尔值（Booleans）、日期（dates）以及文本（text）。

1.  
   public void test() throws IOException {
2.  
   SearchRequest searchRequest = new SearchRequest();
3.  
   SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
4.  
   searchSourceBuilder.query(QueryBuilders.termQuery("name", "张三"));
5.  
   }
6.  
    
7.  
    
8.  
   # terms 是多值判断
9.  
    
10.  
    public void test() throws IOException {
11.  
    SearchRequest searchRequest = new SearchRequest();
12.  
    SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
13.  
    searchSourceBuilder.query(QueryBuilders.termsQuery("name", "张三", "李四", "王五"));
14.  
    }

4.matchPhraseQuery短语搜索

理解:   你会发现，使用“小别克老”没有查询出任何结果，而使用“小别克听”则查询出了我们需要的结果，这便matchPhraseQuery和matchQuery等的区别，在使用matchQuery等时，即使你传入的是“小别克老”，在执行查询时，“小别克老”会被分词器分词，例如paoding解析成“小别/别克/老”，而使用matchPhraseQuery时，“小别克老”并不会被分词器分词，而是直接以一个短语的形式查询，而如果你在创建索引所使用的field的value中没有这么一个短语（顺序无差，且连接在一起），那么将查询不出任何结果。

1.  
   public void test() throws IOException {
2.  
   SearchRequest searchRequest = new SearchRequest();
3.  
   SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
4.  
   searchSourceBuilder.query(QueryBuilders.matchPhraseQuery("name", "张三"));
5.  
   }

5.prefixQuery前缀搜索

如我我们需要查询的title中有“大话西游电影”，“大话西游小说”，使用prefixQuery查询“大话西游”，那么那两条数据就会出来

1.  
   public void test() throws IOException {
2.  
   SearchRequest searchRequest = new SearchRequest();
3.  
   SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
4.  
   searchSourceBuilder.query(QueryBuilders.prefixQuery("title", "大话西游"));
5.  
   }

6.disMaxQuery

disMaxQuery适用于多个field的进行搜索，我们在多个field搜索时候，可能会遇到多个field匹配到了更多的词会在前面，而一个field匹配了更多的词就会排名靠后。disMax就是解决这个问题，dismax使搜索到的结果，应该是某一个field中匹配到了尽可能多的关键词，被排在前面；而不是尽可能多的field匹配到了少数的关键词，排在了前面

1.  
   public void test() throws IOException {
2.  
   SearchRequest searchRequest = new SearchRequest();
3.  
   SearchSourceBuilder searchSourceBuilder = newSearchSourceBuilder();
4.  
   searchSourceBuilder.query(QueryBuilders.disMaxQuery().add(QueryBuilders.matchQuery("name", "张三")));
5.  
   }

7.boolQuery 组合查询条件

boolQuery用来将搜索的条件进行组合，即将多个组合条件组合在一起，常用的几种组合方式有must、should、mustNot，我们拿下面对应的sql语句举例子

1.  
   # sql:select * from sales where brand = ‘小米‘ and color=‘红色‘，通过bool将两个查询条件组合，
2.  
   # must相当于sql中的= 必须匹配的意思
3.  
   BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
4.  
   boolQuery.must(QueryBuilders.termQuery("brand", "小米"))
5.  
   .must(QueryBuilders.termQuery("color", "红色"));
6.  
    
7.  
   # sql:select * from sales where brand = ‘小米‘ or color=‘红色‘；使用should相当于sql语句中的or
8.  
   BoolQueryBuilder boolQuery2 = QueryBuilders.boolQuery();
9.  
   boolQuery2.should(QueryBuilders.termQuery("brand", "小米"))
10.  
    .should(QueryBuilders.termQuery("color", "红色"));
11.  
     
12.  
    # sql:select * from sales where brand = ‘小米‘ and color != ‘红色‘ mustNot相当于!= 必须不匹配
13.  
    BoolQueryBuilder boolQuery3 = QueryBuilders.boolQuery();
14.  
    boolQuery2.must(QueryBuilders.termQuery("brand", "小米"))
15.  
    .mustNot(QueryBuilders.termQuery("color", "红色"));
16.  
     
17.  
    # sql:select * from sales where (brand = ‘小米‘ or color = ‘红色‘) and brand != ‘长虹‘
18.  
    BoolQueryBuilder boolQuery4 = QueryBuilders.boolQuery();
19.  
    BoolQueryBuilder boolQuery5 = QueryBuilders.boolQuery();
20.  
    boolQuery5.should(QueryBuilders.termQuery("brand", "小米"))
21.  
    .should(QueryBuilders.termQuery("color", "红色"));
22.  
    boolQuery4.must(boolQuery5)
23.  
    .mustNot(QueryBuilders.termQuery("brand", "长虹"));
24.  
     
25.  
     
26.  
     
27.  
     
28.  
    //设置查询条件
29.  
     
30.  
    BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
31.  
    if (StringUtils.isNotEmpty(text)) {
32.  
    //查询条件：字段名为text，内容含有text的数据
33.  
    boolQuery.must(QueryBuilders.matchQuery("text", text));
34.  
    }
35.  
    if (StringUtils.isNotEmpty(keywords)) {
36.  
    //查询条件：字段名为keywords，内容含有keywords的数据
37.  
    boolQuery.must(QueryBuilders.matchQuery("keywords", keywords));
38.  
    }
39.  
    if (StringUtils.isNotEmpty(topic)) {
40.  
    //查询条件：字段名为topic，内容含有topic的数据
41.  
    boolQuery.must(QueryBuilders.matchQuery("topic", topic));
42.  
    }

8.rangeQuery属于过滤器查询

是范围查询，有时候，范围查询比精确值查询更有用，比如我想知道价格在20到40之间的商品；

range query可以处理数字（numbers）、日期（dates）以及字符串，不过字符串还是不要用范围查询的好，效率会很低；

对数字取范围没啥好说的， 就大于、大于等于、小于、小于等于四个符号加数字就可以；

1.  
   # 闭区间查询
2.  
   QueryBuilder qb1 = QueryBuilders.rangeQuery("${fieldName}").from(${fieldValue1}).to(${fieldValue2});
3.  
    
4.  
   # 开区间查询
5.  
   QueryBuilder qb1 = QueryBuilders.rangeQuery("${fieldName}").from(${fieldValue1}, false).to(${fieldValue2}, false);
6.  
    
7.  
   # 大于
8.  
   QueryBuilder qb1 = QueryBuilders.rangeQuery("${fieldName}").gt(${fieldValue});
9.  
    
10.  
    #大于等于
11.  
    QueryBuilder qb1 = QueryBuilders.rangeQuery("${fieldName}").gte(${fieldValue});
12.  
     
13.  
    # 小于
14.  
    QueryBuilder qb1 = QueryBuilders.rangeQuery("${fieldName}").lt(${fieldValue});
15.  
     
16.  
    # 小于等于
17.  
    QueryBuilder qb1 = QueryBuilders.rangeQuery("${fieldName}").lte(${fieldValue});
18.  
     
19.  
    # 多条件案例
20.  
    QueryBuilder qb1 = QueryBuilders.moreLikeThisQuery(new String[]{"${fieldName1}"}, new String[]{"${fieldValue1}"}, null);
21.  
    QueryBuilder qb2 = QueryBuilders.rangeQuery("${fieldName2}").gt("${fieldValue2}");
22.  
    QueryBuilder qb3 = QueryBuilders.boolQuery().must(qb1).must(qb2);

ES QueryBuilder

原文：https://www.cnblogs.com/wen-/p/13808401.html