java操作elasticsearch實現批量添加數據（bulk）

java操作elasticsearch實現批量添加主要使用了bulk

代碼如下：

//bulk批量操作(批量添加)
    @Test
    public void test7() throws IOException {
//1、指定es集群  cluster.name 是固定的key值，my-application是ES集群的名稱
        Settings settings = Settings.builder().put("cluster.name", "my-application").build();
        //2.創建訪問ES服務器的客戶端
        TransportClient client = new PreBuiltTransportClient(settings)
                //獲取es主機中節點的ip地址及端口號(以下是單個節點案例)
                                .addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.1.94"), 9300));
        
        BulkRequestBuilder builder = client.prepareBulk();
        IndexRequestBuilder request = client.prepareIndex("lib2","books","8").setSource(
                XContentFactory.jsonBuilder()
                .startObject()
                .field("title","python")
                .field("price",99)
                .endObject()
                );
        IndexRequestBuilder request2 = client.prepareIndex("lib2","books","9").setSource(
                XContentFactory.jsonBuilder()
                .startObject()
                .field("title","VR")
                .field("price",29)
                .endObject()
                );
        builder.add(request);
        builder.add(request2);
//該方法ES默認是分片1秒鍾后刷新，即插入成功后馬上查詢，插入的數據不能馬上被查出
        BulkResponse response = builder.get();
        System.out.println(response.status());
        if(response.hasFailures()) {
            System.out.println("操作失敗");
        }
    }

下一篇博客本人將書寫java操作elasticsearch實現查詢刪除及查詢所有。對后期博客感興趣的朋友可以關注交流，轉發請說明出處，本人的博客地址為：https://www.cnblogs.com/chenyuanbo/

技術在於交流！