org.apache.ode.dao.jpa
Class ProcessInstanceDAOImpl

java.lang.Object
  extended by org.apache.ode.dao.jpa.OpenJPADAO
      extended by 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 Class Summary
 
Nested classes/interfaces inherited from interface org.apache.ode.bpel.dao.ProcessInstanceDAO
org.apache.ode.bpel.dao.ProcessInstanceDAO.EventsFirstLastCountTuple
 
Field Summary
static java.lang.String COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_ID
           
static java.lang.String COUNT_FAILED_INSTANCES_BY_STATUS_AND_PROCESS_IDS
           
static java.lang.String COUNT_INSTANCE_IDS_BY_PROCESS
           
static java.lang.String COUNT_INSTANCES_BY_PROCESSES_IDS_AND_STATES
           
static java.lang.String DELETE_INSTANCES_BY_PROCESS
           
static java.lang.String SELECT_FAULT_IDS_BY_PROCESS
           
static java.lang.String SELECT_INSTANCE_IDS_BY_PROCESS
           
 
Constructor Summary
ProcessInstanceDAOImpl()
           
ProcessInstanceDAOImpl(CorrelatorDAOImpl correlator, ProcessDAOImpl process)
           
 
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 org.apache.ode.dao.jpa.OpenJPADAO
batchUpdateByIds, getConn, getEM, getSingleResult
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

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
Constructor Detail

ProcessInstanceDAOImpl

public ProcessInstanceDAOImpl()

ProcessInstanceDAOImpl

public ProcessInstanceDAOImpl(CorrelatorDAOImpl correlator,
                              ProcessDAOImpl process)
Method Detail

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