Package org.flowable.engine.impl.persistence.entity.data.impl

Class MybatisExecutionDataManager

java.lang.Object

org.flowable.common.engine.impl.db.AbstractDataManager<EntityImpl>

org.flowable.engine.impl.persistence.entity.data.AbstractProcessDataManager<ExecutionEntity>

org.flowable.engine.impl.persistence.entity.data.impl.MybatisExecutionDataManager

All Implemented Interfaces:

DataManager<ExecutionEntity>, ExecutionDataManager

public class MybatisExecutionDataManager
extends AbstractProcessDataManager<ExecutionEntity>
implements ExecutionDataManager

Author:

Joram Barrez

Field Summary

Fields

Modifier and Type	Field	Description
protected CachedEntityMatcher<ExecutionEntity>	executionByProcessInstanceMatcher
protected CachedEntityMatcher<ExecutionEntity>	executionsByParentExecutionIdAndActivityIdEntityMatcher
protected CachedEntityMatcher<ExecutionEntity>	executionsByParentIdMatcher
protected CachedEntityMatcher<ExecutionEntity>	executionsByProcessInstanceIdMatcher
protected CachedEntityMatcher<ExecutionEntity>	executionsByRootProcessInstanceMatcher
protected CachedEntityMatcher<ExecutionEntity>	executionsWithSameRootProcessInstanceIdMatcher
protected CachedEntityMatcher<ExecutionEntity>	inactiveExecutionsByProcInstMatcher
protected CachedEntityMatcher<ExecutionEntity>	inactiveExecutionsInActivityAndProcInstMatcher
protected CachedEntityMatcher<ExecutionEntity>	inactiveExecutionsInActivityMatcher
protected PerformanceSettings	performanceSettings
protected CachedEntityMatcher<ExecutionEntity>	processInstancesByProcessDefinitionMatcher
protected SingleCachedEntityMatcher<ExecutionEntity>	subProcessInstanceBySuperExecutionIdMatcher

Fields inherited from class org.flowable.engine.impl.persistence.entity.data.AbstractProcessDataManager

processEngineConfiguration

Fields inherited from class org.flowable.common.engine.impl.db.AbstractDataManager

MAX_ENTRIES_IN_CLAUSE

Constructor Summary

Constructors

Constructor	Description
MybatisExecutionDataManager(ProcessEngineConfigurationImpl processEngineConfiguration)

Method Summary

Modifier and Type	Method	Description
void	clearAllProcessInstanceLockTimes(String lockOwner)
void	clearProcessInstanceLockTime(String processInstanceId)
long	countActiveExecutionsByParentId(String parentId)
ExecutionEntity	create()
ExecutionEntity	findById(String executionId)
List<ExecutionEntity>	findChildExecutionsByParentExecutionId(String parentExecutionId)
List<ExecutionEntity>	findChildExecutionsByProcessInstanceId(String processInstanceId)
long	findExecutionCountByNativeQuery(Map<String,Object> parameterMap)
long	findExecutionCountByQueryCriteria(ExecutionQueryImpl executionQuery)
List<Execution>	findExecutionsByNativeQuery(Map<String,Object> parameterMap)
List<ExecutionEntity>	findExecutionsByParentExecutionAndActivityIds(String parentExecutionId, Collection<String> activityIds)
List<ExecutionEntity>	findExecutionsByProcessInstanceId(String processInstanceId)
List<ExecutionEntity>	findExecutionsByQueryCriteria(ExecutionQueryImpl executionQuery)
List<ExecutionEntity>	findExecutionsByRootProcessInstanceId(String rootProcessInstanceId)
Collection<ExecutionEntity>	findInactiveExecutionsByActivityIdAndProcessInstanceId(String activityId, String processInstanceId)
Collection<ExecutionEntity>	findInactiveExecutionsByProcessInstanceId(String processInstanceId)
List<ProcessInstance>	findProcessInstanceAndVariablesByQueryCriteria(ProcessInstanceQueryImpl processInstanceQuery)
List<ProcessInstance>	findProcessInstanceByNativeQuery(Map<String,Object> parameterMap)
List<ProcessInstance>	findProcessInstanceByQueryCriteria(ProcessInstanceQueryImpl processInstanceQuery)
long	findProcessInstanceCountByQueryCriteria(ProcessInstanceQueryImpl processInstanceQuery)
List<String>	findProcessInstanceIdsByProcessDefinitionId(String processDefinitionId)
ExecutionEntity	findSubProcessInstanceBySuperExecutionId(String superExecutionId)
Class<? extends ExecutionEntity>	getManagedEntityClass()
protected boolean	isExecutionTreeFetched(String executionId)	Fetches the execution tree related to the execution (if the process definition has been configured to do so)
protected void	setSafeInValueLists(ExecutionQueryImpl executionQuery)
protected void	setSafeInValueLists(ProcessInstanceQueryImpl processInstanceQuery)
void	updateAllExecutionRelatedEntityCountFlags(boolean newValue)
void	updateExecutionTenantIdForDeployment(String deploymentId, String newTenantId)
void	updateProcessInstanceLockTime(String processInstanceId, Date lockDate, String lockOwner, Date expirationTime)

