Package org.camunda.bpm.engine.impl.persistence.entity

Class ExecutionManager

java.lang.Object

org.camunda.bpm.engine.impl.persistence.AbstractManager

org.camunda.bpm.engine.impl.persistence.entity.ExecutionManager

All Implemented Interfaces:

Session

public class ExecutionManager
extends AbstractManager

Author:

Tom Baeyens

Field Summary

Fields

Modifier and Type	Field	Description
protected static final EnginePersistenceLogger	LOG

Constructor Summary

Constructors

Constructor	Description
ExecutionManager()

Method Summary

Modifier and Type	Method	Description
protected ListQueryParameterObject	configureParameterizedQuery(Object parameter)
protected void	configureQuery(AbstractQuery<?,?> query)
protected void	createDefaultAuthorizations(ExecutionEntity execution)
void	deleteExecution(ExecutionEntity execution)
void	deleteProcessInstance(String processInstanceId, String deleteReason)
void	deleteProcessInstance(String processInstanceId, String deleteReason, boolean cascade, boolean skipCustomListeners)
void	deleteProcessInstance(String processInstanceId, String deleteReason, boolean cascade, boolean skipCustomListeners, boolean externallyTerminated, boolean skipIoMappings, boolean skipSubprocesses)
void	deleteProcessInstancesByProcessDefinition(String processDefinitionId, String deleteReason, boolean cascade, boolean skipCustomListeners, boolean skipIoMappings)
List<ExecutionEntity>	findChildExecutionsByParentExecutionId(String parentExecutionId)
List<ImmutablePair<String,String>>	findDeploymentIdMappingsByQueryCriteria(ProcessInstanceQueryImpl processInstanceQuery)
List<ExecutionEntity>	findEventScopeExecutionsByActivityId(String activityRef, String parentExecutionId)
ExecutionEntity	findExecutionById(String executionId)
long	findExecutionCountByNativeQuery(Map<String,Object> parameterMap)
long	findExecutionCountByQueryCriteria(ExecutionQueryImpl executionQuery)
List<Execution>	findExecutionsByNativeQuery(Map<String,Object> parameterMap, int firstResult, int maxResults)
List<ExecutionEntity>	findExecutionsByProcessInstanceId(String processInstanceId)
List<ExecutionEntity>	findExecutionsByQueryCriteria(ExecutionQueryImpl executionQuery, Page page)
List<ProcessInstance>	findProcessInstanceByNativeQuery(Map<String,Object> parameterMap, int firstResult, int maxResults)
long	findProcessInstanceCountByQueryCriteria(ProcessInstanceQueryImpl processInstanceQuery)
List<ProcessInstance>	findProcessInstancesByQueryCriteria(ProcessInstanceQueryImpl processInstanceQuery, Page page)
List<String>	findProcessInstancesIdsByQueryCriteria(ProcessInstanceQueryImpl processInstanceQuery)
ExecutionEntity	findSubProcessInstanceBySuperCaseExecutionId(String superCaseExecutionId)
ExecutionEntity	findSubProcessInstanceBySuperExecutionId(String superExecutionId)
void	insertExecution(ExecutionEntity execution)
void	updateExecutionSuspensionStateByProcessDefinitionId(String processDefinitionId, SuspensionState suspensionState)
void	updateExecutionSuspensionStateByProcessDefinitionKey(String processDefinitionKey, SuspensionState suspensionState)
void	updateExecutionSuspensionStateByProcessDefinitionKeyAndTenantId(String processDefinitionKey, String tenantId, SuspensionState suspensionState)
void	updateExecutionSuspensionStateByProcessInstanceId(String processInstanceId, SuspensionState suspensionState)

Methods inherited from class org.camunda.bpm.engine.impl.persistence.AbstractManager

checkAuthorization, close, configureQuery, delete, deleteAuthorizations, deleteAuthorizationsForGroup, deleteAuthorizationsForUser, deleteDefaultAuthorizations, flush, getAttachmentManager, getAuthorizationManager, getBatchManager, getByteArrayManager, getCamundaFormDefinitionManager, getCaseDefinitionManager, getCaseExecutionManager, getCaseInstanceManager, getCommandContext, getCurrentAuthentication, getDbEntityManager, getDbSqlSession, getDecisionDefinitionManager, getDecisionRequirementsDefinitionManager, getDeploymentManager, getEventSubscriptionManager, getHistoricActivityInstanceManager, getHistoricBatchManager, getHistoricCaseActivityInstanceManager, getHistoricCaseInstanceManager, getHistoricDecisionInstanceManager, getHistoricDetailManager, getHistoricExternalTaskLogManager, getHistoricIdentityLinkManager, getHistoricIncidentManager, getHistoricJobLogManager, getHistoricProcessInstanceManager, getHistoricReportManager, getHistoricTaskInstanceManager, getHistoricVariableInstanceManager, getIdentityInfoManager, getIdentityLinkManager, getJobDefinitionManager, getJobManager, getProcessDefinitionManager, getProcessInstanceManager, getResourceAuthorizationProvider, getResourceManager, getSession, getTaskManager, getTaskReportManager, getTenantManager, getUserOperationLogManager, getVariableInstanceManager, insert, isAuthorizationEnabled, saveDefaultAuthorizations

