public class JdbcAggregateJobQueryDao extends Object implements AggregateJobQueryDao
JdbcJobExecutionDao
but contains Spring Cloud Data Flow specific operations. This functionality might
be migrated to Spring Batch itself eventually.Constructor and Description |
---|
JdbcAggregateJobQueryDao(DataSource dataSource,
org.springframework.cloud.dataflow.schema.service.SchemaService schemaService,
JobServiceContainer jobServiceContainer,
Environment environment) |
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) |
public JdbcAggregateJobQueryDao(DataSource dataSource, org.springframework.cloud.dataflow.schema.service.SchemaService schemaService, JobServiceContainer jobServiceContainer, Environment environment) throws Exception
Exception
public org.springframework.data.domain.Page<JobInstanceExecutions> listJobInstances(String jobName, org.springframework.data.domain.Pageable pageable) throws org.springframework.batch.core.launch.NoSuchJobException
listJobInstances
in interface AggregateJobQueryDao
org.springframework.batch.core.launch.NoSuchJobException
public JobInstanceExecutions getJobInstanceExecution(String jobName, long instanceId)
getJobInstanceExecution
in interface AggregateJobQueryDao
public JobInstanceExecutions getJobInstanceExecutions(long jobInstanceId, String schemaTarget)
getJobInstanceExecutions
in interface AggregateJobQueryDao
public org.springframework.batch.core.JobInstance getJobInstance(long id, String schemaTarget) throws org.springframework.batch.core.launch.NoSuchJobInstanceException
getJobInstance
in interface AggregateJobQueryDao
org.springframework.batch.core.launch.NoSuchJobInstanceException
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
listJobExecutions
in interface AggregateJobQueryDao
org.springframework.batch.core.launch.NoSuchJobExecutionException
public org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsBetween(Date fromDate, Date toDate, org.springframework.data.domain.Pageable pageable)
listJobExecutionsBetween
in interface AggregateJobQueryDao
public org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsWithSteps(org.springframework.data.domain.Pageable pageable)
listJobExecutionsWithSteps
in interface AggregateJobQueryDao
public org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsWithStepCount(org.springframework.data.domain.Pageable pageable)
listJobExecutionsWithStepCount
in interface AggregateJobQueryDao
public org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsForJobWithStepCountFilteredByJobInstanceId(int jobInstanceId, String schemaTarget, org.springframework.data.domain.Pageable pageable)
listJobExecutionsForJobWithStepCountFilteredByJobInstanceId
in interface AggregateJobQueryDao
public org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsForJobWithStepCountFilteredByTaskExecutionId(int taskExecutionId, String schemaTarget, org.springframework.data.domain.Pageable pageable)
listJobExecutionsForJobWithStepCountFilteredByTaskExecutionId
in interface AggregateJobQueryDao
public org.springframework.data.domain.Page<TaskJobExecution> listJobExecutionsForJobWithStepCount(String jobName, org.springframework.data.domain.Pageable pageable) throws org.springframework.batch.core.launch.NoSuchJobException
listJobExecutionsForJobWithStepCount
in interface AggregateJobQueryDao
org.springframework.batch.core.launch.NoSuchJobException
public TaskJobExecution getJobExecution(long jobExecutionId, String schemaTarget) throws org.springframework.batch.core.launch.NoSuchJobExecutionException
getJobExecution
in interface AggregateJobQueryDao
org.springframework.batch.core.launch.NoSuchJobExecutionException
public List<TaskJobExecution> getJobExecutionsWithStepCount(int start, int count)
protected org.springframework.batch.core.JobParameters getJobParameters(Long executionId, String schemaTarget)
Copyright © 2024 Pivotal Software, Inc.. All rights reserved.