Package org.springframework.data.cassandra.repository.support

Class SimpleReactiveCassandraRepository<T,ID>

java.lang.Object

org.springframework.data.cassandra.repository.support.SimpleReactiveCassandraRepository<T,ID>

All Implemented Interfaces:

ReactiveCassandraRepository<T,ID>, ReactiveCrudRepository<T,ID>, Repository<T,ID>

public class SimpleReactiveCassandraRepository<T,ID>
extends Object
implements ReactiveCassandraRepository<T,ID>

Reactive repository base implementation for Cassandra.

Since:

2.0

Author:

Mark Paluch, Christoph Strobl, Jens Schauder

Constructor Summary

Constructors

Constructor	Description
SimpleReactiveCassandraRepository(CassandraEntityInformation<T,ID> metadata, ReactiveCassandraOperations operations)	Create a new SimpleReactiveCassandraRepository for the given CassandraEntityInformation and ReactiveCassandraOperations.

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<Long>	count()
reactor.core.publisher.Mono<Void>	delete(T entity)
reactor.core.publisher.Mono<Void>	deleteAll()
reactor.core.publisher.Mono<Void>	deleteAll(Iterable<? extends T> entities)
reactor.core.publisher.Mono<Void>	deleteAll(org.reactivestreams.Publisher<? extends T> entityStream)
reactor.core.publisher.Mono<Void>	deleteAllById(Iterable<? extends ID> ids)
reactor.core.publisher.Mono<Void>	deleteById(ID id)
reactor.core.publisher.Mono<Void>	deleteById(org.reactivestreams.Publisher<ID> publisher)
reactor.core.publisher.Mono<Boolean>	existsById(ID id)
reactor.core.publisher.Mono<Boolean>	existsById(org.reactivestreams.Publisher<ID> publisher)
reactor.core.publisher.Flux<T>	findAll()
reactor.core.publisher.Flux<T>	findAllById(Iterable<ID> ids)
reactor.core.publisher.Flux<T>	findAllById(org.reactivestreams.Publisher<ID> idStream)
reactor.core.publisher.Mono<T>	findById(ID id)
reactor.core.publisher.Mono<T>	findById(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> entityStream)	Inserts the given a given entities.
<S extends T> reactor.core.publisher.Mono<S>	insert(S entity)	Inserts the given entity.
<S extends T> reactor.core.publisher.Mono<S>	save(S entity)
<S extends T> reactor.core.publisher.Flux<S>	saveAll(Iterable<S> entities)
<S extends T> reactor.core.publisher.Flux<S>	saveAll(org.reactivestreams.Publisher<S> entityStream)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SimpleReactiveCassandraRepository

public SimpleReactiveCassandraRepository(CassandraEntityInformation<T,ID> metadata,
 ReactiveCassandraOperations operations)

Create a new SimpleReactiveCassandraRepository for the given CassandraEntityInformation and ReactiveCassandraOperations.

Parameters:

metadata - must not be null.

operations - must not be null.

Method Details

save

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

Specified by:

save in interface ReactiveCrudRepository<T,ID>

saveAll

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

Specified by:

saveAll in interface ReactiveCrudRepository<T,ID>

saveAll

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

Specified by:

saveAll in interface ReactiveCrudRepository<T,ID>

findById

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

Specified by:

findById in interface ReactiveCrudRepository<T,ID>

findById

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

Specified by:

findById in interface ReactiveCrudRepository<T,ID>

existsById

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

Specified by:

existsById in interface ReactiveCrudRepository<T,ID>

existsById

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

Specified by:

existsById in interface ReactiveCrudRepository<T,ID>

findAll

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

Specified by:

findAll in interface ReactiveCrudRepository<T,ID>

findAllById

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

Description copied from interface: ReactiveCassandraRepository

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

Specified by:

findAllById in interface ReactiveCassandraRepository<T,ID>

Specified by:

findAllById in interface ReactiveCrudRepository<T,ID>

findAllById

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

Description copied from interface: ReactiveCassandraRepository

Fetches each row individually.

Specified by:

findAllById in interface ReactiveCassandraRepository<T,ID>

Specified by:

findAllById in interface ReactiveCrudRepository<T,ID>

count

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

Specified by:

count in interface ReactiveCrudRepository<T,ID>

deleteById

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

Specified by:

deleteById in interface ReactiveCrudRepository<T,ID>

deleteById

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

Specified by:

deleteById in interface ReactiveCrudRepository<T,ID>

delete

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

Specified by:

delete in interface ReactiveCrudRepository<T,ID>

deleteAllById

public reactor.core.publisher.Mono<Void> deleteAllById(Iterable<? extends ID> ids)

Specified by:

deleteAllById in interface ReactiveCrudRepository<T,ID>

deleteAll

public reactor.core.publisher.Mono<Void> deleteAll(Iterable<? extends T> entities)

Specified by:

deleteAll in interface ReactiveCrudRepository<T,ID>

deleteAll

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

Specified by:

deleteAll in interface ReactiveCrudRepository<T,ID>

deleteAll

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

Specified by:

deleteAll in interface ReactiveCrudRepository<T,ID>

insert

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

Description copied from interface: ReactiveCassandraRepository

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.

Specified by:

insert in interface ReactiveCassandraRepository<T,ID>

Parameters:

entity - must not be null.

Returns:

the saved entity

insert

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

Description copied from interface: ReactiveCassandraRepository

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.

Specified by:

insert in interface ReactiveCassandraRepository<T,ID>

Parameters:

entities - must not be null.

Returns:

the saved entity

insert

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

Description copied from interface: ReactiveCassandraRepository

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.

Specified by:

insert in interface ReactiveCassandraRepository<T,ID>

Parameters:

entityStream - must not be null.

Returns:

the saved entity