org.jberet.repository

Class JdbcRepository

java.lang.Object

org.jberet.repository.AbstractRepository

org.jberet.repository.AbstractPersistentRepository

org.jberet.repository.JdbcRepository

All Implemented Interfaces:

JobRepository

public final class JdbcRepository
extends AbstractPersistentRepository

Field Summary

Fields

Modifier and Type	Field and Description
static String	DATASOURCE_JNDI_KEY
static String	DB_PASSWORD_KEY
static String	DB_PROPERTIES_KEY
static String	DB_PROPERTY_DELIM
static String	DB_TABLE_PREFIX_KEY
static String	DB_TABLE_SUFFIX_KEY
static String	DB_URL_KEY
static String	DB_USER_KEY
static String	DDL_FILE_NAME_KEY
static String	SQL_FILE_NAME_KEY

Constructor Summary

Constructors

Constructor and Description
JdbcRepository(DataSource dataSource) Creates a new JDBC job repository.
JdbcRepository(DataSource dataSource, Properties configProperties) Creates a new JDBC job repository.
JdbcRepository(Properties configProperties)

Method Summary

Modifier and Type	Method and Description
void	addPartitionExecution(StepExecutionImpl enclosingStepExecution, PartitionExecutionImpl partitionExecution)
int	countStepStartTimes(String stepName, long jobInstanceId)
static JdbcRepository	create(Properties configProperties)
void	executeStatements(String statements, String statementsResourcePath) Executes a series of sql statements.
StepExecutionImpl	findOriginalStepExecutionForRestart(String stepName, JobExecutionImpl jobExecutionToRestart, ClassLoader classLoader)
JobExecutionImpl	getJobExecution(long jobExecutionId)
List<javax.batch.runtime.JobExecution>	getJobExecutions(javax.batch.runtime.JobInstance jobInstance)
JobInstanceImpl	getJobInstance(long jobInstanceId)
int	getJobInstanceCount(String jobName)
List<javax.batch.runtime.JobInstance>	getJobInstances(String jobName)
List<PartitionExecutionImpl>	getPartitionExecutions(long stepExecutionId, StepExecutionImpl stepExecution, boolean notCompletedOnly, ClassLoader classLoader)
List<Long>	getRunningExecutions(String jobName) Gets the ids of running job executions belonging to a specific job.
void	savePersistentData(javax.batch.runtime.JobExecution jobExecution, AbstractStepExecution stepOrPartitionExecution)
void	updateJobExecution(JobExecutionImpl jobExecution, boolean fullUpdate, boolean saveJobParameters)
void	updateStepExecution(javax.batch.runtime.StepExecution stepExecution)

Methods inherited from class org.jberet.repository.AbstractPersistentRepository

createJobExecution, createJobInstance, getStepExecutions, removeJob, removeJobExecutions, removeJobInstance

Methods inherited from class org.jberet.repository.AbstractRepository

addJob, addStepExecution, createStepExecution, getJob, getJobNames, jobExists

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jberet.repository.JobRepository

addJob, addStepExecution, createStepExecution, getJob, getJobNames, jobExists

Field Detail

DDL_FILE_NAME_KEY

public static final String DDL_FILE_NAME_KEY

See Also:

Constant Field Values

SQL_FILE_NAME_KEY

public static final String SQL_FILE_NAME_KEY

See Also:

Constant Field Values

DATASOURCE_JNDI_KEY

public static final String DATASOURCE_JNDI_KEY

See Also:

Constant Field Values

DB_URL_KEY

public static final String DB_URL_KEY

See Also:

Constant Field Values

DB_USER_KEY

public static final String DB_USER_KEY

See Also:

Constant Field Values

DB_PASSWORD_KEY

public static final String DB_PASSWORD_KEY

See Also:

Constant Field Values

DB_PROPERTIES_KEY

public static final String DB_PROPERTIES_KEY

See Also:

Constant Field Values

DB_PROPERTY_DELIM

public static final String DB_PROPERTY_DELIM

