Class SimpleReactiveCouchbaseRepository<T,ID>

java.lang.Object

org.springframework.data.couchbase.repository.support.CouchbaseRepositoryBase<T,ID>

org.springframework.data.couchbase.repository.support.SimpleReactiveCouchbaseRepository<T,ID>

All Implemented Interfaces:

ReactiveCouchbaseRepository<T,ID>, ReactiveCrudRepository<T,ID>, ReactiveSortingRepository<T,ID>, Repository<T,ID>

public class SimpleReactiveCouchbaseRepository<T,ID>
extends CouchbaseRepositoryBase<T,ID>
implements ReactiveCouchbaseRepository<T,ID>

Reactive repository base implementation for Couchbase.

Since:

3.0

Author:

Subhashni Balakrishnan, Mark Paluch, Christoph Strobl, David Kelly, Douglas Six, Jens Schauder, Michael Reiche

Constructor Summary

Constructors

Constructor	Description
SimpleReactiveCouchbaseRepository(CouchbaseEntityInformation<T,String> entityInformation, ReactiveCouchbaseOperations operations, Class<?> repositoryInterface)	Create a new Repository.

Method Summary

Modifier and Type	Method	Description
Mono<Long>	count()
Mono<Void>	delete(T entity)
Mono<Void>	deleteAll()
Mono<Void>	deleteAll(Iterable<? extends T> entities)
Mono<Void>	deleteAll(Publisher<? extends T> entityStream)
Mono<Void>	deleteAllById(Iterable<? extends ID> ids)
Mono<Void>	deleteById(ID id)
Mono<Void>	deleteById(Publisher<ID> publisher)
Mono<Boolean>	existsById(ID id)
Mono<Boolean>	existsById(Publisher<ID> publisher)
Flux<T>	findAll()
Flux<T>	findAll(Sort sort)
Flux<T>	findAllById(Iterable<ID> ids)
Flux<T>	findAllById(Publisher<ID> entityStream)
Mono<T>	findById(ID id)
Mono<T>	findById(Publisher<ID> publisher)
ReactiveCouchbaseOperations	getOperations()
protected ReactiveCouchbaseTemplate	getReactiveTemplate()
<S extends T> Mono<S>	save(S entity)
<S extends T> Flux<S>	saveAll(Iterable<S> entities)
<S extends T> Flux<S>	saveAll(Publisher<S> entityStream)

Methods inherited from class CouchbaseRepositoryBase

getCollection, getEntityInformation, getOptions, getRepositoryInterface, getScope

Methods inherited from class Object

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

Methods inherited from interface ReactiveCouchbaseRepository

getEntityInformation

Constructor Details

SimpleReactiveCouchbaseRepository

public SimpleReactiveCouchbaseRepository(CouchbaseEntityInformation<T,String> entityInformation,
 ReactiveCouchbaseOperations operations,
 Class<?> repositoryInterface)

Create a new Repository.

Parameters:

entityInformation - the Metadata for the entity.

operations - the reference to the reactive template used.

Method Details

findAll

public Flux<T> findAll(Sort sort)

Specified by:

findAll in interface ReactiveSortingRepository<T,ID>

save

public <S extends T> Mono<S> save(S entity)

Specified by:

save in interface ReactiveCrudRepository<T,ID>

saveAll

public <S extends T> Flux<S> saveAll(Iterable<S> entities)

Specified by:

saveAll in interface ReactiveCrudRepository<T,ID>

saveAll

public <S extends T> Flux<S> saveAll(Publisher<S> entityStream)

Specified by:

saveAll in interface ReactiveCrudRepository<T,ID>

findById

public Mono<T> findById(ID id)

Specified by:

findById in interface ReactiveCrudRepository<T,ID>

findById

public Mono<T> findById(Publisher<ID> publisher)

Specified by:

findById in interface ReactiveCrudRepository<T,ID>

findAllById

public Flux<T> findAllById(Iterable<ID> ids)

Specified by:

findAllById in interface ReactiveCrudRepository<T,ID>

findAllById

public Flux<T> findAllById(Publisher<ID> entityStream)

Specified by:

findAllById in interface ReactiveCrudRepository<T,ID>

existsById

public Mono<Boolean> existsById(ID id)

Specified by:

existsById in interface ReactiveCrudRepository<T,ID>

existsById

public Mono<Boolean> existsById(Publisher<ID> publisher)

Specified by:

existsById in interface ReactiveCrudRepository<T,ID>

findAll

public Flux<T> findAll()

Specified by:

findAll in interface ReactiveCrudRepository<T,ID>

deleteById

public Mono<Void> deleteById(ID id)

Specified by:

deleteById in interface ReactiveCrudRepository<T,ID>

deleteById

public Mono<Void> deleteById(Publisher<ID> publisher)

Specified by:

deleteById in interface ReactiveCrudRepository<T,ID>

delete

public Mono<Void> delete(T entity)

Specified by:

delete in interface ReactiveCrudRepository<T,ID>

deleteAllById

public Mono<Void> deleteAllById(Iterable<? extends ID> ids)

Specified by:

deleteAllById in interface ReactiveCrudRepository<T,ID>

deleteAll

public Mono<Void> deleteAll(Iterable<? extends T> entities)

Specified by:

deleteAll in interface ReactiveCrudRepository<T,ID>

deleteAll

public Mono<Void> deleteAll(Publisher<? extends T> entityStream)

Specified by:

deleteAll in interface ReactiveCrudRepository<T,ID>

deleteAll

public Mono<Void> deleteAll()

Specified by:

deleteAll in interface ReactiveCrudRepository<T,ID>

count

public Mono<Long> count()

Specified by:

count in interface ReactiveCrudRepository<T,ID>

getOperations

public ReactiveCouchbaseOperations getOperations()

Specified by:

getOperations in interface ReactiveCouchbaseRepository<T,ID>

getReactiveTemplate

protected ReactiveCouchbaseTemplate getReactiveTemplate()

Specified by:

getReactiveTemplate in class CouchbaseRepositoryBase<T,ID>