elasticsearch的java搜索语法

elasticsearch做为开源的搜索引擎，支持复杂的搜索，本文示例用java客户端实现的搜索。

一、maven引入依赖jar包

<dependency>
      <groupId>org.elasticsearch</groupId>
      <artifactId>elasticsearch</artifactId>
      <version>1.1.0</version>
</dependency>

二、产生client

Settings settings = ImmutableSettings.settingsBuilder()
            .put("client.transport.sniff", true)
            .build();
 
        TransportClient client = new TransportClient(settings);

三、使用query查询

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来构建组合：

QueryBuilders.inQuery("attr1", new String[{"value1","value2","value3"});
QueryBuilders.rangeQuery("attr1").gt("value1")//gt lt eq gte lte;

查询的形式和意思均可以根据方法名猜想的出来。

四、使用filter查询

filter和query的使用方式相似，它是使用FilterBuilders来构建查询条件。
不过比query多了or、and关系查询

FilterBuilders.orFilter(FilterBuilders.termFilter("attr1", "value1"),FilterBuilders.termFilter("attr2", "value2"));
FilterBuilders.andFilter(FilterBuilders.termFilter("attr1", "value1"),FilterBuilders.termFilter("attr2", "value2"));

是经过 .setPostFilter(filter) 指定给search;
五、分页查询
一种方式是指定from/size

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继续往下查询。

第一次查询

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();

后面的查询

SearchResponse actionGet = elasticClient.prepareSearchScroll(actionGet.getScrollId())
	.setScroll(new TimeValue(600000))
	.execute().actionGet();

第二种分页查询必须在设定的缓存时间内往下查询，并且一旦进行了查询就必须往下继续查，不能回头重复查询。