public class JobRepositoryTestUtils extends AbstractJdbcBatchMetadataDao implements org.springframework.beans.factory.InitializingBean
JobExecution
インスタンスを作成および削除するための便利なクラス。テストケースでの一般的な使用箇所は、トランザクションの前にインスタンスを作成し、結果を保存し、それを使用してトランザクション後に削除することです。DEFAULT_EXIT_MESSAGE_LENGTH, DEFAULT_TABLE_PREFIX
コンストラクターと説明 |
---|
JobRepositoryTestUtils() デフォルトコンストラクター。 |
JobRepositoryTestUtils(JobRepository jobRepository, javax.sql.DataSource dataSource) すべての必須プロパティを含む JobRepositoryTestUtils を作成します。 |
修飾子と型 | メソッドと説明 |
---|---|
void | afterPropertiesSet() |
java.util.List<JobExecution> | createJobExecutions(int count) JobRepository を使用して、それぞれがシングルステップ実行の JobExecution インスタンスをいくつか作成します。 |
java.util.List<JobExecution> | createJobExecutions(java.lang.String jobName, java.lang.String[] stepNames, int count) JobRepository を使用して、それぞれが指定されたジョブ名を持ち、それぞれが指定されたステップ名でステップ実行を持ついくつかの JobExecution インスタンスを作成します。 |
void | removeJobExecutions() すべての JobExecution インスタンス、および関連するすべての JobInstance および StepExecution インスタンスを、Spring Batch によって使用される標準の RDBMS ロケーションから削除します。 |
void | removeJobExecutions(java.util.Collection<JobExecution> list) Spring Batch によって使用される標準の RDBMS ロケーションから、 JobExecution インスタンス、関連するすべての JobInstance および StepExecution インスタンスを削除します。 |
void | setDataSource(javax.sql.DataSource dataSource) |
void | setJobParametersIncrementer(JobParametersIncrementer jobParametersIncrementer) |
void | setJobRepository(JobRepository jobRepository) |
getClobTypeToUse, getJdbcTemplate, getQuery, getTablePrefix, setClobTypeToUse, setJdbcTemplate, setTablePrefix
public JobRepositoryTestUtils()
public JobRepositoryTestUtils(JobRepository jobRepository, javax.sql.DataSource dataSource)
JobRepositoryTestUtils
を作成します。jobRepository
- データベースによる JobRepository
dataSource
- DataSource
public void afterPropertiesSet() throws java.lang.Exception
org.springframework.beans.factory.InitializingBean
の afterPropertiesSet
AbstractJdbcBatchMetadataDao
の afterPropertiesSet
java.lang.Exception
InitializingBean.afterPropertiesSet()
@Autowired public final void setDataSource(javax.sql.DataSource dataSource)
public void setJobParametersIncrementer(JobParametersIncrementer jobParametersIncrementer)
jobParametersIncrementer
- 設定する jobParametersIncrementer@Autowired public void setJobRepository(JobRepository jobRepository)
jobRepository
- 設定する jobRepositorypublic java.util.List<JobExecution> createJobExecutions(java.lang.String jobName, java.lang.String[] stepNames, int count) throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException
JobRepository
を使用して、それぞれが指定されたジョブ名を持ち、それぞれが指定されたステップ名でステップ実行を持ついくつかの JobExecution
インスタンスを作成します。jobName
- ジョブの名前 stepNames
- ステップ実行の名前 count
- 作成する JobExecution
のインスタンスの必要数 JobExecution
のコレクション JobExecutionAlreadyRunningException
- ジョブがすでに実行されている場合にスローされます。JobRestartException
- ジョブが再起動可能でない場合にスローされます。JobInstanceAlreadyCompleteException
- ジョブインスタンスがすでに完了している場合にスローされます。public java.util.List<JobExecution> createJobExecutions(int count) throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException
JobRepository
を使用して、それぞれがシングルステップ実行の JobExecution
インスタンスをいくつか作成します。count
- 作成する JobExecution
のインスタンスの必要数 JobExecution
のコレクション JobExecutionAlreadyRunningException
- ジョブがすでに実行されている場合にスローされます。JobRestartException
- ジョブが再起動可能でない場合にスローされます。JobInstanceAlreadyCompleteException
- ジョブインスタンスがすでに完了している場合にスローされます。public void removeJobExecutions(java.util.Collection<JobExecution> list) throws org.springframework.dao.DataAccessException
JobExecution
インスタンス、関連するすべての JobInstance
および StepExecution
インスタンスを削除します。list
- JobExecution
のリスト org.springframework.dao.DataAccessException
- 問題がある場合 public void removeJobExecutions() throws org.springframework.dao.DataAccessException
JobExecution
インスタンス、および関連するすべての JobInstance
および StepExecution
インスタンスを、Spring Batch によって使用される標準の RDBMS ロケーションから削除します。org.springframework.dao.DataAccessException
- 問題がある場合