分佈式搜索elasticsearch java API 之（五）------搜索

//根據查詢函數想到與之對應的Lucene實例

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