AbstractRxDatastoreClient (GORM for Rx 8.1.2)

org.grails.datastore.rx.AbstractRxDatastoreClient

All Implemented Interfaces and Traits:

RxDatastoreClient<T>, RxDatastoreClientImplementor<T>, org.springframework.context.MessageSourceAware
```
@groovy.transform.CompileStatic
abstract class AbstractRxDatastoreClient<T>
extends java.lang.Object
implements RxDatastoreClient<T>, RxDatastoreClientImplementor<T>, org.springframework.context.MessageSourceAware
```
Abstract implementation the RxDatastoreClient interface
Authors:
Graeme Rocher
Since:
6.0

Field Summary

Fields
Modifiers	Name	Description
`private ConnectionSources<T, ? extends ConnectionSourceSettings>`	`connectionSources`
`private java.util.Map<java.lang.String, RxDatastoreClient<T>>`	`datastoreClients`
`private ConfigurableApplicationEventPublisher`	`eventPublisher`
`protected MappingContext`	`mappingContext`
`private MultiTenancyMode`	`multiTenancyMode`
`private ProxyFactory`	`proxyFactory`
`private TenantResolver`	`tenantResolver`

Properties Summary

Properties
Type	Name and description
`ConnectionSources<T, ? extends ConnectionSourceSettings>`	`connectionSources`
`java.util.Map<java.lang.String, RxDatastoreClient<T>>`	`datastoreClients`
`ConfigurableApplicationEventPublisher`	`eventPublisher`
`ConfigurableApplicationEventPublisher`	`eventPublisher`
`MultiTenancyMode`	`multiTenancyMode`
`ProxyFactory`	`proxyFactory`
`TenantResolver`	`tenantResolver`

Constructor Summary

Constructors
Constructor and description
`AbstractRxDatastoreClient (ConnectionSources<T, ConnectionSourceSettings> connectionSources, MappingContext mappingContext)`

Methods Summary

Methods
Type Params	Return Type	Name and description
	`protected void`	`activeDirtyChecking(java.lang.Object object)`
	`abstract rx.Observable<java.lang.Number>`	`batchDelete(BatchOperation operation)` Executes a batch delete operation
	`abstract rx.Observable<java.lang.Number>`	`batchWrite(BatchOperation operation)` Executes a batch write operation
	`final void`	`close()`
	`Query`	`createEntityQuery(PersistentEntity entity, QueryState queryState)` Creates a query for the given entity
	`abstract Query`	`createEntityQuery(PersistentEntity entity, QueryState queryState, java.util.Map arguments)` Creates a query for the given entity
	`final RxGormInstanceApi`	`createInstanceApi(PersistentEntity entity)`
	`RxGormInstanceApi`	`createInstanceApi(PersistentEntity entity, java.lang.String connectionSourceName)`
	`final Query`	`createQuery(java.lang.Class type, QueryState queryState)`
	`final Query`	`createQuery(java.lang.Class type, QueryState queryState, java.util.Map arguments)`
	`final Query`	`createQuery(java.lang.Class type, java.util.Map arguments)`
	`final Query`	`createQuery(java.lang.Class type)`
	`final RxGormStaticApi`	`createStaticApi(PersistentEntity entity)`
	`RxGormStaticApi`	`createStaticApi(PersistentEntity entity, java.lang.String connectionSourceName)`
	`final RxGormValidationApi`	`createValidationApi(PersistentEntity entity)`
	`RxGormValidationApi`	`createValidationApi(PersistentEntity entity, java.lang.String connectionSourceName)`
	`protected ValidatorRegistry`	`createValidatorRegistry(org.springframework.context.MessageSource messageSource)`
	`final rx.Observable<java.lang.Boolean>`	`delete(java.lang.Object instance)`
	`rx.Observable<java.lang.Boolean>`	`delete(java.lang.Object instance, java.util.Map<java.lang.String, java.lang.Object> arguments)`
	`rx.Observable<java.lang.Number>`	`deleteAll(java.lang.Iterable instances)`
	`rx.Observable<java.lang.Number>`	`deleteAll(java.lang.Iterable instances, java.util.Map<java.lang.String, java.lang.Object> arguments)`
	`abstract void`	`doClose()` Close the client
	`abstract java.io.Serializable`	`generateIdentifier(PersistentEntity entity, java.lang.Object instance, EntityReflector reflector)` Generates an identifier for the given entity and instance
