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

Class ExecutionEntityManagerImpl

java.lang.Object

org.flowable.common.engine.impl.persistence.entity.AbstractEntityManager<EntityImpl,DM>

org.flowable.common.engine.impl.persistence.entity.AbstractEngineEntityManager<ProcessEngineConfigurationImpl,EntityImpl,DM>

org.flowable.engine.impl.persistence.entity.AbstractProcessEngineEntityManager<ExecutionEntity,ExecutionDataManager>

org.flowable.engine.impl.persistence.entity.ExecutionEntityManagerImpl

All Implemented Interfaces:

EntityManager<ExecutionEntity>, ExecutionEntityManager

public class ExecutionEntityManagerImpl
extends AbstractProcessEngineEntityManager<ExecutionEntity,ExecutionDataManager>
implements ExecutionEntityManager

Author:

Tom Baeyens, Joram Barrez

Field Summary

Fields

Modifier and Type	Field	Description
protected CachedEntityMatcher<IdentityLinkEntity>	identityLinkByProcessInstanceMatcher

Fields inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractEngineEntityManager

engineConfiguration

Fields inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractEntityManager

dataManager, engineType

Constructor Summary

Constructors

Constructor	Description
ExecutionEntityManagerImpl(ProcessEngineConfigurationImpl processEngineConfiguration, ExecutionDataManager executionDataManager)

Method Summary

