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(); |
第二种分页查询必须在设定的缓存时间内往下查询，而且一旦进行了查询就必须往下继续查，不能回头重复查询。
除非注明，赵岩的博客文章均为原创，转载请以链接形式标明本文地址
本文地址：https://zhaoyanblog.com/archives/187.html
文中的InQuery我是用的时候好像是查询所有的索引,而不是我指定的某个索引,