`<T>`	`rx.Observable`	`get(java.lang.Class<T> type, java.io.Serializable id, QueryState queryState)`
`<T1>`	`final rx.Observable<T1>`	`get(java.lang.Class<T1> type, java.io.Serializable id)` Retrieve and instance of the given type and id
	`RxDatastoreClient`	`getDatastoreClient(java.lang.String connectionSourceName)`
	`RxDatastoreClient`	`getDatastoreClientForTenantId(java.io.Serializable tenantId)`
	`ConfigurableApplicationEventPublisher`	`getEventPublisher()`
	`MappingContext`	`getMappingContext()`
	`MultiTenancyMode`	`getMultiTenancyMode()`
	`TenantResolver`	`getTenantResolver()`
	`protected void`	`initDefaultEventListeners(ConfigurableApplicationEventPublisher configurableApplicationEventPublisher)`
`<T1>`	`final rx.Observable<T1>`	`insert(T1 instance, java.util.Map<java.lang.String, java.lang.Object> arguments)`
	`rx.Observable<java.util.List<java.io.Serializable>>`	`insertAll(java.lang.Iterable instances)`
	`rx.Observable<java.util.List<java.io.Serializable>>`	`insertAll(java.lang.Iterable instances, java.util.Map<java.lang.String, java.lang.Object> arguments)`
	`protected boolean`	`isIndexed(PersistentProperty property)`
	`boolean`	`isSchemaless()`
`<T1>`	`final rx.Observable<T1>`	`persist(T1 instance, java.util.Map<java.lang.String, java.lang.Object> arguments)` Persist an instance
`<T1>`	`final rx.Observable<T1>`	`persist(T1 instance)`
	`rx.Observable<java.util.List<java.io.Serializable>>`	`persistAll(java.lang.Iterable instances)`
	`rx.Observable<java.util.List<java.io.Serializable>>`	`persistAll(java.lang.Iterable instances, java.util.Map<java.lang.String, java.lang.Object> arguments)`
	`protected rx.Observable<java.util.List<java.io.Serializable>>`	`persistAllInternal(java.lang.Iterable instances, boolean isInsert, java.util.Map<java.lang.String, java.lang.Object> arguments)`
	`void`	`processAssociations(PersistentEntity entity, java.io.Serializable id, java.lang.Object instance, EntityReflector entityReflector, BatchOperation operation, java.util.List<org.springframework.context.ApplicationEvent> postEvents)`
`<T1>`	`ObservableProxy<T1>`	`proxy(java.lang.Class<T1> type, java.io.Serializable id, QueryState queryState)`
	`ObservableProxy`	`proxy(Query query, QueryState queryState)`
	`protected void`	`scheduleInsert(PersistentEntity associatedEntity, DirtyCheckable associatedObject, EntityReflector associationReflector, EntityAccess associationAccess, BatchOperation operation, java.util.List<org.springframework.context.ApplicationEvent> postEvents)`
	`protected void`	`scheduleInsertOrUpdate(PersistentEntity associatedEntity, DirtyCheckable associatedObject, BatchOperation operation, java.util.List<org.springframework.context.ApplicationEvent> postEvents)`
	`protected void`	`scheduleUpdate(PersistentEntity associatedEntity, EntityAccess associationAccess, java.io.Serializable associatedId, DirtyCheckable associatedObject, EntityReflector associationReflector, BatchOperation operation, java.util.List<org.springframework.context.ApplicationEvent> postEvents)`
	`void`	`setEventPublisher(ConfigurableApplicationEventPublisher eventPublisher)`
	`void`	`setMessageSource(org.springframework.context.MessageSource messageSource)`

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class java.lang.Object`	`java.lang.Object#wait(long), java.lang.Object#wait(long, int), java.lang.Object#wait(), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()`

- Field Detail
  - private final ConnectionSources<T, ? extends ConnectionSourceSettings> connectionSources
  - private final java.util.Map<java.lang.String, RxDatastoreClient<T>> datastoreClients
  - private ConfigurableApplicationEventPublisher eventPublisher
  - protected MappingContext mappingContext
  - private final MultiTenancyMode multiTenancyMode
  - private final ProxyFactory proxyFactory
  - private final TenantResolver tenantResolver
- Property Detail
  - final ConnectionSources<T, ? extends ConnectionSourceSettings> connectionSources
  - final java.util.Map<java.lang.String, RxDatastoreClient<T>> datastoreClients
  - ConfigurableApplicationEventPublisher eventPublisher
  - ConfigurableApplicationEventPublisher eventPublisher
  - final MultiTenancyMode multiTenancyMode
  - final ProxyFactory proxyFactory
  - final TenantResolver tenantResolver
