Spring/spring-data-redis
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Clear indexed data if property value is set to null.

Browse Source 
Closes #2882
Original pull request: #2895
This commit is contained in:
Christoph Strobl
2024-04-16 15:23:04 +02:00
committed by Mark Paluch
parent 2d6481b5c2
commit 8afabc1fe3
2 changed files with 34 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/org/springframework/data/redis/core/convert/PathIndexResolver.java
View File

@@ -122,6 +122,7 @@ public class PathIndexResolver implements IndexResolver {
Object propertyValue = accessor.getProperty(persistentProperty);
if (propertyValue == null) {
indexes.addAll(resolveIndex(keyspace, currentPath, persistentProperty, null));
return;
}
@@ -212,7 +213,18 @@ public class PathIndexResolver implements IndexResolver {
IndexedData indexedData = null;
if (transformedValue == null) {
indexedData = new RemoveIndexedData(indexedData);
indexedData = new RemoveIndexedData(new IndexedData() {
@Override
public String getIndexName() {
return indexDefinition.getIndexName();
}
@Override
public String getKeyspace() {
return indexDefinition.getKeyspace();
}
});
} else {
indexedData = indexedDataFactoryProvider.getIndexedDataFactory(indexDefinition).createIndexedDataFor(value);
}
@@ -220,13 +232,13 @@ public class PathIndexResolver implements IndexResolver {
}
}
else if (property != null && property.isAnnotationPresent(Indexed.class)) {
else if (property != null && value != null && property.isAnnotationPresent(Indexed.class)) {
SimpleIndexDefinition indexDefinition = new SimpleIndexDefinition(keyspace, path);
indexConfiguration.addIndexDefinition(indexDefinition);
data.add(indexedDataFactoryProvider.getIndexedDataFactory(indexDefinition).createIndexedDataFor(value));
} else if (property != null && property.isAnnotationPresent(GeoIndexed.class)) {
} else if (property != null && value != null && property.isAnnotationPresent(GeoIndexed.class)) {
GeoIndexDefinition indexDefinition = new GeoIndexDefinition(keyspace, path);
indexConfiguration.addIndexDefinition(indexDefinition);