Elasticsearch Java REST Client 删除、修改

上一篇：Elasticsearch Java REST Client ID查询
下一篇：Elasticsearch Java REST Client Term Vectors API

# 同步删除
@GetMapping("del")
public void del(String id) {
	  try {
	      DeleteRequest request = new DeleteRequest("edu-app-user", "doc", id);
	      restHighLevelClient.delete(request, RequestOptions.DEFAULT);
	  } catch (Exception e) {
	      e.printStackTrace();
	  }
}
# 异步删除
@GetMapping("delAsync")
public void delAsync(String id) {
    try {
        DeleteRequest request = new DeleteRequest("edu-app-user", "doc", id);
        restHighLevelClient.deleteAsync(request, RequestOptions.DEFAULT,new EduAppUserDeleteListen());
    } catch (Exception e) {
        e.printStackTrace();
    }
}
# 监听类
package com.wdz.es.config.es;
import org.elasticsearch.action.ActionListener;
import org.elasticsearch.action.delete.DeleteResponse;

public class EduAppUserDeleteListen implements ActionListener {
    @Override
    public void onResponse(DeleteResponse deleteResponse) {
        System.out.println("异步删除成功："+deleteResponse);
    }

    @Override
    public void onFailure(Exception e) {
        System.out.println("异步删除失败："+e.getMessage());
    }
}

// 方式一
@GetMapping("update2")
public UpdateResponse update2(String id) {
    try {
        XContentBuilder builder = XContentFactory.jsonBuilder();
        builder.startObject();
        {
            builder.timeField("name", "上仙");
            builder.field("age", "1024");
        }
        builder.endObject();
        UpdateRequest request = new UpdateRequest("edu-app-user", "doc", id).doc(builder);
        return restHighLevelClient.update(request, RequestOptions.DEFAULT);
    } catch (Exception e) {
        e.printStackTrace();
    }
    return null;
}
// 方式二
@GetMapping("update")
public UpdateResponse update(String id) {
    try {
        Map map = new HashMap<>();
        map.put("name", "新名称");
        UpdateRequest request = new UpdateRequest("edu-app-user", "doc", id);
        request.doc(map);
        return restHighLevelClient.update(request, RequestOptions.DEFAULT);
    } catch (Exception e) {
        e.printStackTrace();
    }
    return null;
}
// 异步修改
@GetMapping("updateAsync")
public void updateAsync(String id) {
    try {
        UpdateRequest request = new UpdateRequest("edu-app-user", "doc", id);
        request.doc("name", "汝州蟒川蟒窝", "age", "2048");
        restHighLevelClient.updateAsync(request, RequestOptions.DEFAULT,new EduAppUserUpdateListen());
    } catch (Exception e) {
        e.printStackTrace();
    }
}
// 监听类
package com.wdz.es.config.es;

import org.elasticsearch.action.ActionListener;
import org.elasticsearch.action.update.UpdateResponse;

public class EduAppUserUpdateListen implements ActionListener {
    @Override
    public void onResponse(UpdateResponse updateResponse) {
        System.out.println("异步修改成功："+updateResponse);
    }

    @Override
    public void onFailure(Exception e) {
        System.out.println("异步修改失败："+e.getMessage());
    }
}

官网：戳
上一篇：Elasticsearch Java REST Client ID查询
下一篇：Elasticsearch Java REST Client Term Vectors API