org.apache.ode.dao.jpa
Class ProcessInstanceDAOImpl
java.lang.Object
org.apache.ode.dao.jpa.OpenJPADAO
org.apache.ode.dao.jpa.ProcessInstanceDAOImpl
- All Implemented Interfaces:
- org.apache.ode.bpel.dao.ProcessInstanceDAO
public class ProcessInstanceDAOImpl
- extends OpenJPADAO
- implements org.apache.ode.bpel.dao.ProcessInstanceDAO
Nested classes/interfaces inherited from interface org.apache.ode.bpel.dao.ProcessInstanceDAO |
org.apache.ode.bpel.dao.ProcessInstanceDAO.EventsFirstLastCountTuple |
Method Summary |
void |
createActivityRecovery(java.lang.String channel,
long activityId,
java.lang.String reason,
java.util.Date dateTime,
org.w3c.dom.Element data,
java.lang.String[] actions,
int retries)
|
org.apache.ode.bpel.dao.ScopeDAO |
createScope(org.apache.ode.bpel.dao.ScopeDAO parentScope,
java.lang.String name,
int scopeModelId)
|
void |
delete(java.util.Set<org.apache.ode.bpel.iapi.ProcessConf.CLEANUP_CATEGORY> cleanupCategories)
|
void |
delete(java.util.Set<org.apache.ode.bpel.iapi.ProcessConf.CLEANUP_CATEGORY> cleanupCategories,
boolean deleteMyRoleMex)
|
void |
deleteActivityRecovery(java.lang.String channel)
|
void |
finishCompletion()
|
long |
genMonotonic()
|
int |
getActivityFailureCount()
|
java.util.Date |
getActivityFailureDateTime()
|
java.util.Collection<org.apache.ode.bpel.dao.ActivityRecoveryDAO> |
getActivityRecoveries()
|
org.apache.ode.bpel.dao.BpelDAOConnection |
getConnection()
|
org.apache.ode.bpel.dao.CorrelationSetDAO |
getCorrelationSet(java.lang.String name)
|
java.util.Set<org.apache.ode.bpel.dao.CorrelationSetDAO> |
getCorrelationSets()
|
java.util.Date |
getCreateTime()
|
org.apache.ode.bpel.dao.ProcessInstanceDAO.EventsFirstLastCountTuple |
getEventsFirstLastCount()
|
byte[] |
getExecutionState()
|
org.apache.ode.bpel.dao.FaultDAO |
getFault()
|
java.lang.Long |
getInstanceId()
|
org.apache.ode.bpel.dao.CorrelatorDAO |
getInstantiatingCorrelator()
|
java.util.Date |
getLastActiveTime()
|
java.util.Collection<java.lang.String> |
getMessageExchangeIds()
|
short |
getPreviousState()
|
org.apache.ode.bpel.dao.ProcessDAO |
getProcess()
|
org.apache.ode.bpel.dao.ScopeDAO |
getRootScope()
|
org.apache.ode.bpel.dao.ScopeDAO |
getScope(java.lang.Long scopeInstanceId)
|
java.util.Collection<org.apache.ode.bpel.dao.ScopeDAO> |
getScopes()
|
java.util.Collection<org.apache.ode.bpel.dao.ScopeDAO> |
getScopes(java.lang.String scopeName)
|
short |
getState()
|
org.apache.ode.bpel.dao.XmlDataDAO[] |
getVariables(java.lang.String variableName,
int scopeModelId)
|
void |
insertBpelEvent(org.apache.ode.bpel.evt.ProcessInstanceEvent event)
|
java.util.Collection<org.apache.ode.bpel.dao.CorrelationSetDAO> |
selectCorrelationSets(java.util.Collection<org.apache.ode.bpel.dao.ProcessInstanceDAO> instances)
|
void |
setActivityFailureCount(int activityFailureCount)
|
void |
setExecutionState(byte[] execState)
|
void |
setFault(org.apache.ode.bpel.dao.FaultDAO fault)
|
void |
setFault(javax.xml.namespace.QName faultName,
java.lang.String explanation,
int faultLineNo,
int activityId,
org.w3c.dom.Element faultMessage)
|
void |
setLastActiveTime(java.util.Date dt)
|
void |
setState(short state)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DELETE_INSTANCES_BY_PROCESS
public static final java.lang.String DELETE_INSTANCES_BY_PROCESS
- See Also:
- Constant Field Values
SELECT_INSTANCE_IDS_BY_PROCESS
public static final java.lang.String SELECT_INSTANCE_IDS_BY_PROCESS
- See Also:
- Constant Field Values
COUNT_INSTANCE_IDS_BY_PROCESS
public static final java.lang.String COUNT_INSTANCE_IDS_BY_PROCESS
- See Also:
- Constant Field Values
SELECT_FAULT_IDS_BY_PROCESS
public static final java.lang.String SELECT_FAULT_IDS_BY_PROCESS
- See Also:
- Constant Field Values
COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_ID
public static final java.lang.String COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_ID
- See Also:
- Constant Field Values
COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_IDS
public static final java.lang.String COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_IDS
- See Also:
- Constant Field Values
COUNT_INSTANCES_BY_PROCESSES_IDS_AND_STATES
public static final java.lang.String COUNT_INSTANCES_BY_PROCESSES_IDS_AND_STATES
- See Also:
- Constant Field Values
ProcessInstanceDAOImpl
public ProcessInstanceDAOImpl()
ProcessInstanceDAOImpl
public ProcessInstanceDAOImpl(CorrelatorDAOImpl correlator,
ProcessDAOImpl process)
createActivityRecovery
public void createActivityRecovery(java.lang.String channel,
long activityId,
java.lang.String reason,
java.util.Date dateTime,
org.w3c.dom.Element data,
java.lang.String[] actions,
int retries)
- Specified by:
createActivityRecovery
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
createScope
public org.apache.ode.bpel.dao.ScopeDAO createScope(org.apache.ode.bpel.dao.ScopeDAO parentScope,
java.lang.String name,
int scopeModelId)
- Specified by:
createScope
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
selectCorrelationSets
public java.util.Collection<org.apache.ode.bpel.dao.CorrelationSetDAO> selectCorrelationSets(java.util.Collection<org.apache.ode.bpel.dao.ProcessInstanceDAO> instances)
delete
public void delete(java.util.Set<org.apache.ode.bpel.iapi.ProcessConf.CLEANUP_CATEGORY> cleanupCategories)
- Specified by:
delete
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
delete
public void delete(java.util.Set<org.apache.ode.bpel.iapi.ProcessConf.CLEANUP_CATEGORY> cleanupCategories,
boolean deleteMyRoleMex)
- Specified by:
delete
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
deleteActivityRecovery
public void deleteActivityRecovery(java.lang.String channel)
- Specified by:
deleteActivityRecovery
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
finishCompletion
public void finishCompletion()
- Specified by:
finishCompletion
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
genMonotonic
public long genMonotonic()
- Specified by:
genMonotonic
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getActivityFailureCount
public int getActivityFailureCount()
- Specified by:
getActivityFailureCount
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
setActivityFailureCount
public void setActivityFailureCount(int activityFailureCount)
getActivityFailureDateTime
public java.util.Date getActivityFailureDateTime()
- Specified by:
getActivityFailureDateTime
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getActivityRecoveries
public java.util.Collection<org.apache.ode.bpel.dao.ActivityRecoveryDAO> getActivityRecoveries()
- Specified by:
getActivityRecoveries
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getCorrelationSet
public org.apache.ode.bpel.dao.CorrelationSetDAO getCorrelationSet(java.lang.String name)
- Specified by:
getCorrelationSet
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getCorrelationSets
public java.util.Set<org.apache.ode.bpel.dao.CorrelationSetDAO> getCorrelationSets()
- Specified by:
getCorrelationSets
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getCreateTime
public java.util.Date getCreateTime()
- Specified by:
getCreateTime
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getEventsFirstLastCount
public org.apache.ode.bpel.dao.ProcessInstanceDAO.EventsFirstLastCountTuple getEventsFirstLastCount()
- Specified by:
getEventsFirstLastCount
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getExecutionState
public byte[] getExecutionState()
- Specified by:
getExecutionState
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getFault
public org.apache.ode.bpel.dao.FaultDAO getFault()
- Specified by:
getFault
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getInstanceId
public java.lang.Long getInstanceId()
- Specified by:
getInstanceId
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getInstantiatingCorrelator
public org.apache.ode.bpel.dao.CorrelatorDAO getInstantiatingCorrelator()
- Specified by:
getInstantiatingCorrelator
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getLastActiveTime
public java.util.Date getLastActiveTime()
- Specified by:
getLastActiveTime
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getPreviousState
public short getPreviousState()
- Specified by:
getPreviousState
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getProcess
public org.apache.ode.bpel.dao.ProcessDAO getProcess()
- Specified by:
getProcess
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getRootScope
public org.apache.ode.bpel.dao.ScopeDAO getRootScope()
- Specified by:
getRootScope
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getScope
public org.apache.ode.bpel.dao.ScopeDAO getScope(java.lang.Long scopeInstanceId)
- Specified by:
getScope
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getScopes
public java.util.Collection<org.apache.ode.bpel.dao.ScopeDAO> getScopes(java.lang.String scopeName)
- Specified by:
getScopes
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getScopes
public java.util.Collection<org.apache.ode.bpel.dao.ScopeDAO> getScopes()
- Specified by:
getScopes
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getState
public short getState()
- Specified by:
getState
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getVariables
public org.apache.ode.bpel.dao.XmlDataDAO[] getVariables(java.lang.String variableName,
int scopeModelId)
- Specified by:
getVariables
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
insertBpelEvent
public void insertBpelEvent(org.apache.ode.bpel.evt.ProcessInstanceEvent event)
- Specified by:
insertBpelEvent
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
setExecutionState
public void setExecutionState(byte[] execState)
- Specified by:
setExecutionState
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
setFault
public void setFault(org.apache.ode.bpel.dao.FaultDAO fault)
- Specified by:
setFault
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
setFault
public void setFault(javax.xml.namespace.QName faultName,
java.lang.String explanation,
int faultLineNo,
int activityId,
org.w3c.dom.Element faultMessage)
- Specified by:
setFault
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
setLastActiveTime
public void setLastActiveTime(java.util.Date dt)
- Specified by:
setLastActiveTime
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
setState
public void setState(short state)
- Specified by:
setState
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getConnection
public org.apache.ode.bpel.dao.BpelDAOConnection getConnection()
- Specified by:
getConnection
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO
getMessageExchangeIds
public java.util.Collection<java.lang.String> getMessageExchangeIds()
- Specified by:
getMessageExchangeIds
in interface org.apache.ode.bpel.dao.ProcessInstanceDAO