From bfb33e74941514e5ffa482f0cd6e58dfff59e502 Mon Sep 17 00:00:00 2001 From: xingluping Date: Tue, 11 Dec 2018 15:56:30 +0800 Subject: [PATCH] update ElasticsearchRestTemplate.delete,add withFilter() --- .../data/elasticsearch/core/ElasticsearchRestTemplate.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/org/springframework/data/elasticsearch/core/ElasticsearchRestTemplate.java b/src/main/java/org/springframework/data/elasticsearch/core/ElasticsearchRestTemplate.java index 68e14ede54..5d6e24adfe 100644 --- a/src/main/java/org/springframework/data/elasticsearch/core/ElasticsearchRestTemplate.java +++ b/src/main/java/org/springframework/data/elasticsearch/core/ElasticsearchRestTemplate.java @@ -797,7 +797,7 @@ public void delete(DeleteQuery deleteQuery, Class clazz) { Long scrollTimeInMillis = deleteQuery.getScrollTimeInMillis() != null ? deleteQuery.getScrollTimeInMillis() : 10000l; - SearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(deleteQuery.getQuery()).withIndices(indexName) + SearchQuery searchQuery = new NativeSearchQueryBuilder().withFilter(deleteQuery.getQuery()).withQuery(deleteQuery.getQuery()).withIndices(indexName) .withTypes(typeName).withPageable(PageRequest.of(0, pageSize)).build(); SearchResultMapper onlyIdResultMapper = new SearchResultMapper() {