本篇內容介紹了“本地實現es查詢”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

在大洼等地區(qū)，都構建了全面的區(qū)域性戰(zhàn)略布局，加強發(fā)展的系統性、市場前瞻性、產品創(chuàng)新能力，以專注、極致的服務理念，為客戶提供成都網站制作、成都網站設計、外貿營銷網站建設 網站設計制作按需定制網站,公司網站建設,企業(yè)網站建設,品牌網站設計,營銷型網站建設,成都外貿網站建設公司,大洼網站建設費用合理。

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)建訪問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();
    }
}

“本地實現es查詢”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關的知識可以關注創(chuàng)新互聯網站，小編將為大家輸出更多高質量的實用文章！

標題名稱：本地實現es查詢
網頁鏈接：http://www.chinadenli.net/article8/pesjop.html

成都網站建設公司_創(chuàng)新互聯，為您提供外貿網站建設、ChatGPT、面包屑導航、移動網站建設、、App設計

廣告

聲明：本網站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