com.flowable.dataobject.engine.impl.runtime.datasource

Class DataObjectInstanceVariableContainerEntitySession

java.lang.Object

com.flowable.dataobject.engine.impl.runtime.datasource.DataObjectInstanceVariableContainerEntitySession

All Implemented Interfaces:

org.flowable.common.engine.impl.interceptor.Session

public class DataObjectInstanceVariableContainerEntitySession
extends Object
implements org.flowable.common.engine.impl.interceptor.Session

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,Map<Object,Collection<org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity>>>	cachedDefinitionIdDataObjectIdValueFields
protected Map<String,Map<Object,CachedDataObjectInstanceVariableContainer>>	cachedObjects
protected DataObjectRepositoryService	dataObjectRepositoryService
protected Map<String,Map<Object,DataObjectInstanceVariableContainer>>	deletedObjects
protected static org.slf4j.Logger	LOGGER
protected DataObjectOperations	serviceRegistryDataObjectOperations
protected List<DataObjectInstanceVariableContainer>	updatedObjects
protected Set<org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity>	variablesToUpdate

Constructor Summary

Constructors

Constructor and Description
DataObjectInstanceVariableContainerEntitySession(DataObjectRepositoryService dataObjectRepositoryService, DataObjectOperations serviceRegistryDataObjectOperations)

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	debugFlush()
void	delete(DataObjectInstanceVariableContainer entity)
void	determineUpdatedObjects()
DataObjectInstanceVariableContainer	findByDataAndDefinitionId(Map<String,Object> data, String definitionId)
DataObjectInstanceVariableContainer	findByIdAndDefinitionId(String id, String definitionId)
void	flush()
protected void	flushDeleteEntities(String definitionId, Collection<DataObjectInstanceVariableContainer> entities)
protected void	flushDeletes()
protected void	flushInsertEntities(String definitionId, Collection<DataObjectInstanceVariableContainer> entities)
protected void	flushUpdates()
protected void	flushVariableUpdates()
protected DataObjectDefinition	getDataObjectDefinitionByDefinitionId(String definitionId)
protected DataObjectModel	getDataObjectModelByDefinitionId(String definitionId)
void	insert(DataObjectInstanceVariableContainer entity)
boolean	isEntityToBeDeleted(DataObjectInstanceVariableContainer entity)
CachedDataObjectInstanceVariableContainer	putInCache(DataObjectInstanceVariableContainer entity, boolean storeState)
void	putInCacheIfMissing(DataObjectInstanceVariableContainer dataObjectInstance)
void	putInCacheIfMissing(DataObjectInstanceVariableContainer dataObjectInstance, org.flowable.variable.api.types.ValueFields valueFields)
protected void	removeUnnecessaryOperations() Clears all deleted and inserted objects from the cache, and removes inserts and deletes that cancel each other.
protected DataObjectInstanceVariableContainer	selectById(String id, String definitionId)
void	update(DataObjectInstanceVariableContainer entity)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

dataObjectRepositoryService

protected final DataObjectRepositoryService dataObjectRepositoryService

serviceRegistryDataObjectOperations

protected final DataObjectOperations serviceRegistryDataObjectOperations

deletedObjects

protected Map<String,Map<Object,DataObjectInstanceVariableContainer>> deletedObjects

updatedObjects

protected List<DataObjectInstanceVariableContainer> updatedObjects

cachedDefinitionIdDataObjectIdValueFields

protected Map<String,Map<Object,Collection<org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity>>> cachedDefinitionIdDataObjectIdValueFields

variablesToUpdate

protected Set<org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity> variablesToUpdate

cachedObjects

protected Map<String,Map<Object,CachedDataObjectInstanceVariableContainer>> cachedObjects

Constructor Detail

DataObjectInstanceVariableContainerEntitySession

public DataObjectInstanceVariableContainerEntitySession(DataObjectRepositoryService dataObjectRepositoryService,
                                                        DataObjectOperations serviceRegistryDataObjectOperations)

Method Detail

insert

public void insert(DataObjectInstanceVariableContainer entity)

update

public void update(DataObjectInstanceVariableContainer entity)

delete

public void delete(DataObjectInstanceVariableContainer entity)

findByIdAndDefinitionId

public DataObjectInstanceVariableContainer findByIdAndDefinitionId(String id,
                                                                   String definitionId)

findByDataAndDefinitionId

public DataObjectInstanceVariableContainer findByDataAndDefinitionId(Map<String,Object> data,
                                                                     String definitionId)

selectById

protected DataObjectInstanceVariableContainer selectById(String id,
                                                         String definitionId)

putInCacheIfMissing

public void putInCacheIfMissing(DataObjectInstanceVariableContainer dataObjectInstance)

putInCacheIfMissing

public void putInCacheIfMissing(DataObjectInstanceVariableContainer dataObjectInstance,
                                org.flowable.variable.api.types.ValueFields valueFields)

putInCache

public CachedDataObjectInstanceVariableContainer putInCache(DataObjectInstanceVariableContainer entity,
                                                            boolean storeState)

flush

public void flush()

Specified by:

flush in interface org.flowable.common.engine.impl.interceptor.Session

determineUpdatedObjects

public void determineUpdatedObjects()

removeUnnecessaryOperations

protected void removeUnnecessaryOperations()

Clears all deleted and inserted objects from the cache, and removes inserts and deletes that cancel each other.

Also removes deletes with duplicate ids.

flushVariableUpdates

protected void flushVariableUpdates()

isEntityToBeDeleted

public boolean isEntityToBeDeleted(DataObjectInstanceVariableContainer entity)

debugFlush

protected void debugFlush()

flushInsertEntities

protected void flushInsertEntities(String definitionId,
                                   Collection<DataObjectInstanceVariableContainer> entities)

flushUpdates

protected void flushUpdates()

flushDeletes

protected void flushDeletes()

flushDeleteEntities

protected void flushDeleteEntities(String definitionId,
                                   Collection<DataObjectInstanceVariableContainer> entities)

close

public void close()

Specified by:

close in interface org.flowable.common.engine.impl.interceptor.Session

getDataObjectModelByDefinitionId

protected DataObjectModel getDataObjectModelByDefinitionId(String definitionId)

getDataObjectDefinitionByDefinitionId

protected DataObjectDefinition getDataObjectDefinitionByDefinitionId(String definitionId)