Package com.azure.spring.data.cosmos.repository.support

Class SimpleReactiveCosmosRepository<T,K extends Serializable>

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.
All Implemented Interfaces:
ReactiveCosmosRepository<T,K>, org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K>, org.springframework.data.repository.reactive.ReactiveSortingRepository<T,K>, org.springframework.data.repository.Repository<T,K>
public class SimpleReactiveCosmosRepository<T,K extends Serializable> extends Object implements ReactiveCosmosRepository<T,K>
Repository class for simple reactive Cosmos operation

  • 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

    • findAll

      public Flux<T> findAll(org.springframework.data.domain.Sort sort)
      Specified by:
      findAll in interface org.springframework.data.repository.reactive.ReactiveSortingRepository<T,K extends Serializable>

    • findAll

      public Flux<T> findAll(com.azure.cosmos.models.PartitionKey partitionKey)
      Description copied from interface: ReactiveCosmosRepository
      Returns Flux of items in a specific partition
      Specified by:
      findAll in interface ReactiveCosmosRepository<T,K extends Serializable>
      Parameters:
      partitionKey - partition key value
      Returns:
      Flux of items with partition key value

    • save

      public <S extends T> Mono<S> save(S entity)
      Specified by:
      save in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • save

      public <S extends T> Mono<S> save(K id, com.azure.cosmos.models.PartitionKey partitionKey, Class<S> domainType, com.azure.cosmos.models.CosmosPatchOperations patchOperations)
      Description copied from interface: ReactiveCosmosRepository
      Patches an entity by its id and partition key with CosmosPatchItemRequestOptions
      Specified by:
      save in interface ReactiveCosmosRepository<T,K extends Serializable>
      Type Parameters:
      S - type class of domain type
      Parameters:
      id - must not be null
      partitionKey - must not be null
      domainType - must not be null
      patchOperations - must not be null, max operations is 10
      Returns:
      the patched entity

    • save

      public <S extends T> Mono<S> save(K id, com.azure.cosmos.models.PartitionKey partitionKey, Class<S> domainType, com.azure.cosmos.models.CosmosPatchOperations patchOperations, com.azure.cosmos.models.CosmosPatchItemRequestOptions options)
      Description copied from interface: ReactiveCosmosRepository
      Patches an entity by its id and partition key with CosmosPatchItemRequestOptions
      Specified by:
      save in interface ReactiveCosmosRepository<T,K extends Serializable>
      Type Parameters:
      S - type class of domain type
      Parameters:
      id - must not be null
      partitionKey - must not be null
      domainType - must not be null
      patchOperations - must not be null, max operations is 10
      options - Optional CosmosPatchItemRequestOptions, e.g. options.setFilterPredicate("FROM products p WHERE p.used = false");
      Returns:
      the patched entity

    • saveAll

      public <S extends T> Flux<S> saveAll(Iterable<S> entities)
      Specified by:
      saveAll in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • saveAll

      public <S extends T> Flux<S> saveAll(org.reactivestreams.Publisher<S> entityStream)
      Specified by:
      saveAll in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • findById

      public Mono<T> findById(K id)
      Specified by:
      findById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • findById

      public Mono<T> findById(org.reactivestreams.Publisher<K> publisher)
      Specified by:
      findById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • findById

      public Mono<T> findById(K id, com.azure.cosmos.models.PartitionKey partitionKey)
      Description copied from interface: ReactiveCosmosRepository
      Retrieves an entity by its id and partition key.
      Specified by:
      findById in interface ReactiveCosmosRepository<T,K extends Serializable>
      Parameters:
      id - must not be null.
      partitionKey - partition key value of the entity, must not be null.
      Returns:
      Mono emitting the entity with the given id or Mono.empty() if none found.

    • existsById

      public Mono<Boolean> existsById(K id)
      Specified by:
      existsById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • existsById

      public Mono<Boolean> existsById(org.reactivestreams.Publisher<K> publisher)
      Specified by:
      existsById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • findAll

      public Flux<T> findAll()
      Specified by:
      findAll in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • findAllById

      public Flux<T> findAllById(Iterable<K> ids)
      Specified by:
      findAllById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • findAllById

      public Flux<T> findAllById(org.reactivestreams.Publisher<K> ids)
      Specified by:
      findAllById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • count

      public Mono<Long> count()
      Specified by:
      count in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • deleteById

      public Mono<Void> deleteById(K id)
      Specified by:
      deleteById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • deleteById

      public Mono<Void> deleteById(org.reactivestreams.Publisher<K> publisher)
      Specified by:
      deleteById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • deleteById

      public Mono<Void> deleteById(K id, com.azure.cosmos.models.PartitionKey partitionKey)
      Description copied from interface: ReactiveCosmosRepository
      Deletes an entity by its id and partition key.
      Specified by:
      deleteById in interface ReactiveCosmosRepository<T,K extends Serializable>
      Parameters:
      id - must not be null.
      partitionKey - partition key value of the entity, must not be null.
      Returns:
      Mono emitting the void Mono.

    • delete

      public Mono<Void> delete(@NonNull T entity)
      Specified by:
      delete in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • deleteAllById

      public Mono<Void> deleteAllById(Iterable<? extends K> ids)
      Specified by:
      deleteAllById in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • deleteAll

      public Mono<Void> deleteAll(Iterable<? extends T> entities)
      Specified by:
      deleteAll in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • deleteAll

      public Mono<Void> deleteAll(org.reactivestreams.Publisher<? extends T> entityStream)
      Specified by:
      deleteAll in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>

    • deleteAll

      public Mono<Void> deleteAll()
      Specified by:
      deleteAll in interface org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K extends Serializable>