Package org.operaton.bpm.engine.impl.history.event

Class HistoricDecisionInstanceManager

java.lang.Object

org.operaton.bpm.engine.impl.persistence.AbstractManager

org.operaton.bpm.engine.impl.persistence.AbstractHistoricManager

org.operaton.bpm.engine.impl.history.event.HistoricDecisionInstanceManager

All Implemented Interfaces:

Session

public class HistoricDecisionInstanceManager
extends AbstractHistoricManager

Data base operations for HistoricDecisionInstanceEntity.

Author:

Philipp Ossler

Field Summary

Fields inherited from class org.operaton.bpm.engine.impl.persistence.AbstractHistoricManager

historyLevel, isHistoryEnabled, isHistoryLevelFullEnabled, LOG

Fields inherited from class org.operaton.bpm.engine.impl.persistence.AbstractManager

ACTIVITY_ID, BATCH_ID, BATCH_SIZE, CASE_INSTANCE_IDS, CURRENT_TIMESTAMP, ID, IS_PROCESS_DEFINITION_TENANT_ID_SET, IS_TENANT_ID_SET, JOB_DEFINITION_ID, MAX_RESULTS, MINUTE_FROM, MINUTE_TO, PROCESS_DEFINITION_ID, PROCESS_DEFINITION_KEY, PROCESS_DEFINITION_TENANT_ID, PROCESS_INSTANCE_ID, PROCESS_INSTANCE_IDS, REMOVAL_TIME, ROOT_PROCESS_INSTANCE_ID, SUSPENSION_STATE, TASK_CASE_INSTANCE_IDS, TASK_ID, TASK_PROCESS_INSTANCE_IDS, TENANT_ID

Constructor Summary

Constructors

Constructor	Description
HistoricDecisionInstanceManager()

Method Summary

Modifier and Type	Method	Description
void	addRemovalTimeToDecisionsByDecisionInstanceId(String instanceId, Date removalTime)
void	addRemovalTimeToDecisionsByProcessInstanceId(String processInstanceId, Date removalTime)
Map<Class<? extends DbEntity>,DbOperation>	addRemovalTimeToDecisionsByProcessInstanceId(String processInstanceId, Date removalTime, Integer batchSize, Set<String> entities)
void	addRemovalTimeToDecisionsByRootDecisionInstanceId(String rootInstanceId, Date removalTime)
void	addRemovalTimeToDecisionsByRootProcessInstanceId(String rootProcessInstanceId, Date removalTime)
Map<Class<? extends DbEntity>,DbOperation>	addRemovalTimeToDecisionsByRootProcessInstanceId(String rootProcessInstanceId, Date removalTime, Integer batchSize, Set<String> entities)
protected void	appendHistoricDecisionInputInstances(Map<String,HistoricDecisionInstanceEntity> decisionInstancesById, HistoricDecisionInstanceQueryImpl query)
protected void	appendHistoricDecisionOutputInstances(Map<String,HistoricDecisionInstanceEntity> decisionInstancesById, HistoricDecisionInstanceQueryImpl query)
protected ListQueryParameterObject	configureParameterizedQuery(Object parameter)
protected void	configureQuery(HistoricDecisionInstanceQueryImpl query)
void	deleteHistoricDecisionInstanceByIds(List<String> decisionInstanceIds)
void	deleteHistoricDecisionInstancesByDecisionDefinitionId(String decisionDefinitionId)
Map<Class<? extends DbEntity>,DbOperation>	deleteHistoricDecisionsByRemovalTime(Date removalTime, int minuteFrom, int minuteTo, int batchSize)
void	enrichHistoricDecisionsWithInputsAndOutputs(HistoricDecisionInstanceQueryImpl query, List<HistoricDecisionInstance> decisionInstances)
protected void	fetchVariableValue(HistoricDecisionInputInstanceEntity decisionInputInstance, boolean isCustomObjectDeserializationEnabled)
protected void	fetchVariableValue(HistoricDecisionOutputInstanceEntity decisionOutputInstance, boolean isCustomObjectDeserializationEnabled)
List<CleanableHistoricDecisionInstanceReportResult>	findCleanableHistoricDecisionInstancesReportByCriteria(CleanableHistoricDecisionInstanceReportImpl query, Page page)
long	findCleanableHistoricDecisionInstancesReportCountByCriteria(CleanableHistoricDecisionInstanceReportImpl query)
protected List<HistoricDecisionInputInstanceEntity>	findHistoricDecisionInputInstancesByDecisionInstanceIds(Set<String> historicDecisionInstanceKeys)
HistoricDecisionInstanceEntity	findHistoricDecisionInstance(String historicDecisionInstanceId)
long	findHistoricDecisionInstanceCountByNativeQuery(Map<String,Object> parameterMap)
long	findHistoricDecisionInstanceCountByQueryCriteria(HistoricDecisionInstanceQueryImpl query)
List<ImmutablePair<String,String>>	findHistoricDecisionInstanceDeploymentIdMappingsByQueryCriteria(HistoricDecisionInstanceQueryImpl query)
List<String>	findHistoricDecisionInstanceIdsForCleanup(Integer batchSize, int minuteFrom, int minuteTo)
protected List<HistoricDecisionInstanceEntity>	findHistoricDecisionInstancesByDecisionDefinitionId(String decisionDefinitionId)
List<HistoricDecisionInstance>	findHistoricDecisionInstancesByNativeQuery(Map<String,Object> parameterMap, int firstResult, int maxResults)
List<HistoricDecisionInstance>	findHistoricDecisionInstancesByQueryCriteria(HistoricDecisionInstanceQueryImpl query, Page page)
protected List<HistoricDecisionOutputInstanceEntity>	findHistoricDecisionOutputInstancesByDecisionInstanceIds(Set<String> decisionInstanceKeys)
protected void	initializeInputInstances(Collection<HistoricDecisionInstanceEntity> decisionInstances)
protected void	initializeOutputInstances(Collection<HistoricDecisionInstanceEntity> decisionInstances)
protected void	insertHistoricDecisionInputInstances(List<HistoricDecisionInputInstance> inputs, String decisionInstanceId)
protected void	insertHistoricDecisionInstance(HistoricDecisionInstanceEntity historicDecisionInstance)
void	insertHistoricDecisionInstances(HistoricDecisionEvaluationEvent event)
protected void	insertHistoricDecisionOutputInstances(List<HistoricDecisionOutputInstance> outputs, String decisionInstanceId)
protected boolean	isBinaryValue(HistoricDecisionInputInstance decisionInputInstance)
protected boolean	isBinaryValue(HistoricDecisionOutputInstance decisionOutputInstance)

