Package de.hybris.platform.task.impl
Class TaskDAO
java.lang.Object
de.hybris.platform.task.impl.TaskDAO
- Direct Known Subclasses:
TaskDAOLockingTest.MockTaskDAO
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected StringfetchAllRunningProcessTask(Set<PK> tasksToCheck) protected Stringprotected StringgetColumnName(String column, Class clazz) protected Stringprotected Stringprotected Stringprotected Stringprotected Stringprotected DataSourceprotected Stringprotected StringgetTableName(Class clazz) protected Stringprotected intprotected voidinvalidateCache(String uniqueID) voidprotected int
-
Constructor Details
-
TaskDAO
-
-
Method Details
-
initializeClusterId
protected int initializeClusterId() -
getDataSource
-
getConditionFetchQuery
-
getConditionFulfillQuery
-
getConditionWithChoiceFulfillQuery
-
getConditionConsumeQuery
-
getConditionMatchQuery
-
getLockQuery
-
getUnlockQuery
-
allRunningProcessTaskQuery
-
getAllProcessTaskQuery
-
unlock
-
fetchAllRunningProcessTask
- Parameters:
tasksToCheck-- Returns:
- list of task PKs which are passed in the tasksToCheck param and are present on the DB and have runningColumn that matches tenant's clusterID
-
invalidateCache
-
update
protected int update(String upQuery, Object[] params) throws org.springframework.dao.DataAccessException - Throws:
org.springframework.dao.DataAccessException
-
getTableName
-
getColumnName
-