创建索引和中文的分词器
PUT /index1
{
"settings":{
"number_of_shards": 3
, "number_of_replicas": 0
},
"mappings":{
"blog":{
"properties":{
"id":{
"type":"long"
},
"title":{
"type":"text",
"analyzer": "ik_max_word"
},
"content":{
"type":"text",
"analyzer": "ik_max_word"
},
"postdate":{
"type":"date"
},
"url":{
"type":"text"
}
}
}
}
}
添加数据
@Test
public void test2() throws IOException {
//指定ES集群
Settings settings = Settings.builder().put("cluster.name","haijines").build();
//创建访问es服务器的客户端
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.42.159"),9300));
//添加文档
/*
*
*/
// {
// "id":"1",
// "title":"java查询elasticsearch的数据",
// "content":"java查询elasticsearch的数据",
// "postdate":"2020-02-28",
// "url":"https://www.haijin.xyz/user/info/info.html?id=75"
// }
XContentBuilder doc = XContentFactory.jsonBuilder()
.startObject()
.field("id","1")
.field("title","java查询elasticsearch的数据")
.field("content","java查询elasticsearch的数据")
.field("postdate","2020-02-28")
.field("url","https://www.haijin.xyz/user/info/info.html?id=75")
.endObject();
//添加文档
IndexResponse response = client.prepareIndex("index1", "blog","10")
.setSource(doc).get();
System.out.println(response.status());
}
删除数据
//删除文档
@Test
public void test3() throws UnknownHostException{
//指定ES集群
Settings settings = Settings.builder().put("cluster.name","haijines").build();
//创建访问es服务器的客户端
TransportClient client = new PreBuiltTransportClient(settings)
.addTransportAddress(new TransportAddress(InetAddress.getByName("192.168.42.159"),9300));
//删除文档
DeleteResponse response = client.prepareDelete("index1","blog","10").get();
System.out.println(response.status());
}
kibana查询
GET index1/blog/10