員工資訊

姓名
年齡
職位
國家
入職日期
薪水

1、maven依賴

log4j2.properties

appender.console.type = Console
appender.console.name = console
appender.console.layout.type = PatternLayout

rootLogger.level = info
rootLogger.appenderRef.console.ref = console

2、構建client

Settings settings = Settings.builder()
.put(“cluster.name”, “myClusterName”).build();
TransportClient client = new PreBuiltTransportClient(settings);

TransportClient client = new PreBuiltTransportClient(Settings.EMPTY)
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(“host1”), 9300))
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(“host2”), 9300));

client.close();

3、建立document

IndexResponse response = client.prepareIndex(“index”, “type”, “1”)
.setSource(jsonBuilder()
.startObject()
.field(“user”, “kimchy”)
.field(“postDate”, new Date())
.field(“message”, “trying out Elasticsearch”)
.endObject()
)
.get();

4、查詢document

GetResponse response = client.prepareGet(“index”, “type”, “1”).get();

5、修改document

client.prepareUpdate(“index”, “type”, “1”)
.setDoc(jsonBuilder()
.startObject()
.field(“gender”, “male”)
.endObject())
.get();

6、刪除document

DeleteResponse response = client.prepareDelete(“index”, “type”, “1”).get();