Modifier and Type | Class and Description |
---|---|
protected static class |
AbstractDataStore.EntityLoadInfo |
Modifier and Type | Field and Description |
---|---|
protected EntityStates |
entityStates |
protected KeyValueMapper |
keyValueMapper |
protected java.util.List<DataStoreEventListener> |
listeners |
protected Metadata |
metadata |
protected MetadataTools |
metadataTools |
Constructor and Description |
---|
AbstractDataStore() |
Modifier and Type | Method and Description |
---|---|
protected void |
beforeLoadTransactionCommit(LoadContext<?> context,
java.util.Collection<java.lang.Object> entities) |
protected void |
beforeSaveTransactionCommit(SaveContext context,
java.util.Collection<java.lang.Object> savedEntities,
java.util.Collection<java.lang.Object> removedEntities) |
protected void |
beforeSaveTransactionRollback(SaveContext context) |
protected abstract java.lang.Object |
beginLoadTransaction(boolean joinTransaction) |
protected abstract java.lang.Object |
beginSaveTransaction(boolean joinTransaction) |
protected java.util.List<java.lang.Object> |
checkAndReorderLoadedEntities(LoadContext<?> context,
java.util.List<java.lang.Object> entities) |
protected abstract void |
commitTransaction(java.lang.Object transaction) |
protected void |
copyNonPersistentAttributes(java.lang.Object source,
java.lang.Object destination) |
protected abstract long |
countAll(LoadContext<?> context) |
protected abstract long |
countAllValues(ValueLoadContext context) |
protected abstract java.util.Set<java.lang.Object> |
deleteAll(SaveContext context) |
protected <T extends BaseDataStoreEvent> |
fireEvent(T event) |
long |
getCount(LoadContext<?> context)
Returns the number of entity instances for the given query passed in the
LoadContext . |
long |
getCount(ValueLoadContext context)
Returns the number of key-value pairs for the given query passed in the
ValueLoadContext . |
protected FetchPlan |
getFetchPlanForSave(java.util.Map<java.lang.Object,FetchPlan> fetchPlans,
java.lang.Object entity) |
java.lang.Object |
load(LoadContext<?> context)
Loads a single entity instance.
|
protected abstract java.util.List<java.lang.Object> |
loadAll(LoadContext<?> context) |
protected java.util.Set<java.lang.Object> |
loadAllAfterSave(SaveContext context,
java.util.Set<java.lang.Object> savedEntities) |
protected abstract java.util.List<java.lang.Object> |
loadAllValues(ValueLoadContext context) |
java.util.List<java.lang.Object> |
loadList(LoadContext<?> context)
Loads collection of entity instances.
|
protected java.util.List<java.lang.Object> |
loadListByBatches(LoadContext<?> context,
int actualSize,
EventSharedState eventState) |
protected abstract java.lang.Object |
loadOne(LoadContext<?> context) |
java.util.List<KeyValueEntity> |
loadValues(ValueLoadContext context)
Loads list of key-value pairs.
|
void |
registerInterceptor(DataStoreEventListener listener) |
protected abstract void |
rollbackTransaction(java.lang.Object transaction) |
java.util.Set<?> |
save(SaveContext context)
Saves a collection of entity instances.
|
protected abstract java.util.Set<java.lang.Object> |
saveAll(SaveContext context) |
void |
setEntityStates(EntityStates entityStates) |
void |
setKeyValueMapper(KeyValueMapper keyValueMapper) |
void |
setMetadata(Metadata metadata) |
void |
setMetadataTools(MetadataTools metadataTools) |
protected final java.util.List<DataStoreEventListener> listeners
protected Metadata metadata
protected MetadataTools metadataTools
protected EntityStates entityStates
protected KeyValueMapper keyValueMapper
@Autowired public void setMetadata(Metadata metadata)
@Autowired public void setMetadataTools(MetadataTools metadataTools)
@Autowired public void setEntityStates(EntityStates entityStates)
@Autowired public void setKeyValueMapper(KeyValueMapper keyValueMapper)
@Nullable public java.lang.Object load(LoadContext<?> context)
DataStore
public java.util.List<java.lang.Object> loadList(LoadContext<?> context)
DataStore
public long getCount(LoadContext<?> context)
DataStore
LoadContext
.public java.util.Set<?> save(SaveContext context)
DataStore
public java.util.List<KeyValueEntity> loadValues(ValueLoadContext context)
DataStore
loadValues
in interface DataStore
context
- defines a query for scalar values and a list of keys for returned KeyValueEntitypublic long getCount(ValueLoadContext context)
DataStore
ValueLoadContext
.@Nullable protected abstract java.lang.Object loadOne(LoadContext<?> context)
protected abstract java.util.List<java.lang.Object> loadAll(LoadContext<?> context)
protected abstract long countAll(LoadContext<?> context)
protected abstract java.util.Set<java.lang.Object> saveAll(SaveContext context)
protected abstract java.util.Set<java.lang.Object> deleteAll(SaveContext context)
protected abstract java.util.List<java.lang.Object> loadAllValues(ValueLoadContext context)
protected abstract long countAllValues(ValueLoadContext context)
protected abstract java.lang.Object beginLoadTransaction(boolean joinTransaction)
protected abstract java.lang.Object beginSaveTransaction(boolean joinTransaction)
protected abstract void commitTransaction(java.lang.Object transaction)
protected abstract void rollbackTransaction(java.lang.Object transaction)
protected void beforeLoadTransactionCommit(LoadContext<?> context, java.util.Collection<java.lang.Object> entities)
protected void beforeSaveTransactionCommit(SaveContext context, java.util.Collection<java.lang.Object> savedEntities, java.util.Collection<java.lang.Object> removedEntities)
protected void beforeSaveTransactionRollback(SaveContext context)
public void registerInterceptor(DataStoreEventListener listener)
protected <T extends BaseDataStoreEvent> void fireEvent(T event)
protected java.util.List<java.lang.Object> loadListByBatches(LoadContext<?> context, int actualSize, EventSharedState eventState)
protected java.util.List<java.lang.Object> checkAndReorderLoadedEntities(LoadContext<?> context, java.util.List<java.lang.Object> entities)
protected java.util.Set<java.lang.Object> loadAllAfterSave(SaveContext context, java.util.Set<java.lang.Object> savedEntities)
protected FetchPlan getFetchPlanForSave(java.util.Map<java.lang.Object,FetchPlan> fetchPlans, java.lang.Object entity)
protected void copyNonPersistentAttributes(java.lang.Object source, java.lang.Object destination)