- Constructor Detail
  - AbstractRxDatastoreClient(ConnectionSources<T, ConnectionSourceSettings> connectionSources, MappingContext mappingContext)
- Method Detail
  - protected void activeDirtyChecking(java.lang.Object object)
  - abstract rx.Observable<java.lang.Number> batchDelete(BatchOperation operation)
    
    Executes a batch delete operation
    Parameters:
    operation - The batch operation
    Returns:
    The total number of records deleted
  - abstract rx.Observable<java.lang.Number> batchWrite(BatchOperation operation)
    
    Executes a batch write operation
    Parameters:
    operation - The batch operation
    Returns:
    The total number of records updated, deleted or inserted
  - @java.lang.Override final void close()
  - Query createEntityQuery(PersistentEntity entity, QueryState queryState)
    
    Creates a query for the given entity
    Parameters:
    entity - The entity
    Returns:
    The query object
  - abstract Query createEntityQuery(PersistentEntity entity, QueryState queryState, java.util.Map arguments)
    
    Creates a query for the given entity
    Parameters:
    entity - The entity
    Returns:
    The query object
  - @java.lang.Override final RxGormInstanceApi createInstanceApi(PersistentEntity entity)
  - @java.lang.Override RxGormInstanceApi createInstanceApi(PersistentEntity entity, java.lang.String connectionSourceName)
  - @java.lang.Override final Query createQuery(java.lang.Class type, QueryState queryState)
  - @java.lang.Override final Query createQuery(java.lang.Class type, QueryState queryState, java.util.Map arguments)
  - @java.lang.Override final Query createQuery(java.lang.Class type, java.util.Map arguments)
  - @java.lang.Override final Query createQuery(java.lang.Class type)
  - @java.lang.Override final RxGormStaticApi createStaticApi(PersistentEntity entity)
  - @java.lang.Override RxGormStaticApi createStaticApi(PersistentEntity entity, java.lang.String connectionSourceName)
  - @java.lang.Override final RxGormValidationApi createValidationApi(PersistentEntity entity)
  - @java.lang.Override RxGormValidationApi createValidationApi(PersistentEntity entity, java.lang.String connectionSourceName)
  - protected ValidatorRegistry createValidatorRegistry(org.springframework.context.MessageSource messageSource)
  - @java.lang.Override final rx.Observable<java.lang.Boolean> delete(java.lang.Object instance)
  - @java.lang.Override rx.Observable<java.lang.Boolean> delete(java.lang.Object instance, java.util.Map<java.lang.String, java.lang.Object> arguments)
  - @java.lang.Override rx.Observable<java.lang.Number> deleteAll(java.lang.Iterable instances)
  - @java.lang.Override rx.Observable<java.lang.Number> deleteAll(java.lang.Iterable instances, java.util.Map<java.lang.String, java.lang.Object> arguments)
  - abstract void doClose()
    
    Close the client
  - abstract java.io.Serializable generateIdentifier(PersistentEntity entity, java.lang.Object instance, EntityReflector reflector)
    
    Generates an identifier for the given entity and instance
    Parameters:
    entity
    instance
    reflector
    Returns:
    The generated identifier
  - <T> @java.lang.Override rx.Observable get(java.lang.Class<T> type, java.io.Serializable id, QueryState queryState)
  - <T1> @java.lang.Override final rx.Observable<T1> get(java.lang.Class<T1> type, java.io.Serializable id)
    
    Retrieve and instance of the given type and id
    Parameters:
    type - The type
    id - The id
    Returns:
    An observable
  - @java.lang.Override RxDatastoreClient getDatastoreClient(java.lang.String connectionSourceName)
  - @java.lang.Override RxDatastoreClient getDatastoreClientForTenantId(java.io.Serializable tenantId)
  - ConfigurableApplicationEventPublisher getEventPublisher()
  - MappingContext getMappingContext()
  - @java.lang.Override MultiTenancyMode getMultiTenancyMode()
  - @java.lang.Override TenantResolver getTenantResolver()
  - protected void initDefaultEventListeners(ConfigurableApplicationEventPublisher configurableApplicationEventPublisher)
  - <T1> @java.lang.Override final rx.Observable<T1> insert(T1 instance, java.util.Map<java.lang.String, java.lang.Object> arguments)
  - @java.lang.Override rx.Observable<java.util.List<java.io.Serializable>> insertAll(java.lang.Iterable instances)
  - @java.lang.Override rx.Observable<java.util.List<java.io.Serializable>> insertAll(java.lang.Iterable instances, java.util.Map<java.lang.String, java.lang.Object> arguments)
  - protected boolean isIndexed(PersistentProperty property)
  - @java.lang.Override boolean isSchemaless()
  - <T1> @java.lang.Override final rx.Observable<T1> persist(T1 instance, java.util.Map<java.lang.String, java.lang.Object> arguments)
    
    Persist an instance
    Parameters:
    instance - The instance
    Returns:
    An observable
  - <T1> @java.lang.Override final rx.Observable<T1> persist(T1 instance)
  - @java.lang.Override rx.Observable<java.util.List<java.io.Serializable>> persistAll(java.lang.Iterable instances)
  - @java.lang.Override rx.Observable<java.util.List<java.io.Serializable>> persistAll(java.lang.Iterable instances, java.util.Map<java.lang.String, java.lang.Object> arguments)
  - protected rx.Observable<java.util.List<java.io.Serializable>> persistAllInternal(java.lang.Iterable instances, boolean isInsert, java.util.Map<java.lang.String, java.lang.Object> arguments)
  - void processAssociations(PersistentEntity entity, java.io.Serializable id, java.lang.Object instance, EntityReflector entityReflector, BatchOperation operation, java.util.List<org.springframework.context.ApplicationEvent> postEvents)
  - <T1> @java.lang.Override ObservableProxy<T1> proxy(java.lang.Class<T1> type, java.io.Serializable id, QueryState queryState)
  - @java.lang.Override ObservableProxy proxy(Query query, QueryState queryState)
  - protected void scheduleInsert(PersistentEntity associatedEntity, DirtyCheckable associatedObject, EntityReflector associationReflector, EntityAccess associationAccess, BatchOperation operation, java.util.List<org.springframework.context.ApplicationEvent> postEvents)
  - protected void scheduleInsertOrUpdate(PersistentEntity associatedEntity, DirtyCheckable associatedObject, BatchOperation operation, java.util.List<org.springframework.context.ApplicationEvent> postEvents)
  - protected void scheduleUpdate(PersistentEntity associatedEntity, EntityAccess associationAccess, java.io.Serializable associatedId, DirtyCheckable associatedObject, EntityReflector associationReflector, BatchOperation operation, java.util.List<org.springframework.context.ApplicationEvent> postEvents)
  - void setEventPublisher(ConfigurableApplicationEventPublisher eventPublisher)
  - @java.lang.Override void setMessageSource(org.springframework.context.MessageSource messageSource)