Modifier and Type	Method	Description
void	clearAllProcessInstanceLockTimes(String lockOwner)
void	clearProcessInstanceLockTime(String processInstanceId)
List<ExecutionEntity>	collectChildren(ExecutionEntity executionEntity)	Returns all child executions of a given ExecutionEntity.
protected List<ExecutionEntity>	collectChildren(ExecutionEntity executionEntity, Collection<String> executionIdsToExclude)
protected void	collectChildren(ExecutionEntity executionEntity, List<ExecutionEntity> collectedChildExecution, Collection<String> executionIdsToExclude)
long	countActiveExecutionsByParentId(String parentId)
ExecutionEntity	createChildExecution(ExecutionEntity parentExecutionEntity)	Creates a new execution.
ExecutionEntity	createProcessInstanceExecution(ProcessDefinition processDefinition, String predefinedProcessInstanceId, String businessKey, String businessStatus, String processInstanceName, String callbackId, String callbackType, String referenceId, String referenceType, String propagatedStageInstanceId, String tenantId, String initiatorVariableName, String startActivityId)
ExecutionEntity	createSubprocessInstance(ProcessDefinition processDefinition, ExecutionEntity superExecutionEntity, String businessKey, String activityId)
void	delete(ExecutionEntity entity)
void	delete(ExecutionEntity entity, boolean fireDeleteEvent)
protected void	deleteActivityInstances(ExecutionEntity executionEntity, CommandContext commandContext)
void	deleteChildExecutions(ExecutionEntity executionEntity, String deleteReason, boolean cancel)
void	deleteChildExecutions(ExecutionEntity executionEntity, Collection<String> executionIdsNotToDelete, Collection<String> executionIdsNotToSendCancelledEventFor, String deleteReason, boolean cancel, FlowElement cancelActivity)
protected void	deleteEntityLinks(ExecutionEntity executionEntity, CommandContext commandContext, boolean eventDispatcherEnabled)
protected void	deleteEventSubScriptions(ExecutionEntity executionEntity, boolean enableExecutionRelationshipCounts, boolean eventDispatcherEnabled)
void	deleteExecutionAndRelatedData(ExecutionEntity executionEntity, String deleteReason, boolean deleteHistory)
void	deleteExecutionAndRelatedData(ExecutionEntity executionEntity, String deleteReason, boolean deleteHistory, boolean directDeleteInDatabase)
void	deleteExecutionAndRelatedData(ExecutionEntity executionEntity, String deleteReason, boolean deleteHistory, boolean directDeleteInDatabase, boolean cancel, FlowElement cancelActivity)
protected void	deleteIdentityLinks(ExecutionEntity executionEntity, CommandContext commandContext, boolean eventDispatcherEnabled)
protected void	deleteJobs(ExecutionEntity executionEntity, CommandContext commandContext, boolean enableExecutionRelationshipCounts, boolean eventDispatcherEnabled)
void	deleteProcessInstance(String processInstanceId, String deleteReason, boolean cascade)
void	deleteProcessInstance(String processInstanceId, String deleteReason, boolean cascade, boolean directDeleteInDatabase)
protected void	deleteProcessInstanceCascade(ExecutionEntity execution, String deleteReason, boolean deleteHistory, boolean directDeleteInDatabase)
void	deleteProcessInstanceExecutionEntity(String processInstanceId, String currentFlowElementId, String deleteReason, boolean cascade, boolean cancel, boolean fireEvents)
void	deleteProcessInstancesByProcessDefinition(String processDefinitionId, String deleteReason, boolean cascade)
void	deleteRelatedDataForExecution(ExecutionEntity executionEntity, String deleteReason, boolean directDeleteInDatabase)
protected void	deleteSubCases(ExecutionEntity executionEntity, boolean directDeleteInDatabase, CommandContext commandContext)
protected void	deleteUserTasks(ExecutionEntity executionEntity, String deleteReason, CommandContext commandContext, boolean enableExecutionRelationshipCounts, boolean eventDispatcherEnabled)
protected void	deleteVariables(ExecutionEntity executionEntity, CommandContext commandContext, boolean enableExecutionRelationshipCounts, boolean eventDispatcherEnabled)
protected void	dispatchActivityCancelled(ExecutionEntity execution, FlowElement cancelActivity)
protected void	dispatchExecutionCancelled(ExecutionEntity execution, FlowElement cancelActivity)
protected void	dispatchMultiInstanceActivityCancelled(ExecutionEntity execution, FlowElement cancelActivity)
ExecutionEntity	findByRootProcessInstanceId(String rootProcessInstanceId)	Finds the ExecutionEntity for the given root process instance id.
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>	findExecutionsByQueryCriteria(ExecutionQueryImpl executionQuery)
ExecutionEntity	findFirstMultiInstanceRoot(ExecutionEntity executionEntity)
ExecutionEntity	findFirstScope(ExecutionEntity executionEntity)
Collection<ExecutionEntity>	findInactiveExecutionsByActivityIdAndProcessInstanceId(String activityId, String processInstanceId)
Collection<ExecutionEntity>	findInactiveExecutionsByProcessInstanceId(String processInstanceId)
List<ProcessInstance>	findProcessInstanceAndVariablesByQueryCriteria(ProcessInstanceQueryImpl executionQuery)
List<ProcessInstance>	findProcessInstanceByNativeQuery(Map<String,Object> parameterMap)
List<ProcessInstance>	findProcessInstanceByQueryCriteria(ProcessInstanceQueryImpl executionQuery)
long	findProcessInstanceCountByQueryCriteria(ProcessInstanceQueryImpl executionQuery)
ExecutionEntity	findSubProcessInstanceBySuperExecutionId(String superExecutionId)
protected ActivityInstanceEntityManager	getActivityInstanceEntityManager()
protected String	getActivityType(FlowElement flowNode)
protected AsyncExecutor	getAsyncExecutor()
protected ByteArrayEntityManager	getByteArrayEntityManager()
protected HistoryManager	getHistoryManager()
protected void	inheritCommonProperties(ExecutionEntity parentExecutionEntity, ExecutionEntity childExecution)
protected boolean	isRootProcessInstance(ExecutionEntity executionEntity)
protected ExecutionEntity	processExecutionTree(String rootProcessInstanceId, List<ExecutionEntity> executions)	Processes a collection of ExecutionEntity instances, which form on execution tree.
void	updateExecutionTenantIdForDeployment(String deploymentId, String newTenantId)
String	updateProcessInstanceBusinessKey(ExecutionEntity executionEntity, String businessKey)
String	updateProcessInstanceBusinessStatus(ExecutionEntity executionEntity, String businessStatus)
void	updateProcessInstanceLockTime(String processInstanceId, String lockOwner, Date lockTime)

Methods inherited from class org.flowable.engine.impl.persistence.entity.AbstractProcessEngineEntityManager

createEntityEvent

Methods inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractEngineEntityManager

getClock, getCommandExecutor, getEngineConfiguration, getEventDispatcher

Methods inherited from class org.flowable.common.engine.impl.persistence.entity.AbstractEntityManager

create, delete, findById, fireEntityDeletedEvent, fireEntityInsertedEvent, fireEntityUpdatedEvent, getDataManager, insert, insert, setDataManager, update, 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.EntityManager

create, delete, findById, insert, insert, update, update

Field Details

identityLinkByProcessInstanceMatcher

protected CachedEntityMatcher<IdentityLinkEntity> identityLinkByProcessInstanceMatcher

Constructor Details

ExecutionEntityManagerImpl