Methods inherited from class org.flowable.engine.impl.persistence.entity.data.AbstractProcessDataManager

getClock, getIdGenerator, getProcessEngineConfiguration

Methods inherited from class org.flowable.common.engine.impl.db.AbstractDataManager

bulkDelete, bulkDeleteEntities, bulkUpdateEntities, createSafeInValuesList, delete, delete, deleteCachedEntities, deleteCachedEntities, executeChangeWithInClause, findByQuery, getCommandContext, getDbSqlSession, getEntity, getEntityCache, getList, getList, getList, getList, getList, getListFromCache, getListFromCache, getManagedEntitySubClasses, getSession, insert, isEntityInserted, update

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.flowable.common.engine.impl.persistence.entity.data.DataManager

delete, delete, insert, update

Field Details

performanceSettings

protected PerformanceSettings performanceSettings

executionsByParentIdMatcher

protected CachedEntityMatcher<ExecutionEntity> executionsByParentIdMatcher

executionsByProcessInstanceIdMatcher

protected CachedEntityMatcher<ExecutionEntity> executionsByProcessInstanceIdMatcher

subProcessInstanceBySuperExecutionIdMatcher

protected SingleCachedEntityMatcher<ExecutionEntity> subProcessInstanceBySuperExecutionIdMatcher

executionsWithSameRootProcessInstanceIdMatcher

protected CachedEntityMatcher<ExecutionEntity> executionsWithSameRootProcessInstanceIdMatcher

inactiveExecutionsInActivityAndProcInstMatcher

protected CachedEntityMatcher<ExecutionEntity> inactiveExecutionsInActivityAndProcInstMatcher

inactiveExecutionsByProcInstMatcher

protected CachedEntityMatcher<ExecutionEntity> inactiveExecutionsByProcInstMatcher

inactiveExecutionsInActivityMatcher

protected CachedEntityMatcher<ExecutionEntity> inactiveExecutionsInActivityMatcher

executionByProcessInstanceMatcher

protected CachedEntityMatcher<ExecutionEntity> executionByProcessInstanceMatcher

executionsByRootProcessInstanceMatcher

protected CachedEntityMatcher<ExecutionEntity> executionsByRootProcessInstanceMatcher

executionsByParentExecutionIdAndActivityIdEntityMatcher

protected CachedEntityMatcher<ExecutionEntity> executionsByParentExecutionIdAndActivityIdEntityMatcher

processInstancesByProcessDefinitionMatcher

protected CachedEntityMatcher<ExecutionEntity> processInstancesByProcessDefinitionMatcher

Constructor Details

MybatisExecutionDataManager

public MybatisExecutionDataManager(ProcessEngineConfigurationImpl processEngineConfiguration)

Method Details

getManagedEntityClass

public Class<? extends ExecutionEntity> getManagedEntityClass()

Specified by:

getManagedEntityClass in class AbstractDataManager<ExecutionEntity>

create

public ExecutionEntity create()

Specified by:

create in interface DataManager<ExecutionEntity>

findById

public ExecutionEntity findById(String executionId)

Specified by:

findById in interface DataManager<ExecutionEntity>

Overrides:

findById in class AbstractDataManager<ExecutionEntity>

isExecutionTreeFetched

protected boolean isExecutionTreeFetched(String executionId)

Fetches the execution tree related to the execution (if the process definition has been configured to do so)

Returns:

True if the tree has been fetched, false otherwise or if fetching is disabled.

findSubProcessInstanceBySuperExecutionId

public ExecutionEntity findSubProcessInstanceBySuperExecutionId(String superExecutionId)

Specified by:

findSubProcessInstanceBySuperExecutionId in interface ExecutionDataManager

findChildExecutionsByParentExecutionId

public List<ExecutionEntity> findChildExecutionsByParentExecutionId(String parentExecutionId)

Specified by:

findChildExecutionsByParentExecutionId in interface ExecutionDataManager

findChildExecutionsByProcessInstanceId

public List<ExecutionEntity> findChildExecutionsByProcessInstanceId(String processInstanceId)

Specified by:

findChildExecutionsByProcessInstanceId in interface ExecutionDataManager

findExecutionsByParentExecutionAndActivityIds

public List<ExecutionEntity> findExecutionsByParentExecutionAndActivityIds(String parentExecutionId,
 Collection<String> activityIds)

Specified by:

