ealsticsearch多条件查询

前段时间在做多条件检索的时间遇到了一些问题，不晓得怎么构建多条件查询，跟solr有些不同，一开始是使用QueryBuider，可是发现不行，废话不多说了，直接贴代码：

以下代码是动态构建查询语句：

 private SearchRequestBuilder dynamicSearch(String index, String type, String startTime, String endTime, String status, String title, String city, String resOfficer, int pageIndex, int pageCapacity) {
        SearchRequestBuilder searchRequestBuilder = client.prepareSearch(index)
                .setTypes(type)
                .setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
                .setPostFilter(FilterBuilders.rangeFilter("start_time").from(startTime).to(endTime))
                .setFrom(pageIndex).setSize(pageCapacity)
                .setExplain(true);
        BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();
        queryBuilder.mustNot(QueryBuilders.matchQuery("site", "www.huodongxing.com"));

        //活动名称
        if (!StringUtils.isEmpty(title)) {
            queryBuilder.must(QueryBuilders.queryString(title).field("title"));
        }

        //城市
        if (!StringUtils.isEmpty(city)) {
            queryBuilder.must(termQuery("city", city));
        }

        //业务状态
        if (!StringUtils.isEmpty(status)) {
            if (status.equals(BusinessStatus.REJECTED.getCode()) || status.equals(BusinessStatus.COOPERATED.getCode())) {
                queryBuilder.must(termQuery("bus_status", status));
            }
        }

        //负责人
        if (!StringUtils.isEmpty(resOfficer)) {
            queryBuilder.must(queryString(resOfficer).field("resOfficer"));
        }

        if (StringUtils.isEmpty(title) && StringUtils.isEmpty(city) && StringUtils.isEmpty(status) && StringUtils.isEmpty(resOfficer)) {
            searchRequestBuilder.setQuery(matchAllQuery());
        }
        searchRequestBuilder.setQuery(queryBuilder);
        return searchRequestBuilder;
    }

}
index 参数为elasticsearch的index，

type 为elasticsearch的type，这两个值是相当重要的。千万不能写错了哦。

然后直接调用

//start为页索引，length为页容量，其它参数为查询条件。

SearchRequestBuilder searchRequestBuilder = dynamicSearch(esIndex, esType, startTime, endTime, businessState, title, city, resOfficer, start, length);
SearchResponse response = searchRequestBuilder.execute().actionGet();
以下就是循环取数据了，网上都可以查到，少了一个构建Client的方法。补上：
import org.elasticsearch.ElasticsearchException;import org.elasticsearch.client.Client;import org.elasticsearch.client.transport.TransportClient;import org.elasticsearch.common.settings.ImmutableSettings;import org.elasticsearch.common.settings.Settings;import org.elasticsearch.common.transport.InetSocketTransportAddress;import org.slf4j.Logger;import org.slf4j.LoggerFactory;/** * Created by lixiaopeng on 2015/6/25. */public class ESUtils {    private static final Logger logger = LoggerFactory.getLogger(ESUtils.class);    private static Client client;    private static PropUtil prop = PropUtil.getInstance("/global.properties");    static String IP = prop.getProperties().get("esIP").toString();    static int port = Integer.valueOf(prop.getProperties().get("esPort").toString());    public static Client getClient() {        try {//            Settings settings = ImmutableSettings.settingsBuilder()//                    .put("cluster.name", "accu-elasticsearch").build();            Settings settings = ImmutableSettings.settingsBuilder()                    .put("cluster.name", "behavior").build();            client = new TransportClient(settings).addTransportAddress(new InetSocketTransportAddress(IP, port));        } catch (ElasticsearchException e) {            e.printStackTrace();            logger.error("open elasticsearch client failure");        }        return client;    }    public static void closeClient(){        client.close();    }}