Java操作ElasticSearch

# ##java客戶端連接到ElasticSearch伺服器

創建maven工程 添加坐標 最好跟伺服器elasticsearch一致

<dependency>
     <groupId>org.elasticsearch.client</groupId>
     <artifactId>transport</artifactId>
     <version>6.2.4</version>
</dependency>
<dependency>
　　  <groupId>net.sf.json-lib</groupId>
　　　<artifactId>json-lib</artifactId>
　　　<version>2.4</version>
　　　<classifier>jdk15</classifier>
</dependency>

# ## 獲取TransportClient

java程式連接elasticsearch通過TransportClient類 

TransportClient類是一個抽象類  具體的實現是PreBulitTransportClient  

public class TestEs {

      private static String host="192.168.88.133"; // 伺服器地址
      private static int port=9300; // 埠
        
      /**
       * 創建客戶端連接到elasticsearch伺服器
       */
      @Test      
      public void teseConnection() throws Exception{
            TransportClient client = new PreBuiltTransportClient(Settings.EMPTY);
            client .addTransportAddress(new TransportAddress(InetAddress.getByName(TestEs.host), TestEs.port));
            System.out.println(client);
            client.close();
        }
}

public class TestEs {

      private static String host="192.168.88.133"; // 伺服器地址
      private static int port=9300; // 埠
      private TransportClient client=null;
        
         /**
         * 獲取連接
         * @return
         */
        @Before
        public void getCient()throws Exception{
             client = new PreBuiltTransportClient(Settings.EMPTY)
                       .addTransportAddress(new TransportAddress(InetAddress.getByName(TestEs.host), TestEs.port));
            System.out.println(client);
        }
         
        /**
         * 關閉連接
         * @param client
         */
        @After
        public void close(){
            if(client!=null){
                client.close();
            }
        }
         
        /**
         * 添加索引
         */
        @Test
        public void testAdd()throws Exception{
            IndexResponse response =client.prepareIndex("hello", "es", "1")
                .setSource(XContentFactory.jsonBuilder()
                        .startObject()
                        .field("name", "zhangsan")
                        .field("birthday", new Date())
                        .field("age", 20)
                    .endObject()
                        )
                .get();
            System.out.println("索引名稱："+response.getIndex());
            System.out.println("類型："+response.getType());
            System.out.println("文檔ID："+response.getId()); // 第一次使用是1
            System.out.println("當前實例狀態："+response.status());
        }
         
}

ElasticSearch提供了根據索引名稱，類別，文檔ID來獲取數據

　　　　 @Test
        public void testGet(){
            GetResponse getResponse=client.prepareGet("hello", "es", "1").get();
            System.out.println(getResponse.getSourceAsString());
        }

ElasticSearch提供了根據索引名稱 類別 文檔ID來修改數據 修改的設置數據可以是Map son串等

　　 @Test
    public void testUpdate() {
        Map<String, Object> map = new HashMap<String, Object>();
        map.put("name", "lisi");
        map.put("birthday", new Date());
        map.put("age", "25");
        UpdateResponse response = client.prepareUpdate("hello", "es", "1").setDoc(map).get();
        System.out.println("索引名稱：" + response.getIndex());
        System.out.println("類型：" + response.getType());
        System.out.println("文檔ID：" + response.getId()); // 第一次使用是1
        System.out.println("當前實例狀態：" + response.status());
    }

ElasticSearch提供了根據索引名稱 類別 文檔ID來刪除數據

　　@Test
    public void testDelete(){
        DeleteResponse response=client.prepareDelete("hello", "es", "1").get();
        System.out.println("索引名稱："+response.getIndex());
        System.out.println("類型："+response.getType());
        System.out.println("文檔ID："+response.getId()); // 第一次使用是1
        System.out.println("當前實例狀態："+response.status());
    }