Adopt to newly introduced ParameterAccessor.getScrollPosition().
Closes #1696
This commit is contained in:
@@ -21,6 +21,7 @@ import java.util.Optional;
|
|||||||
import org.springframework.data.couchbase.core.convert.CouchbaseConverter;
|
import org.springframework.data.couchbase.core.convert.CouchbaseConverter;
|
||||||
import org.springframework.data.couchbase.core.query.N1QLExpression;
|
import org.springframework.data.couchbase.core.query.N1QLExpression;
|
||||||
import org.springframework.data.domain.Pageable;
|
import org.springframework.data.domain.Pageable;
|
||||||
|
import org.springframework.data.domain.ScrollPosition;
|
||||||
import org.springframework.data.domain.Sort;
|
import org.springframework.data.domain.Sort;
|
||||||
import org.springframework.data.repository.query.ParameterAccessor;
|
import org.springframework.data.repository.query.ParameterAccessor;
|
||||||
import org.springframework.data.repository.query.parser.PartTree;
|
import org.springframework.data.repository.query.parser.PartTree;
|
||||||
@@ -50,6 +51,11 @@ public class N1qlCountQueryCreator extends OldN1qlQueryCreator {
|
|||||||
this.delegate = delegate;
|
this.delegate = delegate;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public ScrollPosition getScrollPosition() {
|
||||||
|
return delegate.getScrollPosition();
|
||||||
|
}
|
||||||
|
|
||||||
public Pageable getPageable() {
|
public Pageable getPageable() {
|
||||||
return delegate.getPageable().isPaged() ? new CountPageable(delegate.getPageable()) : Pageable.unpaged();
|
return delegate.getPageable().isPaged() ? new CountPageable(delegate.getPageable()) : Pageable.unpaged();
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user