public ExecutionEntityManagerImpl(ProcessEngineConfigurationImpl processEngineConfiguration,
 ExecutionDataManager executionDataManager)

Method Details

delete

public void delete(ExecutionEntity entity)

Specified by:

delete in interface EntityManager<ExecutionEntity>

Overrides:

delete in class AbstractEntityManager<ExecutionEntity,ExecutionDataManager>

delete

public void delete(ExecutionEntity entity,
 boolean fireDeleteEvent)

Specified by:

delete in interface EntityManager<ExecutionEntity>

Overrides:

delete in class AbstractEntityManager<ExecutionEntity,ExecutionDataManager>

findSubProcessInstanceBySuperExecutionId

public ExecutionEntity findSubProcessInstanceBySuperExecutionId(String superExecutionId)

Specified by:

findSubProcessInstanceBySuperExecutionId in interface ExecutionEntityManager

findChildExecutionsByParentExecutionId

public List<ExecutionEntity> findChildExecutionsByParentExecutionId(String parentExecutionId)

Specified by:

findChildExecutionsByParentExecutionId in interface ExecutionEntityManager

findChildExecutionsByProcessInstanceId

public List<ExecutionEntity> findChildExecutionsByProcessInstanceId(String processInstanceId)

Specified by:

findChildExecutionsByProcessInstanceId in interface ExecutionEntityManager

findExecutionsByParentExecutionAndActivityIds

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

Specified by:

findExecutionsByParentExecutionAndActivityIds in interface ExecutionEntityManager

findExecutionCountByQueryCriteria

public long findExecutionCountByQueryCriteria(ExecutionQueryImpl executionQuery)

Specified by:

findExecutionCountByQueryCriteria in interface ExecutionEntityManager

findExecutionsByQueryCriteria

public List<ExecutionEntity> findExecutionsByQueryCriteria(ExecutionQueryImpl executionQuery)

Specified by:

findExecutionsByQueryCriteria in interface ExecutionEntityManager

findProcessInstanceCountByQueryCriteria

public long findProcessInstanceCountByQueryCriteria(ProcessInstanceQueryImpl executionQuery)

Specified by:

findProcessInstanceCountByQueryCriteria in interface ExecutionEntityManager

findProcessInstanceByQueryCriteria

public List<ProcessInstance> findProcessInstanceByQueryCriteria(ProcessInstanceQueryImpl executionQuery)

Specified by:

findProcessInstanceByQueryCriteria in interface ExecutionEntityManager

findByRootProcessInstanceId

public ExecutionEntity findByRootProcessInstanceId(String rootProcessInstanceId)

Description copied from interface: ExecutionEntityManager

Finds the ExecutionEntity for the given root process instance id. All children will have been fetched and initialized.

Specified by:

findByRootProcessInstanceId in interface ExecutionEntityManager

processExecutionTree

protected ExecutionEntity processExecutionTree(String rootProcessInstanceId,
 List<ExecutionEntity> executions)

Processes a collection of ExecutionEntity instances, which form on execution tree. All the executions share the same rootProcessInstanceId (which is provided). The return value will be the root ExecutionEntity instance, with all child ExecutionEntity instances populated and set using the ExecutionEntity instances from the provided collections

findProcessInstanceAndVariablesByQueryCriteria

public List<ProcessInstance> findProcessInstanceAndVariablesByQueryCriteria(ProcessInstanceQueryImpl executionQuery)

Specified by:

findProcessInstanceAndVariablesByQueryCriteria in interface ExecutionEntityManager

findInactiveExecutionsByProcessInstanceId

public Collection<ExecutionEntity> findInactiveExecutionsByProcessInstanceId(String processInstanceId)

Specified by:

findInactiveExecutionsByProcessInstanceId in interface ExecutionEntityManager

findInactiveExecutionsByActivityIdAndProcessInstanceId

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

Specified by:

findInactiveExecutionsByActivityIdAndProcessInstanceId in interface ExecutionEntityManager

findExecutionsByNativeQuery

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

Specified by:

findExecutionsByNativeQuery in interface ExecutionEntityManager

findProcessInstanceByNativeQuery

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

Specified by:

findProcessInstanceByNativeQuery in interface ExecutionEntityManager

findExecutionCountByNativeQuery

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

Specified by:

findExecutionCountByNativeQuery in interface ExecutionEntityManager

countActiveExecutionsByParentId

public long countActiveExecutionsByParentId(String parentId)

Specified by:

