public interface JobRepository
バッチメタデータエンティティの永続化を担当するリポジトリ。
JobInstance
, JobExecution
, StepExecution
修飾子と型 | メソッドと説明 |
---|---|
void | add(StepExecution stepExecution) StepExecution とその ExecutionContext を保存します。 |
void | addAll(java.util.Collection<StepExecution> stepExecutions) StepExecution と各 ExecutionContext のコレクションを保存します。 |
JobExecution | createJobExecution(JobInstance jobInstance, JobParameters jobParameters, java.lang.String jobConfigurationLocation) |
JobExecution | createJobExecution(java.lang.String jobName, JobParameters jobParameters) |
JobInstance | createJobInstance(java.lang.String jobName, JobParameters jobParameters) 指定された名前とジョブパラメーターを使用して、新しい JobInstance を作成します。 |
JobExecution | getLastJobExecution(java.lang.String jobName, JobParameters jobParameters) |
StepExecution | getLastStepExecution(JobInstance jobInstance, java.lang.String stepName) |
int | getStepExecutionCount(JobInstance jobInstance, java.lang.String stepName) |
boolean | isJobInstanceExists(java.lang.String jobName, JobParameters jobParameters) 指定されたパラメーターを使用して、このジョブのインスタンスがすでに存在するかどうかを確認します。 |
void | update(JobExecution jobExecution) JobExecution を更新します(ただし、ExecutionContext は更新しません)。 |
void | update(StepExecution stepExecution) StepExecution を更新します(ただし、ExecutionContext は更新しません)。 |
void | updateExecutionContext(JobExecution jobExecution) 指定された JobExecution の更新された ExecutionContext を永続化します。 |
void | updateExecutionContext(StepExecution stepExecution) 指定された StepExecution の更新された ExecutionContext を永続化します。 |
boolean isJobInstanceExists(java.lang.String jobName, JobParameters jobParameters)
jobName
- ジョブの名前 jobParameters
- 一致するパラメーター JobInstance
がすでに存在する場合は trueJobInstance createJobInstance(java.lang.String jobName, JobParameters jobParameters)
JobInstance
を作成します。jobName
- ジョブの論理名 jobParameters
- ジョブの実行に使用されるパラメーター JobInstance
JobExecution createJobExecution(JobInstance jobInstance, JobParameters jobParameters, java.lang.String jobConfigurationLocation)
jobInstance
- 新しい JobExecution を初期化する JobInstance
インスタンス。jobParameters
- 新しい JobExecution を初期化する JobParameters
インスタンス。jobConfigurationLocation
- 新しい JobExecution を初期化する String
インスタンス。JobExecution
JobExecution createJobExecution(java.lang.String jobName, JobParameters jobParameters) throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException
指定された Job
および JobParameters
の JobExecution
を作成します。一致する JobInstance
がすでに存在する場合、ジョブは再開可能でなければならず、最後の JobExecution は * 完了 * してはなりません。一致する JobInstance
がまだ存在しない場合は作成されます。
このメソッドが(通常どおり) Isolation.REPEATABLE_READ
以上の分離レベルでトランザクションで実行される場合、このメソッドは(同じ JobParameters
とジョブ名に対して)別のトランザクションがすでに実行している場合、ブロックする必要があります。このシナリオで最初に完了するトランザクションは、有効な JobExecution
を取得し、他のトランザクションは JobExecutionAlreadyRunningException
(またはタイムアウト)をスローします。JobInstanceDao
および JobExecutionDao
がトランザクション分離レベルを考慮しない場合(たとえば、非リレーショナルデータストアを使用する場合、プラットフォームがより高い分離レベルをサポートしない場合)、そのような保証はありません。
jobName
- 実行されるジョブの名前 jobParameters
- ジョブの実行時パラメーター JobExecution
JobExecutionAlreadyRunningException
- 指定されたジョブとパラメーターを使用して、ジョブインスタンスに対して JobExecution
がすでに実行されている場合。JobRestartException
- 1 つ以上の既存の JobInstance
が同じパラメーターで見つかり、Job.isRestartable()
が false の場合。JobInstanceAlreadyCompleteException
- JobInstance
が見つかり、すでに正常に完了した場合。void update(JobExecution jobExecution)
JobExecution
を更新します(ただし、ExecutionContext
は更新しません)。前提条件: JobExecution
には有効な JobInstance
が含まれており、保存されている(ID が割り当てられている)必要があります。jobExecution
- リポジトリで更新される JobExecution
インスタンス。void add(StepExecution stepExecution)
StepExecution
とその ExecutionContext
を保存します。ID が割り当てられます。このメソッドを呼び出す前に ID を割り当てることは許可されていません。代わりに、JobRepository
によって割り当てられるように、空白のままにしてください。前提条件: StepExecution
には有効な Step
が必要です。stepExecution
- リポジトリに追加される StepExecution
インスタンス。void addAll(java.util.Collection<StepExecution> stepExecutions)
StepExecution
と各 ExecutionContext
のコレクションを保存します。StepExecution ID が割り当てられます。このメソッドを呼び出す前に ID を割り当てることは許可されていません。代わりに、JobRepository
によって割り当てられるように、空白のままにしてください。前提条件: StepExecution
には有効な Step
が必要です。stepExecutions
- リポジトリに追加される StepExecution
インスタンスのコレクション。void update(StepExecution stepExecution)
stepExecution
- リポジトリで更新される StepExecution
インスタンス。void updateExecutionContext(StepExecution stepExecution)
StepExecution
の更新された ExecutionContext
を永続化します。stepExecution
- コンテキストの更新に使用される StepExecution
インスタンス。void updateExecutionContext(JobExecution jobExecution)
JobExecution
の更新された ExecutionContext
を永続化します。jobExecution
- コンテキストの更新に使用される JobExecution
インスタンス。@Nullable StepExecution getLastStepExecution(JobInstance jobInstance, java.lang.String stepName)
jobInstance
- ステップ実行を含む JobInstance
インスタンス。stepName
- 実行された可能性のあるステップ実行の名前。int getStepExecutionCount(JobInstance jobInstance, java.lang.String stepName)
jobInstance
- ステップ実行を含む JobInstance
インスタンス。stepName
- 実行された可能性のあるステップ実行の名前。@Nullable JobExecution getLastJobExecution(java.lang.String jobName, JobParameters jobParameters)
jobName
- 実行された可能性のあるジョブの名前 jobParameters
- JobInstance
を識別するパラメーター