Skip to content

Commit d761b16

Browse files
committed
Polishing.
Signed-off-by: Youssef Aouichaoui <youssef3wi@icloud.com>
1 parent a9d7d66 commit d761b16

File tree

3 files changed

+16
-3
lines changed

3 files changed

+16
-3
lines changed

src/main/java/org/springframework/data/elasticsearch/client/elc/RequestConverter.java

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -973,7 +973,6 @@ public DeleteByQueryRequest documentDeleteByQueryRequest(DeleteQuery query, @Nul
973973
Assert.notNull(query, "query must not be null");
974974
Assert.notNull(index, "index must not be null");
975975

976-
// Old documentDeleteByQueryRequest needs to be refactored.
977976
return DeleteByQueryRequest.of(dqb -> {
978977
dqb.index(Arrays.asList(index.getIndexNames())) //
979978
.query(getQuery(query.getQuery(), clazz))//
@@ -1014,7 +1013,15 @@ public DeleteByQueryRequest documentDeleteByQueryRequest(DeleteQuery query, @Nul
10141013
if (!sortOptions.isEmpty()) {
10151014
dqb.sort(
10161015
sortOptions.stream()
1017-
.map(sortOption -> sortOption.field().field() + ":" + sortOption.field().order().jsonValue())
1016+
.map(sortOption -> {
1017+
String order = "asc";
1018+
var sortField = sortOption.field();
1019+
if (sortField.order() != null) {
1020+
order = sortField.order().jsonValue();
1021+
}
1022+
1023+
return sortField.field() + ":" + order;
1024+
})
10181025
.collect(Collectors.toList())
10191026
);
10201027
}

src/main/java/org/springframework/data/elasticsearch/core/query/DeleteQuery.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import org.springframework.data.elasticsearch.core.query.types.ConflictsType;
2121
import org.springframework.data.elasticsearch.core.query.types.OperatorType;
2222
import org.springframework.lang.Nullable;
23+
import org.springframework.util.Assert;
2324

2425
import java.time.Duration;
2526
import java.util.EnumSet;
@@ -222,7 +223,7 @@ public static Builder builder(Query query) {
222223
return new Builder(query);
223224
}
224225

225-
public DeleteQuery(Builder builder) {
226+
private DeleteQuery(Builder builder) {
226227
this.q = builder.luceneQuery;
227228
this.analyzeWildcard = builder.analyzeWildcard;
228229
this.analyzer = builder.analyzer;
@@ -450,6 +451,8 @@ public static final class Builder {
450451
private final Query query;
451452

452453
private Builder(Query query) {
454+
Assert.notNull(query, "query must not be null");
455+
453456
this.query = query;
454457
}
455458

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
@org.springframework.lang.NonNullApi
2+
@org.springframework.lang.NonNullFields
3+
package org.springframework.data.elasticsearch.core.query.types;

0 commit comments

Comments
 (0)