jp.terasoluna.fw.batch.init
クラス JobControlTableHandlerImpl

java.lang.Object
  上位を拡張 jp.terasoluna.fw.batch.init.JobControlTableHandlerImpl
すべての実装されたインタフェース:
JobControlTableHandler

public class JobControlTableHandlerImpl
extends java.lang.Object
implements JobControlTableHandler

ジョブ依頼情報取得・更新用クラス。

  • jobControl-sqlMap.xmlに定義された以下のSQL文を実行 する。
  • 
         <!-- ジョブ依頼情報取得 -->
        <select id="SELECT_JOB_INFO_ALL" resultClass="jobControlInfo">
            SELECT 
                REQUEST_NO    AS jobRequestNo , 
                JOB_ID        AS jobId , 
                JOB_FILE      AS jobDiscriptorPath , 
                PARAMETER     AS jobParameters, 
                STATE         AS jobState, 
                END_CODE      AS jobExitCode, 
                UPDATE_TIME   AS updateTime, 
                REGISTER_TIME AS registerTime
            FROM JOB_CONTROL 
            WHERE REQUEST_NO = ( 
                SELECT 
                    MIN(REQUEST_NO) 
                FROM 
                    JOB_CONTROL 
                WHERE 
                    STATE = '0'
                )  
        </select>
    
         <!-- ジョブ依頼情報取得 -->
         <select id="SELECT_JOB_INFO"  parameterClass="jobControlInfo" 
         resultClass="jobControlInfo">
            SELECT 
                REQUEST_NO    AS jobRequestNo , 
                JOB_ID        AS jobId , 
                JOB_FILE      AS jobDiscriptorPath , 
                PARAMETER     AS jobParameters, 
                STATE         AS jobState, 
                 END_CODE      AS jobExitCode, 
                UPDATE_TIME   AS updateTime, 
                REGISTER_TIME AS registerTime
            FROM JOB_CONTROL 
            WHERE REQUEST_NO = ( 
                SELECT 
                    MIN(REQUEST_NO) 
                FROM 
                    JOB_CONTROL 
                WHERE 
                    STATE = '0' AND
                    REQUEST_NO > #jobRequestNo#
                )  
         </select>
         
         <!-- ジョブ依頼情報更新 -->
         <update id="UPDATE_JOB_START" parameterClass="jobControlInfo">
            UPDATE JOB_CONTROL SET 
                STATE       = '1' , 
                UPDATE_TIME = current_timestamp , 
                START_TIME  = current_timestamp 
            WHERE 
                REQUEST_NO    = #jobRequestNo#     AND
                JOB_ID        = #jobId#            AND
                JOB_FILE      = #jobDiscriptorPath#  AND
                STATE         = '0'  
         </update>
     
         <!-- ジョブ終了情報更新 -->
         <update id="UPDATE_JOB_RESULT" parameterClass="jobControlInfo">
             UPDATE JOB_CONTROL SET 
                 STATE       = #jobState# , 
                 END_CODE    = #jobExitCode# ,
                 UPDATE_TIME = current_timestamp 
             WHERE 
                 REQUEST_NO = #jobRequestNo#
         </update>
    


    フィールドの概要
    private static java.lang.String GET_JOB_REQUEST_DATA
              「jobControl-sqlMap.xml」に定義されたジョブ依頼情報取得用SQLキー。
    private static java.lang.String GET_JOB_REQUEST_DATA_ALL
              「jobControl-sqlMap.xml」に定義されたジョブ依頼情報取得用SQLキー。
    private  QueryDAO queryDAO
              SELECT用DAO。
    private static java.lang.String SET_JOB_END
              「jobControl-sqlMap.xml」に定義されたジョブ処理結果更新用SQLキー。
    private static java.lang.String SET_JOB_START
              「jobControl-sqlMap.xml」に定義されたジョブ開始処理用SQLキー。
    private  UpdateDAO updateDAO
              UPDATE用DAO。
     
    コンストラクタの概要
    JobControlTableHandlerImpl()
               
     
    メソッドの概要
     JobInfo getJobRequestData()
              ジョブ依頼情報検索用メソッド。
     JobInfo getJobRequestData(JobInfo jobInfo)
              ジョブ依頼情報検索用メソッド。
     void setQueryDAO(QueryDAO queryDAO)
              SELECT用DAOを設定する。
     void setUpdateDAO(UpdateDAO updateDAO)
              更新用DAOを設定する。
     int updateJobEnd(JobInfo jobInfo)
              ジョブ処理結果の更新処理。
     int updateJobStart(JobInfo jobInfo)
              ジョブ依頼情報の「起動状況」更新用メソッド。
     
    クラス java.lang.Object から継承されたメソッド
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
     

    フィールドの詳細

    queryDAO

    private QueryDAO queryDAO
    SELECT用DAO。 SpringのDI機能を用いて設定する。


    updateDAO

    private UpdateDAO updateDAO
    UPDATE用DAO。 SpringのDI機能を用いて設定する。


    GET_JOB_REQUEST_DATA

    private static final java.lang.String GET_JOB_REQUEST_DATA
    「jobControl-sqlMap.xml」に定義されたジョブ依頼情報取得用SQLキー。

    関連項目:
    定数フィールド値

    GET_JOB_REQUEST_DATA_ALL

    private static final java.lang.String GET_JOB_REQUEST_DATA_ALL
    「jobControl-sqlMap.xml」に定義されたジョブ依頼情報取得用SQLキー。

    関連項目:
    定数フィールド値

    SET_JOB_START

    private static final java.lang.String SET_JOB_START
    「jobControl-sqlMap.xml」に定義されたジョブ開始処理用SQLキー。

    関連項目:
    定数フィールド値

    SET_JOB_END

    private static final java.lang.String SET_JOB_END
    「jobControl-sqlMap.xml」に定義されたジョブ処理結果更新用SQLキー。

    関連項目:
    定数フィールド値
    コンストラクタの詳細

    JobControlTableHandlerImpl

    public JobControlTableHandlerImpl()
    メソッドの詳細

    getJobRequestData

    public JobInfo getJobRequestData()
    ジョブ依頼情報検索用メソッド。

    定義:
    インタフェース JobControlTableHandler 内の getJobRequestData
    戻り値:
    ジョブ依頼情報。

    getJobRequestData

    public JobInfo getJobRequestData(JobInfo jobInfo)
    ジョブ依頼情報検索用メソッド。

    定義:
    インタフェース JobControlTableHandler 内の getJobRequestData
    パラメータ:
    jobInfo - ジョブ依頼情報の検索条件。
    戻り値:
    検索されたジョブ依頼情報。

    updateJobStart

    public int updateJobStart(JobInfo jobInfo)
    ジョブ依頼情報の「起動状況」更新用メソッド。

    定義:
    インタフェース JobControlTableHandler 内の updateJobStart
    パラメータ:
    jobInfo - 更新対象のジョブ依頼情報
    戻り値:
    int 更新されたレコード数。

    updateJobEnd

    public int updateJobEnd(JobInfo jobInfo)
    ジョブ処理結果の更新処理。

    定義:
    インタフェース JobControlTableHandler 内の updateJobEnd
    パラメータ:
    jobInfo - 更新対象のジョブ依頼情報
    戻り値:
    int 更新されたレコード数。

    setQueryDAO

    public void setQueryDAO(QueryDAO queryDAO)
    SELECT用DAOを設定する。

    パラメータ:
    queryDAO - SELECT用DAO

    setUpdateDAO

    public void setUpdateDAO(UpdateDAO updateDAO)
    更新用DAOを設定する。

    パラメータ:
    updateDAO - 更新用DAO