elasticsearch JAVA客户端操作---索引的CURD
程序员文章站
2022-07-01 15:29:10
...
源码地址:源码下载点击
索引的创建
public void addindex01() {
UserModel user = new UserModel();
user.setId(1);
user.setName("李四");
user.setAge("101");
user.setSex("1231");
user.setTel("Tel");
String jsondata = ESUtils.toJson(user);
System.out.println("封装的json:"+jsondata);
IndexResponse res = client.prepareIndex().setIndex("test").setType("test01").setId("14")
.setSource(jsondata).execute().actionGet();
System.out.println("索引创建成功,版本号:"+res.getVersion());
}
public void addindex02(int i) {
UserModel user = new UserModel();
user.setId(new Random().nextInt(20));
user.setName("张三_"+new Random().nextInt(10));
user.setAge("1012");
if(new Random().nextInt(20)%2==0){
user.setSex("boy");
}
else{
user.setSex("grile");
}
user.setTel("1514414");
String jsondata = ESUtils.toJson(user);
System.out.println("封装的json:"+jsondata);
IndexResponse res = client.prepareIndex().setIndex("test4").setType("test04").setId(String.valueOf(i))
.setSource(jsondata).execute().actionGet();
System.out.println("索引创建成功,版本号:"+res.getVersion());
}
删除
public void del01() {
DeleteResponse res = client.prepareDelete().setIndex("test2")
.setType("test02").setId("4").execute().actionGet();
System.out.println("删除成功");
}
查询
public void getIndex() {
GetResponse res = client.prepareGet().setIndex("test")
.setType("test01").setId("1").execute().actionGet();
System.out.println(res.getSource());
}
更改:
更改就是索引删除之后 在重新建立
转载于:https://my.oschina.net/u/580135/blog/612178
推荐阅读
-
Java中使用elasticsearch搜索引擎实现简单、修改等操作
-
从Elasticsearch索引库中读取数据的操作
-
Elasticsearch Java API 的使用(14)—优化索引创建之setting设置、写入优化
-
使用Java客户端操作elasticsearch
-
elasticsearch的java代码操作详解
-
Elasticsearch关于Java客户端的基本操作 (RestHighLevelClient)
-
elasticsearch系列-Java客户端的查询操作
-
ELASTICSEARCH的java客户端和springboot整合(二)
-
Elasticsearch Java 客户端的选择
-
Java配置带密码的ElasticSearch客户端