elasticsearch Delete By Query API（根据条件删除）

之前在 版本里 这个Delete By Query功能被去掉了 因为官方认为会引发一些错误 如需使用 需要自己安装插件。

bin/plugin install delete-by-query

需要使用时

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

那么在版本中 这个api又被官方重新加回自带功能。新特性里是这么说的。

Delete-by-query 和 Update-by-query 重新回到 core ，以前是插件，现在可以直接使用了，
也是构建在 Reindex 机制之上。
(版本是直接支持，在中提取为插件，继续回归直接支持)

我查看了官方手册后发现使用也不一样了 见下图

官方地址：/guide/en/elasticsearch/reference/5.2/

即替换以前的 _query 为_delete_by_query 便可达到目的。

通过header插件删除

使用head插件删除指定数据

http://serverhost:9200/index/type/_delete_by_query   post

{
   "query": {
      "match": {
         属性字段: 要删除的属性值
      }
   }
}


##根据ID批量删除
{
   "query": {
      "terms": {
         "productID":[1516721,1516725]
      }
   }
}

Java代码实现：

String index = "wareic";
    		
BoolQueryBuilder queryBuilder = ();
(("groupID", "42023"));  

BulkIndexByScrollResponse response =
		(client)
			.filter(queryBuilder) 
			.source(index)                                  
			.get();                                             

long deleted = ();                                           
(deleted);

另一种实现方式：

String index = "wareic";
String type = "product";
BulkRequestBuilder bulkRequest = ();  
SearchRequestBuilder searchRequestBuilder = (index).setTypes(type);
//分页
(0).setSize(1000);

BoolQueryBuilder queryBuilder = ();
(("groupID", "3445"));  

(queryBuilder);
SearchResponse response = ().get();
for(SearchHit hit : ()){  
	String id = ();  
	((index, type, id).request());
}  
BulkResponse bulkResponse = ();  
if (()) {  
	for(BulkItemResponse item : ()){  
		(());  
	}  
} else {  
	("delete ok");  
}  

文章参考地址：/guide/en/elasticsearch/client/java-api/5.2/