From ae66cbd619b012b898072ef059de71ac1626b330 Mon Sep 17 00:00:00 2001 From: Peter-Josef Meisch Date: Sat, 25 Jun 2022 19:55:22 +0200 Subject: [PATCH] Fix updatebyquery request. Original Pull Request #2197 Closes #2191 (cherry picked from commit f90138076659e5452fd38444c85cfee0745b074c) --- .../data/elasticsearch/core/RequestFactory.java | 3 +-- .../core/ElasticsearchERHLCIntegrationTests.java | 5 +++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/org/springframework/data/elasticsearch/core/RequestFactory.java b/src/main/java/org/springframework/data/elasticsearch/core/RequestFactory.java index 96aca1477..8daa0192b 100644 --- a/src/main/java/org/springframework/data/elasticsearch/core/RequestFactory.java +++ b/src/main/java/org/springframework/data/elasticsearch/core/RequestFactory.java @@ -1092,8 +1092,7 @@ class RequestFactory { public UpdateByQueryRequest updateByQueryRequest(UpdateQuery query, IndexCoordinates index) { - String indexName = index.getIndexName(); - final UpdateByQueryRequest updateByQueryRequest = new UpdateByQueryRequest(indexName); + final UpdateByQueryRequest updateByQueryRequest = new UpdateByQueryRequest(index.getIndexNames()); updateByQueryRequest.setScript(getScript(query)); if (query.getAbortOnVersionConflict() != null) { diff --git a/src/test/java/org/springframework/data/elasticsearch/core/ElasticsearchERHLCIntegrationTests.java b/src/test/java/org/springframework/data/elasticsearch/core/ElasticsearchERHLCIntegrationTests.java index ce4332816..ab921ae95 100644 --- a/src/test/java/org/springframework/data/elasticsearch/core/ElasticsearchERHLCIntegrationTests.java +++ b/src/test/java/org/springframework/data/elasticsearch/core/ElasticsearchERHLCIntegrationTests.java @@ -239,7 +239,7 @@ public class ElasticsearchERHLCIntegrationTests extends ElasticsearchIntegration assertThat(fetchSourceContext.excludes()).containsExactlyInAnyOrder("excl"); } - @Test // #1446 + @Test // #1446, #2191 void shouldUseAllOptionsFromUpdateByQuery() throws JSONException { Query searchQuery = new NativeSearchQueryBuilder().withQuery(matchAllQuery()) // @@ -269,9 +269,10 @@ public class ElasticsearchERHLCIntegrationTests extends ElasticsearchIntegration " }" + " }" + '}'; // when - UpdateByQueryRequest request = getRequestFactory().updateByQueryRequest(updateQuery, IndexCoordinates.of("index")); + UpdateByQueryRequest request = getRequestFactory().updateByQueryRequest(updateQuery, IndexCoordinates.of("index1", "index2")); // then + assertThat(request.indices()).containsExactlyInAnyOrder("index1", "index2"); assertThat(request).isNotNull(); assertThat(request.getSearchRequest().indicesOptions()).usingRecursiveComparison() .isEqualTo(IndicesOptions.LENIENT_EXPAND_OPEN);