ElasticSearch BoolQueryBuilder使用

package com.agileeagle.gf.dw.test;

import com.agileeagle.gf.dw.util.DateUtils;
import com.google.common.collect.Lists;
import org.apache.lucene.queryparser.xml.builders.BooleanQueryBuilder;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.search.SearchType;
import org.elasticsearch.client.Client;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.Strings;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.MatchAllQueryBuilder;
import org.elasticsearch.index.query.MatchQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.sort.SortOrder;
import org.junit.*;

import java.net.InetSocketAddress;
import java.util.List;
import java.util.Map;

/**
* Created by wangpeng on 2016/11/8.
*/
public class TestNew {
public static final String  clusterName = "my-application";
public static final String  host = "192.168.0.209";
public static final int  port = 9300;
private static final String TIMESTAMP = "@timestamp";
private static final String DCREATETIME = "d_create_time";
private static final String DEFAULTSTRING = "0";
private static final String PARAMETER = "s_content";
private static final String GROUPID = "n_group_id";
private static final String NID = "n_id";
private static final String QUANCOMMENTS = "quan-dynamic-comments";
private static final String QUANINFO = "quan-dynamic-info";
private static final String TOKEN_URL = "token.connect.url";
private static final String GROUP_URL = "cid.connect.url";
private static final int ESSIZE = 100;
private static final int GROUP = 1;
private static final int IM = 2;
private static final int DYNAMIC = 3;
private static final int STARTNUM = 0;

private DateUtils dateUtils = new DateUtils();

private TransportClient getTransportClient() {
TransportClient transportClient = null;
Settings settings = Settings.settingsBuilder().put("cluster.name", clusterName).put("client.transport.sniff", true).build();
try {
transportClient = new TransportClient.Builder().settings(settings).build()
.addTransportAddress(new InetSocketTransportAddress(new InetSocketAddress(host, port)));
} catch (Exception e) {
e.printStackTrace();
}
return transportClient;
}

@org.junit.Test
public void testNew() throws Exception {
int info = 1;
String startDate = "2016-10-01 00:00:00";
String endDate = "2016-11-08 23:59:59";
String torres = "测试";
String uid = "";
String groupId = "320";

String[] indexName = {"group-message-2016.10"};
String[] type = {"group-message"};

List<Map<String,Object>> mapList = getGroupInfoFromES(startDate, endDate, torres, uid, groupId, indexName, type );
System.out.println(mapList);
}

private List<Map<String,Object>> getGroupInfoFromES(String startDate, String endDate, String torres, String uid, String groupId, String[] indexName, String[] type) throws Exception{
Client client = getTransportClient();

SearchRequestBuilder srq = client.prepareSearch(indexName).setTypes(type);
srq.setSearchType(SearchType.DFS_QUERY_AND_FETCH);

BoolQueryBuilder booleanQueryBuilder = QueryBuilders.boolQuery();
if (Strings.isNullOrEmpty(torres)) {
//            MatchAllQueryBuilder matchAllQueryBuilder = QueryBuilders.matchAllQuery();
//            srq.setQuery(matchAllQueryBuilder);
booleanQueryBuilder.must(QueryBuilders.matchAllQuery());
} else {
//            MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchPhraseQuery(PARAMETER, torres).slop(0);
//            srq.setQuery(matchQueryBuilder);
booleanQueryBuilder.must(QueryBuilders.matchPhraseQuery(PARAMETER, torres).slop(0));
}
if (!Strings.isNullOrEmpty(startDate) && !Strings.isNullOrEmpty(endDate)) {
srq.setPostFilter(QueryBuilders.rangeQuery(TIMESTAMP).from(
dateUtils.getUTCTimeZoneTime(startDate)).to(dateUtils.getUTCTimeZoneTime(endDate))
);
}
if (!Strings.isNullOrEmpty(uid)) {
//            MatchQueryBuilder matchQuery = QueryBuilders.matchQuery(NID, uid);
//            srq.setQuery(matchQuery);
booleanQueryBuilder.must(QueryBuilders.matchQuery(NID, uid));
}
if (!Strings.isNullOrEmpty(groupId)) {
//            MatchQueryBuilder matchQuery = QueryBuilders.matchQuery(GROUPID, groupId);
//            srq.setQuery(matchQuery);
booleanQueryBuilder.must(QueryBuilders.matchQuery(GROUPID, groupId));
}
srq.setQuery(booleanQueryBuilder).addSort(TIMESTAMP, SortOrder.DESC);

SearchResponse response = srq.setFrom(STARTNUM).setSize(ESSIZE).execute().actionGet();
SearchHits hits = response.getHits();

List<Map<String,Object>> mapList = Lists.newArrayList();
for (int i = STARTNUM; i < hits.getHits().length; i++) {
SearchHit hit = hits.getHits()[i];
Map<String, Object> val = hit.getSource();
mapList.add(val);
}

return mapList;
}
}