Es學習第十一課，使用java操作elasticsearch

  前面十節課我們已經把ES的基本概念和使用講的差不多了，現在我們就用基於java來實際開發一個操作ES的小項目，帶大家來一起練練手。

1、我們用IDEA創建一個maven項目

項目結構如上圖所示，然后我們就引入操作ES需要用到的jar和JUNIT,pom.xml最終配置如下：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.kakatadage</groupId>
    <artifactId>esdemo</artifactId>
    <version>1.0-SNAPSHOT</version>

<dependencies>
    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <version>4.12</version>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>transport</artifactId>
        <version>6.5.1</version>
    </dependency>

</dependencies>

    <build>
    <finalName>esdemo</finalName>
    <plugins>
    <plugin>
        <!-- 設置javac編譯器的版本和編碼字符 -->
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-compiler-plugin</artifactId>
        <configuration>
            <source>1.8</source>
            <target>1.8</target>
            <encoding>utf8</encoding><!-- 編譯器編碼 -->
        </configuration>
    </plugin>
    </plugins>
    </build>
</project>

 項目創建完成后，我們就可以針對ES實現數據的增刪改查了。

2、實現ES實現查詢

 新建一個測試類，如下圖：

 

 最后代碼如下所示：

package com.kakatadage.esdemo.test;

import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.TransportAddress;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import org.junit.Test;

import java.net.InetAddress;
import java.net.UnknownHostException;

public class EsDemo {

    //從ES中查詢數據
    @Test
    public void test1() throws UnknownHostException {
        //指定ES集群
        Settings setting = Settings.builder().put("cluster.name",
                "my-application").build();

        //創建訪問ES服務器的客戶端
        TransportClient client = new PreBuiltTransportClient(Settings.EMPTY)
                                 .addTransportAddress(
                                         new TransportAddress(
                                                 InetAddress.getByName("127.0.0.1"),9300));
        //get方式數據查詢 ,參數為Index,type和id
        GetResponse response = client.prepareGet("lib4","items","5").get();

        System.out.println(response.getSourceAsString());
        client.close();
    }
}

返回結果就是一個JSON字符串

{ "price" : null, "itemID" : "ID1005" }

 

3、java 插入ES一條數據

   //插入數據
    @Test
    public void test2() throws IOException {
        //指定ES集群
        Settings setting = Settings.builder().put("cluster.name",
                "my-application").build();

        //創建訪問ES服務器的客戶端
        TransportClient client = new PreBuiltTransportClient(Settings.EMPTY)
                .addTransportAddress(
                        new TransportAddress(
                                InetAddress.getByName("127.0.0.1"),9300));

        XContentBuilder doc = XContentFactory.jsonBuilder()
                .startObject()
                .field("id","1")
                .field("title","我在學習es插入操作")
                .field("content","好好學習，天天向上")
                .endObject();

        //添加一個doc
        IndexResponse response = client.prepareIndex("lib5","testadd",null)//id為null，由ES自己生成
                .setSource(doc).get();
        System.out.println(response.status());//打印添加是否成功
        client.close();
    }

返回結果：

{
  "took": 1,
  "timed_out": false,
  "_shards": {
    "total": 5,
    "successful": 5,
    "skipped": 0,
    "failed": 0
  },
  "hits": {
    "total": 1,
    "max_score": 1,
    "hits": [
      {
        "_index": "lib5",
        "_type": "testadd",
        "_id": "dympT2cBfvwZhJjhaFQ3",
        "_score": 1,
        "_source": {
          "id": "1",
          "title": "我在學習es插入操作",
          "content": "好好學習，天天向上"
        }
      }
    ]
  }
}

4、java 刪除ES一個文檔

    //刪除文檔
    @Test
    public void test3() throws IOException {
        //指定ES集群
        Settings setting = Settings.builder().put("cluster.name",
                "my-application").build();

        //創建訪問ES服務器的客戶端
        TransportClient client = new PreBuiltTransportClient(Settings.EMPTY)
                .addTransportAddress(
                        new TransportAddress(
                                InetAddress.getByName("127.0.0.1"),9300));

        DeleteResponse response = client.prepareDelete("lib5","testadd","dympT2cBfvwZhJjhaFQ3")
                .get();
        System.out.println(response.status());//打印添加是否成功
        client.close();
    }

5、java 修改ES一個文檔

我們先新增一個，然后根據它的ID來更新

    //更新文檔
    @Test
    public void test4() throws IOException, ExecutionException, InterruptedException {
        //指定ES集群
        Settings setting = Settings.builder().put("cluster.name",
                "my-application").build();

        //創建訪問ES服務器的客戶端
        TransportClient client = new PreBuiltTransportClient(Settings.EMPTY)
                .addTransportAddress(
                        new TransportAddress(
                                InetAddress.getByName("127.0.0.1"),9300));
        UpdateRequest request = new UpdateRequest();
        request.index("lib5")
                .type("testadd")
                .id("eCm1T2cBfvwZhJjhF1SM")
                .doc(
                        XContentFactory.jsonBuilder().startObject()
                        .field("title","我在學習ES的修改操作")
                                .field("newadd","新增字段")
                        .endObject()
                );
        UpdateResponse response = client.update(request).get();

        System.out.println(response.status());//打印是否成功
        client.close();
    }