Elasticsearch Java API—多条件查询(must)

Posted 2020-10-11 人艰不拆_zmc

多条件设置

//多条件设置
MatchPhraseQueryBuilder mpq1 = QueryBuilders
                .matchPhraseQuery("pointid","W3.UNIT1.10LBG01CP301");
MatchPhraseQueryBuilder mpq2 = QueryBuilders
                .matchPhraseQuery("inputtime","2016-07-21 00:00:01");
QueryBuilder qb2 = QueryBuilders.boolQuery().must(mpq1).must(mpq2);

Demo:

package com.zx.znyd.es;
 
import java.io.IOException;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;import org.apache.commons.lang.StringUtils;
import org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.search.SearchType;
import org.elasticsearch.client.Client;
import org.elasticsearch.client.Requests;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.mustache.Mustache;
import org.elasticsearch.common.settings.ImmutableSettings;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.common.transport.TransportAddress;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentFactory;
import org.elasticsearch.index.query.MatchQueryBuilder.Operator;
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.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
import com.alibaba.fastjson.JSONObject;
import com.zx.znyd.common.MD5;
import com.zx.znyd.common.SpringContextUtil;
import com.zx.znyd.dao.AutoReplyDao;
import com.zx.znyd.data.model.AutoReply;
import com.zx.znyd.data.model.LogIndex;
import com.zx.znyd.service.AutoReplyDeployService;
 
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:applicationContext.xml")
public class TestES {
 
    @Autowired
    @Qualifier("esClient")
    private Client client;
     
    @Test 
    public void testSearch() 
    { 
        String index="index_log_daily";
        String type="uq_log";
        String uquestion = "139";
        String province = "江苏";
        SearchResponse searchResponse = client.prepareSearch(index) 
                .setTypes(type) 
                .setQuery(QueryBuilders.matchAllQuery()) //查询所有
                .setQuery(QueryBuilders.boolQuery()
                .must(QueryBuilders.matchQuery("uquestion", uquestion))//查询uquestion为139的
                .must(QueryBuilders.matchQuery("province", province)))//查询省份为江苏的       
                .setSearchType(SearchType.QUERY_THEN_FETCH) 
                .setFrom(0).setSize(10)//分页 
                //.addSort("age", SortOrder.DESC)//排序 
                .get(); 
           
        SearchHits hits = searchResponse.getHits(); 
        long total = hits.getTotalHits(); 
        System.out.println(total); 
        SearchHit[] searchHits = hits.hits(); 
        for(SearchHit s : searchHits) 
        { 
            System.out.println(s.getSourceAsString());
            String []logindex=s.getSourceAsString().split(",");
             
        } 
    } 
}

　　贴下我的代码：

       /**
	 * 错误日志统计
	 */
	@Override
	public List<TomcatModel> errorTomcatRequest(Page page, String index,String startDate, String endDate) {
		TransportClient client = getClient();
		if (index.isEmpty() == true) {
			return null;
		}
		DateInterval dateInterval = RegexUtil.getDateInterval(new DateInterval(startDate,endDate),"yyyyMMdd");
		List<TomcatModel> list = new ArrayList<TomcatModel>();
		try {
			SearchResponse response = client.prepareSearch(index).setTypes(getIndexType()).setFrom(page.getStart())
					.setSize(page.getLength())
					.setQuery(QueryBuilders.boolQuery().must(QueryBuilders.regexpQuery("response", "[4-6][0-9][0-9]"))
					.must(QueryBuilders.rangeQuery("@timestamp").format("yyyyMMdd").from(dateInterval.getStartDate()).to(dateInterval.getEndDate())))
					.addSort("@timestamp", SortOrder.ASC)
					.execute().actionGet();
			SearchHits myhits = response.getHits();
			page.setRecordsFiltered((int) myhits.getTotalHits());
			page.setRecordsTotal((int) myhits.getTotalHits());

			int i = 1;
			for (SearchHit hit : myhits.getHits()) {
				TomcatModel tomcat = new TomcatModel();
				Map<String, Object> map = hit.getSource();
				tomcat.setClientip((String) map.get("clientip"));
				tomcat.setResponse((String) map.get("response"));
				tomcat.setMessage((String) map.get("message"));
				tomcat.setType((String) map.get("verb"));
				tomcat.setTimestamp((String) map.get("timestamp"));
				tomcat.setRowId(i);
				list.add(tomcat);
				i++;
			}
		} catch (IndexNotFoundException e) {
			System.err.println("此索引不存在!");
		}catch (Exception e) {
			e.printStackTrace();
		}
		return list;
	}