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

Class DatabaseSchemaDataObjectInstanceEntitySession

java.lang.Object

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

All Implemented Interfaces:

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

public class DatabaseSchemaDataObjectInstanceEntitySession
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<String,Collection<org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity>>>	cachedDefinitionIdDataObjectIdValueFields
protected Map<String,Map<String,org.flowable.common.engine.impl.persistence.cache.CachedEntity>>	cachedObjects
protected DatabaseSchemaDataObjectJdbcOperations	databaseSchemaDataObjectJdbcOperations
protected DataObjectRepositoryService	dataObjectRepositoryService
protected Map<String,Map<String,DatabaseSchemaDataObjectInstanceEntity>>	deletedObjects
protected Map<String,Map<String,DatabaseSchemaDataObjectInstanceEntity>>	insertedObjects
protected static org.slf4j.Logger	LOGGER
protected List<DatabaseSchemaDataObjectInstanceEntity>	updatedObjects
protected Set<org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity>	variablesToUpdate

Constructor Summary

Constructors

Constructor and Description
DatabaseSchemaDataObjectInstanceEntitySession(DataObjectRepositoryService dataObjectRepositoryService, DatabaseSchemaDataObjectJdbcOperations databaseSchemaDataObjectJdbcOperations)

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	debugFlush()
void	delete(DatabaseSchemaDataObjectInstanceEntity entity)
void	determineUpdatedObjects()
DatabaseSchemaDataObjectInstanceEntity	findByIdAndDefinitionId(String id, String definitionId)
void	flush()
protected void	flushDeleteEntities(String definitionId, Collection<DatabaseSchemaDataObjectInstanceEntity> entities)
protected void	flushDeletes()
protected void	flushInsertEntities(String definitionId, Collection<DatabaseSchemaDataObjectInstanceEntity> entities)
protected void	flushInserts()
protected void	flushUpdates()
protected void	flushVariableUpdates()
protected DatabaseSchemaDataObjectModel	getObjectModelByDefinitionId(String definitionId)
void	insert(DatabaseSchemaDataObjectInstanceEntity entity)
boolean	isEntityInserted(DatabaseSchemaDataObjectInstanceEntity entity)
boolean	isEntityInserted(String entityId, String definitionId)
boolean	isEntityToBeDeleted(DatabaseSchemaDataObjectInstanceEntity entity)
org.flowable.common.engine.impl.persistence.cache.CachedEntity	putInCache(DatabaseSchemaDataObjectInstanceEntity entity, boolean storeState)
void	putInCacheIfMissing(DataObjectInstance dataObjectInstance)
void	putInCacheIfMissing(DataObjectInstance 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 DatabaseSchemaDataObjectInstanceEntity	selectById(String id, String definitionId)
void	update(DatabaseSchemaDataObjectInstanceEntity 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

databaseSchemaDataObjectJdbcOperations

protected final DatabaseSchemaDataObjectJdbcOperations databaseSchemaDataObjectJdbcOperations

insertedObjects

protected Map<String,Map<String,DatabaseSchemaDataObjectInstanceEntity>> insertedObjects

deletedObjects

protected Map<String,Map<String,DatabaseSchemaDataObjectInstanceEntity>> deletedObjects

updatedObjects

protected List<DatabaseSchemaDataObjectInstanceEntity> updatedObjects

cachedDefinitionIdDataObjectIdValueFields

protected Map<String,Map<String,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<String,org.flowable.common.engine.impl.persistence.cache.CachedEntity>> cachedObjects

Constructor Detail

DatabaseSchemaDataObjectInstanceEntitySession

public DatabaseSchemaDataObjectInstanceEntitySession(DataObjectRepositoryService dataObjectRepositoryService,
                                                     DatabaseSchemaDataObjectJdbcOperations databaseSchemaDataObjectJdbcOperations)

Method Detail

insert

public void insert(DatabaseSchemaDataObjectInstanceEntity entity)

update

public void update(DatabaseSchemaDataObjectInstanceEntity entity)

delete

public void delete(DatabaseSchemaDataObjectInstanceEntity entity)

findByIdAndDefinitionId

public DatabaseSchemaDataObjectInstanceEntity findByIdAndDefinitionId(String id,
                                                                      String definitionId)

selectById

protected DatabaseSchemaDataObjectInstanceEntity selectById(String id,
                                                            String definitionId)

putInCacheIfMissing

public void putInCacheIfMissing(DataObjectInstance dataObjectInstance)

putInCacheIfMissing

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

putInCache

public org.flowable.common.engine.impl.persistence.cache.CachedEntity putInCache(DatabaseSchemaDataObjectInstanceEntity 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()

isEntityInserted

public boolean isEntityInserted(DatabaseSchemaDataObjectInstanceEntity entity)

isEntityInserted

public boolean isEntityInserted(String entityId,
                                String definitionId)

isEntityToBeDeleted

public boolean isEntityToBeDeleted(DatabaseSchemaDataObjectInstanceEntity entity)

debugFlush

protected void debugFlush()

flushInserts

protected void flushInserts()

flushInsertEntities

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

flushUpdates

protected void flushUpdates()

flushDeletes

protected void flushDeletes()

flushDeleteEntities

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

close

public void close()

Specified by:

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

getObjectModelByDefinitionId

protected DatabaseSchemaDataObjectModel getObjectModelByDefinitionId(String definitionId)