パッケージ org.springframework.data.cassandra.repository

インターフェース ReactiveCassandraRepository<T,ID>

すべてのスーパーインターフェース:
ReactiveCrudRepository<T,ID>, Repository<T,ID>
すべての既知の実装クラス:
SimpleReactiveCassandraRepository
@NoRepositoryBean public interface ReactiveCassandraRepository<T,ID> extends ReactiveCrudRepository<T,ID>
リアクティブサポートを備えた Cassandra 固有の Repository インターフェース。
導入:
2.0
作成者:
Mark Paluch

  • メソッドの詳細

    • insert

      <S extends T> reactor.core.publisher.Mono<S> insert(S entity)
      指定されたエンティティを挿入します。挿入の最適化を適用できるように、インスタンスが新規であると想定します。保存操作によってエンティティインスタンスが完全に変更される可能性があるため、返されたインスタンスを以降の操作に使用します。ストア固有の API の使用を避けるため、代わりに ReactiveCrudRepository.save(Object) を使用することをお勧めします。
      パラメーター:
      entity - null であってはなりません。
      戻り値:
      保存されたエンティティ

    • insert

      <S extends T> reactor.core.publisher.Flux<S> insert(IterableSE<S> entities)
      指定されたエンティティを挿入します。挿入の最適化を適用できるように、インスタンスが新規であると想定します。保存操作によってエンティティインスタンスが完全に変更される可能性があるため、返されたインスタンスを以降の操作に使用します。ストア固有の API の使用を避けるため、代わりに ReactiveCrudRepository.save(Object) を使用することをお勧めします。
      パラメーター:
      entities - null であってはなりません。
      戻り値:
      保存されたエンティティ

    • insert

      <S extends T> reactor.core.publisher.Flux<S> insert(org.reactivestreams.Publisher<S> entities)
      指定されたエンティティを挿入します。挿入の最適化を適用できるように、インスタンスが新規であると想定します。保存操作によってエンティティインスタンスが完全に変更される可能性があるため、返されたインスタンスを以降の操作に使用します。ストア固有の API の使用を避けるため、代わりに ReactiveCrudRepository.save(Object) を使用することをお勧めします。
      パラメーター:
      entities - null であってはなりません。
      戻り値:
      保存されたエンティティ

    • findAllById

      reactor.core.publisher.Flux<T> findAllById(IterableSE<ID> iterable)

      メモ: Cassandra は単一フィールドの IN クエリのみをサポートします。複数のコンポーネントで MapId を使用する場合は、各行を個別にフェッチします。

      次で指定:
      インターフェース ReactiveCrudRepository<T,ID> の findAllById 

    • findAllById

      reactor.core.publisher.Flux<T> findAllById(org.reactivestreams.Publisher<ID> publisher)

      各行を個別に取得します。

      次で指定:
      インターフェース ReactiveCrudRepository<T,ID> の findAllById