|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.springframework.batch.core.repository.dao.AbstractJdbcBatchMetadataDao
org.springframework.batch.core.repository.dao.JdbcJobInstanceDao
public class JdbcJobInstanceDao
Jdbc implementation of JobInstanceDao. Uses sequences (via Spring's
DataFieldMaxValueIncrementer abstraction) to create all primary keys
before inserting a new row. Objects are checked to ensure all mandatory
fields to be stored are not null. If any are found to be null, an
IllegalArgumentException will be thrown. This could be left to JdbcTemplate,
however, the exception will be fairly vague, and fails to highlight which
field caused the exception.
| Field Summary |
|---|
| Fields inherited from class org.springframework.batch.core.repository.dao.AbstractJdbcBatchMetadataDao |
|---|
DEFAULT_EXIT_MESSAGE_LENGTH, DEFAULT_TABLE_PREFIX |
| Constructor Summary | |
|---|---|
JdbcJobInstanceDao()
|
|
| Method Summary | |
|---|---|
void |
afterPropertiesSet()
|
JobInstance |
createJobInstance(java.lang.String jobName,
JobParameters jobParameters)
In this jdbc implementation a job id is obtained by asking the jobIncrementer (which is likely a sequence) for the next long value, and then passing the Id and parameter values into an INSERT statement. |
protected java.lang.String |
createJobKey(JobParameters jobParameters)
|
JobInstance |
getJobInstance(JobExecution jobExecution)
Fetch the JobInstance for the provided JobExecution. |
JobInstance |
getJobInstance(java.lang.Long instanceId)
Fetch the job instance with the provided identifier. |
JobInstance |
getJobInstance(java.lang.String jobName,
JobParameters jobParameters)
The job table is queried for any jobs that match the given identifier, adding them to a list via the RowMapper callback. |
java.util.List<JobInstance> |
getJobInstances(java.lang.String jobName,
int start,
int count)
Fetch the last job instances with the provided name, sorted backwards by primary key. |
java.util.List<java.lang.String> |
getJobNames()
Retrieve the names of all job instances sorted alphabetically - i.e. |
void |
setJobIncrementer(org.springframework.jdbc.support.incrementer.DataFieldMaxValueIncrementer jobIncrementer)
Setter for DataFieldMaxValueIncrementer to be used when
generating primary keys for JobInstance instances. |
| Methods inherited from class org.springframework.batch.core.repository.dao.AbstractJdbcBatchMetadataDao |
|---|
getClobTypeToUse, getJdbcTemplate, getQuery, getTablePrefix, setClobTypeToUse, setJdbcTemplate, setTablePrefix |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public JdbcJobInstanceDao()
| Method Detail |
|---|
public JobInstance createJobInstance(java.lang.String jobName,
JobParameters jobParameters)
createJobInstance in interface JobInstanceDaojava.lang.IllegalArgumentException - if any JobParameters fields are null.JobInstanceDao.createJobInstance(String, JobParameters)protected java.lang.String createJobKey(JobParameters jobParameters)
public JobInstance getJobInstance(java.lang.String jobName,
JobParameters jobParameters)
getJobInstance in interface JobInstanceDaojobName - the name of the jobjobParameters - the parameters with which the job was executed
JobInstance object matching the job name and
JobParameters or null
java.lang.IllegalArgumentException - if any JobParameters fields are null.JobInstanceDao.getJobInstance(String, JobParameters)public JobInstance getJobInstance(java.lang.Long instanceId)
JobInstanceDao
getJobInstance in interface JobInstanceDaoinstanceId - the job identifier
public java.util.List<java.lang.String> getJobNames()
JobInstanceDao
getJobNames in interface JobInstanceDao
public java.util.List<JobInstance> getJobInstances(java.lang.String jobName,
int start,
int count)
JobInstanceDao
getJobInstances in interface JobInstanceDaojobName - the job namestart - the start index of the instances to returncount - the maximum number of objects to return
public JobInstance getJobInstance(JobExecution jobExecution)
JobInstanceDao
getJobInstance in interface JobInstanceDaojobExecution - the JobExecution
public void setJobIncrementer(org.springframework.jdbc.support.incrementer.DataFieldMaxValueIncrementer jobIncrementer)
DataFieldMaxValueIncrementer to be used when
generating primary keys for JobInstance instances.
jobIncrementer - the DataFieldMaxValueIncrementer
public void afterPropertiesSet()
throws java.lang.Exception
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanafterPropertiesSet in class AbstractJdbcBatchMetadataDaojava.lang.Exception
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||