Elasticsearch(Transport Client)常用操作

這里描述操作elasticsearch采用TransportClient這種方式，官方明確表示在ES 7.0版本中將棄用TransportClient客戶端，且在8.0版本中完全移除它.
記錄一些常用的方法：

官方文檔：
TransportClient

/** * 簡單查詢es 指定index type id */
@Test
  public void search() throws UnknownHostException {
         //獲取client
        Settings settings= Settings.builder().put("cluster.name","my-application").build();
        TransportClient transportClient=new PreBuiltTransportClient(settings);
        transportClient.addTransportAddress(new 
          TransportAddress(InetAddress.getByName("localhost"),9300));
        // 發起請求得到響應
        GetResponse  response=transportClient.prepareGet("index3","user3","10").get();
        System.out.println(response.getSource());
  }
 /** * 增加文檔 */
    @Test
     public void insert() throws Exception{
         Settings settings= Settings.builder().put("cluster.name","my-application").build();
         TransportClient client=new PreBuiltTransportClient(settings);
         client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));
         XContentBuilder contentBuilder= XContentFactory.jsonBuilder()
                 .startObject()
                 .field("catid","22")
                 .field("classify",54)
                 .field("author","ssve")
                 .field("id","1")
                 .field("title","菜鳥成長記")
                 .endObject();
         IndexResponse indexResponse = client.prepareIndex("index3", "user3", "10")
                 .setSource(contentBuilder)
                 .get();
         System.out.println(indexResponse.status());
     }
 /** * 刪除文檔 */
     @Test
    public void delete() throws Exception{
        Settings settings=Settings.builder().put("cluster.name","my-application").build();
        TransportClient client=new PreBuiltTransportClient(settings);
        client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));
 
        DeleteResponse deleteResponse = client.prepareDelete("index3", "user3", "10").get();
 
        System.out.println(deleteResponse.status());
    }
 /** * 修改文檔 */
    @Test
    public void update() throws Exception{
        Settings settings=Settings.builder().put("cluster.name","my-application").build();
        TransportClient client=new PreBuiltTransportClient(settings);
        client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));
 
        UpdateRequest request=new UpdateRequest();
        XContentBuilder contentBuilder=XContentFactory.jsonBuilder()
                .startObject()
                .field("id","555")
                .endObject();
        request.index("index3")
                .type("user3")
                .id("10")
                .doc(contentBuilder);
        UpdateResponse updateResponse = client.update(request).get();
 
        System.out.println(updateResponse.status());
    }
 /** *upsert使用 如有存在對應文檔就修改 不存在就新增 需要指定修改的文檔 和新增的文檔 */
    @Test
    public void upsert() throws IOException, ExecutionException, InterruptedException {
        Settings settings=Settings.builder().put("cluster.name","my-application").build();
        TransportClient client=new PreBuiltTransportClient(settings);
        client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));
 
        XContentBuilder builder=XContentFactory.jsonBuilder()
                .startObject()
                .field("catid","22")
                .field("classify",54)
                .field("author","zhang")
                .field("id","10")
                .field("title","菜鳥成長記")
                .endObject();
        UpdateRequest request=new UpdateRequest();
        IndexRequest indexRequest=new IndexRequest();
        indexRequest.index("index3")
                .type("user3")
                .id("11")
                .source(builder);
        request.index("index3")
                .type("user3")
                .id("11")
                .doc(new XContentFactory().jsonBuilder()
                        .startObject()
                        .field("id","i love you")
                        .endObject()
                ).upsert(indexRequest);
        UpdateResponse updateResponse = client.update(request).get();
 
        System.out.println(updateResponse.status());
 
    }
 /** * * 批量查詢 multiGet */
    @Test
    public  void multiGet() throws Exception{
        Settings settings=Settings.builder().put("cluster.name","my-application").build();
        TransportClient client=new PreBuiltTransportClient(settings);
        client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));
 
 
        MultiGetRequest request=new MultiGetRequest();
        request.add("index3","user3","11");
        request.add("index3","user3","10");
        request.add("index3","user3","13");
        request.add("index3","user3","14");
        MultiGetResponse multiGetItemResponses = client.multiGet(request).get();
 
        for (MultiGetItemResponse response:multiGetItemResponses) {
            System.out.println(response.getResponse().getSourceAsString());
        }
 
    }
    /** * * bulk實現批量增刪改操作。 */
    @Test
    public void bulk() throws Exception{
        Settings settings=Settings.builder().put("cluster.name","my-application").build();
        TransportClient client=new PreBuiltTransportClient(settings);
        client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));
 
        BulkRequestBuilder bulkRequestBuilder = client.prepareBulk();
        IndexRequest request=new IndexRequest();
        request.index("index3")
                .type("user3")
                .id("13")
                .source(XContentFactory.jsonBuilder()
                .startObject()
                .field("catid","85")
                .field("classify","85")
                .field("author","宇宙無敵")
                .field("id","漫威")
                .field("title","漫威")
                .endObject());
 
        IndexRequest request1=new IndexRequest();
        request1.index("index3")
                .type("user3")
                .id("14")
                .source(XContentFactory.jsonBuilder()
                        .startObject()
                        .field("catid","55")
                        .field("classify","85")
                        .field("author","宇宙無敵")
                        .field("id","漫威")
                        .field("title","漫威")
                        .endObject());
        bulkRequestBuilder.add(request1);
        bulkRequestBuilder.add(request);
        BulkResponse bulkItemResponses = bulkRequestBuilder.get();
        System.out.println(bulkItemResponses.status());
 
    }
  /** * * 使用query查詢 match_all 查詢所有 */
    @Test
    public void query() throws Exception{
        Settings settings=Settings.builder().put("cluster.name","my-application").build();
        TransportClient client=new PreBuiltTransportClient(settings);
        client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));
 
        MatchAllQueryBuilder builder= QueryBuilders.matchAllQuery();
 
 
        SearchRequestBuilder index3 = client.prepareSearch("index3")
                .setQuery(builder)
                .setSize(5);
        SearchResponse searchResponse = index3.get();
        SearchHits hits =  searchResponse.getHits();
        for (SearchHit hit:hits) {
            System.out.println(hit.getSourceAsString());
        }
    }
    /** * * 使用query查詢 match 查詢 */
    @Test
    public void matchQuery() throws Exception{
        Settings settings=Settings.builder().put("cluster.name","my-application").build();
        TransportClient client=new PreBuiltTransportClient(settings);
        client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));
 
        MatchQueryBuilder matchQueryBuilder = QueryBuilders.matchQuery("title", "愛");
        SearchRequestBuilder index = client.prepareSearch("index3").setQuery(matchQueryBuilder).setSize(10);
        SearchHits hits = index.get().getHits();
        for (SearchHit hit:hits
             ) {
            System.out.println(hit.getSourceAsString());
        }
    }
    /** * * 使用query查詢 mutilMatch 查詢 */
    @Test
    public void mutilMatchQuery() throws Exception{
        Settings settings=Settings.builder().put("cluster.name","my-application").build();
        TransportClient client=new PreBuiltTransportClient(settings);
        client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));
 
        MultiMatchQueryBuilder multiMatchQueryBuilder = QueryBuilders.multiMatchQuery("周星馳影帝", "author","title");
        SearchRequestBuilder index = client.prepareSearch("index3").setQuery(multiMatchQueryBuilder).setSize(10);
        SearchHits hits = index.get().getHits();
        for (SearchHit hit:hits
        ) {
            System.out.println(hit.getSourceAsString());
        }
    }
 
    /** * * 使用query查詢 termheterms查詢 */
    @Test
    public void termsMatchQuery() throws Exception{
        Settings settings=Settings.builder().put("cluster.name","my-application").build();
        TransportClient client=new PreBuiltTransportClient(settings);
        client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));
 
        TermsQueryBuilder termsQueryBuilder = QueryBuilders.termsQuery("title", "周星馳", "影帝");
        SearchRequestBuilder index = client.prepareSearch("index3").setQuery(termsQueryBuilder).setSize(10);
        SearchHits hits = index.get().getHits();
        for (SearchHit hit:hits
        ) {
            System.out.println(hit.getSourceAsString());
        }
    }
 
    /** * * 使用query查詢 范圍 通配符 前綴 模糊查詢 */
    @Test
    public void query1() throws Exception{
        Settings settings=Settings.builder().put("cluster.name","my-application").build();
        TransportClient client=new PreBuiltTransportClient(settings);
        client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));
        //范圍查詢
        //QueryBuilder queryBuilder = QueryBuilders.rangeQuery("classify").from("1").to("40");
 
        //通配符查詢 * 零個或多個
