Database implementation of IJobExecutionDao. Uses sequences (via IDataFieldMaxValueIncrementer 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 ArgumentException will be thrown. More...
Public Member Functions | |
void | SaveJobExecution (JobExecution jobExecution) |
Persists a new job execution. The corresponding job instance must have been persisted. More... | |
void | UpdateJobExecution (JobExecution jobExecution) |
Updates the updates of a job execution. The job execution must have already been persisted. More... | |
IList< JobExecution > | FindJobExecutions (JobInstance jobInstance) |
Finds all the job executions for a job instance, sorted by descending creation order (the first element is the most recent). More... | |
JobExecution | GetLastJobExecution (JobInstance jobInstance) |
Returns the last job execution for a given job instance. More... | |
ISet< JobExecution > | FindRunningJobExecutions (string jobName) |
Returns all running job executions for the given job name. More... | |
JobExecution | GetJobExecution (long executionId) |
Returns the job execution for the given execution id. More... | |
void | SynchronizeStatus (JobExecution jobExecution) |
Persists the status and version fields of a job execution. The job execution must have already been persisted. More... | |
Public Member Functions inherited from Summer.Batch.Core.Repository.Dao.AbstractDbBatchMetadataDao | |
virtual void | AfterPropertiesSet () |
Checks that DbOperator has been correctly set. More... | |
Properties | |
int | ExitMessageLength [set] |
The exit message maximum length. More... | |
IDataFieldMaxValueIncrementer | JobIncrementer [set] |
The data field incrementer for job execution ids. More... | |
Properties inherited from Summer.Batch.Core.Repository.Dao.AbstractDbBatchMetadataDao | |
string | TablePrefix [get, set] |
The prefix for the batch persistence tables in the database. Default value is "BATCH_". More... | |
DbOperator | DbOperator [get, set] |
The database operator used for persistence. More... | |
IPlaceholderGetter | PlaceholderGetter [get, set] |
The parameter helper used to create parameter placeholders in queries. More... | |
Additional Inherited Members | |
Public Attributes inherited from Summer.Batch.Core.Repository.Dao.AbstractDbBatchMetadataDao | |
const string | TablePrefixSetting = "TablePrefix" |
The name of the setting for the table prefix. More... | |
const string | DefaultTablePrefix = "BATCH_" |
Default table prefix constant. More... | |
const int | DefaultExitMessageLength = 2500 |
Default exit message length constant. More... | |
Protected Member Functions inherited from Summer.Batch.Core.Repository.Dao.AbstractDbBatchMetadataDao | |
string | InsertTablePrefix (string query) |
Inserts the table prefix in the specified query. It uses the string.Format(string,object) syntax, and expect the prefix to be the parameter 0 ( More... | |
Static Protected Attributes inherited from Summer.Batch.Core.Repository.Dao.AbstractDbBatchMetadataDao | |
static readonly TransactionOptions | TransactionOptions |
The default transaction options for transaction scopes in the DAOs. More... | |
Detailed Description
Database implementation of IJobExecutionDao. Uses sequences (via IDataFieldMaxValueIncrementer 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 ArgumentException will be thrown.
Member Function Documentation
IList<JobExecution> Summer.Batch.Core.Repository.Dao.DbJobExecutionDao.FindJobExecutions | ( | JobInstance | jobInstance | ) |
Finds all the job executions for a job instance, sorted by descending creation order (the first element is the most recent).
- Parameters
-
jobInstance a job instance
- Returns
- a list of job executions
Implements Summer.Batch.Core.Repository.Dao.IJobExecutionDao.
ISet<JobExecution> Summer.Batch.Core.Repository.Dao.DbJobExecutionDao.FindRunningJobExecutions | ( | string | jobName | ) |
Returns all running job executions for the given job name.
- Parameters
-
jobName a job name
- Returns
- a set containing the job executions that are still running for the specified job name
Implements Summer.Batch.Core.Repository.Dao.IJobExecutionDao.
JobExecution Summer.Batch.Core.Repository.Dao.DbJobExecutionDao.GetJobExecution | ( | long | executionId | ) |
Returns the job execution for the given execution id.
- Parameters
-
executionId an id for an existing job execution
- Returns
- the job execution with the given id
Implements Summer.Batch.Core.Repository.Dao.IJobExecutionDao.
JobExecution Summer.Batch.Core.Repository.Dao.DbJobExecutionDao.GetLastJobExecution | ( | JobInstance | jobInstance | ) |
Returns the last job execution for a given job instance.
- Parameters
-
jobInstance a job instance
- Returns
- the last created job execution for the job instance
Implements Summer.Batch.Core.Repository.Dao.IJobExecutionDao.
void Summer.Batch.Core.Repository.Dao.DbJobExecutionDao.SaveJobExecution | ( | JobExecution | jobExecution | ) |
Persists a new job execution. The corresponding job instance must have been persisted.
- Parameters
-
jobExecution a job execution
Implements Summer.Batch.Core.Repository.Dao.IJobExecutionDao.
void Summer.Batch.Core.Repository.Dao.DbJobExecutionDao.SynchronizeStatus | ( | JobExecution | jobExecution | ) |
Persists the status and version fields of a job execution. The job execution must have already been persisted.
- Parameters
-
jobExecution
Implements Summer.Batch.Core.Repository.Dao.IJobExecutionDao.
void Summer.Batch.Core.Repository.Dao.DbJobExecutionDao.UpdateJobExecution | ( | JobExecution | jobExecution | ) |
Updates the updates of a job execution. The job execution must have already been persisted.
- Parameters
-
jobExecution a job execution
Implements Summer.Batch.Core.Repository.Dao.IJobExecutionDao.
Property Documentation
|
set |
The exit message maximum length.
|
set |
The data field incrementer for job execution ids.
The documentation for this class was generated from the following file:
- Summer.Batch.Core/Core/Repository/Dao/DbJobExecutionDao.cs