countActiveExecutionsByParentId in interface ExecutionEntityManager

createProcessInstanceExecution

public ExecutionEntity createProcessInstanceExecution(ProcessDefinition processDefinition,
 String predefinedProcessInstanceId,
 String businessKey,
 String businessStatus,
 String processInstanceName,
 String callbackId,
 String callbackType,
 String referenceId,
 String referenceType,
 String propagatedStageInstanceId,
 String tenantId,
 String initiatorVariableName,
 String startActivityId)

Specified by:

createProcessInstanceExecution in interface ExecutionEntityManager

createChildExecution

public ExecutionEntity createChildExecution(ExecutionEntity parentExecutionEntity)

Creates a new execution. properties processDefinition, processInstance and activity will be initialized.

Specified by:

createChildExecution in interface ExecutionEntityManager

createSubprocessInstance

public ExecutionEntity createSubprocessInstance(ProcessDefinition processDefinition,
 ExecutionEntity superExecutionEntity,
 String businessKey,
 String activityId)

Specified by:

createSubprocessInstance in interface ExecutionEntityManager

inheritCommonProperties

protected void inheritCommonProperties(ExecutionEntity parentExecutionEntity,
 ExecutionEntity childExecution)

updateExecutionTenantIdForDeployment

public void updateExecutionTenantIdForDeployment(String deploymentId,
 String newTenantId)

Specified by:

updateExecutionTenantIdForDeployment in interface ExecutionEntityManager

deleteProcessInstancesByProcessDefinition

public void deleteProcessInstancesByProcessDefinition(String processDefinitionId,
 String deleteReason,
 boolean cascade)

Specified by:

deleteProcessInstancesByProcessDefinition in interface ExecutionEntityManager

deleteProcessInstance

public void deleteProcessInstance(String processInstanceId,
 String deleteReason,
 boolean cascade)

Specified by:

deleteProcessInstance in interface ExecutionEntityManager

deleteProcessInstance

public void deleteProcessInstance(String processInstanceId,
 String deleteReason,
 boolean cascade,
 boolean directDeleteInDatabase)

Specified by:

deleteProcessInstance in interface ExecutionEntityManager

deleteProcessInstanceCascade

protected void deleteProcessInstanceCascade(ExecutionEntity execution,
 String deleteReason,
 boolean deleteHistory,
 boolean directDeleteInDatabase)

deleteExecutionAndRelatedData

public void deleteExecutionAndRelatedData(ExecutionEntity executionEntity,
 String deleteReason,
 boolean deleteHistory,
 boolean directDeleteInDatabase,
 boolean cancel,
 FlowElement cancelActivity)

Specified by:

deleteExecutionAndRelatedData in interface ExecutionEntityManager

deleteExecutionAndRelatedData

public void deleteExecutionAndRelatedData(ExecutionEntity executionEntity,
 String deleteReason,
 boolean deleteHistory)

Specified by:

deleteExecutionAndRelatedData in interface ExecutionEntityManager

deleteExecutionAndRelatedData

public void deleteExecutionAndRelatedData(ExecutionEntity executionEntity,
 String deleteReason,
 boolean deleteHistory,
 boolean directDeleteInDatabase)

Specified by:

deleteExecutionAndRelatedData in interface ExecutionEntityManager

deleteProcessInstanceExecutionEntity

public void deleteProcessInstanceExecutionEntity(String processInstanceId,
 String currentFlowElementId,
 String deleteReason,
 boolean cascade,
 boolean cancel,
 boolean fireEvents)

Specified by:

deleteProcessInstanceExecutionEntity in interface ExecutionEntityManager

deleteChildExecutions

public void deleteChildExecutions(ExecutionEntity executionEntity,
 String deleteReason,
 boolean cancel)

Specified by:

deleteChildExecutions in interface ExecutionEntityManager

deleteChildExecutions

public void deleteChildExecutions(ExecutionEntity executionEntity,
 Collection<String> executionIdsNotToDelete,
 Collection<String> executionIdsNotToSendCancelledEventFor,
 String deleteReason,
 boolean cancel,
 FlowElement cancelActivity)

Specified by:

deleteChildExecutions in interface ExecutionEntityManager

collectChildren

public List<ExecutionEntity> collectChildren(ExecutionEntity executionEntity)

Description copied from interface: ExecutionEntityManager

Returns all child executions of a given ExecutionEntity. In the list, child executions will be behind parent executions. Children include subprocessinstances and its children.

Specified by:

collectChildren in interface ExecutionEntityManager

