Package org.springframework.data.cassandra.repository

Interface ReactiveCassandraRepository<T,ID>

All Superinterfaces:
org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID>, org.springframework.data.repository.Repository<T,ID>
All Known Implementing Classes:
SimpleReactiveCassandraRepository
@NoRepositoryBean public interface ReactiveCassandraRepository<T,ID> extends org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID>
Cassandra specific Repository interface with reactive support.
Since:
2.0
Author:
Mark Paluch

  • Method Summary

    Modifier and Type
    Method
    Description
    reactor.core.publisher.Flux<T>
    findAllById(Iterable<ID> iterable)
    reactor.core.publisher.Flux<T>
    findAllById(org.reactivestreams.Publisher<ID> publisher)
    <S extends T>
    reactor.core.publisher.Flux<S>
    insert(Iterable<S> entities)
    Inserts the given entities.
    <S extends T>
    reactor.core.publisher.Flux<S>
    insert(org.reactivestreams.Publisher<S> entities)
    Inserts the given a given entities.
    <S extends T>
    reactor.core.publisher.Mono<S>
    insert(S entity)
    Inserts the given entity.

    Methods inherited from interface org.springframework.data.repository.reactive.ReactiveCrudRepository

    count, delete, deleteAll, deleteAll, deleteAll, deleteAllById, deleteById, deleteById, existsById, existsById, findAll, findById, findById, save, saveAll, saveAll

  • Method Details

    • insert

      <S extends T> reactor.core.publisher.Mono<S> insert(S entity)
      Inserts the given entity. Assumes the instance to be new to be able to apply insertion optimizations. Use the returned instance for further operations as the save operation might have changed the entity instance completely. Prefer using ReactiveCrudRepository.save(Object) instead to avoid the usage of store-specific API.
      Parameters:
      entity - must not be null.
      Returns:
      the saved entity

    • insert

      <S extends T> reactor.core.publisher.Flux<S> insert(Iterable<S> entities)
      Inserts the given entities. Assumes the instance to be new to be able to apply insertion optimizations. Use the returned instance for further operations as the save operation might have changed the entity instance completely. Prefer using ReactiveCrudRepository.save(Object) instead to avoid the usage of store-specific API.
      Parameters:
      entities - must not be null.
      Returns:
      the saved entity

    • insert

      <S extends T> reactor.core.publisher.Flux<S> insert(org.reactivestreams.Publisher<S> entities)
      Inserts the given a given entities. Assumes the instance to be new to be able to apply insertion optimizations. Use the returned instance for further operations as the save operation might have changed the entity instance completely. Prefer using ReactiveCrudRepository.save(Object) instead to avoid the usage of store-specific API.
      Parameters:
      entities - must not be null.
      Returns:
      the saved entity

    • findAllById

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

      Note: Cassandra supports single-field IN queries only. Fetches each row individually when using MapId with multiple components.

      Specified by:
      findAllById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID>

    • findAllById

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

      Fetches each row individually.

      Specified by:
      findAllById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,ID>