package org.fanli.elastic;
|
|
import java.io.IOException;
|
|
import org.apache.http.HttpHost;
|
import org.elasticsearch.ElasticsearchException;
|
import org.elasticsearch.action.DocWriteResponse;
|
import org.elasticsearch.action.delete.DeleteRequest;
|
import org.elasticsearch.action.delete.DeleteResponse;
|
import org.elasticsearch.action.get.GetRequest;
|
import org.elasticsearch.action.support.replication.ReplicationResponse;
|
import org.elasticsearch.client.RequestOptions;
|
import org.elasticsearch.client.RestClient;
|
import org.elasticsearch.client.RestHighLevelClient;
|
import org.elasticsearch.rest.RestStatus;
|
import org.elasticsearch.search.fetch.subphase.FetchSourceContext;
|
|
public class DeleteUtils {
|
|
private static String clusterName = "my-application";
|
private static String host = "192.168.1.200";
|
private static Integer port = 9200;
|
|
// 相当于数据库名称
|
public static String indexName = "shose";
|
|
// 初始化api客户端
|
public static RestHighLevelClient client = new RestHighLevelClient(
|
RestClient.builder(new HttpHost(host, port, "http")));
|
|
public static void get1() {
|
DeleteRequest request = new DeleteRequest("posts", "2");
|
|
// // 可选参数
|
// request.timeout(TimeValue.timeValueMinutes(2));
|
// request.timeout("2m");
|
//
|
// // 策略
|
// request.setRefreshPolicy(WriteRequest.RefreshPolicy.WAIT_UNTIL);
|
// request.setRefreshPolicy("wait_for");
|
//
|
// // 版本
|
// request.version(2);
|
// request.versionType(VersionType.EXTERNAL);
|
|
try {
|
DeleteResponse deleteResponse = client.delete(request, RequestOptions.DEFAULT);
|
|
|
//
|
// // 返回的值DeleteResponse允许检索有关已执行操作的信息，
|
// String index = deleteResponse.getIndex();
|
// String id = deleteResponse.getId();
|
// long version = deleteResponse.getVersion();
|
// ReplicationResponse.ShardInfo shardInfo = deleteResponse.getShardInfo();
|
// if (shardInfo.getTotal() != shardInfo.getSuccessful()) {
|
//
|
// // 处理成功分片数量少于总分片数量的情况
|
// }
|
// if (shardInfo.getFailed() > 0) {
|
// for (ReplicationResponse.ShardInfo.Failure failure :
|
// shardInfo.getFailures()) {
|
// String reason = failure.reason();
|
// }
|
// // 处理潜在的故障
|
// }
|
//
|
// // 可以检查是否找到了该文档：
|
// DeleteRequest request = new DeleteRequest("posts", "does_not_exist");
|
// DeleteResponse deleteResponse = client.delete(
|
// request, RequestOptions.DEFAULT);
|
// if (deleteResponse.getResult() == DocWriteResponse.Result.NOT_FOUND) {
|
//
|
// }
|
//
|
// try {
|
// DeleteResponse deleteResponse = client.delete(
|
// new DeleteRequest("posts", "1").setIfSeqNo(100).setIfPrimaryTerm(2),
|
// RequestOptions.DEFAULT);
|
// } catch (ElasticsearchException exception) {
|
// if (exception.status() == RestStatus.CONFLICT) {
|
//
|
// }
|
// }
|
//
|
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
|
}
|
|
public static void main(String[] args) {
|
get1();
|
|
System.out.println("------------ 测试结束 -------------------------");
|
}
|
|
}
|
