elasticsearch作為開源的搜索引擎，支持復雜的搜索，本文示例用java客戶端實現的搜索。
1、maven引入依賴jar包
1 2 3 4 5 |
<dependency> <groupId>org.elasticsearch</groupId> <artifactId>elasticsearch</artifactId> <version>1.1.0</version> </dependency> |
2、產生client
1 2 3 4 5 |
Settings settings = ImmutableSettings.settingsBuilder()
.put("client.transport.sniff", true)
.build();
TransportClient client = new TransportClient(settings); |
3、使用query查詢
1 2 3 4 5 6 7 8 9 10 |
SearchResponse actionGet = client.prepareSearch("indexName")
.setTypes("typeName")
.setQuery( QueryBuilders.boolQuery().must(QueryBuilders.termQuery("attr1", "value1"))
).execute().actionGet();
SearchHits hits = actionGet.getHits();
List<Map<String, Object>> matchRsult = new LinkedList<Map<String, Object>>();
for (SearchHit hit : hits.getHits())
{
matchRsult.add(hit.getSource());
} |
查詢條件有好多種形式，都可以通過QueryBuilders來構建組合：
1 2 |
QueryBuilders.inQuery("attr1", new String[{"value1","value2","value3"});
QueryBuilders.rangeQuery("attr1").gt("value1")//gt lt eq gte lte; |
查詢的形式和意思都可以根據方法名猜測的出來。
4、使用filter查詢
filter和query的使用方式類似，它是使用FilterBuilders來構建查詢條件。
不過比query多了or、and關系查詢
1 2 |
FilterBuilders.orFilter(FilterBuilders.termFilter("attr1", "value1"),FilterBuilders.termFilter("attr2", "value2"));
FilterBuilders.andFilter(FilterBuilders.termFilter("attr1", "value1"),FilterBuilders.termFilter("attr2", "value2")); |
是通過 .setPostFilter(filter) 指定給search;
5、分頁查詢
一種方式是指定from/size
1 2 3 4 5 6 7 8 |
SearchResponse actionGet = elasticClient.prepareSearch("indexName")
.setTypes("typeName")
.setQuery(
QueryBuilders.boolQuery().must(QueryBuilders.termQuery("attr1", "value1"))
)
.setFrom(100)
.setSize(200)
.execute().actionGet(); |
另外一種是使用Scroll/size，如果結果超過size大小，會返回size條記錄，並返回一個scrollId，可以用這個scrollId繼續往下查詢。
第一次查詢
1 2 3 4 5 6 7 8 |
SearchResponse actionGet = elasticClient.prepareSearch("indexName")
.setTypes("typeName")
.setQuery( QueryBuilders.boolQuery().must(QueryBuilders.termQuery("attr1", "value1")) )
.setScroll(new TimeValue(60000))
.setSize(200)
.execute().actionGet();
String scrollId = actionGet.getScrollId(); |
后面的查詢
1 2 3 |
SearchResponse actionGet = elasticClient.prepareSearchScroll(actionGet.getScrollId()) .setScroll(new TimeValue(600000)) .execute().actionGet(); |
第二種分頁查詢必須在設定的緩存時間內往下查詢，而且一旦進行了查詢就必須往下繼續查，不能回頭重復查詢。