首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > 开发语言 > 编程 >

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

2013-10-28 
5.分布式搜索elasticsearch java API )------搜索elasticsearch的查询是通过执行json格式的查询条件,在jav

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

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字段的值。

热点排行