diff --git a/src/main/java/org/springframework/data/keyvalue/repository/query/KeyValuePartTreeQuery.java b/src/main/java/org/springframework/data/keyvalue/repository/query/KeyValuePartTreeQuery.java index 0e0d270..a21ab6c 100644 --- a/src/main/java/org/springframework/data/keyvalue/repository/query/KeyValuePartTreeQuery.java +++ b/src/main/java/org/springframework/data/keyvalue/repository/query/KeyValuePartTreeQuery.java @@ -16,10 +16,8 @@ package org.springframework.data.keyvalue.repository.query; import java.lang.reflect.Constructor; -import java.util.Optional; import org.springframework.beans.BeanUtils; -import org.springframework.data.domain.Page; import org.springframework.data.domain.PageImpl; import org.springframework.data.domain.Pageable; import org.springframework.data.domain.Sort; @@ -87,7 +85,7 @@ public class KeyValuePartTreeQuery implements RepositoryQuery { ParameterAccessor accessor = new ParametersParameterAccessor(getQueryMethod().getParameters(), parameters); KeyValueQuery query = prepareQuery(parameters); - ResultProcessor processor = queryMethod.getResultProcessor().withDynamicProjection(Optional.ofNullable(accessor)); + ResultProcessor processor = queryMethod.getResultProcessor().withDynamicProjection(accessor); return processor.processResult(doExecute(parameters, query)); } @@ -151,9 +149,9 @@ public class KeyValuePartTreeQuery implements RepositoryQuery { Pageable pageable = accessor.getPageable(); Sort sort = accessor.getSort(); - query.setOffset(pageable != null && Pageable.NONE.equals(pageable) ? -1L : pageable.getOffset()); + query.setOffset(pageable.toOptional().map(Pageable::getOffset).orElse(-1L)); - if (pageable != null && !Pageable.NONE.equals(pageable)) { + if (pageable.isPaged()) { query.setRows(pageable.getPageSize()); } else if (instance.getRows() >= 0) { query.setRows(instance.getRows()); diff --git a/src/main/java/org/springframework/data/keyvalue/repository/support/SimpleKeyValueRepository.java b/src/main/java/org/springframework/data/keyvalue/repository/support/SimpleKeyValueRepository.java index 3919a32..0691a12 100644 --- a/src/main/java/org/springframework/data/keyvalue/repository/support/SimpleKeyValueRepository.java +++ b/src/main/java/org/springframework/data/keyvalue/repository/support/SimpleKeyValueRepository.java @@ -75,14 +75,14 @@ public class SimpleKeyValueRepository implements Key if (pageable == null) { List result = findAll(); - return new PageImpl(result, Pageable.NONE, result.size()); + return new PageImpl(result, Pageable.unpaged(), result.size()); } Iterable content = operations.findInRange(pageable.getOffset(), pageable.getPageSize(), pageable.getSort(), entityInformation.getJavaType()); - return new PageImpl(IterableConverter.toList(content), pageable, this.operations.count(entityInformation - .getJavaType())); + return new PageImpl(IterableConverter.toList(content), pageable, + this.operations.count(entityInformation.getJavaType())); } /* @@ -188,7 +188,8 @@ public class SimpleKeyValueRepository implements Key */ @Override public void delete(T entity) { - delete(entityInformation.getId(entity).orElseThrow(() -> new IllegalArgumentException("Cannot delete entity with 'null' id."))); + delete(entityInformation.getId(entity) + .orElseThrow(() -> new IllegalArgumentException("Cannot delete entity with 'null' id."))); } /*