public class RxJavaCouchbaseTemplate extends Object implements RxJavaCouchbaseOperations
Modifier and Type | Field and Description |
---|---|
protected MappingContext<? extends CouchbasePersistentEntity<?>,CouchbasePersistentProperty> |
mappingContext |
Constructor and Description |
---|
RxJavaCouchbaseTemplate(com.couchbase.client.java.cluster.ClusterInfo clusterInfo,
com.couchbase.client.java.Bucket client) |
RxJavaCouchbaseTemplate(com.couchbase.client.java.cluster.ClusterInfo clusterInfo,
com.couchbase.client.java.Bucket client,
CouchbaseConverter converter,
TranslationService translationService) |
RxJavaCouchbaseTemplate(com.couchbase.client.java.cluster.ClusterInfo clusterInfo,
com.couchbase.client.java.Bucket client,
TranslationService translationService) |
Modifier and Type | Method and Description |
---|---|
rx.Observable<Boolean> |
exists(String id) |
<T> rx.Observable<T> |
findById(String id,
Class<T> entityClass) |
<T> rx.Observable<T> |
findByN1QL(com.couchbase.client.java.query.N1qlQuery query,
Class<T> entityClass) |
<T> rx.Observable<T> |
findByN1QLProjection(com.couchbase.client.java.query.N1qlQuery query,
Class<T> entityClass) |
<T> rx.Observable<T> |
findBySpatialView(com.couchbase.client.java.view.SpatialViewQuery query,
Class<T> entityClass) |
<T> rx.Observable<T> |
findByView(com.couchbase.client.java.view.ViewQuery query,
Class<T> entityClass) |
CouchbaseConverter |
getConverter() |
com.couchbase.client.java.Bucket |
getCouchbaseBucket()
Returns the linked
Bucket to this template. |
com.couchbase.client.java.cluster.ClusterInfo |
getCouchbaseClusterInfo() |
Consistency |
getDefaultConsistency() |
<T> rx.Observable<T> |
insert(Iterable<T> batchToSave) |
<T> rx.Observable<T> |
insert(Iterable<T> batchToSave,
com.couchbase.client.java.PersistTo persistTo,
com.couchbase.client.java.ReplicateTo replicateTo) |
<T> rx.Observable<T> |
insert(T objectToSave) |
<T> rx.Observable<T> |
insert(T objectToSave,
com.couchbase.client.java.PersistTo persistTo,
com.couchbase.client.java.ReplicateTo replicateTo) |
rx.Observable<com.couchbase.client.java.query.AsyncN1qlQueryResult> |
queryN1QL(com.couchbase.client.java.query.N1qlQuery query) |
rx.Observable<com.couchbase.client.java.view.AsyncSpatialViewResult> |
querySpatialView(com.couchbase.client.java.view.SpatialViewQuery query) |
rx.Observable<com.couchbase.client.java.view.AsyncViewResult> |
queryView(com.couchbase.client.java.view.ViewQuery query) |
<T> rx.Observable<T> |
remove(Iterable<T> batchToRemove) |
<T> rx.Observable<T> |
remove(Iterable<T> batchToRemove,
com.couchbase.client.java.PersistTo persistTo,
com.couchbase.client.java.ReplicateTo replicateTo) |
<T> rx.Observable<T> |
remove(T objectToRemove) |
<T> rx.Observable<T> |
remove(T objectToRemove,
com.couchbase.client.java.PersistTo persistTo,
com.couchbase.client.java.ReplicateTo replicateTo) |
<T> rx.Observable<T> |
save(Iterable<T> batchToSave) |
<T> rx.Observable<T> |
save(Iterable<T> batchToSave,
com.couchbase.client.java.PersistTo persistTo,
com.couchbase.client.java.ReplicateTo replicateTo) |
<T> rx.Observable<T> |
save(T objectToSave) |
<T> rx.Observable<T> |
save(T objectToSave,
com.couchbase.client.java.PersistTo persistTo,
com.couchbase.client.java.ReplicateTo replicateTo) |
void |
setDefaultConsistency(Consistency consistency) |
void |
setWriteResultChecking(WriteResultChecking writeResultChecking) |
<T> rx.Observable<T> |
update(Iterable<T> batchToSave) |
<T> rx.Observable<T> |
update(Iterable<T> batchToSave,
com.couchbase.client.java.PersistTo persistTo,
com.couchbase.client.java.ReplicateTo replicateTo) |
<T> rx.Observable<T> |
update(T objectToSave) |
<T> rx.Observable<T> |
update(T objectToSave,
com.couchbase.client.java.PersistTo persistTo,
com.couchbase.client.java.ReplicateTo replicateTo) |
protected final MappingContext<? extends CouchbasePersistentEntity<?>,CouchbasePersistentProperty> mappingContext
public RxJavaCouchbaseTemplate(com.couchbase.client.java.cluster.ClusterInfo clusterInfo, com.couchbase.client.java.Bucket client)
public RxJavaCouchbaseTemplate(com.couchbase.client.java.cluster.ClusterInfo clusterInfo, com.couchbase.client.java.Bucket client, TranslationService translationService)
public RxJavaCouchbaseTemplate(com.couchbase.client.java.cluster.ClusterInfo clusterInfo, com.couchbase.client.java.Bucket client, CouchbaseConverter converter, TranslationService translationService)
public <T> rx.Observable<T> save(T objectToSave)
save
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> save(Iterable<T> batchToSave)
save
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> save(T objectToSave, com.couchbase.client.java.PersistTo persistTo, com.couchbase.client.java.ReplicateTo replicateTo)
save
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> save(Iterable<T> batchToSave, com.couchbase.client.java.PersistTo persistTo, com.couchbase.client.java.ReplicateTo replicateTo)
save
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> insert(T objectToSave)
insert
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> insert(Iterable<T> batchToSave)
insert
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> insert(T objectToSave, com.couchbase.client.java.PersistTo persistTo, com.couchbase.client.java.ReplicateTo replicateTo)
insert
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> insert(Iterable<T> batchToSave, com.couchbase.client.java.PersistTo persistTo, com.couchbase.client.java.ReplicateTo replicateTo)
insert
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> update(T objectToSave)
update
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> update(Iterable<T> batchToSave)
update
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> update(T objectToSave, com.couchbase.client.java.PersistTo persistTo, com.couchbase.client.java.ReplicateTo replicateTo)
update
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> update(Iterable<T> batchToSave, com.couchbase.client.java.PersistTo persistTo, com.couchbase.client.java.ReplicateTo replicateTo)
update
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> remove(T objectToRemove)
remove
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> remove(Iterable<T> batchToRemove)
remove
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> remove(T objectToRemove, com.couchbase.client.java.PersistTo persistTo, com.couchbase.client.java.ReplicateTo replicateTo)
remove
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> remove(Iterable<T> batchToRemove, com.couchbase.client.java.PersistTo persistTo, com.couchbase.client.java.ReplicateTo replicateTo)
remove
in interface RxJavaCouchbaseOperations
public void setWriteResultChecking(WriteResultChecking writeResultChecking)
public rx.Observable<Boolean> exists(String id)
exists
in interface RxJavaCouchbaseOperations
public rx.Observable<com.couchbase.client.java.query.AsyncN1qlQueryResult> queryN1QL(com.couchbase.client.java.query.N1qlQuery query)
queryN1QL
in interface RxJavaCouchbaseOperations
public rx.Observable<com.couchbase.client.java.view.AsyncViewResult> queryView(com.couchbase.client.java.view.ViewQuery query)
queryView
in interface RxJavaCouchbaseOperations
public rx.Observable<com.couchbase.client.java.view.AsyncSpatialViewResult> querySpatialView(com.couchbase.client.java.view.SpatialViewQuery query)
querySpatialView
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> findById(String id, Class<T> entityClass)
findById
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> findByView(com.couchbase.client.java.view.ViewQuery query, Class<T> entityClass)
findByView
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> findByN1QL(com.couchbase.client.java.query.N1qlQuery query, Class<T> entityClass)
findByN1QL
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> findBySpatialView(com.couchbase.client.java.view.SpatialViewQuery query, Class<T> entityClass)
findBySpatialView
in interface RxJavaCouchbaseOperations
public <T> rx.Observable<T> findByN1QLProjection(com.couchbase.client.java.query.N1qlQuery query, Class<T> entityClass)
findByN1QLProjection
in interface RxJavaCouchbaseOperations
public Consistency getDefaultConsistency()
getDefaultConsistency
in interface RxJavaCouchbaseOperations
public void setDefaultConsistency(Consistency consistency)
public CouchbaseConverter getConverter()
getConverter
in interface RxJavaCouchbaseOperations
public com.couchbase.client.java.Bucket getCouchbaseBucket()
RxJavaCouchbaseOperations
Bucket
to this template.getCouchbaseBucket
in interface RxJavaCouchbaseOperations
public com.couchbase.client.java.cluster.ClusterInfo getCouchbaseClusterInfo()
getCouchbaseClusterInfo
in interface RxJavaCouchbaseOperations
Copyright © 2011–2017 Pivotal Software, Inc.. All rights reserved.