Package org.springframework.data.couchbase.core

Interface ReactiveCouchbaseOperations

All Superinterfaces:
ReactiveExistsByIdOperation, ReactiveFindByAnalyticsOperation, ReactiveFindByIdOperation, ReactiveFindByQueryOperation, ReactiveFindFromReplicasByIdOperation, ReactiveFluentCouchbaseOperations, ReactiveInsertByIdOperation, ReactiveRemoveByIdOperation, ReactiveRemoveByQueryOperation, ReactiveReplaceByIdOperation, ReactiveUpsertByIdOperation
All Known Implementing Classes:
ReactiveCouchbaseTemplate
public interface ReactiveCouchbaseOperations extends ReactiveFluentCouchbaseOperations
Defines common operations on the Couchbase data source, most commonly implemented by ReactiveCouchbaseTemplate.
Author:
Michael Nitschinger, Michael Reiche

  • Method Details

    • getConverter

      CouchbaseConverter getConverter()
      Returns the converter used for this template/operations.

    • getBucketName

      String getBucketName()
      The name of the bucket used.

    • getScopeName

      String getScopeName()
      The name of the scope used, null if the default scope is used.

    • getCouchbaseClientFactory

      CouchbaseClientFactory getCouchbaseClientFactory()
      Returns the underlying client factory.

    • save

      <T> reactor.core.publisher.Mono<T> save(T entity, String... scopeAndCollection)
      Save the entity to couchbase.
      If there is no version property on the entity class, and this is in a transaction, use insert.
      If there is no version property on the entity class, and this is not in a transaction, use upsert.
      If there is a version property on the entity class, and it is non-zero, then this is an existing document, use replace.
      Otherwise, there is a version property for the entity, but it is zero or null, use insert.
      Type Parameters:
      T - the entity class
      Parameters:
      entity - the entity to save in couchbase
      scopeAndCollection - for use by repositories only. these are varargs for the scope and collection.
      Returns:

    • count

      <T> reactor.core.publisher.Mono<Long> count(Query query, Class<T> domainType)
      Returns the count of documents found by the query.
      Type Parameters:
      T -
      Parameters:
      query -
      domainType -
      Returns:

    • getConsistency

      com.couchbase.client.java.query.QueryScanConsistency getConsistency()
      Returns:
      the default consistency to use for queries