findExecutionsByParentExecutionAndActivityIds in interface ExecutionDataManager

findExecutionsByRootProcessInstanceId

public List<ExecutionEntity> findExecutionsByRootProcessInstanceId(String rootProcessInstanceId)

Specified by:

findExecutionsByRootProcessInstanceId in interface ExecutionDataManager

findExecutionsByProcessInstanceId

public List<ExecutionEntity> findExecutionsByProcessInstanceId(String processInstanceId)

Specified by:

findExecutionsByProcessInstanceId in interface ExecutionDataManager

findInactiveExecutionsByProcessInstanceId

public Collection<ExecutionEntity> findInactiveExecutionsByProcessInstanceId(String processInstanceId)

Specified by:

findInactiveExecutionsByProcessInstanceId in interface ExecutionDataManager

findInactiveExecutionsByActivityIdAndProcessInstanceId

public Collection<ExecutionEntity> findInactiveExecutionsByActivityIdAndProcessInstanceId(String activityId,
 String processInstanceId)

Specified by:

findInactiveExecutionsByActivityIdAndProcessInstanceId in interface ExecutionDataManager

findProcessInstanceIdsByProcessDefinitionId

public List<String> findProcessInstanceIdsByProcessDefinitionId(String processDefinitionId)

Specified by:

findProcessInstanceIdsByProcessDefinitionId in interface ExecutionDataManager

findExecutionCountByQueryCriteria

public long findExecutionCountByQueryCriteria(ExecutionQueryImpl executionQuery)

Specified by:

findExecutionCountByQueryCriteria in interface ExecutionDataManager

findExecutionsByQueryCriteria

public List<ExecutionEntity> findExecutionsByQueryCriteria(ExecutionQueryImpl executionQuery)

Specified by:

findExecutionsByQueryCriteria in interface ExecutionDataManager

findProcessInstanceCountByQueryCriteria

public long findProcessInstanceCountByQueryCriteria(ProcessInstanceQueryImpl processInstanceQuery)

Specified by:

findProcessInstanceCountByQueryCriteria in interface ExecutionDataManager

findProcessInstanceByQueryCriteria

public List<ProcessInstance> findProcessInstanceByQueryCriteria(ProcessInstanceQueryImpl processInstanceQuery)

Specified by:

findProcessInstanceByQueryCriteria in interface ExecutionDataManager

findProcessInstanceAndVariablesByQueryCriteria

public List<ProcessInstance> findProcessInstanceAndVariablesByQueryCriteria(ProcessInstanceQueryImpl processInstanceQuery)

Specified by:

findProcessInstanceAndVariablesByQueryCriteria in interface ExecutionDataManager

findExecutionsByNativeQuery

public List<Execution> findExecutionsByNativeQuery(Map<String,Object> parameterMap)

Specified by:

findExecutionsByNativeQuery in interface ExecutionDataManager

findProcessInstanceByNativeQuery

public List<ProcessInstance> findProcessInstanceByNativeQuery(Map<String,Object> parameterMap)

Specified by:

findProcessInstanceByNativeQuery in interface ExecutionDataManager

findExecutionCountByNativeQuery

public long findExecutionCountByNativeQuery(Map<String,Object> parameterMap)

Specified by:

findExecutionCountByNativeQuery in interface ExecutionDataManager

countActiveExecutionsByParentId

public long countActiveExecutionsByParentId(String parentId)

Specified by:

countActiveExecutionsByParentId in interface ExecutionDataManager

updateExecutionTenantIdForDeployment

public void updateExecutionTenantIdForDeployment(String deploymentId,
 String newTenantId)

Specified by:

updateExecutionTenantIdForDeployment in interface ExecutionDataManager

updateProcessInstanceLockTime

public void updateProcessInstanceLockTime(String processInstanceId,
 Date lockDate,
 String lockOwner,
 Date expirationTime)

Specified by:

updateProcessInstanceLockTime in interface ExecutionDataManager

updateAllExecutionRelatedEntityCountFlags

public void updateAllExecutionRelatedEntityCountFlags(boolean newValue)

Specified by:

updateAllExecutionRelatedEntityCountFlags in interface ExecutionDataManager

clearProcessInstanceLockTime

public void clearProcessInstanceLockTime(String processInstanceId)

Specified by:

clearProcessInstanceLockTime in interface ExecutionDataManager

clearAllProcessInstanceLockTimes

public void clearAllProcessInstanceLockTimes(String lockOwner)

Specified by:

clearAllProcessInstanceLockTimes in interface ExecutionDataManager

setSafeInValueLists

protected void setSafeInValueLists(ExecutionQueryImpl executionQuery)

setSafeInValueLists

protected void setSafeInValueLists(ProcessInstanceQueryImpl processInstanceQuery)