| java.lang.Object
 org.enhydra.shark.instancepersistence.DODSPersistentManager
| DODSPersistentManager | | public class DODSPersistentManager implements PersistentManagerInterface(Code) | | Used to save, restore or delete relevant engine objects from database, using DODS
persistent layer.
author:
Sasa Bojanic
version:
1.2 |
| Method Summary | |
| protected DBTransaction | __getDBTransaction()
| | protected boolean | canDeleteFinishedProcess(WMSessionHandle shandle, String procId)
| | public void | configure(CallbackUtilities cut)
| | public void | delete(WMSessionHandle shandle, ProcessVariablePersistenceObject var)
| | public void | delete(WMSessionHandle shandle, ActivityVariablePersistenceObject var)
| | public void | deleteActivity(WMSessionHandle shandle, String procId, String actId)
| | public void | deleteAndJoinEntries(WMSessionHandle shandle, String procId, String blockActId, String aDefId)
| | public void | deleteAssignment(WMSessionHandle shandle, String procId, String actId, String resUsername)
| | public void | deleteDeadlines(WMSessionHandle shandle, String procId)
| | public void | deleteDeadlines(WMSessionHandle shandle, String procId, String actId)
| | public List | deleteProcess(WMSessionHandle shandle, String procId, boolean administrative)
| | public void | deleteProcessMgr(WMSessionHandle shandle, String mgrName)
| | public void | deleteResource(WMSessionHandle shandle, String resUsername)
| | public List | getActivitiesForProcess(WMSessionHandle shandle, String procId, String actState)
| | protected DeadlineDO[] | getActivitiesPersistedDeadlines(String actId, long timeLimitBoundary)
| | public List | getActivitiesWhere(WMSessionHandle shandle, String sqlWhere, int startAt, int limit)
| | protected Object | getActivityDataValue(WMSessionHandle shandle, ActivityDataDO DO)
| | protected Object | getActivityDataValue(WMSessionHandle shandle, ActivityDataWOBDO DO)
| | public List | getActivityVariables(WMSessionHandle shandle, String procId, String actId, List variableIds)
| | public List | getAllActiveActivitiesForProcess(WMSessionHandle shandle, String procId)
| | public List | getAllActivities(WMSessionHandle shandle)
| | public List | getAllActivitiesForProcess(WMSessionHandle shandle, String procId)
| | public List | getAllAssignments(WMSessionHandle shandle)
| | public List | getAllAssignmentsForActivity(WMSessionHandle shandle, String procId, String actId)
Returns all assignments that are ever created for that activity, no matter if
activity is already in "closed" state or some of its sub-states. | | public List | getAllAssignmentsForResource(WMSessionHandle shandle, String resUsername)
Returns all assignments for the resource, no matter if its activity is in "closed"
state (or some of its sub-states). | | public List | getAllDeadlinesForActivity(WMSessionHandle shandle, String procId, String actId)
| | public List | getAllDeadlinesForActivity(WMSessionHandle shandle, String procId, String actId, long timeLimitBoundary)
| | public List | getAllDeadlinesForProcess(WMSessionHandle shandle, String procId)
| | public List | getAllDeadlinesForProcess(WMSessionHandle shandle, String procId, long timeLimitBoundary)
| | public List | getAllFinishedActivitiesForProcess(WMSessionHandle shandle, String procId)
| | public List | getAllFinishedProcesses(WMSessionHandle shandle)
| | public List | getAllIdsForProcessesWithExpiriedDeadlines(WMSessionHandle shandle, long timeLimitBoundary)
| | protected AssignmentDO[] | getAllPersistedAssignments(String sqlWhere, int startAt, int limit)
| | protected ProcessDefinitionDO[] | getAllPersistedProcessMgrs(String where, int startAt, int limit)
| | protected ResourceDO[] | getAllPersistedResources(String sqlWhere, int startAt, int limit)
| | public List | getAllProcessMgrs(WMSessionHandle shandle)
| | public List | getAllProcesses(WMSessionHandle shandle)
| | public List | getAllProcessesForMgr(WMSessionHandle shandle, String mgrName)
| | public List | getAllResources(WMSessionHandle shandle)
| | public List | getAllRunningProcesses(WMSessionHandle shandle)
| | public List | getAllValidAssignmentsForActivity(WMSessionHandle shandle, String procId, String actId)
If activity is in "closed" state, or some of its sub-states, returns an empty list,
otherwise it returns either all assignments that are ever created for that activity
if activity is not accepted, or just the assignment for the resource that accepted
activity. | | public List | getAllValidAssignmentsForResource(WMSessionHandle shandle, String resUsername)
Returns only the assignments that can be currently executed by the resource with a
given username. | | public List | getAllVariablesForActivity(WMSessionHandle shandle, String procId, String actId)
| | protected List | getAllVariablesForActivityBLOB(WMSessionHandle shandle, String actId)
| | protected List | getAllVariablesForActivityWOB(WMSessionHandle shandle, String actId)
| | public List | getAllVariablesForProcess(WMSessionHandle shandle, String procId)
| | protected List | getAllVariablesForProcessBLOB(WMSessionHandle shandle, String procId)
| | protected List | getAllVariablesForProcessWOB(WMSessionHandle shandle, String procId)
| | public List | getAndJoinEntries(WMSessionHandle shandle, String procId, String blockActId, String aDefId)
| | public List | getAssignmentsWhere(WMSessionHandle shandle, String sqlWhere, int startAt, int limit)
| | public int | getExecuteCount(WMSessionHandle shandle, String procId, String aDefId)
| | public BigDecimal | getNextDecId(String idName)
| | public String | getNextId(String idName)
| | protected ActivityDO[] | getPersistedActivities(int type, ProcessDO pDO, String sqlWhere, int startAt, int limit)
| | protected ActivityDO | getPersistedActivityObject(String actId)
| | protected ActivityStateDO | getPersistedActivityStateObject(String value, boolean searchByKeyValue, DBTransaction ti)
| | protected ActivityDataBLOBDO | getPersistedActivityVariableBLOBObject(ActivityDataWOBDO adDO)
| | protected ActivityDataDO | getPersistedActivityVariableObject(String actId, String defId)
| | protected ActivityDataWOBDO | getPersistedActivityVariableObject2(String actId, String defId)
| | protected ActivityDataDO[] | getPersistedActivityVariableObjects(String actId, String defId)
| | protected ActivityDataWOBDO[] | getPersistedActivityVariableObjects2(String procId, String defId)
| | protected AndJoinEntryDO[] | getPersistedAndJoinEntries(String procId, String blockActId, String aDefId)
| | protected AssignmentDO | getPersistedAssignmentObject(String actId, String username)
| | protected DeadlineDO | getPersistedDeadlineObject(String uniqueId)
| | protected DeadlineDO[] | getPersistedDeadlines(String procId, long timeLimitBoundary)
| | protected ProcessDefinitionDO | getPersistedObject(ProcessMgrPersistenceObject mgr)
| | protected ProcessDO | getPersistedObject(ProcessPersistenceObject proc)
| | protected ActivityDO | getPersistedObject(ActivityPersistenceObject act)
| | protected ResourceDO | getPersistedObject(ResourcePersistenceObject res)
| | protected AssignmentDO | getPersistedObject(AssignmentPersistenceObject ass)
| | protected DeadlineDO | getPersistedObject(DeadlinePersistenceObject dpe)
| | protected ProcessDataDO | getPersistedObject(ProcessVariablePersistenceObject var)
| | protected ProcessDataBLOBDO | getPersistedObject(ProcessDataWOBDO pdDO)
| | protected ActivityDataDO | getPersistedObject(ActivityVariablePersistenceObject var)
| | protected ActivityDataBLOBDO | getPersistedObject(ActivityDataWOBDO adDO)
| | protected ProcessDataWOBDO | getPersistedObject2(ProcessVariablePersistenceObject var)
| | protected ActivityDataWOBDO | getPersistedObject2(ActivityVariablePersistenceObject var)
| | protected ProcessDataDO[] | getPersistedObjects(ProcessVariablePersistenceObject var)
| | protected ActivityDataDO[] | getPersistedObjects(ActivityVariablePersistenceObject var)
| | protected ProcessDataWOBDO[] | getPersistedObjects2(ProcessVariablePersistenceObject var)
| | protected ActivityDataWOBDO[] | getPersistedObjects2(ActivityVariablePersistenceObject var)
| | protected ProcessDefinitionDO | getPersistedProcessMgrObject(String name)
| | protected ProcessDO | getPersistedProcessObject(String procId)
| | protected ProcessStateDO | getPersistedProcessStateObject(String value, boolean searchByKeyValue, DBTransaction ti)
| | protected ProcessDataBLOBDO | getPersistedProcessVariableBLOBObject(ProcessDataWOBDO pdDO)
| | protected ProcessDataDO | getPersistedProcessVariableObject(String procId, String defId)
| | protected ProcessDataWOBDO | getPersistedProcessVariableObject2(String procId, String defId)
| | protected ProcessDataDO[] | getPersistedProcessVariableObjects(String procId, String defId)
| | protected ProcessDataWOBDO[] | getPersistedProcessVariableObjects2(String procId, String defId)
| | protected ProcessDO[] | getPersistedProcesses(int type, String sqlWhere, int startAt, int limit)
| | protected ProcessRequesterDO | getPersistedRequesterObject(String procId)
| | protected ResourceDO | getPersistedResourceObject(String username)
| | protected Object | getProcessDataValue(WMSessionHandle shandle, ProcessDataDO DO)
| | protected Object | getProcessDataValue(WMSessionHandle shandle, ProcessDataWOBDO DO)
| | public List | getProcessMgrsWhere(WMSessionHandle shandle, String sqlWhere, int startAt, int limit)
| | protected ProcessRequesterDO | getProcessRequester(String procId)
| | public List | getProcessVariables(WMSessionHandle shandle, String procId, List variableIds)
| | public List | getProcessesWhere(WMSessionHandle shandle, String sqlWhere, int startAt, int limit)
| | public List | getResourceRequestersProcessIds(WMSessionHandle shandle, String resUsername)
| | public List | getResourcesWhere(WMSessionHandle shandle, String sqlWhere, int startAt, int limit)
| | protected List | getSortedVariableDOs(ProcessDataDO[] DOs)
| | protected List | getSortedVariableDOs(ProcessDataWOBDO[] DOs)
| | protected List | getSortedVariableDOs(ActivityDataDO[] DOs)
| | protected List | getSortedVariableDOs(ActivityDataWOBDO[] DOs)
| | public int | howManyAndJoinEntries(WMSessionHandle shandle, String procId, String blockActId, String aDefId)
| | protected void | initActivityAndProcessStatesTable()
Fills the state table with possible activity and process states. | | protected void | performCascadeDeletion(WMSessionHandle shandle, String procId, Map procIds)
| | public void | persist(WMSessionHandle shandle, ProcessMgrPersistenceObject pm, boolean isInitialPersistence)
| | public void | persist(WMSessionHandle shandle, ProcessPersistenceObject pr, boolean isInitialPersistence)
| | public void | persist(WMSessionHandle shandle, ActivityPersistenceObject act, boolean isInitialPersistence)
| | public void | persist(WMSessionHandle shandle, ResourcePersistenceObject res, boolean isInitialPersistence)
| | public void | persist(WMSessionHandle shandle, AssignmentPersistenceObject ass, boolean isInitialPersistence)
| | public void | persist(WMSessionHandle shandle, AssignmentPersistenceObject ass, String oldResUname)
| | public void | persist(WMSessionHandle shandle, ProcessVariablePersistenceObject var, boolean isInitialPersistence)
| | public void | persist(WMSessionHandle shandle, ActivityVariablePersistenceObject var, boolean isInitialPersistence)
| | public void | persist(WMSessionHandle shandle, AndJoinEntryPersitenceObject aje)
| | public void | persist(WMSessionHandle shandle, DeadlinePersistenceObject dpe, boolean isInitialPersistence)
| | protected void | persistVariablesBLOB(WMSessionHandle shandle, ProcessVariablePersistenceObject var, boolean isInitialPersistence)
| | protected void | persistVariablesBLOB(WMSessionHandle shandle, ProcessDataDO DO, Object vv, boolean isInitialPersistence, int ordNo)
| | protected void | persistVariablesBLOB(WMSessionHandle shandle, ActivityVariablePersistenceObject var, boolean isInitialPersistence)
| | protected void | persistVariablesBLOB(WMSessionHandle shandle, ActivityDataDO DO, Object vv, boolean isInitialPersistence, int ordNo)
| | protected void | persistVariablesWOB(WMSessionHandle shandle, ProcessVariablePersistenceObject var, boolean isInitialPersistence)
| | protected void | persistVariablesWOB(WMSessionHandle shandle, ProcessDataWOBDO DO, Object vv, boolean isInitialPersistence, int ordNo)
| | protected void | persistVariablesWOB(WMSessionHandle shandle, ActivityVariablePersistenceObject var, boolean isInitialPersistence)
| | protected void | persistVariablesWOB(WMSessionHandle shandle, ActivityDataWOBDO DO, Object vv, boolean isInitialPersistence, int ordNo)
| | protected void | refreshDOCaches()
| | protected ProcessMgrPersistenceObject | restore(WMSessionHandle shandle, ProcessDefinitionDO DO)
| | protected ProcessPersistenceObject | restore(WMSessionHandle shandle, ProcessDO DO)
| | protected ActivityPersistenceObject | restore(WMSessionHandle shandle, ActivityDO DO)
| | protected ResourcePersistenceObject | restore(WMSessionHandle shandle, ResourceDO DO)
| | protected AssignmentPersistenceObject | restore(WMSessionHandle shandle, AssignmentDO DO)
| | public boolean | restore(WMSessionHandle shandle, ProcessVariablePersistenceObject var)
| | public boolean | restore(WMSessionHandle shandle, ActivityVariablePersistenceObject var)
| | public ActivityPersistenceObject | restoreActivity(WMSessionHandle shandle, String procId, String actId)
| | public AssignmentPersistenceObject | restoreAssignment(WMSessionHandle shandle, String procId, String actId, String resUsername)
| | protected boolean | restoreBLOB(WMSessionHandle shandle, ProcessVariablePersistenceObject engineObj, ProcessDataDO[] DOs)
| | protected boolean | restoreBLOB(WMSessionHandle shandle, ActivityVariablePersistenceObject engineObj, ActivityDataDO[] DOs)
| | public ProcessPersistenceObject | restoreProcess(WMSessionHandle shandle, String procId)
| | public ProcessMgrPersistenceObject | restoreProcessMgr(WMSessionHandle shandle, String mgrName)
| | public ResourcePersistenceObject | restoreResource(WMSessionHandle shandle, String resUsername)
| | protected boolean | restoreWOB(WMSessionHandle shandle, ProcessVariablePersistenceObject engineObj, ProcessDataWOBDO[] DOs)
| | protected boolean | restoreWOB(WMSessionHandle shandle, ActivityVariablePersistenceObject engineObj, ActivityDataWOBDO[] DOs)
| | protected void | setLDBName()
| | public void | shutdownDatabase(WMSessionHandle shandle)
| | public void | synchronizeProcess(WMSessionHandle shandle, String procId)
|
| DB_TYPE_BLOB | | final protected static short DB_TYPE_BLOB(Code) | | |
| DB_TYPE_BOOLEAN | | final protected static short DB_TYPE_BOOLEAN(Code) | | |
| DB_TYPE_DATE | | final protected static short DB_TYPE_DATE(Code) | | |
| DB_TYPE_DOUBLE | | final protected static short DB_TYPE_DOUBLE(Code) | | |
| DB_TYPE_LONG | | final protected static short DB_TYPE_LONG(Code) | | |
| DB_TYPE_VCHAR | | final protected static short DB_TYPE_VCHAR(Code) | | |
| DB_TYPE_XML | | final protected static short DB_TYPE_XML(Code) | | |
| MAX_VCHAR_SIZE_LIMIT | | final protected static int MAX_VCHAR_SIZE_LIMIT(Code) | | |
| _actClosedStatesBigDecimals | | protected List _actClosedStatesBigDecimals(Code) | | |
| _actOpenStatesBigDecimals | | protected List _actOpenStatesBigDecimals(Code) | | |
| _prClosedStatesBigDecimals | | protected List _prClosedStatesBigDecimals(Code) | | |
| _prOpenStatesBigDecimals | | protected List _prOpenStatesBigDecimals(Code) | | |
| db | | protected LogicalDatabase db(Code) | | |
| deleteFinishedProcesses | | protected boolean deleteFinishedProcesses(Code) | | |
| max_vchar_size | | protected static int max_vchar_size(Code) | | |
| storeArraysAsBLOBs | | protected boolean storeArraysAsBLOBs(Code) | | |
| usingStandardVariableDataModel | | protected boolean usingStandardVariableDataModel(Code) | | |
| __getDBTransaction | | protected DBTransaction __getDBTransaction() throws Exception(Code) | | |
| getAllAssignmentsForActivity | | public List getAllAssignmentsForActivity(WMSessionHandle shandle, String procId, String actId) throws PersistenceException(Code) | | Returns all assignments that are ever created for that activity, no matter if
activity is already in "closed" state or some of its sub-states.
|
| getAllAssignmentsForResource | | public List getAllAssignmentsForResource(WMSessionHandle shandle, String resUsername) throws PersistenceException(Code) | | Returns all assignments for the resource, no matter if its activity is in "closed"
state (or some of its sub-states).
|
| getAllValidAssignmentsForActivity | | public List getAllValidAssignmentsForActivity(WMSessionHandle shandle, String procId, String actId) throws PersistenceException(Code) | | If activity is in "closed" state, or some of its sub-states, returns an empty list,
otherwise it returns either all assignments that are ever created for that activity
if activity is not accepted, or just the assignment for the resource that accepted
activity.
|
| getAllValidAssignmentsForResource | | public List getAllValidAssignmentsForResource(WMSessionHandle shandle, String resUsername) throws PersistenceException(Code) | | Returns only the assignments that can be currently executed by the resource with a
given username. This means the ones which activity is not finished and not accepted
(it doesn't have TheResource field set), and the ones which activity is accepted by
this resource (its TheResource field is set to the resource with given username).
|
| getPersistedActivities | | protected ActivityDO[] getPersistedActivities(int type, ProcessDO pDO, String sqlWhere, int startAt, int limit) throws PersistenceException(Code) | | |
| getPersistedActivityStateObject | | protected ActivityStateDO getPersistedActivityStateObject(String value, boolean searchByKeyValue, DBTransaction ti) throws PersistenceException(Code) | | |
| getPersistedActivityVariableBLOBObject | | protected ActivityDataBLOBDO getPersistedActivityVariableBLOBObject(ActivityDataWOBDO adDO) throws PersistenceException(Code) | | |
| getPersistedProcessStateObject | | protected ProcessStateDO getPersistedProcessStateObject(String value, boolean searchByKeyValue, DBTransaction ti) throws PersistenceException(Code) | | |
| getPersistedProcessVariableBLOBObject | | protected ProcessDataBLOBDO getPersistedProcessVariableBLOBObject(ProcessDataWOBDO pdDO) throws PersistenceException(Code) | | |
| getSortedVariableDOs | | protected List getSortedVariableDOs(ProcessDataDO[] DOs) throws Throwable(Code) | | |
| getSortedVariableDOs | | protected List getSortedVariableDOs(ProcessDataWOBDO[] DOs) throws Throwable(Code) | | |
| getSortedVariableDOs | | protected List getSortedVariableDOs(ActivityDataDO[] DOs) throws Throwable(Code) | | |
| getSortedVariableDOs | | protected List getSortedVariableDOs(ActivityDataWOBDO[] DOs) throws Throwable(Code) | | |
| initActivityAndProcessStatesTable | | protected void initActivityAndProcessStatesTable() throws PersistenceException(Code) | | Fills the state table with possible activity and process states. For now, the
'keyValue' and the 'name' attribute of state record has the same value, but in the
future, if the names of states changes, it will be very easy to change this table
entries without affecting other tables. NOTE: When new names are introduced, the
getPersistentXXX that use it also has to be changed
|
| setLDBName | | protected void setLDBName()(Code) | | |
|
|