Methods inherited from class org.operaton.bpm.engine.impl.persistence.AbstractHistoricManager

addOperation, addOperation, checkHistoryEnabled, isHistoryEnabled, isHistoryLevelFullEnabled, isPerformUpdate, isPerformUpdateOnly

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

checkAuthorization, configureQuery, delete, deleteAuthorizations, deleteAuthorizationsForGroup, deleteAuthorizationsForUser, deleteDefaultAuthorizations, getAttachmentManager, getAuthorizationManager, getBatchManager, getByteArrayManager, 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, getOperatonFormDefinitionManager, 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

Methods inherited from interface org.operaton.bpm.engine.impl.interceptor.Session

close, flush

Constructor Details

HistoricDecisionInstanceManager

public HistoricDecisionInstanceManager()

Method Details

deleteHistoricDecisionInstancesByDecisionDefinitionId

public void deleteHistoricDecisionInstancesByDecisionDefinitionId(String decisionDefinitionId)

findHistoricDecisionInstancesByDecisionDefinitionId

protected List<HistoricDecisionInstanceEntity> findHistoricDecisionInstancesByDecisionDefinitionId(String decisionDefinitionId)

deleteHistoricDecisionInstanceByIds

public void deleteHistoricDecisionInstanceByIds(List<String> decisionInstanceIds)

insertHistoricDecisionInstances

public void insertHistoricDecisionInstances(HistoricDecisionEvaluationEvent event)

insertHistoricDecisionInstance

protected void insertHistoricDecisionInstance(HistoricDecisionInstanceEntity historicDecisionInstance)

insertHistoricDecisionInputInstances

protected void insertHistoricDecisionInputInstances(List<HistoricDecisionInputInstance> inputs,
 String decisionInstanceId)

insertHistoricDecisionOutputInstances

protected void insertHistoricDecisionOutputInstances(List<HistoricDecisionOutputInstance> outputs,
 String decisionInstanceId)

findHistoricDecisionInstancesByQueryCriteria

public List<HistoricDecisionInstance> findHistoricDecisionInstancesByQueryCriteria(HistoricDecisionInstanceQueryImpl query,
 Page page)

findHistoricDecisionInstanceDeploymentIdMappingsByQueryCriteria

public List<ImmutablePair<String,String>> findHistoricDecisionInstanceDeploymentIdMappingsByQueryCriteria(HistoricDecisionInstanceQueryImpl query)

enrichHistoricDecisionsWithInputsAndOutputs

public void enrichHistoricDecisionsWithInputsAndOutputs(HistoricDecisionInstanceQueryImpl query,
 List<HistoricDecisionInstance> decisionInstances)

findHistoricDecisionInstanceIdsForCleanup

