org.springframework.cloud.dataflow.server.repository

Class JdbcAggregateJobQueryDao

java.lang.Object

org.springframework.cloud.dataflow.server.repository.JdbcAggregateJobQueryDao

All Implemented Interfaces:

AggregateJobQueryDao

public class JdbcAggregateJobQueryDao
extends Object
implements AggregateJobQueryDao

Stores job execution information to a JDBC DataSource. Mirrors the JdbcJobExecutionDao but contains Spring Cloud Data Flow specific operations. This functionality might be migrated to Spring Batch itself eventually.

Author:

Gunnar Hillert, Corneil du Plessis

Constructor Summary

Constructors

Constructor and Description
JdbcAggregateJobQueryDao(DataSource dataSource, org.springframework.cloud.dataflow.schema.service.SchemaService schemaService, JobServiceContainer jobServiceContainer)

Method Summary

Modifier and Type	Method and Description
TaskJobExecution	getJobExecution(long jobExecutionId, String schemaTarget)
List<TaskJobExecution>	getJobExecutionsWithStepCount(int start, int count)
JobInstanceExecutions	getJobInstanceExecution(String jobName, long instanceId)
JobInstanceExecutions	getJobInstanceExecutions(long jobInstanceId, String schemaTarget)
protected org.springframework.batch.core.JobParameters	getJobParameters(Long executionId, String schemaTarget)
protected String	getQuery(String base, String tablePrefix)
org.springframework.data.domain.Page<TaskJobExecution>	listJobExecutions(String jobName, org.springframework.batch.core.BatchStatus status, org.springframework.data.domain.Pageable pageable)
org.springframework.data.domain.Page<TaskJobExecution>	listJobExecutionsBetween(Date fromDate, Date toDate, org.springframework.data.domain.Pageable pageable)
org.springframework.data.domain.Page<TaskJobExecution>	listJobExecutionsForJobWithStepCount(String jobName, org.springframework.data.domain.Pageable pageable)
org.springframework.data.domain.Page<TaskJobExecution>	listJobExecutionsForJobWithStepCountFilteredByJobInstanceId(int jobInstanceId, String schemaTarget, org.springframework.data.domain.Pageable pageable)
org.springframework.data.domain.Page<TaskJobExecution>	listJobExecutionsForJobWithStepCountFilteredByTaskExecutionId(int taskExecutionId, String schemaTarget, org.springframework.data.domain.Pageable pageable)
org.springframework.data.domain.Page<TaskJobExecution>	listJobExecutionsWithStepCount(org.springframework.data.domain.Pageable pageable)
org.springframework.data.domain.Page<TaskJobExecution>	listJobExecutionsWithSteps(org.springframework.data.domain.Pageable pageable)
org.springframework.data.domain.Page<JobInstanceExecutions>	listJobInstances(String jobName, org.springframework.data.domain.Pageable pageable)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JdbcAggregateJobQueryDao

public JdbcAggregateJobQueryDao(DataSource dataSource,
                                org.springframework.cloud.dataflow.schema.service.SchemaService schemaService,
                                JobServiceContainer jobServiceContainer)
                         throws Exception

Throws:

Exception

Method Detail

listJobInstances

public org.springframework.data.domain.Page<JobInstanceExecutions> listJobInstances(String jobName,
                                                                                    org.springframework.data.domain.Pageable pageable)

Specified by:

listJobInstances in interface AggregateJobQueryDao

getJobInstanceExecution

public JobInstanceExecutions getJobInstanceExecution(String jobName,
                                                     long instanceId)

Specified by:

getJobInstanceExecution in interface AggregateJobQueryDao

getJobInstanceExecutions

public JobInstanceExecutions getJobInstanceExecutions(long jobInstanceId,
                                                      String schemaTarget)

Specified by:

getJobInstanceExecutions in interface AggregateJobQueryDao

listJobExecutions

public org.springframework.data.domain.Page<TaskJobExecution> listJobExecutions(String jobName,
                                                                                org.springframework.batch.core.BatchStatus status,
                                                                                org.springframework.data.domain.Pageable pageable)
                                                                         throws org.springframework.batch.core.launch.NoSuchJobExecutionException

Specified by:

listJobExecutions in interface AggregateJobQueryDao

Throws:

org.springframework.batch.core.launch.NoSuchJobExecutionException

listJobExecutionsBetween

public org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsBetween(Date fromDate,
                                                                                       Date toDate,
                                                                                       org.springframework.data.domain.Pageable pageable)

Specified by:

listJobExecutionsBetween in interface AggregateJobQueryDao

listJobExecutionsWithSteps

public org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsWithSteps(org.springframework.data.domain.Pageable pageable)

Specified by:

listJobExecutionsWithSteps in interface AggregateJobQueryDao

listJobExecutionsWithStepCount

public org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsWithStepCount(org.springframework.data.domain.Pageable pageable)

Specified by:

listJobExecutionsWithStepCount in interface AggregateJobQueryDao

listJobExecutionsForJobWithStepCountFilteredByJobInstanceId

public org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsForJobWithStepCountFilteredByJobInstanceId(int jobInstanceId,
                                                                                                                          String schemaTarget,
                                                                                                                          org.springframework.data.domain.Pageable pageable)

Specified by:

listJobExecutionsForJobWithStepCountFilteredByJobInstanceId in interface AggregateJobQueryDao

listJobExecutionsForJobWithStepCountFilteredByTaskExecutionId

public org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsForJobWithStepCountFilteredByTaskExecutionId(int taskExecutionId,
                                                                                                                            String schemaTarget,
                                                                                                                            org.springframework.data.domain.Pageable pageable)

Specified by:

listJobExecutionsForJobWithStepCountFilteredByTaskExecutionId in interface AggregateJobQueryDao

listJobExecutionsForJobWithStepCount

public org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsForJobWithStepCount(String jobName,
                                                                                                   org.springframework.data.domain.Pageable pageable)
                                                                                            throws org.springframework.batch.core.launch.NoSuchJobException

Specified by:

listJobExecutionsForJobWithStepCount in interface AggregateJobQueryDao

Throws:

org.springframework.batch.core.launch.NoSuchJobException

getJobExecution

public TaskJobExecution getJobExecution(long jobExecutionId,
                                        String schemaTarget)
                                 throws org.springframework.batch.core.launch.NoSuchJobExecutionException

Specified by:

getJobExecution in interface AggregateJobQueryDao

Throws:

org.springframework.batch.core.launch.NoSuchJobExecutionException

getJobExecutionsWithStepCount

public List<TaskJobExecution> getJobExecutionsWithStepCount(int start,
                                                            int count)

getJobParameters

protected org.springframework.batch.core.JobParameters getJobParameters(Long executionId,
                                                                        String schemaTarget)

getQuery

protected String getQuery(String base,
                          String tablePrefix)