欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

5.分布式搜索elasticsearch java API )------搜索

程序员文章站 2022-04-27 21:17:48
...

elasticsearch的查询是通过执行json格式的查询条件,在java api中就是构造QueryBuilder对象,elasticsearch完全支持queryDSL风格的查询方式,QueryBuilder的构建类是QueryBuilders,filter的构建类是FilterBuilders。下面是构造QueryBuilder的例子:

[java] view plaincopy
  1. import static org.elasticsearch.index.query.FilterBuilders.*;   
  2.     import static org.elasticsearch.index.query.QueryBuilders.*;   
  3.        
  4.     QueryBuilder qb1 = termQuery("name""kimchy");   
  5.        
  6.     QueryBuilder qb2 = boolQuery()   
  7.                         .must(termQuery("content""test1"))   
  8.                         .must(termQuery("content""test4"))   
  9.                         .mustNot(termQuery("content""test2"))   
  10.                         .should(termQuery("content""test3"));   
  11.        
  12.     QueryBuilder qb3 = filteredQuery(   
  13.                 termQuery("name.first""shay"),    
  14.                 rangeFilter("age")   
  15.                     .from(23)   
  16.                     .to(54)   
  17.                     .includeLower(true)   
  18.                     .includeUpper(false)   
  19.                 );  

其中qb1构造了一个TermQuery,对name这个字段进行项搜索,项是最小的索引片段,这个查询对应lucene本身的TermQuery。 qb2构造了一个组合查询(BoolQuery),其对应lucene本身的BooleanQuery,可以通过must、should、mustNot方法对QueryBuilder进行组合,形成多条件查询。 qb3构造了一个过滤查询,就是在TermQuery的基础上添加一个过滤条件RangeFilter,这个范围过滤器将限制查询age字段大于等于23,小于等于54的结果。除了这三个,elasticsearch还支持很多种类的查询方式,迟点写个介绍。

构造好了Query就要传到elasticsearch里面进行查询,下面是例子:

[java] view plaincopy
  1. SearchResponse response = client.prepareSearch("test")   
  2.         .setQuery(query)   
  3.         .setFrom(0).setSize(60).setExplain(true)   
  4.         .execute()   
  5.         .actionGet();  

这句的意思是,查询test索引,查询条件为query,从第0条记录开始,最多返回60条记录。返回结果为SearchResponse,下面解析SearchResponse:

[java] view plaincopy
  1. SearchHits hits = searchResponse.hits();  
  2.         for (int i = 0; i < 60; i++) {  
  3.             System.out.println(hits.getAt(i).getSource().get("field"));  
  4.         }  

获得SearchResponse中的SearchHits,然后hits.getAt(i).getSource().get("field")获得field字段的值。