ElasticSearch 利用Java接口创建索引以及操作文档
pom.xml：
<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>org.ssgroup</groupId>
<artifactId>elasticsearch</artifactId>
<version>0.0.1-SNAPSHOT</version>
<dependencies>
<dependency>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
<version>6.3.2</version>
</dependency>
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>transport</artifactId>
<version>6.3.2</version>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.8.2</version>
</dependency>
</dependencies>
</project>
ElasticSearch Demo：
package org.ssgroup;
import java.net.InetAddress;
import java.net.UnknownHostException;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.TransportAddress;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import com.google.gson.JsonObject;
public class ElasticSearchConnection {
private static String ES_HOST1 = "192.168.10.252";
private static String ES_HOST2 = "192.168.10.254";
private static String ES_HOST3 = "192.168.10.255";
private static int ES_PORT = 9300;
@SuppressWarnings({ "resource", "unchecked" })
public static void main(String[] args) throws UnknownHostException {
Settings settings = Settings.builder()
.put("cluster.name", "my-application").build();
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName(ES_HOST1), ES_PORT))
.addTransportAddress(new TransportAddress(InetAddress.getByName(ES_HOST2), ES_PORT))
.addTransportAddress(new TransportAddress(InetAddress.getByName(ES_HOST3), ES_PORT));
//创建索引
createIndex(client);
//获取文档
getDoc(client);
//更新文档
updateDoc(client);
//删除文档
deleteDoc(client);
client.close();
}
/**
* 创建索引
* @param client
*/
public static void createIndex(TransportClient client) {
JsonObject jsonObject = new JsonObject();
jsonObject.addProperty("name", "java编程思想");
jsonObject.addProperty("publishDate", "2018-10-24");
jsonObject.addProperty("price", "100");
IndexResponse response = client.prepareIndex("book", "java","1")
.setSource(jsonObject.toString(),XContentType.JSON).get();
System.out.println("索引名称："+response.getIndex());
System.out.println("文档类型："+response.getType());
System.out.println("文档ID："+response.getId());
System.out.println("当前实例状态："+response.status());
}
/**
* 获取文档
* @param client
*/
public static void getDoc(TransportClient client) {
GetResponse response = client.prepareGet("book", "java","1").get();
System.out.println(response.getSourceAsString());
}
/**
* 更新文档
* @param client
*/
public static void updateDoc(TransportClient client) {
JsonObject jsonObject = new JsonObject();
jsonObject.addProperty("name", "java-编程思想-2");
jsonObject.addProperty("publishDate", "2018-10-25");
jsonObject.addProperty("price", "100");
UpdateResponse response = client.prepareUpdate("book", "java","1").setDoc(jsonObject.toString(), XContentType.JSON).get();
System.out.println("索引名称："+response.getIndex());
System.out.println("文档类型："+response.getType());
System.out.println("文档ID："+response.getId());
System.out.println("当前实例状态："+response.status());
}
/**
* 删除文档
* @param client
*/
public static void deleteDoc(TransportClient client) {
DeleteResponse response = client.prepareDelete("book", "java","1").get();
System.out.println("索引名称："+response.getIndex());
System.out.println("文档类型："+response.getType());
System.out.println("文档ID："+response.getId());
System.out.println("当前实例状态："+response.status());
}
}
