ElasticSearch基於Java實現員工資訊的增刪改查
員工資訊
姓名
年齡
職位
國家
入職日期
薪水
1、maven依賴
org.elasticsearch.client transport 5.2.2 org.apache.logging.log4j log4j-api 2.7 org.apache.logging.log4j log4j-core 2.7log4j2.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();