Spring data r2dbc and pagination

Question

I'm using the new spring data r2dbc module and i'm able to extract the data using a ReactiveCrudRepository. Now i need to introduce pagination but i cannot manage to do it. I tried with this

public interface TestRepository extends ReactiveCrudRepository<MyEntity, Long> {
    Flux<MyEntity> findByEntityId(Long entityId, Pageable page);
}

but when i try to execute this i obtain this error

org.springframework.data.repository.query.ParameterOutOfBoundsException: Invalid parameter index! You seem to have declared too little query method parameters!
    at org.springframework.data.repository.query.Parameters.getParameter(Parameters.java:237)
    Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 

is there a way to use pagination with this module?

Answer 1

The new R2dbcEntityTemplate Spring Data R2dbc 1.2 contains pagination operations like this.

 private final R2dbcEntityTemplate template;

    public Flux<Post> findByTitleContains(String name) {
        return this.template.select(Post.class)
                .matching(Query.query(where("title").like("%" + name + "%")).limit(10).offset(0))
                .all();
    }

Spring Data R2dbc 1.2 (not released yet) will accept a Pageable parameter as in Repository.

 public Flux<PostSummary> findByTitleLike(String title, Pageable pageable);

The complete code examples, check here, test codes.

Answer 2

No, there currently is no way to use implicit pagination. You should specify your whole queries to use it.

Here is an example:

@Query("SELECT * FROM my_entity WHERE entity_id = :entityId OFFSET :offset LIMIT :limit")
Flux<MyEntity> findByEntityId(Long entityId, int offset, int limit);