本地實(shí)現(xiàn)es查詢

本篇內(nèi)容介紹了“本地實(shí)現(xiàn)es查詢”的有關(guān)知識(shí)，在實(shí)際案例的操作過(guò)程中，不少人都會(huì)遇到這樣的困境，接下來(lái)就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧！希望大家仔細(xì)閱讀，能夠?qū)W有所成！

import cn.jpush.statistics.elasticsearch.ReportDO;
import cn.jpush.statistics.util.JsonUtil;
import com.google.common.collect.Lists;
import lombok.extern.slf4j.Slf4j;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.TransportAddress;
import org.elasticsearch.index.query.*;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import org.joda.time.DateTime;
import org.joda.time.DateTimeFieldType;
import org.joda.time.LocalDate;

import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import static org.elasticsearch.index.query.QueryBuilders.matchQuery;

@Slf4j
public class EsClient {
    public static void main(String[] args) throws UnknownHostException {
            esSearch();
    }

    private static void esSearch() throws UnknownHostException {
        //指定集群
        Settings settings = Settings.builder().put("cluster.name", "elasticsearch").put("client.transport.sniff",false).build();
        // 創(chuàng)建訪問(wèn)es的客戶端
        TransportClient client = new PreBuiltTransportClient(settings)
                .addTransportAddress(new TransportAddress(InetAddress.getByName("127.0.0.1"),9300));
//        TermQueryBuilder query = QueryBuilders.termQuery("channel", "GDT");
        BoolQueryBuilder query = QueryBuilders.boolQuery();
        List<QueryBuilder> must = query.must();
        must.add(QueryBuilders.termsQuery("channel", "GDT".toLowerCase()));
        DateTime start = new DateTime(2017,1,1,0,0,0);
        DateTime end = new DateTime(2020,9,1,0,0,0);
        must.add(QueryBuilders.termQuery( "advertiser_id", 12));
        must.add(QueryBuilders.termQuery( "product_id", 98));
        RangeQueryBuilder rangeQueryBuilder = QueryBuilders
                .rangeQuery("query_time")
                .gt(start.getMillis())
                .lte(end.getMillis())
                .format("epoch_millis");
        must.add(rangeQueryBuilder);
//        must.add(QueryBuilders.termsQuery("advertiser_id", Lists.newArrayList(243)));
        SearchRequestBuilder builder = client.prepareSearch("ad-report-v3-20*")
                .setTypes("report")
                .setQuery(query);

        log.info("elastic.list.query.string: \n\n{}\n\n",builder.toString());
        SearchResponse response = builder
//                .setSize(3)
                .get();
        for (SearchHit hit : response.getHits()) {
            String sourceAsString = hit.getSourceAsString();
            ReportDO reportDO = JsonUtil.parseObject(sourceAsString, ReportDO.class);

            System.out.println(JsonUtil.toJsonString(reportDO));
        }
        client.close();
    }
}

“本地實(shí)現(xiàn)es查詢”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注億速云網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實(shí)用文章！