クラス SimpleReactiveCassandraRepository<T,ID>

メソッドの詳細

• save

  public <S extends T> reactor.core.publisher.Mono<S> save(S entity)

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の save 

• saveAll

  public <S extends T> reactor.core.publisher.Flux<S> saveAll(IterableSE<S> entities)

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の saveAll 

• saveAll

  public <S extends T> reactor.core.publisher.Flux<S> saveAll(org.reactivestreams.Publisher<S> entityStream)

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の saveAll 

• findById

  public reactor.core.publisher.Mono<T> findById(ID id)

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の findById 

• findById

  public reactor.core.publisher.Mono<T> findById(org.reactivestreams.Publisher<ID> publisher)

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の findById 

• existsById

  public reactor.core.publisher.Mono<BooleanSE> existsById(ID id)

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の existsById 

• existsById

  public reactor.core.publisher.Mono<BooleanSE> existsById(org.reactivestreams.Publisher<ID> publisher)

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の existsById 

• findAll

  public reactor.core.publisher.Flux<T> findAll()

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の findAll 

• findAllById

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

  インターフェースからコピーされた説明: ReactiveCassandraRepository

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

  次で指定:

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

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の findAllById 

• findAllById

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

  インターフェースからコピーされた説明: ReactiveCassandraRepository

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

  次で指定:

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

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の findAllById 

• count

  public reactor.core.publisher.Mono<LongSE> count()

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の count 

• deleteById

  public reactor.core.publisher.Mono<VoidSE> deleteById(ID id)

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の deleteById 

• deleteById

  public reactor.core.publisher.Mono<VoidSE> deleteById(org.reactivestreams.Publisher<ID> publisher)

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の deleteById 

• delete

  public reactor.core.publisher.Mono<VoidSE> delete(T entity)

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の delete 

• deleteAllById

  public reactor.core.publisher.Mono<VoidSE> deleteAllById(IterableSE<? extends ID> ids)

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の deleteAllById 

• deleteAll

  public reactor.core.publisher.Mono<VoidSE> deleteAll(IterableSE<? extends T> entities)

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の deleteAll 

• deleteAll

  public reactor.core.publisher.Mono<VoidSE> deleteAll(org.reactivestreams.Publisher<? extends T> entityStream)

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の deleteAll 

• deleteAll

  public reactor.core.publisher.Mono<VoidSE> deleteAll()

  次で指定:

  インターフェース ReactiveCrudRepository<T,ID> の deleteAll 

• insert

  public <S extends T> reactor.core.publisher.Mono<S> insert(S entity)

  インターフェースからコピーされた説明: ReactiveCassandraRepository

  指定されたエンティティを挿入します。挿入の最適化を適用できるように、インスタンスが新規であると想定します。保存操作によってエンティティインスタンスが完全に変更される可能性があるため、返されたインスタンスを以降の操作に使用します。ストア固有の API の使用を避けるため、代わりに ReactiveCrudRepository.save(Object) を使用することをお勧めします。

  次で指定:

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

  パラメーター:

  entity - null であってはなりません。

  戻り値:

  保存されたエンティティ

• insert

  public <S extends T> reactor.core.publisher.Flux<S> insert(IterableSE<S> entities)

  インターフェースからコピーされた説明: ReactiveCassandraRepository

  指定されたエンティティを挿入します。挿入の最適化を適用できるように、インスタンスが新規であると想定します。保存操作によってエンティティインスタンスが完全に変更される可能性があるため、返されたインスタンスを以降の操作に使用します。ストア固有の API の使用を避けるため、代わりに ReactiveCrudRepository.save(Object) を使用することをお勧めします。

  次で指定:

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

  パラメーター:

  entities - null であってはなりません。

  戻り値:

  保存されたエンティティ

• insert

  public <S extends T> reactor.core.publisher.Flux<S> insert(org.reactivestreams.Publisher<S> entityStream)

  インターフェースからコピーされた説明: ReactiveCassandraRepository

  指定されたエンティティを挿入します。挿入の最適化を適用できるように、インスタンスが新規であると想定します。保存操作によってエンティティインスタンスが完全に変更される可能性があるため、返されたインスタンスを以降の操作に使用します。ストア固有の API の使用を避けるため、代わりに ReactiveCrudRepository.save(Object) を使用することをお勧めします。

  次で指定:

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

  パラメーター:

  entityStream - null であってはなりません。

  戻り値:

  保存されたエンティティ