根據(jù)文檔：https ://docs.spring.io/spring-data/cassandra/docs/2.1.4.RELEASE/reference/html/#repositories.limit-query-resultSpring cassandra 數(shù)據(jù)使獲取分頁信息變得容易。但我無法讓它工作?；刭?、調(diào)用和錯誤：1. 響應(yīng)式呼叫回購：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));錯誤："exceptionDescription":"org.springframework.core.codec.CodecException: 類型定義錯誤：[簡單類型，類 com.datastax.driver.core.PagingState]；嵌套異常是 com.fasterxml.jackson.databind.exc.InvalidDefinitionException:沒有為類 com.datastax.driver.core.PagingState 找到序列化程序，也沒有發(fā)現(xiàn)創(chuàng)建 BeanSerializer 的屬性（為避免異常，請禁用 SerializationFeature.FAIL_ON_EMPTY_BEANS）（通過參考鏈：org.springframework.data.domain.SliceImpl[\"pageable\ "]->org.springframework.data.cassandra.core.query.CassandraPageRequest[\"pagingState\"])","lines":["org.springframework.http.codec.json.AbstractJackson2Encoder.encodeValue(AbstractJackson2Encoder.java :175)","org.springframework.http.codec.json.AbstractJackson2Encoder。lambda$encode$0(AbstractJackson2Encoder.java:122)","reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:100)","reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java :67)","reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114)","reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.onNext(FluxDefaultIfEmpty.java:92)","reactor。 core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)","reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:241)","r
1 回答
MMTTMM
TA貢獻(xiàn)1869條經(jīng)驗 獲得超4個贊
歡迎來到堆棧溢出。
第一個例子是合適的：
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));
問題是當(dāng)您將其傳遞給 WebFlux（根據(jù)堆棧跟蹤）時，Jackson 無法對SliceImpl（的實現(xiàn)）進(jìn)行編碼。Slice所以查詢產(chǎn)生了正確的結(jié)果，但如果你想對它進(jìn)行 JSON 編碼，你需要傳遞Slice內(nèi)容，而不是Slice本身。
相關(guān)說明：ReactiveCassandraRepository不實現(xiàn)ReactiveSortingRepository，因為帶有Sort參數(shù)的 Casandra 查詢始終需要一個WHERE子句。查看ReactiveSortingRepository，您會看到一個findAll(Sort)不采用過濾條件的方法：
public interface ReactiveSortingRepository<T, ID> extends ReactiveCrudRepository<T, ID> {
Flux<T> findAll(Sort sort);
}
添加回答
舉報
0/150
提交
取消