public List<String> findHistoricDecisionInstanceIdsForCleanup(Integer batchSize,
 int minuteFrom,
 int minuteTo)

appendHistoricDecisionInputInstances

protected void appendHistoricDecisionInputInstances(Map<String,HistoricDecisionInstanceEntity> decisionInstancesById,
 HistoricDecisionInstanceQueryImpl query)

initializeInputInstances

protected void initializeInputInstances(Collection<HistoricDecisionInstanceEntity> decisionInstances)

findHistoricDecisionInputInstancesByDecisionInstanceIds

protected List<HistoricDecisionInputInstanceEntity> findHistoricDecisionInputInstancesByDecisionInstanceIds(Set<String> historicDecisionInstanceKeys)

isBinaryValue

protected boolean isBinaryValue(HistoricDecisionInputInstance decisionInputInstance)

fetchVariableValue

protected void fetchVariableValue(HistoricDecisionInputInstanceEntity decisionInputInstance,
 boolean isCustomObjectDeserializationEnabled)

appendHistoricDecisionOutputInstances

protected void appendHistoricDecisionOutputInstances(Map<String,HistoricDecisionInstanceEntity> decisionInstancesById,
 HistoricDecisionInstanceQueryImpl query)

initializeOutputInstances

protected void initializeOutputInstances(Collection<HistoricDecisionInstanceEntity> decisionInstances)

findHistoricDecisionOutputInstancesByDecisionInstanceIds

protected List<HistoricDecisionOutputInstanceEntity> findHistoricDecisionOutputInstancesByDecisionInstanceIds(Set<String> decisionInstanceKeys)

isBinaryValue

protected boolean isBinaryValue(HistoricDecisionOutputInstance decisionOutputInstance)

fetchVariableValue

protected void fetchVariableValue(HistoricDecisionOutputInstanceEntity decisionOutputInstance,
 boolean isCustomObjectDeserializationEnabled)

findHistoricDecisionInstance

public HistoricDecisionInstanceEntity findHistoricDecisionInstance(String historicDecisionInstanceId)

findHistoricDecisionInstanceCountByQueryCriteria

public long findHistoricDecisionInstanceCountByQueryCriteria(HistoricDecisionInstanceQueryImpl query)

findHistoricDecisionInstancesByNativeQuery

public List<HistoricDecisionInstance> findHistoricDecisionInstancesByNativeQuery(Map<String,Object> parameterMap,
 int firstResult,
 int maxResults)

findHistoricDecisionInstanceCountByNativeQuery

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

configureQuery

protected void configureQuery(HistoricDecisionInstanceQueryImpl query)

configureParameterizedQuery

protected ListQueryParameterObject configureParameterizedQuery(Object parameter)

findCleanableHistoricDecisionInstancesReportByCriteria

public List<CleanableHistoricDecisionInstanceReportResult> findCleanableHistoricDecisionInstancesReportByCriteria(CleanableHistoricDecisionInstanceReportImpl query,
 Page page)

findCleanableHistoricDecisionInstancesReportCountByCriteria

public long findCleanableHistoricDecisionInstancesReportCountByCriteria(CleanableHistoricDecisionInstanceReportImpl query)

addRemovalTimeToDecisionsByRootProcessInstanceId

public void addRemovalTimeToDecisionsByRootProcessInstanceId(String rootProcessInstanceId,
 Date removalTime)

addRemovalTimeToDecisionsByRootProcessInstanceId

public Map<Class<? extends DbEntity>,DbOperation> addRemovalTimeToDecisionsByRootProcessInstanceId(String rootProcessInstanceId,
 Date removalTime,
 Integer batchSize,
 Set<String> entities)

addRemovalTimeToDecisionsByProcessInstanceId

public void addRemovalTimeToDecisionsByProcessInstanceId(String processInstanceId,
 Date removalTime)

addRemovalTimeToDecisionsByProcessInstanceId

public Map<Class<? extends DbEntity>,DbOperation> addRemovalTimeToDecisionsByProcessInstanceId(String processInstanceId,
 Date removalTime,
 Integer batchSize,
 Set<String> entities)

addRemovalTimeToDecisionsByRootDecisionInstanceId

public void addRemovalTimeToDecisionsByRootDecisionInstanceId(String rootInstanceId,
 Date removalTime)

addRemovalTimeToDecisionsByDecisionInstanceId

public void addRemovalTimeToDecisionsByDecisionInstanceId(String instanceId,
 Date removalTime)

deleteHistoricDecisionsByRemovalTime

public Map<Class<? extends DbEntity>,DbOperation> deleteHistoricDecisionsByRemovalTime(Date removalTime,
 int minuteFrom,
 int minuteTo,
 int batchSize)