// QueryBuilder queryBuilder = QueryBuilders.wildcardQuery("author","周*");
 
        //前綴查詢
// QueryBuilder queryBuilder = QueryBuilders.prefixQuery("author","周");
 
        //模糊查詢 查詢類型的
// QueryBuilder queryBuilder = QueryBuilders.fuzzyQuery("id","aac");
 
        //id查詢
 
        QueryBuilder queryBuilder = QueryBuilders.idsQuery().addIds("1","2","4");
        SearchRequestBuilder index = client.prepareSearch("index3").setQuery(queryBuilder).setSize(10);
        SearchHits hits = index.get().getHits();
        for (SearchHit hit:hits
        ) {
            System.out.println(hit.getSourceAsString());
        }
    }
 
    /** * * 聚合查詢 */
    @Test
    public void aggregation() throws Exception{
        Settings settings=Settings.builder().put("cluster.name","my-application").build();
        TransportClient client=new PreBuiltTransportClient(settings);
        client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));
 
 
        AggregationBuilder aggregationBuilder= AggregationBuilders.max("max").field("id");
 
        SearchResponse index3 = client.prepareSearch("index3").addAggregation(aggregationBuilder).get();
 
        Max max = index3.getAggregations().get("max");
 
        System.out.println(max.getValue());
    }
    /** * * queryString */
    @Test
    public void queryString() throws Exception{
        Settings settings=Settings.builder().put("cluster.name","my-application").build();
        TransportClient client=new PreBuiltTransportClient(settings);
        client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));
        // + 代表必須有 -代表沒有 
        QueryBuilder queryBuilder=QueryBuilders.queryStringQuery("+周星馳 -sss");
        SearchRequestBuilder index3 = client.prepareSearch("index3")
                .setQuery(queryBuilder)
                .setSize(10);
        SearchResponse searchResponse = index3.get();
        for (SearchHit hit:searchResponse.getHits()) {
            System.out.println(hit.getSourceAsString());
        }
    }
 
    /** * * 組合查詢 */
    @Test
    public void boolQuery() throws Exception{
        Settings settings=Settings.builder().put("cluster.name","my-application").build();
        TransportClient client=new PreBuiltTransportClient(settings);
        client.addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"),9300));
        QueryBuilder queryBuilder=QueryBuilders.boolQuery()
                .must(QueryBuilders.matchQuery("author","周星馳"))
                .mustNot(QueryBuilders.matchQuery("title","梁朝偉"))
                .should(QueryBuilders.matchQuery("title","影帝"))
                .filter(QueryBuilders.rangeQuery("id").gte("1"));
 
 
        SearchRequestBuilder index3 = client.prepareSearch("index3")
                .setQuery(queryBuilder)
                .setSize(10);
        SearchResponse searchResponse = index3.get();
        for (SearchHit hit:searchResponse.getHits()) {
            System.out.println(hit.getSourceAsString());
        }
    }