パッケージ org.springframework.batch.core.repository.support

クラス SimpleJobRepository

java.lang.ObjectSE
org.springframework.batch.core.repository.support.SimpleJobRepository
実装されたすべてのインターフェース:
JobRepository
public class SimpleJobRepository extends ObjectSE implements JobRepository

注入された DAO を使用して、ジョブインスタンス、ジョブ実行、ステップ実行を格納する JobRepository の実装。

作成者:
Lucas Ward, Dave Syer, Robert Kasanicky, David Turanski, Mahmoud Ben Hassine, Baris Cubukcuoglu, Parikshit Dutta, Mark John Moreno
関連事項:

  • コンストラクターの詳細

  • メソッドの詳細

    • getJobNames

      public ListSE<StringSE> getJobNames()
      インターフェースからコピーされた説明: JobRepository
      アルファベット順にソートされたすべてのジョブインスタンスの名前、つまり、これまでに実行されたジョブを取得します。
      次で指定:
      インターフェース JobRepository の getJobNames 
      戻り値:
      すべてのジョブインスタンスの名前

    • findJobInstancesByName

      public ListSE<JobInstance> findJobInstancesByName(StringSE jobName, int start, int count)
      インターフェースからコピーされた説明: JobRepository
      'like' 条件を使用して、指定された名前で最後のジョブインスタンスをフェッチし、主キーで後方にソートします
      次で指定:
      インターフェース JobRepository の findJobInstancesByName 
      パラメーター:
      jobName - ジョブの名前を含む StringSE。
      start - ジョブインスタンスの結果リストの開始位置のオフセットを含む int。
      count - 返すジョブインスタンスの数を含む int。
      戻り値:
      リクエストされたジョブ名の JobInstance のリスト。

    • findJobExecutions

      public ListSE<JobExecution> findJobExecutions(JobInstance jobInstance)
      インターフェースからコピーされた説明: JobRepository
      指定された JobInstance のすべての JobExecution を、作成順で逆順にソートして返します（したがって、最初の要素が最新になります）。
      次で指定:
      インターフェース JobRepository の findJobExecutions 
      パラメーター:
      jobInstance - 検索する JobExecution の親 JobInstance
      戻り値:
      jobInstance 用の JobExecutions を含む ListSE。

    • isJobInstanceExists

      public boolean isJobInstanceExists(StringSE jobName, JobParameters jobParameters)
      インターフェースからコピーされた説明: JobRepository
      指定されたパラメーターを使用して、このジョブのインスタンスがすでに存在するかどうかを確認します。
      次で指定:
      インターフェース JobRepository の isJobInstanceExists 
      パラメーター:
      jobName - ジョブの名前
      jobParameters - 一致するパラメーター
      戻り値:
      このジョブ名とジョブパラメーターに対して JobInstance がすでに存在する場合は true

    • createJobExecution

      public JobExecution createJobExecution(StringSE jobName, JobParameters jobParameters) throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException
      インターフェースからコピーされた説明: JobRepository

      指定された Job および JobParameters の JobExecution を作成します。一致する JobInstance がすでに存在する場合、ジョブは再開可能でなければならず、最後の JobExecution は * 完了 * してはなりません。一致する JobInstance がまだ存在しない場合は作成されます。

      このメソッドが（通常どおり） Isolation.REPEATABLE_READ 以上の分離レベルでトランザクションで実行される場合、このメソッドは（同じ JobParameters とジョブ名に対して）別のトランザクションがすでに実行している場合、ブロックする必要があります。このシナリオで最初に完了するトランザクションは、有効な JobExecution を取得し、他のトランザクションは JobExecutionAlreadyRunningException（またはタイムアウト）をスローします。JobInstanceDao および JobExecutionDao がトランザクション分離レベルを考慮しない場合（たとえば、非リレーショナルデータストアを使用する場合、プラットフォームがより高い分離レベルをサポートしない場合）、そのような保証はありません。

      次で指定:
      インターフェース JobRepository の createJobExecution 
      パラメーター:
      jobName - 実行されるジョブの名前
      jobParameters - ジョブの実行時パラメーター
      戻り値:
      指定された引数の有効な JobExecution
      例外:
      JobExecutionAlreadyRunningException - 指定されたジョブとパラメーターを使用して、ジョブインスタンスに対して JobExecution がすでに実行されている場合。
      JobRestartException - 1 つ以上の既存の JobInstance が同じパラメーターで見つかり、Job.isRestartable() が false の場合。
      JobInstanceAlreadyCompleteException - JobInstance が見つかり、すでに正常に完了した場合。

    • update

      public void update(JobExecution jobExecution)
      インターフェースからコピーされた説明: JobRepository
      JobExecution を更新します（ただし、ExecutionContext は更新しません）。

      事前条件: JobExecution には有効な JobInstance が含まれており、保存される (ID が割り当てられる) 必要があります。

      次で指定:
      インターフェース JobRepository の update 
      パラメーター:
      jobExecution - リポジトリで更新される JobExecution インスタンス。

    • add

      public void add(StepExecution stepExecution)
      インターフェースからコピーされた説明: JobRepository
      StepExecution とその ExecutionContext を保存します。ID が割り当てられます - このメソッドを呼び出す前に ID を割り当てることは許可されていません。代わりに、JobRepository によって割り当てられるように、空白のままにしておく必要があります。

      事前条件: StepExecution には有効な Step が必要です。

      次で指定:
      インターフェース JobRepository の add 
      パラメーター:
      stepExecution - リポジトリに追加される StepExecution インスタンス。

    • addAll

      public void addAll(CollectionSE<StepExecution> stepExecutions)
      インターフェースからコピーされた説明: JobRepository
      StepExecution と各 ExecutionContext のコレクションを保存します。StepExecution ID が割り当てられます。このメソッドを呼び出す前に ID を割り当てることは許可されていません。代わりに、JobRepository によって割り当てられるように、空白のままにしておく必要があります。

      事前条件: StepExecution には有効な Step が必要です。

      次で指定:
      インターフェース JobRepository の addAll 
      パラメーター:
      stepExecutions - リポジトリに追加される StepExecution インスタンスのコレクション。

    • update

      public void update(StepExecution stepExecution)
      インターフェースからコピーされた説明: JobRepository
      StepExecution を更新します（ただし、ExecutionContext は更新しません）。

      事前条件: StepExecution は保存する必要があります (ID が割り当てられている)。

      次で指定:
      インターフェース JobRepository の update 
      パラメーター:
      stepExecution - リポジトリで更新される StepExecution インスタンス。

    • updateExecutionContext

      public void updateExecutionContext(StepExecution stepExecution)
      インターフェースからコピーされた説明: JobRepository
      指定された StepExecution の更新された ExecutionContext を永続化します。
      次で指定:
      インターフェース JobRepository の updateExecutionContext 
      パラメーター:
      stepExecution - コンテキストの更新に使用される StepExecution インスタンス。

    • updateExecutionContext

      public void updateExecutionContext(JobExecution jobExecution)
      インターフェースからコピーされた説明: JobRepository
      指定された JobExecution の更新された ExecutionContext を永続化します。
      次で指定:
      インターフェース JobRepository の updateExecutionContext 
      パラメーター:
      jobExecution - コンテキストの更新に使用される JobExecution インスタンス。

    • getJobInstance

      public JobInstance getJobInstance(StringSE jobName, JobParameters jobParameters)
      次で指定:
      インターフェース JobRepository の getJobInstance 
      パラメーター:
      jobName - StringSE ジョブの名前。
      jobParameters - ジョブインスタンスの JobParameters パラメーター。
      戻り値:
      指定された名前とパラメーターを持つ JobInstance、または null。

    • getLastStepExecution

      @Nullable public StepExecution getLastStepExecution(JobInstance jobInstance, StringSE stepName)
      次で指定:
      インターフェース JobRepository の getLastStepExecution 
      パラメーター:
      jobInstance - ステップ実行を含む JobInstance インスタンス。
      stepName - 実行された可能性のあるステップ実行の名前。
      戻り値:
      指定されたジョブインスタンスのステップの最後の実行。

    • getStepExecutionCount

      public long getStepExecutionCount(JobInstance jobInstance, StringSE stepName)
      次で指定:
      インターフェース JobRepository の getStepExecutionCount 
      パラメーター:
      jobInstance - ステップ実行を含む JobInstance インスタンス。
      stepName - 実行された可能性のあるステップ実行の名前。
      戻り値:
      特定のジョブインスタンス内のステップの実行回数

    • getLastJobExecution

      @Nullable public JobExecution getLastJobExecution(StringSE jobName, JobParameters jobParameters)
      次で指定:
      インターフェース JobRepository の getLastJobExecution 
      パラメーター:
      jobName - 実行された可能性のあるジョブの名前
      jobParameters - JobInstance を識別するパラメーター
      戻り値:
      存在する場合はジョブの最後の実行、そうでない場合は null

    • deleteStepExecution

      public void deleteStepExecution(StepExecution stepExecution)
      インターフェースからコピーされた説明: JobRepository
      ステップ実行をその実行コンテキストとともに削除します。
      次で指定:
      インターフェース JobRepository の deleteStepExecution 
      パラメーター:
      stepExecution - 削除するステップ実行

    • deleteJobExecution

      public void deleteJobExecution(JobExecution jobExecution)
      インターフェースからコピーされた説明: JobRepository
      ジョブ実行オブジェクトグラフの削除 (つまり、ジョブの実行とその実行コンテキスト、関連するすべてのステップ実行とその実行コンテキスト、関連するジョブパラメーター)
      次で指定:
      インターフェース JobRepository の deleteJobExecution 
      パラメーター:
      jobExecution - 削除するジョブ実行

    • deleteJobInstance

      public void deleteJobInstance(JobInstance jobInstance)
      インターフェースからコピーされた説明: JobRepository
      ジョブインスタンスオブジェクトグラフ (つまり、関連付けられたすべてのジョブ実行を含むジョブインスタンスと、JobRepository.deleteJobExecution(JobExecution) で指定されたそれぞれのオブジェクトグラフ) を削除します。
      次で指定:
      インターフェース JobRepository の deleteJobInstance 
      パラメーター:
      jobInstance - 削除するジョブインスタンス

    • createJobInstance

      public JobInstance createJobInstance(StringSE jobName, JobParameters jobParameters)
      インターフェースからコピーされた説明: JobRepository
      指定された名前とジョブパラメーターを使用して、新しい JobInstance を作成します。
      次で指定:
      インターフェース JobRepository の createJobInstance 
      パラメーター:
      jobName - ジョブの論理名
      jobParameters - ジョブの実行に使用されるパラメーター
      戻り値:
      新しい JobInstance