Cwikius-Spring/spring-data-elasticsearch
1
0
Fork 0
mirror of https://github.com/spring-projects/spring-data-elasticsearch.git synced 2025-11-24 02:31:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix missing return value in ByQueryResponse.

Browse Source 
Original Pull Request #3109
Closes #3108

Signed-off-by: Peter-Josef Meisch <pj.meisch@sothawo.com>
(cherry picked from commit ebbe242a7228d7f573b8a25f0565060e2c0fa528)
This commit is contained in:
Peter-Josef Meisch 2025-05-14 13:53:58 +02:00
parent 4767a8215e
commit ea51ce062e
No known key found for this signature in database
GPG Key ID: E24DEB87861622D3
2 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/org/springframework/data/elasticsearch/client/elc/ResponseConverter.java
View File

@ -500,6 +500,10 @@ class ResponseConverter {
builder.withDeleted(response.deleted()); builder.withDeleted(response.deleted());
} }
if(response.updated() != null) {
builder.withUpdated(response.updated());
}
if (response.batches() != null) { if (response.batches() != null) {
builder.withBatches(Math.toIntExact(response.batches())); builder.withBatches(Math.toIntExact(response.batches()));
} }

4
src/test/java/org/springframework/data/elasticsearch/core/ElasticsearchIntegrationTests.java
View File

@ -1636,7 +1636,9 @@ public abstract class ElasticsearchIntegrationTests {
.withParams(Collections.singletonMap("newMessage", messageAfterUpdate)).withAbortOnVersionConflict(true) .withParams(Collections.singletonMap("newMessage", messageAfterUpdate)).withAbortOnVersionConflict(true)
.build(); .build();
operations.updateByQuery(updateQuery, IndexCoordinates.of(indexNameProvider.indexName())); var byQueryResponse = operations.updateByQuery(updateQuery, IndexCoordinates.of(indexNameProvider.indexName()));
assertThat(byQueryResponse.getUpdated()).isEqualTo(1);
SampleEntity indexedEntity = operations.get(documentId, SampleEntity.class, SampleEntity indexedEntity = operations.get(documentId, SampleEntity.class,
IndexCoordinates.of(indexNameProvider.indexName())); IndexCoordinates.of(indexNameProvider.indexName()));