Package org.springframework.cloud.dataflow.server.repository

Class JdbcDataflowTaskExecutionDao

java.lang.Object
org.springframework.cloud.dataflow.server.repository.JdbcDataflowTaskExecutionDao
All Implemented Interfaces:
DataflowTaskExecutionDao
public class JdbcDataflowTaskExecutionDao extends Object implements DataflowTaskExecutionDao
Manages Task Execution information using a JDBC DataSource. Mirrors the JdbcTaskExecutionDao but contains Spring Cloud Data Flow specific operations. This functionality might be migrated to Spring Cloud Task itself eventually.
Author:
Gunnar Hillert, Glenn Renfro, Ilayaperumal Gopinathan, Corneil du Plessis

  • Constructor Details

    • JdbcDataflowTaskExecutionDao

      public JdbcDataflowTaskExecutionDao(DataSource dataSource, org.springframework.cloud.task.configuration.TaskProperties taskProperties)
      Parameters:
      dataSource - used by the dao to execute queries and updates the tables.
      taskProperties - the TaskProperties to use for this dao.

  • Method Details

    • deleteTaskExecutionsByTaskExecutionIds

      public int deleteTaskExecutionsByTaskExecutionIds(Set<Long> taskExecutionIds)
      Description copied from interface: DataflowTaskExecutionDao
      Deletes 1 or more task executions
      Specified by:
      deleteTaskExecutionsByTaskExecutionIds in interface DataflowTaskExecutionDao
      Parameters:
      taskExecutionIds - Must contain at least 1 taskExecutionId
      Returns:
      The number of affected records

    • deleteTaskExecutionParamsByTaskExecutionIds

      public int deleteTaskExecutionParamsByTaskExecutionIds(Set<Long> taskExecutionIds)
      Description copied from interface: DataflowTaskExecutionDao
      Deletes 1 or more task execution parameter records.
      Specified by:
      deleteTaskExecutionParamsByTaskExecutionIds in interface DataflowTaskExecutionDao
      Parameters:
      taskExecutionIds - Must contain at least 1 taskExecutionId
      Returns:
      The number of affected records

    • deleteTaskTaskBatchRelationshipsByTaskExecutionIds

      public int deleteTaskTaskBatchRelationshipsByTaskExecutionIds(Set<Long> taskExecutionIds)
      Description copied from interface: DataflowTaskExecutionDao
      Deletes 1 or more task batch relationship records that links batch executions to task executions.
      Specified by:
      deleteTaskTaskBatchRelationshipsByTaskExecutionIds in interface DataflowTaskExecutionDao
      Parameters:
      taskExecutionIds - Must contain at least 1 taskExecutionId
      Returns:
      The number of affected records

    • findChildTaskExecutionIds

      public Set<Long> findChildTaskExecutionIds(Set<Long> taskExecutionIds)
      Description copied from interface: DataflowTaskExecutionDao
      Finds all the child tasks for the taskExecution that is provided.
      Specified by:
      findChildTaskExecutionIds in interface DataflowTaskExecutionDao
      Parameters:
      taskExecutionIds - The ids to theTaskExecutions to be searched
      Returns:
      a list of child TaskExecutions that correspond to the TaskExecutions passed.

    • getTaskExecutionIdsByTaskName

      public Set<Long> getTaskExecutionIdsByTaskName(String taskName)
      Description copied from interface: DataflowTaskExecutionDao
      Returns the Set of task execution IDs by the given task name.
      Specified by:
      getTaskExecutionIdsByTaskName in interface DataflowTaskExecutionDao
      Parameters:
      taskName - the task name
      Returns:
      the Set of task execution IDs

    • getAllTaskExecutionsCount

      public Integer getAllTaskExecutionsCount(boolean onlyCompleted, String taskName)
      Description copied from interface: DataflowTaskExecutionDao
      Returns the size of all the task executions with the option to include only the completed executions.
      Specified by:
      getAllTaskExecutionsCount in interface DataflowTaskExecutionDao
      Parameters:
      onlyCompleted - filter by completed task executions
      taskName - the task name, if null then retrieve all the tasks
      Returns:
      The count of task executions matching inputs.

    • getAllTaskExecutionIds

      public Set<Long> getAllTaskExecutionIds(boolean onlyCompleted, String taskName)
      Description copied from interface: DataflowTaskExecutionDao
      Returns all the task execution IDs of the completed task executions.
      Specified by:
      getAllTaskExecutionIds in interface DataflowTaskExecutionDao
      Parameters:
      onlyCompleted - filter by completed task executions
      taskName - the task name, if null then retrieve all the tasks
      Returns:
      The set of all execution ids matching inputs.