diff --git a/src/main/java/org/springframework/data/couchbase/core/CouchbaseOperations.java b/src/main/java/org/springframework/data/couchbase/core/CouchbaseOperations.java index 2e0b4b36..a50d8c98 100644 --- a/src/main/java/org/springframework/data/couchbase/core/CouchbaseOperations.java +++ b/src/main/java/org/springframework/data/couchbase/core/CouchbaseOperations.java @@ -17,6 +17,7 @@ package org.springframework.data.couchbase.core; +import com.couchbase.client.CouchbaseClient; import com.couchbase.client.protocol.views.Query; import com.couchbase.client.protocol.views.ViewResponse; import net.spy.memcached.PersistTo; @@ -273,4 +274,11 @@ public interface CouchbaseOperations { */ CouchbaseConverter getConverter(); + /** + * Returns the linked {@link CouchbaseClient} to this template. + * + * @return the client used for the template. + */ + CouchbaseClient getCouchbaseClient(); + } diff --git a/src/main/java/org/springframework/data/couchbase/core/CouchbaseTemplate.java b/src/main/java/org/springframework/data/couchbase/core/CouchbaseTemplate.java index 4439f47c..b91594d3 100644 --- a/src/main/java/org/springframework/data/couchbase/core/CouchbaseTemplate.java +++ b/src/main/java/org/springframework/data/couchbase/core/CouchbaseTemplate.java @@ -486,4 +486,8 @@ public class CouchbaseTemplate implements CouchbaseOperations, ApplicationEventP } } + @Override + public CouchbaseClient getCouchbaseClient() { + return client; + } }