インターフェース JobRepository

すべての既知の実装クラス:
SimpleJobRepository

public interface JobRepository

バッチメタデータエンティティの永続化を担当するリポジトリ。

作成者:
Lucas Ward, Dave Syer, Robert Kasanicky, David Turanski, Michael Minella, Mahmoud Ben Hassine, Parikshit Dutta
関連事項:
  • メソッドの詳細

    • getJobNames

      default ListSE<StringSE> getJobNames()
      アルファベット順にソートされたすべてのジョブインスタンスの名前、つまり、これまでに実行されたジョブを取得します。
      戻り値:
      すべてのジョブインスタンスの名前
      導入:
      5.0
    • findJobInstancesByName

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

      default ListSE<JobExecution> findJobExecutions(JobInstance jobInstance)
      指定された JobInstance のすべての JobExecution を、作成順で逆順にソートして返します(したがって、最初の要素が最新になります)。
      パラメーター:
      jobInstance - 検索する JobExecution の親 JobInstance
      戻り値:
      jobInstance の JobExecutions を含む ListSE
      導入:
      5.0
    • isJobInstanceExists

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

      JobInstance createJobInstance(StringSE jobName, JobParameters jobParameters)
      指定された名前とジョブパラメーターを使用して、新しい JobInstance を作成します。
      パラメーター:
      jobName - ジョブの論理名
      jobParameters - ジョブの実行に使用されるパラメーター
      戻り値:
      新しい JobInstance
    • createJobExecution

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

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

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

      void update(JobExecution jobExecution)
      JobExecution を更新します(ただし、ExecutionContext は更新しません)。

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

      パラメーター:
      jobExecution - リポジトリで更新される JobExecution インスタンス。
    • add

      void add(StepExecution stepExecution)
      StepExecution とその ExecutionContext を保存します。ID が割り当てられます - このメソッドを呼び出す前に ID を割り当てることは許可されていません。代わりに、JobRepository によって割り当てられるように、空白のままにしておく必要があります。

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

      パラメーター:
      stepExecution - リポジトリに追加される StepExecution インスタンス。
    • addAll

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

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

      パラメーター:
      stepExecutions - リポジトリに追加される StepExecution インスタンスのコレクション。
    • update

      void update(StepExecution stepExecution)
      StepExecution を更新します(ただし、ExecutionContext は更新しません)。

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

      パラメーター:
      stepExecution - リポジトリで更新される StepExecution インスタンス。
    • updateExecutionContext

      void updateExecutionContext(StepExecution stepExecution)
      指定された StepExecution の更新された ExecutionContext を永続化します。
      パラメーター:
      stepExecution - コンテキストの更新に使用される StepExecution インスタンス。
    • updateExecutionContext

      void updateExecutionContext(JobExecution jobExecution)
      指定された JobExecution の更新された ExecutionContext を永続化します。
      パラメーター:
      jobExecution - コンテキストの更新に使用される JobExecution インスタンス。
    • getJobInstance

      @Nullable default JobInstance getJobInstance(StringSE jobName, JobParameters jobParameters)
      パラメーター:
      jobName - StringSE ジョブの名前。
      jobParameters - ジョブインスタンスの JobParameters パラメーター。
      戻り値:
      指定された名前とパラメーターを持つ JobInstance、または null
      導入:
      5.0
    • getLastStepExecution

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

      long getStepExecutionCount(JobInstance jobInstance, StringSE stepName)
      パラメーター:
      jobInstance - ステップ実行を含む JobInstance インスタンス。
      stepName - 実行された可能性のあるステップ実行の名前。
      戻り値:
      指定されたジョブインスタンス内のステップの実行カウント。
    • getLastJobExecution

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

      default void deleteStepExecution(StepExecution stepExecution)
      ステップ実行をその実行コンテキストとともに削除します。
      パラメーター:
      stepExecution - 削除するステップ実行
      導入:
      5.0
    • deleteJobExecution

      default void deleteJobExecution(JobExecution jobExecution)
      ジョブ実行オブジェクトグラフの削除 (つまり、ジョブの実行とその実行コンテキスト、関連するすべてのステップ実行とその実行コンテキスト、関連するジョブパラメーター)
      パラメーター:
      jobExecution - 削除するジョブ実行
      導入:
      5.0
    • deleteJobInstance

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