SimpleReactiveCosmosRepository<T,K> Class

Package:
com.azure.spring.data.cosmos.repository.support
Maven Artifact:
com.azure:azure-spring-data-cosmos:6.4.0
  • java.lang.Object
    • com.azure.spring.data.cosmos.repository.support.SimpleReactiveCosmosRepository<T,K>

Type Parameters

T

the type of the domain class managed by this repository.

K

the type of the id of the domain class managed by this repository.

Implements

ReactiveCosmosRepository<T,K>

public class SimpleReactiveCosmosRepository<T,K>
implements ReactiveCosmosRepository<T,K>

Repository class for simple reactive Cosmos operation

Constructor Summary

Constructor Description
SimpleReactiveCosmosRepository(CosmosEntityInformation<T,K> metadata, ReactiveCosmosOperations reactiveCosmosOperations)

Initialization with metadata and reactiveCosmosOperations

Method Summary

Modifier and Type Method and 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(Publisher<? extends T> entityStream)
reactor.core.publisher.Mono<Void> deleteAllById(Iterable<? extends K> ids)
reactor.core.publisher.Mono<Void> deleteById(K id)
reactor.core.publisher.Mono<Void> deleteById(K id, PartitionKey partitionKey)

Deletes an entity by its id and partition key.
reactor.core.publisher.Mono<Void> deleteById(Publisher<K> publisher)
reactor.core.publisher.Mono<Boolean> existsById(K id)
reactor.core.publisher.Mono<Boolean> existsById(Publisher<K> publisher)
reactor.core.publisher.Flux<T> findAll()
reactor.core.publisher.Flux<T> findAll(PartitionKey partitionKey)

Returns Flux of items in a specific partition
reactor.core.publisher.Flux<T> findAll(Sort sort)
reactor.core.publisher.Flux<T> findAllById(Iterable<K> ids)
reactor.core.publisher.Flux<T> findAllById(Publisher<K> ids)
reactor.core.publisher.Mono<T> findById(K id)
reactor.core.publisher.Mono<T> findById(K id, PartitionKey partitionKey)

Retrieves an entity by its id and partition key.
reactor.core.publisher.Mono<T> findById(Publisher<K> publisher)
reactor.core.publisher.Mono<S> save(K id, PartitionKey partitionKey, Class<S> domainType, CosmosPatchOperations patchOperations)

Patches an entity by its id and partition key with CosmosPatchItemRequestOptions
reactor.core.publisher.Mono<S> save(K id, PartitionKey partitionKey, Class<S> domainType, CosmosPatchOperations patchOperations, CosmosPatchItemRequestOptions options)

Patches an entity by its id and partition key with CosmosPatchItemRequestOptions
reactor.core.publisher.Mono<S> save(S entity)
reactor.core.publisher.Flux<S> saveAll(Iterable<S> entities)
reactor.core.publisher.Flux<S> saveAll(Publisher<S> entityStream)

Methods inherited from java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Details

SimpleReactiveCosmosRepository

public SimpleReactiveCosmosRepository(CosmosEntityInformation<T,K> metadata, ReactiveCosmosOperations reactiveCosmosOperations)

Initialization with metadata and reactiveCosmosOperations

Parameters:

metadata - for entityInformation
reactiveCosmosOperations - for cosmosOperations

Method Details

count

public Mono<Long> count()

delete

public Mono<Void> delete(T entity)

Parameters:

entity

deleteAll

public Mono<Void> deleteAll()

deleteAll

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

Parameters:

entities

deleteAll

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

Parameters:

entityStream

deleteAllById

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

Parameters:

ids

deleteById

public Mono<Void> deleteById(K id)

Parameters:

id

deleteById

public Mono<Void> deleteById(K id, PartitionKey partitionKey)

Deletes an entity by its id and partition key.

Parameters:

id
partitionKey

deleteById

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

Parameters:

publisher

existsById

public Mono<Boolean> existsById(K id)

Parameters:

id

existsById

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

Parameters:

publisher

findAll

public Flux<T> findAll()

findAll

public Flux<T> findAll(PartitionKey partitionKey)

Returns Flux of items in a specific partition

Parameters:

partitionKey

findAll

public Flux<T> findAll(Sort sort)

Parameters:

sort

findAllById

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

Parameters:

ids

findAllById

public Flux<T> findAllById(Publisher<K> ids)

Parameters:

ids

findById

public Mono<T> findById(K id)

Parameters:

id

findById

public Mono<T> findById(K id, PartitionKey partitionKey)

Retrieves an entity by its id and partition key.

Parameters:

id
partitionKey

findById

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

Parameters:

publisher

save

public Mono save(K id, PartitionKey partitionKey, Class domainType, CosmosPatchOperations patchOperations)

Patches an entity by its id and partition key with CosmosPatchItemRequestOptions

Parameters:

id
partitionKey
domainType
patchOperations

save

public Mono save(K id, PartitionKey partitionKey, Class domainType, CosmosPatchOperations patchOperations, CosmosPatchItemRequestOptions options)

Patches an entity by its id and partition key with CosmosPatchItemRequestOptions

Parameters:

id
partitionKey
domainType
patchOperations
options

save

public Mono save(S entity)

Parameters:

entity

saveAll

public Flux saveAll(Iterable entities)

Parameters:

entities

saveAll

public Flux saveAll(Publisher entityStream)

Parameters:

entityStream

Applies to