Represents a client connection pool that can be used to interact with a backing implementation in RxGORM
The
- native client interfaceFields inherited from class | Fields |
---|---|
interface Settings |
PREFIX, SETTING_AUTO_FLUSH, SETTING_CUSTOM_TYPES, SETTING_DATASOURCE, SETTING_DATASOURCES, SETTING_DB_CREATE, SETTING_DEFAULT_CONSTRAINTS, SETTING_DEFAULT_MAPPING, SETTING_FAIL_ON_ERROR, SETTING_FLUSH_MODE, SETTING_MULTI_TENANCY_MODE, SETTING_MULTI_TENANT_RESOLVER, SETTING_MULTI_TENANT_RESOLVER_CLASS |
Type Params | Return Type | Name and description |
---|---|---|
|
Query |
createQuery(java.lang.Class type) Creates a query for the given type |
|
Query |
createQuery(java.lang.Class type, java.util.Map arguments) Creates a query for the given type |
|
java.util.Observable<java.lang.Boolean> |
delete(java.lang.Object instance) Deletes an instance |
|
java.util.Observable<java.lang.Boolean> |
delete(java.lang.Object instance, java.util.Map<java.lang.String, java.lang.Object> arguments) Deletes an instance |
|
java.util.Observable<java.lang.Number> |
deleteAll(java.lang.Iterable instances) Deletes a number of instances |
|
java.util.Observable<java.lang.Number> |
deleteAll(java.lang.Iterable instances, java.util.Map<java.lang.String, java.lang.Object> arguments) Deletes a number of instances |
<T1> |
java.util.Observable<T1> |
get(java.lang.Class<T1> type, java.io.Serializable id) Obtains a single instance for the given type and id |
|
ConnectionSources<T, ConnectionSourceSettings> |
getConnectionSources() @return Obtain the connection sources |
|
RxDatastoreClient |
getDatastoreClient(java.lang.String connectionSourceName) Obtain another RxDatastoreClient for the given ConnectionSource name |
|
RxDatastoreClient |
getDatastoreClientForTenantId(java.io.Serializable tenantId) Obtains the datastore for the given tenant id. |
|
ConfigurableApplicationEventPublisher |
getEventPublisher() @return The event publisher |
|
MappingContext |
getMappingContext() @return The mapping context |
|
MultiTenancyMode |
getMultiTenancyMode() @return The multi tenancy mode |
|
T |
getNativeInterface() @return The native interface to the datastore |
|
TenantResolver |
getTenantResolver() @return Obtain the tenant resolver |
<T1> |
java.util.Observable<T1> |
insert(T1 instance, java.util.Map<java.lang.String, java.lang.Object> arguments) Force an insert of an instance and return the observable |
|
java.util.Observable<java.util.List<java.io.Serializable>> |
insertAll(java.lang.Iterable objects) Batch insert all all of the given objects |
|
java.util.Observable<java.util.List<java.io.Serializable>> |
insertAll(java.lang.Iterable objects, java.util.Map<java.lang.String, java.lang.Object> arguments) Batch insert all all of the given objects |
<T1> |
java.util.Observable<T1> |
persist(T1 instance, java.util.Map<java.lang.String, java.lang.Object> arguments) Persist and instance and return the observable |
<T1> |
java.util.Observable<T1> |
persist(T1 instance) Persist and instance and return the observable |
|
java.util.Observable<java.util.List<java.io.Serializable>> |
persistAll(java.lang.Iterable objects) Batch saves all of the given objects |
|
java.util.Observable<java.util.List<java.io.Serializable>> |
persistAll(java.lang.Iterable objects, java.util.Map<java.lang.String, java.lang.Object> arguments) Batch saves all of the given objects |
<T1> |
ObservableProxy<T1> |
proxy(java.lang.Class<T1> type, java.io.Serializable id) Obtain an ObservableProxy for the given type and id |
|
ObservableProxy |
proxy(Query query) Obtain an ObservableProxy that executes the given query to initialize |
Methods inherited from class | Name |
---|---|
interface java.io.Closeable |
java.io.Closeable#close() |
interface ConnectionSourcesProvider |
getConnectionSources |
interface QueryCreator |
createQuery, isSchemaless |
Creates a query for the given type
type
- The typeCreates a query for the given type
type
- The typeDeletes an instance
instance
- The object to deleteDeletes an instance
instance
- The object to deleteDeletes a number of instances
instances
- The objects to deleteDeletes a number of instances
instances
- The objects to deleteObtains a single instance for the given type and id
type
- The persistent typeid
- The identifier
Obtain another RxDatastoreClient for the given ConnectionSource name
connectionSourceName
- The name of the clientObtains the datastore for the given tenant id. In SINGLE mode this will be a unique datastore for each tenant. For MULTI mode a single datastore is used for all tenants
tenantId
- The tenant id
Force an insert of an instance and return the observable
instance
- The instancearguments
- The argumentsBatch insert all all of the given objects
objects
- The objects to saveBatch insert all all of the given objects
objects
- The objects to savePersist and instance and return the observable
instance
- The instancearguments
- The argumentsPersist and instance and return the observable
instance
- The instancearguments
- The argumentsBatch saves all of the given objects
objects
- The objects to saveBatch saves all of the given objects
objects
- The objects to saveObtain an ObservableProxy for the given type and id
type
- The typeid
- The idObtain an ObservableProxy that executes the given query to initialize
query
- The query