spring cassandra data Version 2.1.4分页

Question

1.被动呼叫

回购：

public interface MyRepository extends ReactiveCassandraRepository<MyClass, String> {
  @Query("select * from my_keyspace.my_table where solr_query = ?0")
  Mono<Slice<MyClass>> findMono(String solrQuery, Pageable page);
}

呼叫：

 Mono<Slice<MyClass>>  repository.findMono(queryString, CassandraPageRequest.first(20));

public interface LocationRepository extends ReactiveSortingRepository<MyClass, String> {
}

 repository.findAll(CassandraPageRequest.first(20))

3.获取页面的简单调用。

回购：

public interface MyRepository extends CassandraRepository<MyClass, MyClassKey> {
Page<MyClass> findByKeyTerminalIdAndSolrQuery(String solrQuery, Pageable page);
}

启动时出错：

public interface MyRepository extends PagingAndSortingRepository<MyClass, MyClassKey> {

}

   Page<Vessel> vessels = repository.findAll(CassandraPageRequest.first(10));

Answer 1

欢迎使用堆栈溢出。

第一个例子是恰当的：

public interface MyRepository extends ReactiveCassandraRepository<MyClass, String> {
  @Query("select * from my_keyspace.my_table where solr_query = ?0")
  Mono<Slice<MyClass>> findMono(String solrQuery, Pageable page);
}

Mono<Slice<MyClass>>  repository.findMono(queryString, CassandraPageRequest.first(20));

问题是Jackson无法在将sliceimpl(slice)传递给WebFlux时对其进行编码（根据堆栈跟踪）。所以查询会产生正确的结果，但是如果要对slice进行JSON编码，则需要传递slice内容，而不是slice本身。

public interface ReactiveSortingRepository<T, ID> extends ReactiveCrudRepository<T, ID> {
    Flux<T> findAll(Sort sort);
}