collectChildren

protected List<ExecutionEntity> collectChildren(ExecutionEntity executionEntity,
 Collection<String> executionIdsToExclude)

collectChildren

protected void collectChildren(ExecutionEntity executionEntity,
 List<ExecutionEntity> collectedChildExecution,
 Collection<String> executionIdsToExclude)

dispatchExecutionCancelled

protected void dispatchExecutionCancelled(ExecutionEntity execution,
 FlowElement cancelActivity)

dispatchActivityCancelled

protected void dispatchActivityCancelled(ExecutionEntity execution,
 FlowElement cancelActivity)

dispatchMultiInstanceActivityCancelled

protected void dispatchMultiInstanceActivityCancelled(ExecutionEntity execution,
 FlowElement cancelActivity)

getActivityType

protected String getActivityType(FlowElement flowNode)

findFirstScope

public ExecutionEntity findFirstScope(ExecutionEntity executionEntity)

Specified by:

findFirstScope in interface ExecutionEntityManager

findFirstMultiInstanceRoot

public ExecutionEntity findFirstMultiInstanceRoot(ExecutionEntity executionEntity)

Specified by:

findFirstMultiInstanceRoot in interface ExecutionEntityManager

deleteRelatedDataForExecution

public void deleteRelatedDataForExecution(ExecutionEntity executionEntity,
 String deleteReason,
 boolean directDeleteInDatabase)

Specified by:

deleteRelatedDataForExecution in interface ExecutionEntityManager

deleteSubCases

protected void deleteSubCases(ExecutionEntity executionEntity,
 boolean directDeleteInDatabase,
 CommandContext commandContext)

deleteActivityInstances

protected void deleteActivityInstances(ExecutionEntity executionEntity,
 CommandContext commandContext)

deleteIdentityLinks

protected void deleteIdentityLinks(ExecutionEntity executionEntity,
 CommandContext commandContext,
 boolean eventDispatcherEnabled)

deleteEntityLinks

protected void deleteEntityLinks(ExecutionEntity executionEntity,
 CommandContext commandContext,
 boolean eventDispatcherEnabled)

isRootProcessInstance

protected boolean isRootProcessInstance(ExecutionEntity executionEntity)

deleteVariables

protected void deleteVariables(ExecutionEntity executionEntity,
 CommandContext commandContext,
 boolean enableExecutionRelationshipCounts,
 boolean eventDispatcherEnabled)

deleteUserTasks

protected void deleteUserTasks(ExecutionEntity executionEntity,
 String deleteReason,
 CommandContext commandContext,
 boolean enableExecutionRelationshipCounts,
 boolean eventDispatcherEnabled)

deleteJobs

protected void deleteJobs(ExecutionEntity executionEntity,
 CommandContext commandContext,
 boolean enableExecutionRelationshipCounts,
 boolean eventDispatcherEnabled)

deleteEventSubScriptions

protected void deleteEventSubScriptions(ExecutionEntity executionEntity,
 boolean enableExecutionRelationshipCounts,
 boolean eventDispatcherEnabled)

updateProcessInstanceLockTime

public void updateProcessInstanceLockTime(String processInstanceId,
 String lockOwner,
 Date lockTime)

Specified by:

updateProcessInstanceLockTime in interface ExecutionEntityManager

clearProcessInstanceLockTime

public void clearProcessInstanceLockTime(String processInstanceId)

Specified by:

clearProcessInstanceLockTime in interface ExecutionEntityManager

clearAllProcessInstanceLockTimes

public void clearAllProcessInstanceLockTimes(String lockOwner)

Specified by:

clearAllProcessInstanceLockTimes in interface ExecutionEntityManager

updateProcessInstanceBusinessKey

public String updateProcessInstanceBusinessKey(ExecutionEntity executionEntity,
 String businessKey)

Specified by:

updateProcessInstanceBusinessKey in interface ExecutionEntityManager

updateProcessInstanceBusinessStatus

public String updateProcessInstanceBusinessStatus(ExecutionEntity executionEntity,
 String businessStatus)

Specified by:

updateProcessInstanceBusinessStatus in interface ExecutionEntityManager

getHistoryManager

protected HistoryManager getHistoryManager()

getAsyncExecutor

protected AsyncExecutor getAsyncExecutor()

getByteArrayEntityManager

protected ByteArrayEntityManager getByteArrayEntityManager()

getActivityInstanceEntityManager

protected ActivityInstanceEntityManager getActivityInstanceEntityManager()