Summary:
Field
Property
Constructor
Method

Groovy Documentation

[Groovy] Class AbstractRxDatastoreClient<T>

Field Summary

Properties Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

private final ConnectionSources<T, ? extends ConnectionSourceSettings> connectionSources

private final java.util.Map<java.lang.String, RxDatastoreClient<T>> datastoreClients

private ConfigurableApplicationEventPublisher eventPublisher

protected MappingContext mappingContext

private final MultiTenancyMode multiTenancyMode

private final ProxyFactory proxyFactory

private final TenantResolver tenantResolver

Property Detail

final ConnectionSources<T, ? extends ConnectionSourceSettings> connectionSources

final java.util.Map<java.lang.String, RxDatastoreClient<T>> datastoreClients

ConfigurableApplicationEventPublisher eventPublisher

ConfigurableApplicationEventPublisher eventPublisher

final MultiTenancyMode multiTenancyMode

final ProxyFactory proxyFactory

final TenantResolver tenantResolver

Constructor Detail

AbstractRxDatastoreClient(ConnectionSources<T, ConnectionSourceSettings> connectionSources, MappingContext mappingContext)

Method Detail

protected void activeDirtyChecking(java.lang.Object object)

abstract rx.Observable<java.lang.Number> batchDelete(BatchOperation operation)

abstract rx.Observable<java.lang.Number> batchWrite(BatchOperation operation)

@java.lang.Override final void close()

Query createEntityQuery(PersistentEntity entity, QueryState queryState)

abstract Query createEntityQuery(PersistentEntity entity, QueryState queryState, java.util.Map arguments)

@java.lang.Override final RxGormInstanceApi createInstanceApi(PersistentEntity entity)

@java.lang.Override RxGormInstanceApi createInstanceApi(PersistentEntity entity, java.lang.String connectionSourceName)

@java.lang.Override final Query createQuery(java.lang.Class type, QueryState queryState)

@java.lang.Override final Query createQuery(java.lang.Class type, QueryState queryState, java.util.Map arguments)