See Also:

Constant Field Values

DB_TABLE_PREFIX_KEY

public static final String DB_TABLE_PREFIX_KEY

See Also:

Constant Field Values

DB_TABLE_SUFFIX_KEY

public static final String DB_TABLE_SUFFIX_KEY

See Also:

Constant Field Values

Constructor Detail

JdbcRepository

public JdbcRepository(Properties configProperties)

JdbcRepository

public JdbcRepository(DataSource dataSource)

Creates a new JDBC job repository.

Parameters:

dataSource - the data source used to connect to the database

JdbcRepository

public JdbcRepository(DataSource dataSource,
                      Properties configProperties)

Creates a new JDBC job repository.

Parameters:

dataSource - the data source used to connect to the database

configProperties - the configuration properties to use

Method Detail

create

public static JdbcRepository create(Properties configProperties)

getJobInstances

public List<javax.batch.runtime.JobInstance> getJobInstances(String jobName)

getJobInstance

public JobInstanceImpl getJobInstance(long jobInstanceId)

Specified by:

getJobInstance in interface JobRepository

Overrides:

getJobInstance in class AbstractPersistentRepository

getJobInstanceCount

public int getJobInstanceCount(String jobName)

updateJobExecution

public void updateJobExecution(JobExecutionImpl jobExecution,
                               boolean fullUpdate,
                               boolean saveJobParameters)

Specified by:

updateJobExecution in interface JobRepository

Overrides:

updateJobExecution in class AbstractRepository

getJobExecution

public JobExecutionImpl getJobExecution(long jobExecutionId)

Specified by:

getJobExecution in interface JobRepository

Overrides:

getJobExecution in class AbstractPersistentRepository

getJobExecutions

public List<javax.batch.runtime.JobExecution> getJobExecutions(javax.batch.runtime.JobInstance jobInstance)

getRunningExecutions

public List<Long> getRunningExecutions(String jobName)

Description copied from interface: JobRepository

Gets the ids of running job executions belonging to a specific job.

Parameters:

jobName - the name of the job, not null

Returns:

a list of job execution ids

See Also:

AbstractJobOperator.getRunningExecutions(java.lang.String)

updateStepExecution

public void updateStepExecution(javax.batch.runtime.StepExecution stepExecution)

savePersistentData

public void savePersistentData(javax.batch.runtime.JobExecution jobExecution,
                               AbstractStepExecution stepOrPartitionExecution)

Specified by:

savePersistentData in interface JobRepository

Overrides:

savePersistentData in class AbstractRepository

addPartitionExecution

public void addPartitionExecution(StepExecutionImpl enclosingStepExecution,
                                  PartitionExecutionImpl partitionExecution)

Specified by:

addPartitionExecution in interface JobRepository

Overrides:

addPartitionExecution in class AbstractRepository

findOriginalStepExecutionForRestart

public StepExecutionImpl findOriginalStepExecutionForRestart(String stepName,
                                                             JobExecutionImpl jobExecutionToRestart,
                                                             ClassLoader classLoader)

Specified by:

findOriginalStepExecutionForRestart in interface JobRepository

Overrides:

findOriginalStepExecutionForRestart in class AbstractPersistentRepository

getPartitionExecutions

public List<PartitionExecutionImpl> getPartitionExecutions(long stepExecutionId,
                                                           StepExecutionImpl stepExecution,
                                                           boolean notCompletedOnly,
                                                           ClassLoader classLoader)

Specified by:

getPartitionExecutions in interface JobRepository

Overrides:

getPartitionExecutions in class AbstractRepository

countStepStartTimes

public int countStepStartTimes(String stepName,
                               long jobInstanceId)

executeStatements

public void executeStatements(String statements,
                              String statementsResourcePath)
                       throws SQLException

Executes a series of sql statements.

Parameters:

statements - sql statements as string separated with ; character; not null unless statementsResourcePath is present.

statementsResourcePath - loadable resource path to obtain sql statements. Ignored when statements is present.

Throws:

SQLException