elasticsearch的java搜索语法

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

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

  1. Z说道:

    文中的InQuery我是用的时候好像是查询所有的索引,而不是我指定的某个索引,

留言

提示:你的email不会被公布,欢迎留言^_^

*

验证码 * Time limit is exhausted. Please reload CAPTCHA.