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.QueryBuilders;

import org.elasticsearch.search.SearchHit;

import org.elasticsearch.search.sort.SortOrder;

import org.elasticsearch.transport.client.PreBuiltTransportClient;

import org.junit.Test;

import java.net.InetAddress;

import java.net.UnknownHostException;

import java.util.Map;

public class ElasticsearchTest {

    @Test

    public void queryTest() throws UnknownHostException {

        //集群设置

        //Settings settings = Settings.builder().put("cluster.name", "myClusterName").build();  //设置ES实例的名称

        Settings settings = Settings.builder().put("client.transport.sniff", false).build();

        TransportClient client = new PreBuiltTransportClient(settings);

        client.addTransportAddress(new TransportAddress(InetAddress.getByName("172.16.4.141"), 9300));

        SearchRequestBuilder searchBuilder = client.prepareSearch("logstash-*").setSize(10).setFrom(0);

        searchBuilder.addSort("@timestamp", SortOrder.DESC);

        searchBuilder.setQuery(QueryBuilders.multiMatchQuery("Success", "logger_name", "message", "host"));

        searchBuilder.setQuery(QueryBuilders.matchPhraseQuery("level", "INFO"));

        searchBuilder.setQuery(QueryBuilders.matchPhraseQuery("appName", "backend-sync"));

        searchBuilder.setQuery(QueryBuilders.rangeQuery("@timestamp").from("2018-12-04T10:50:19.379Z").to("2018-12-04T10:58:19.379Z"));

        SearchResponse response = searchBuilder.execute().actionGet();

        System.out.println("TotalHits:" + response.getHits().getTotalHits());

        System.out.println("TotalHits Return:" + response.getHits().getHits().length);

        System.out.println("MaxScore:" + response.getHits().getMaxScore());

        for (SearchHit hit : response.getHits()) {

            Map<String, Object> map = hit.getSourceAsMap();

            if (map != null) {

                System.out.println(hit.getSourceAsString());

            }

        }

        client.close();

    }

}