@java.lang.Override final Query createQuery(java.lang.Class type, java.util.Map arguments)

@java.lang.Override final Query createQuery(java.lang.Class type)

@java.lang.Override final RxGormStaticApi createStaticApi(PersistentEntity entity)

@java.lang.Override RxGormStaticApi createStaticApi(PersistentEntity entity, java.lang.String connectionSourceName)

@java.lang.Override final RxGormValidationApi createValidationApi(PersistentEntity entity)

@java.lang.Override RxGormValidationApi createValidationApi(PersistentEntity entity, java.lang.String connectionSourceName)

protected ValidatorRegistry createValidatorRegistry(org.springframework.context.MessageSource messageSource)

@java.lang.Override final rx.Observable<java.lang.Boolean> delete(java.lang.Object instance)

@java.lang.Override rx.Observable<java.lang.Boolean> delete(java.lang.Object instance, java.util.Map<java.lang.String, java.lang.Object> arguments)

@java.lang.Override rx.Observable<java.lang.Number> deleteAll(java.lang.Iterable instances)

@java.lang.Override rx.Observable<java.lang.Number> deleteAll(java.lang.Iterable instances, java.util.Map<java.lang.String, java.lang.Object> arguments)

abstract void doClose()

abstract java.io.Serializable generateIdentifier(PersistentEntity entity, java.lang.Object instance, EntityReflector reflector)

<T> @java.lang.Override rx.Observable get(java.lang.Class<T> type, java.io.Serializable id, QueryState queryState)

<T1> @java.lang.Override final rx.Observable<T1> get(java.lang.Class<T1> type, java.io.Serializable id)

@java.lang.Override RxDatastoreClient getDatastoreClient(java.lang.String connectionSourceName)

@java.lang.Override RxDatastoreClient getDatastoreClientForTenantId(java.io.Serializable tenantId)

ConfigurableApplicationEventPublisher getEventPublisher()

MappingContext getMappingContext()

@java.lang.Override MultiTenancyMode getMultiTenancyMode()

@java.lang.Override TenantResolver getTenantResolver()

protected void initDefaultEventListeners(ConfigurableApplicationEventPublisher configurableApplicationEventPublisher)

<T1> @java.lang.Override final rx.Observable<T1> insert(T1 instance, java.util.Map<java.lang.String, java.lang.Object> arguments)

@java.lang.Override rx.Observable<java.util.List<java.io.Serializable>> insertAll(java.lang.Iterable instances)

@java.lang.Override rx.Observable<java.util.List<java.io.Serializable>> insertAll(java.lang.Iterable instances, java.util.Map<java.lang.String, java.lang.Object> arguments)

protected boolean isIndexed(PersistentProperty property)

@java.lang.Override boolean isSchemaless()

<T1> @java.lang.Override final rx.Observable<T1> persist(T1 instance, java.util.Map<java.lang.String, java.lang.Object> arguments)

<T1> @java.lang.Override final rx.Observable<T1> persist(T1 instance)

@java.lang.Override rx.Observable<java.util.List<java.io.Serializable>> persistAll(java.lang.Iterable instances)

@java.lang.Override rx.Observable<java.util.List<java.io.Serializable>> persistAll(java.lang.Iterable instances, java.util.Map<java.lang.String, java.lang.Object> arguments)

protected rx.Observable<java.util.List<java.io.Serializable>> persistAllInternal(java.lang.Iterable instances, boolean isInsert, java.util.Map<java.lang.String, java.lang.Object> arguments)

void processAssociations(PersistentEntity entity, java.io.Serializable id, java.lang.Object instance, EntityReflector entityReflector, BatchOperation operation, java.util.List<org.springframework.context.ApplicationEvent> postEvents)

<T1> @java.lang.Override ObservableProxy<T1> proxy(java.lang.Class<T1> type, java.io.Serializable id, QueryState queryState)

@java.lang.Override ObservableProxy proxy(Query query, QueryState queryState)

protected void scheduleInsert(PersistentEntity associatedEntity, DirtyCheckable associatedObject, EntityReflector associationReflector, EntityAccess associationAccess, BatchOperation operation, java.util.List<org.springframework.context.ApplicationEvent> postEvents)

protected void scheduleInsertOrUpdate(PersistentEntity associatedEntity, DirtyCheckable associatedObject, BatchOperation operation, java.util.List<org.springframework.context.ApplicationEvent> postEvents)

void setEventPublisher(ConfigurableApplicationEventPublisher eventPublisher)

@java.lang.Override void setMessageSource(org.springframework.context.MessageSource messageSource)