org.jberet.repository

Class MongoRepository

java.lang.Object

org.jberet.repository.AbstractRepository

org.jberet.repository.AbstractPersistentRepository

org.jberet.repository.MongoRepository

All Implemented Interfaces:

JobRepository

public final class MongoRepository
extends AbstractPersistentRepository

Constructor Summary

Constructors

Constructor and Description
MongoRepository(Properties configProperties)

Method Summary

Modifier and Type	Method and Description
void	addPartitionExecution(StepExecutionImpl enclosingStepExecution, PartitionExecutionImpl partitionExecution)
int	countStepStartTimes(String stepName, long jobInstanceId)
static MongoRepository	create(Properties configProperties)
void	executeRemoveQueries(String removeQueries) Executes MongoDB remove queries.
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

Constructor Detail

MongoRepository

public MongoRepository(Properties configProperties)

Method Detail

create

public static MongoRepository 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)

executeRemoveQueries

public void executeRemoveQueries(String removeQueries)

Executes MongoDB remove queries.

Parameters:

removeQueries - a series of remove queries delimited by semi-colon (;). For example, db.PARTITION_EXECUTION.remove({ STEPEXECUTIONID: { $gt: 100 } }); db.STEP_EXECUTION.remove({ STEPEXECUTIONID: { $gt: 100 } }); db.JOB_EXECUTION.remove({ JOBEXECUTIONID: { $gt: 10 } }); db.JOB_INSTANCE.remove({ JOBINSTANCEID: { $gt: 10 } })