クラス JdbcJobExecutionDao

java.lang.ObjectSE
org.springframework.batch.core.repository.dao.AbstractJdbcBatchMetadataDao
org.springframework.batch.core.repository.dao.JdbcJobExecutionDao
実装されたすべてのインターフェース:
JobExecutionDaoorg.springframework.beans.factory.InitializingBean

public class JdbcJobExecutionDao extends AbstractJdbcBatchMetadataDao implements JobExecutionDao, org.springframework.beans.factory.InitializingBean
JobExecutionDao の JDBC 実装。シーケンス(Spring の DataFieldMaxValueIncrementer 抽象化を使用)を使用して、新しい行を挿入する前にすべての主キーを作成します。オブジェクトは、格納されるすべての必須フィールドが null でないことを確認するためにチェックされます。null が見つかった場合、IllegalArgumentException がスローされます。これは JdbcTemplate に任せることができますが、例外はかなりあいまいになり、どのフィールドが例外を引き起こしたかを強調できません。
作成者:
Lucas Ward, Dave Syer, Robert Kasanicky, Michael Minella, Mahmoud Ben Hassine, Dimitrios Liapis, Philippe Marschall, Jinwoo Bae
  • コンストラクターの詳細

    • JdbcJobExecutionDao

      public JdbcJobExecutionDao()
  • メソッドの詳細

    • setExitMessageLength

      public void setExitMessageLength(int exitMessageLength)
      データベース内の出口メッセージ長のパブリック setter。スキーマを変更していない場合は、これを設定しないでください。
      パラメーター:
      exitMessageLength - 設定する exitMessageLength
    • setJobExecutionIncrementer

      public void setJobExecutionIncrementer(org.springframework.jdbc.support.incrementer.DataFieldMaxValueIncrementer jobExecutionIncrementer)
      JobExecution インスタンスの主キーを生成するときに使用される DataFieldMaxValueIncrementer の Setter。
      パラメーター:
      jobExecutionIncrementer - DataFieldMaxValueIncrementer
    • setConversionService

      public void setConversionService(@NonNull org.springframework.core.convert.support.ConfigurableConversionService conversionService)
      ジョブパラメーターを文字列リテラルから型指定された値に、またはその逆に変換するために使用する変換サービスを設定します。
    • afterPropertiesSet

      public void afterPropertiesSet() throws ExceptionSE
      次で指定:
      インターフェース org.springframework.beans.factory.InitializingBeanafterPropertiesSet 
      オーバーライド:
      クラス AbstractJdbcBatchMetadataDaoafterPropertiesSet 
      例外:
      ExceptionSE
    • findJobExecutions

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

      public void saveJobExecution(JobExecution jobExecution)
      Spring インクリメンター抽象化を介したシーケンスを使用した SQL 実装。新しい ID が取得されると、JobExecution は SQL INSERT ステートメントを介して保存されます。
      次で指定:
      インターフェース JobExecutionDaosaveJobExecution 
      パラメーター:
      jobExecution - 保存する JobExecution インスタンス。
      例外:
      IllegalArgumentExceptionSE - jobExecution が null の場合、およびそのフィールドのいずれかが永続化される場合。
      関連事項:
    • updateJobExecution

      public void updateJobExecution(JobExecution jobExecution)
      SQL UPDATE ステートメントを使用して、指定された JobExecution を更新します。JobExecution が最初にチェックされ、すべてのフィールドが null ではなく、ID があることを確認します。次に、データベースにクエリを実行して、ID が存在することを確認し、有効であることを確認します。
      次で指定:
      インターフェース JobExecutionDaoupdateJobExecution 
      パラメーター:
      jobExecution - 更新される JobExecution インスタンス。
      関連事項:
    • getLastJobExecution

      @Nullable public JobExecution getLastJobExecution(JobInstance jobInstance)
      インターフェースからコピーされた説明: JobExecutionDao
      特定の JobInstance 用に作成された最後の JobExecution を見つけます。
      次で指定:
      インターフェース JobExecutionDaogetLastJobExecution 
      パラメーター:
      jobInstance - JobInstance
      戻り値:
      このインスタンスに対して実行する最後の JobExecution または特定のジョブインスタンスに対してジョブ実行が見つからない場合は null 
    • getJobExecution

      @Nullable public JobExecution getJobExecution(LongSE executionId)
      次で指定:
      インターフェース JobExecutionDaogetJobExecution 
      パラメーター:
      executionId - 実行の ID を含む LongSE
      戻り値:
      指定された識別子の JobExecution
    • findRunningJobExecutions

      public SetSE<JobExecution> findRunningJobExecutions(StringSE jobName)
      次で指定:
      インターフェース JobExecutionDaofindRunningJobExecutions 
      パラメーター:
      jobName - ジョブの名前を含む StringSE
      戻り値:
      指定されたジョブ名について、まだ実行中の(または不確定な状態の)すべての JobExecution、つまり終了日が null のすべての JobExecution
    • synchronizeStatus

      public void synchronizeStatus(JobExecution jobExecution)
      インターフェースからコピーされた説明: JobExecutionDao
      実行中に JobExecution のステータスが更新される可能性があるため、次のメソッドはステータスフィールドとバージョンフィールドのみを同期します。
      次で指定:
      インターフェース JobExecutionDaosynchronizeStatus 
      パラメーター:
      jobExecution - 更新されます。
    • deleteJobExecution

      public void deleteJobExecution(JobExecution jobExecution)
      指定されたジョブ実行を削除します。
      次で指定:
      インターフェース JobExecutionDaodeleteJobExecution 
      パラメーター:
      jobExecution - 削除するジョブ実行
    • deleteJobExecutionParameters

      public void deleteJobExecutionParameters(JobExecution jobExecution)
      指定されたジョブの実行に関連付けられたパラメーターを削除します。
      次で指定:
      インターフェース JobExecutionDaodeleteJobExecutionParameters 
      パラメーター:
      jobExecution - ジョブパラメーターを削除する必要があるジョブの実行
    • getJobParameters

      protected JobParameters getJobParameters(LongSE executionId)
      パラメーター:
      executionId - 実行の ID を含む LongSE
      戻り値:
      リクエストされた実行 ID のジョブパラメーター