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

野性酷女 2022-06-03 02:45 136阅读 0赞

**之前在 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][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": {
             属性字段: 要删除的属性值
          }
       }
    }
    
    
    ##根据ID批量删除
    {
       "query": {
          "terms": {
             "productID":[1516721,1516725]
          }
       }
    }

**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][https_www.elastic.co_guide_en_elasticsearch_client_java-api_5.2_java-docs-delete-by-query.html]

[https_www.elastic.co_guide_en_elasticsearch_reference_5.2_docs-delete-by-query.html]: https://www.elastic.co/guide/en/elasticsearch/reference/5.2/docs-delete-by-query.html
[https_www.elastic.co_guide_en_elasticsearch_client_java-api_5.2_java-docs-delete-by-query.html]: https://www.elastic.co/guide/en/elasticsearch/client/java-api/5.2/java-docs-delete-by-query.html