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

Interface ReactiveCosmosRepository<T,K>

All Superinterfaces:
org.springframework.data.repository.reactive.ReactiveCrudRepository<T,K>, org.springframework.data.repository.reactive.ReactiveSortingRepository<T,K>, org.springframework.data.repository.Repository<T,K>
All Known Implementing Classes:
SimpleReactiveCosmosRepository
@NoRepositoryBean public interface ReactiveCosmosRepository<T,K> extends org.springframework.data.repository.reactive.ReactiveSortingRepository<T,K>
Repository interface with search and delete operation

  • Method Summary

    Modifier and Type
    Method
    Description
    Mono<Void>
    deleteById(K id, PartitionKey partitionKey)
    Deletes an entity by its id and partition key.
    Flux<T>
    findAll(PartitionKey partitionKey)
    Returns Flux of items in a specific partition
    Mono<T>
    findById(K id, PartitionKey partitionKey)
    Retrieves an entity by its id and partition key.

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

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

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

    findAll

  • Method Details

    • findById

      Mono<T> findById(K id, PartitionKey partitionKey)
      Retrieves an entity by its id and partition key.
      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.
      Throws:
      IllegalArgumentException - in case the given id is null.

    • deleteById

      Mono<Void> deleteById(K id, PartitionKey partitionKey)
      Deletes an entity by its id and partition key.
      Parameters:
      id - must not be null.
      partitionKey - partition key value of the entity, must not be null.
      Returns:
      Mono emitting the void Mono.
      Throws:
      IllegalArgumentException - in case the given id is null.

    • findAll

      Flux<T> findAll(PartitionKey partitionKey)
      Returns Flux of items in a specific partition
      Parameters:
      partitionKey - partition key value
      Returns:
      Flux of items with partition key value