欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

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