public class JDBCPersistenceManagerService extends Object implements PersistenceManagerService
PersistenceManagerService.TimestampType
Modifier and Type | Field and Description |
---|---|
protected DataSource |
dataSource |
protected String |
driver |
protected String |
jndiName |
protected String |
pwd |
protected String |
schema |
protected String |
url |
protected String |
user |
Constructor and Description |
---|
JDBCPersistenceManagerService() |
Modifier and Type | Method and Description |
---|---|
void |
cleanUp(Date until) |
void |
cleanUp(long instanceId) |
void |
createCheckpointData(CheckpointDataKey key,
CheckpointData value) |
RuntimeFlowInSplitExecution |
createFlowInSplitExecution(javax.batch.runtime.JobInstance jobInstance,
javax.batch.runtime.BatchStatus batchStatus) |
RuntimeJobExecution |
createJobExecution(javax.batch.runtime.JobInstance jobInstance,
Properties jobParameters,
javax.batch.runtime.BatchStatus batchStatus)
Create a JobExecution
|
javax.batch.runtime.JobInstance |
createJobInstance(String name,
String jobXml)
Creates a JobIntance
|
JobStatus |
createJobStatus(long jobInstanceId)
Create a JobStatus
|
StepExecutionImpl |
createStepExecution(long rootJobExecId,
StepContextImpl stepContext)
Create a StepExecution
|
StepStatus |
createStepStatus(long stepExecId)
Create a StepStatus
|
javax.batch.runtime.JobInstance |
createSubJobInstance(String name) |
CheckpointData |
getCheckpointData(CheckpointDataKey key) |
protected Connection |
getConnection() |
protected Connection |
getConnectionToDefaultSchema() |
long |
getJobInstanceIdByExecutionId(long executionId) |
Set<String> |
getJobNames() |
JobStatus |
getJobStatus(long instanceId)
Get a JobStatus
|
JobStatus |
getJobStatusFromExecution(long executionId) |
long |
getMostRecentExecutionId(long jobInstanceId) |
Properties |
getParameters(long executionId) |
javax.batch.runtime.StepExecution |
getStepExecutionByStepExecutionId(long stepExecId) |
List<javax.batch.runtime.StepExecution> |
getStepExecutionsForJobExecution(long execid) |
StepStatus |
getStepStatus(long instanceId,
String stepName)
Get a StepStatus
The parent job instance id and this step name from the job xml
are used to determine if the current step execution have previously run.
|
void |
init(Properties batchConfig) |
InternalJobExecution |
jobOperatorGetJobExecution(long jobExecutionId) |
List<InternalJobExecution> |
jobOperatorGetJobExecutions(long jobInstanceId) |
int |
jobOperatorGetJobInstanceCount(String jobName)
JOB OPERATOR ONLY METHODS
|
List<Long> |
jobOperatorGetJobInstanceIds(String jobName,
int start,
int count) |
Set<Long> |
jobOperatorGetRunningExecutions(String jobName) |
String |
jobOperatorQueryJobExecutionBatchStatus(long key) |
String |
jobOperatorQueryJobExecutionExitStatus(long key) |
Timestamp |
jobOperatorQueryJobExecutionTimestamp(long key,
PersistenceManagerService.TimestampType timestampType) |
void |
markJobStarted(long key,
Timestamp startTS) |
void |
setCheckpointData(CheckpointDataKey key,
CheckpointData value) |
String |
toString() |
void |
updateBatchStatusOnly(long key,
javax.batch.runtime.BatchStatus batchStatus,
Timestamp updatets) |
void |
updateJobStatus(long instanceId,
JobStatus jobStatus)
Update a JobStatus
|
void |
updateStepExecution(long rootJobExecId,
StepContextImpl stepContext)
Update a StepExecution
|
void |
updateStepStatus(long stepExecutionId,
StepStatus stepStatus)
Update a StepStatus
|
void |
updateWithFinalExecutionStatusesAndTimestamps(long key,
javax.batch.runtime.BatchStatus batchStatus,
String exitStatus,
Timestamp updatets) |
protected DataSource dataSource
protected String jndiName
protected String driver
protected String schema
protected String url
protected String user
protected String pwd
public void init(Properties batchConfig) throws BatchContainerServiceException
init
in interface BatchService
BatchContainerServiceException
protected Connection getConnection() throws SQLException
SQLException
public void createCheckpointData(CheckpointDataKey key, CheckpointData value)
public CheckpointData getCheckpointData(CheckpointDataKey key)
getCheckpointData
in interface PersistenceManagerService
public void setCheckpointData(CheckpointDataKey key, CheckpointData value)
setCheckpointData
in interface PersistenceManagerService
protected Connection getConnectionToDefaultSchema() throws SQLException
SQLException
public int jobOperatorGetJobInstanceCount(String jobName)
PersistenceManagerService
jobOperatorGetJobInstanceCount
in interface PersistenceManagerService
public List<Long> jobOperatorGetJobInstanceIds(String jobName, int start, int count)
jobOperatorGetJobInstanceIds
in interface PersistenceManagerService
public Set<String> getJobNames()
getJobNames
in interface PersistenceManagerService
public Timestamp jobOperatorQueryJobExecutionTimestamp(long key, PersistenceManagerService.TimestampType timestampType)
jobOperatorQueryJobExecutionTimestamp
in interface PersistenceManagerService
public String jobOperatorQueryJobExecutionBatchStatus(long key)
jobOperatorQueryJobExecutionBatchStatus
in interface PersistenceManagerService
public String jobOperatorQueryJobExecutionExitStatus(long key)
jobOperatorQueryJobExecutionExitStatus
in interface PersistenceManagerService
public Properties getParameters(long executionId) throws javax.batch.operations.NoSuchJobExecutionException
getParameters
in interface PersistenceManagerService
javax.batch.operations.NoSuchJobExecutionException
public List<javax.batch.runtime.StepExecution> getStepExecutionsForJobExecution(long execid)
getStepExecutionsForJobExecution
in interface PersistenceManagerService
public javax.batch.runtime.StepExecution getStepExecutionByStepExecutionId(long stepExecId)
getStepExecutionByStepExecutionId
in interface PersistenceManagerService
public void updateBatchStatusOnly(long key, javax.batch.runtime.BatchStatus batchStatus, Timestamp updatets)
updateBatchStatusOnly
in interface PersistenceManagerService
public void updateWithFinalExecutionStatusesAndTimestamps(long key, javax.batch.runtime.BatchStatus batchStatus, String exitStatus, Timestamp updatets)
updateWithFinalExecutionStatusesAndTimestamps
in interface PersistenceManagerService
public void markJobStarted(long key, Timestamp startTS)
markJobStarted
in interface PersistenceManagerService
public InternalJobExecution jobOperatorGetJobExecution(long jobExecutionId)
jobOperatorGetJobExecution
in interface PersistenceManagerService
public List<InternalJobExecution> jobOperatorGetJobExecutions(long jobInstanceId)
jobOperatorGetJobExecutions
in interface PersistenceManagerService
public Set<Long> jobOperatorGetRunningExecutions(String jobName)
jobOperatorGetRunningExecutions
in interface PersistenceManagerService
public JobStatus getJobStatusFromExecution(long executionId)
getJobStatusFromExecution
in interface PersistenceManagerService
public long getJobInstanceIdByExecutionId(long executionId) throws javax.batch.operations.NoSuchJobExecutionException
getJobInstanceIdByExecutionId
in interface PersistenceManagerService
javax.batch.operations.NoSuchJobExecutionException
public javax.batch.runtime.JobInstance createSubJobInstance(String name)
createSubJobInstance
in interface PersistenceManagerService
public javax.batch.runtime.JobInstance createJobInstance(String name, String jobXml)
PersistenceManagerService
createJobInstance
in interface PersistenceManagerService
name
- the job id from job.xmljobXml
- the resolved job xmlpublic RuntimeJobExecution createJobExecution(javax.batch.runtime.JobInstance jobInstance, Properties jobParameters, javax.batch.runtime.BatchStatus batchStatus)
PersistenceManagerService
createJobExecution
in interface PersistenceManagerService
jobInstance
- the parent job instancejobParameters
- the parent job instance parametersbatchStatus
- the current BatchStatuspublic RuntimeFlowInSplitExecution createFlowInSplitExecution(javax.batch.runtime.JobInstance jobInstance, javax.batch.runtime.BatchStatus batchStatus)
createFlowInSplitExecution
in interface PersistenceManagerService
public StepExecutionImpl createStepExecution(long rootJobExecId, StepContextImpl stepContext)
PersistenceManagerService
createStepExecution
in interface PersistenceManagerService
rootJobExecId
- the parent JobExecution idstepContext
- the step context for this step executionpublic void updateStepExecution(long rootJobExecId, StepContextImpl stepContext)
PersistenceManagerService
updateStepExecution
in interface PersistenceManagerService
rootJobExecId
- the parent JobExecution idstepContext
- the step context for this step executionpublic JobStatus createJobStatus(long jobInstanceId)
PersistenceManagerService
createJobStatus
in interface PersistenceManagerService
jobInstanceId
- the parent job instance idpublic JobStatus getJobStatus(long instanceId)
PersistenceManagerService
getJobStatus
in interface PersistenceManagerService
instanceId
- the parent job instance idpublic void updateJobStatus(long instanceId, JobStatus jobStatus)
PersistenceManagerService
updateJobStatus
in interface PersistenceManagerService
instanceId
- the parent job instance idjobStatus
- the job status to be updatedpublic StepStatus createStepStatus(long stepExecId)
PersistenceManagerService
createStepStatus
in interface PersistenceManagerService
stepExecId
- the parent step execution idpublic StepStatus getStepStatus(long instanceId, String stepName)
PersistenceManagerService
The parent job instance id and this step name from the job xml are used to determine if the current step execution have previously run.
getStepStatus
in interface PersistenceManagerService
instanceId
- the parent job instance idstepName
- the step namepublic void updateStepStatus(long stepExecutionId, StepStatus stepStatus)
PersistenceManagerService
updateStepStatus
in interface PersistenceManagerService
stepExecutionId
- the parent step execution idstepStatus
- the step status to be updatedpublic long getMostRecentExecutionId(long jobInstanceId)
getMostRecentExecutionId
in interface PersistenceManagerService
public void cleanUp(long instanceId)
cleanUp
in interface PersistenceManagerService
public void cleanUp(Date until)
cleanUp
in interface PersistenceManagerService
Copyright © 2017 The Apache Software Foundation. All rights reserved.