elasticsearch Delete （根據條件刪除）

之前在 2.X版本里 這個Delete By Query功能被去掉了 因為官方認為會引發一些錯誤 如需使用 需要自己安裝插件。

bin/plugin install delete-by-query

需要使用時

DELETE /索引名/需要清空的type/_query
{
"query": {
"match_all": {}
}
}

那么在5.x版本中 這個api又被官方重新加回自帶功能。新特性里是這么說的。

Delete-by-query 和 Update-by-query 重新回到 core ，以前是插件，現在可以直接使用了，
也是構建在 Reindex 機制之上。
(es1.x版本是直接支持，在es2.x中提取為插件，5.x繼續回歸直接支持)

我查看了官方手冊后發現使用也不一樣了 見下圖

官方地址：https://www.elastic.co/guide/en/elasticsearch/reference/5.2/docs-delete-by-query.html

即替換以前的 _query 為_delete_by_query 便可達到目的。

通過header插件刪除

使用head插件刪除指定數據
 
http://serverhost:9200/index/type/_delete_by_query   post
 
{
   "query": {
      "match": {
         屬性字段: 要刪除的屬性值
      }
   }
}

Java代碼實現：

String index = "wareic";
            
BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();
queryBuilder.must(QueryBuilders.termQuery("groupID", "42023"));  
 
BulkIndexByScrollResponse response =
        DeleteByQueryAction.INSTANCE.newRequestBuilder(client)
            .filter(queryBuilder) 
            .source(index)                                  
            .get();                                             
 
long deleted = response.getDeleted();                                           
System.out.println(deleted);

另一種實現方式：

String index = "wareic";
String type = "product";
BulkRequestBuilder bulkRequest = client.prepareBulk();  
SearchRequestBuilder searchRequestBuilder = client.prepareSearch(index).setTypes(type);
//分頁
searchRequestBuilder.setFrom(0).setSize(1000);
 
BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();
queryBuilder.must(QueryBuilders.termQuery("groupID", "3445"));  
 
searchRequestBuilder.setQuery(queryBuilder);
SearchResponse response = searchRequestBuilder.execute().get();
for(SearchHit hit : response.getHits()){  
    String id = hit.getId();  
    bulkRequest.add(client.prepareDelete(index, type, id).request());
}  
BulkResponse bulkResponse = bulkRequest.get();  
if (bulkResponse.hasFailures()) {  
    for(BulkItemResponse item : bulkResponse.getItems()){  
        System.out.println(item.getFailureMessage());  
    }  
} else {  
    System.out.println("delete ok");  
}  

文章參考地址：https://www.elastic.co/guide/en/elasticsearch/client/java-api/5.2/java-docs-delete-by-query.html

http://www.a-du.net