Class TaskDAO

java.lang.Object
de.hybris.platform.task.impl.TaskDAO
Direct Known Subclasses:
TaskDAOLockingTest.MockTaskDAO

public class TaskDAO extends Object
  • Constructor Details

    • TaskDAO

      public TaskDAO(Tenant t)
  • Method Details

    • initializeClusterId

      protected int initializeClusterId()
    • getDataSource

      protected DataSource getDataSource()
    • getConditionFetchQuery

      protected String getConditionFetchQuery()
    • getConditionFulfillQuery

      protected String getConditionFulfillQuery()
    • getConditionWithChoiceFulfillQuery

      protected String getConditionWithChoiceFulfillQuery()
    • getConditionConsumeQuery

      protected String getConditionConsumeQuery()
    • getConditionMatchQuery

      protected String getConditionMatchQuery()
    • getLockQuery

      protected String getLockQuery()
    • getUnlockQuery

      protected String getUnlockQuery()
    • allRunningProcessTaskQuery

      protected String allRunningProcessTaskQuery()
    • getAllProcessTaskQuery

      protected String getAllProcessTaskQuery()
    • unlock

      public void unlock(Long pk)
    • fetchAllRunningProcessTask

      public List<PK> fetchAllRunningProcessTask(Set<PK> tasksToCheck)
      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

      protected void invalidateCache(String uniqueID)
    • update

      protected int update(String upQuery, Object[] params) throws org.springframework.dao.DataAccessException
      Throws:
      org.springframework.dao.DataAccessException
    • getTableName

      protected String getTableName(Class clazz)
    • getColumnName

      protected String getColumnName(String column, Class clazz)