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.

Since:

2.11.0

Author:

Corneil du Plessis

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
TaskJobExecution	getJobExecution(long jobExecutionId, String schemaTarget)
List<TaskJobExecution>	getJobExecutionsWithStepCount(int start, int count)
org.springframework.batch.core.JobInstance	getJobInstance(long id, String schemaTarget)
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)
void	populateCtrStatus(Collection<org.springframework.cloud.dataflow.schema.AggregateTaskExecution> aggregateTaskExecutions)

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,
                                Environment environment)
                         throws Exception

Throws:

Exception

Method Detail

listJobInstances

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

Specified by:

listJobInstances in interface AggregateJobQueryDao

Throws:

org.springframework.batch.core.launch.NoSuchJobException

populateCtrStatus

public void populateCtrStatus(Collection<org.springframework.cloud.dataflow.schema.AggregateTaskExecution> aggregateTaskExecutions)

Specified by:

populateCtrStatus 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

getJobInstance

public org.springframework.batch.core.JobInstance getJobInstance(long id,
                                                                 String schemaTarget)
                                                          throws org.springframework.batch.core.launch.NoSuchJobInstanceException

Specified by:

getJobInstance in interface AggregateJobQueryDao

Throws:

org.springframework.batch.core.launch.NoSuchJobInstanceException

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)