Methods inherited from class java.lang.Object

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

Field Details

LOG

protected static final EnginePersistenceLogger LOG

Constructor Details

ExecutionManager

public ExecutionManager()

Method Details

insertExecution

public void insertExecution(ExecutionEntity execution)

deleteExecution

public void deleteExecution(ExecutionEntity execution)

deleteProcessInstancesByProcessDefinition

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

deleteProcessInstance

public void deleteProcessInstance(String processInstanceId,
 String deleteReason)

deleteProcessInstance

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

deleteProcessInstance

public void deleteProcessInstance(String processInstanceId,
 String deleteReason,
 boolean cascade,
 boolean skipCustomListeners,
 boolean externallyTerminated,
 boolean skipIoMappings,
 boolean skipSubprocesses)

findSubProcessInstanceBySuperExecutionId

public ExecutionEntity findSubProcessInstanceBySuperExecutionId(String superExecutionId)

findSubProcessInstanceBySuperCaseExecutionId

public ExecutionEntity findSubProcessInstanceBySuperCaseExecutionId(String superCaseExecutionId)

findChildExecutionsByParentExecutionId

public List<ExecutionEntity> findChildExecutionsByParentExecutionId(String parentExecutionId)

findExecutionsByProcessInstanceId

public List<ExecutionEntity> findExecutionsByProcessInstanceId(String processInstanceId)

findExecutionById

public ExecutionEntity findExecutionById(String executionId)

findExecutionCountByQueryCriteria

public long findExecutionCountByQueryCriteria(ExecutionQueryImpl executionQuery)

findExecutionsByQueryCriteria

public List<ExecutionEntity> findExecutionsByQueryCriteria(ExecutionQueryImpl executionQuery,
 Page page)

findProcessInstanceCountByQueryCriteria

public long findProcessInstanceCountByQueryCriteria(ProcessInstanceQueryImpl processInstanceQuery)

findProcessInstancesByQueryCriteria

public List<ProcessInstance> findProcessInstancesByQueryCriteria(ProcessInstanceQueryImpl processInstanceQuery,
 Page page)

findProcessInstancesIdsByQueryCriteria

public List<String> findProcessInstancesIdsByQueryCriteria(ProcessInstanceQueryImpl processInstanceQuery)

findDeploymentIdMappingsByQueryCriteria

public List<ImmutablePair<String,String>> findDeploymentIdMappingsByQueryCriteria(ProcessInstanceQueryImpl processInstanceQuery)

findEventScopeExecutionsByActivityId

public List<ExecutionEntity> findEventScopeExecutionsByActivityId(String activityRef,
 String parentExecutionId)

findExecutionsByNativeQuery

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

findProcessInstanceByNativeQuery

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

findExecutionCountByNativeQuery

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

updateExecutionSuspensionStateByProcessDefinitionId

public void updateExecutionSuspensionStateByProcessDefinitionId(String processDefinitionId,
 SuspensionState suspensionState)

updateExecutionSuspensionStateByProcessInstanceId

public void updateExecutionSuspensionStateByProcessInstanceId(String processInstanceId,
 SuspensionState suspensionState)

updateExecutionSuspensionStateByProcessDefinitionKey

public void updateExecutionSuspensionStateByProcessDefinitionKey(String processDefinitionKey,
 SuspensionState suspensionState)

updateExecutionSuspensionStateByProcessDefinitionKeyAndTenantId

public void updateExecutionSuspensionStateByProcessDefinitionKeyAndTenantId(String processDefinitionKey,
 String tenantId,
 SuspensionState suspensionState)

createDefaultAuthorizations

protected void createDefaultAuthorizations(ExecutionEntity execution)

configureQuery

protected void configureQuery(AbstractQuery<?,?> query)

configureParameterizedQuery

protected ListQueryParameterObject configureParameterizedQuery(Object parameter)