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

bin/plugin install delete-by-query

需要使用時

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

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

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

我查看了官方手冊后發(fā)現(xiàn)使用也不一樣了 見下圖

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

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

通過header插件刪除

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

Java代碼實現(xiàn)：

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);

另一種實現(xiàn)方式：

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

轉(zhuǎn)載于:https://www.cnblogs.com/a-du/p/9583434.html

總結(jié)

以上是生活随笔為你收集整理的elasticsearch 5.x Delete By Query API（根据条件删除）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。