public abstract class AbstractBatchExecutor extends Object implements BatchExecutor
修飾子とタイプ | フィールドと説明 |
---|---|
protected static String |
APPLICATION_CONTEXT
アプリケーションコンテキストクラス名.
|
protected static int |
ARGUMENT_COUNT
バッチ引数の数.
|
protected static String |
BEAN_DEFINITION_ADMIN_CLASSPATH_KEY
管理用Bean定義ファイルを配置するクラスパス.
|
protected static String |
BEAN_DEFINITION_BUSINESS_CLASSPATH_KEY
業務用Bean定義ファイルを配置するクラスパス.
|
protected static String |
BEAN_DEFINITION_DATASOURCE
管理用Bean定義(データソース部)
|
protected static String |
BEAN_DEFINITION_DEFAULT
管理用Bean定義(基本部)
|
protected static String |
BEAN_MESSAGE_ACCESSOR_DEFAULT
メッセージソースアクセサのBean名取得キー.
|
protected static ClassLoader |
cl
クラスローダ.
|
protected static String |
DEFAULT_BLOGIC_BEAN_NAME_SUFFIX
BLogicのBean名に付与する接尾語.
|
protected static String |
DEFAULT_BLOGIC_EXCEPTION_HANDLER_BEAN_NAME
デフォルトの例外ハンドラのBean名.
|
protected static String |
DEFAULT_BLOGIC_EXCEPTION_HANDLER_BEAN_NAME_SUFFIX
例外ハンドラのBean名に付与する接尾語.
|
protected org.springframework.context.ApplicationContext |
defaultApplicationContext
システム用アプリケーションコンテキスト.
|
protected static String |
ENABLE_JOBCOMPONENT_ANNOTATION
JobComponentアノテーション有効化フラグ取得キー.
|
protected boolean |
enableJobComponentAnnotation
JobComponentアノテーション有効化フラグ
|
protected static String |
ENV_BLOGIC_APP_STATUS
環境変数:業務ステータス.
|
protected static String |
ENV_CUR_APP_STATUS
環境変数:ステータス.
|
protected static String |
ENV_JOB_APP_CD
環境変数:ジョブ業務コード.
|
protected static int |
ENV_JOB_ARG_MAX
環境変数:引数の最大個数.
|
protected static String |
ENV_JOB_ARG_NM
環境変数:引数.
|
protected static String |
ENV_JOB_ARG_NM1
環境変数:引数1.
|
protected static String |
ENV_JOB_ARG_NM10
環境変数:引数10.
|
protected static String |
ENV_JOB_ARG_NM11
環境変数:引数11.
|
protected static String |
ENV_JOB_ARG_NM12
環境変数:引数12.
|
protected static String |
ENV_JOB_ARG_NM13
環境変数:引数13.
|
protected static String |
ENV_JOB_ARG_NM14
環境変数:引数14.
|
protected static String |
ENV_JOB_ARG_NM15
環境変数:引数15.
|
protected static String |
ENV_JOB_ARG_NM16
環境変数:引数16.
|
protected static String |
ENV_JOB_ARG_NM17
環境変数:引数17.
|
protected static String |
ENV_JOB_ARG_NM18
環境変数:引数18.
|
protected static String |
ENV_JOB_ARG_NM19
環境変数:引数19.
|
protected static String |
ENV_JOB_ARG_NM2
環境変数:引数2.
|
protected static String |
ENV_JOB_ARG_NM20
環境変数:引数20.
|
protected static String |
ENV_JOB_ARG_NM3
環境変数:引数3.
|
protected static String |
ENV_JOB_ARG_NM4
環境変数:引数4.
|
protected static String |
ENV_JOB_ARG_NM5
環境変数:引数5.
|
protected static String |
ENV_JOB_ARG_NM6
環境変数:引数6.
|
protected static String |
ENV_JOB_ARG_NM7
環境変数:引数7.
|
protected static String |
ENV_JOB_ARG_NM8
環境変数:引数8.
|
protected static String |
ENV_JOB_ARG_NM9
環境変数:引数9.
|
protected static String |
ENV_JOB_BEAN_DEFINITION_PATH
環境変数:bean定義ファイルパス.
|
protected static String |
ENV_JOB_SEQ_ID
環境変数:ジョブシーケンスコード.
|
protected static String |
FIELD_JOB_ARG
バッチ引数のフィールド名.
|
protected static String |
PROPERTY_BEAN_FILENAME_SUFFIX
Bean定義ファイル名.
|
protected static String |
REPLACE_STRING_JOB_APP_CD
置換文字列:ジョブ業務コード
|
protected static String |
REPLACE_STRING_JOB_APP_CD_LOWER
置換文字列:ジョブ業務コード(小文字)
|
protected static String |
REPLACE_STRING_JOB_APP_CD_UPPER
置換文字列:ジョブ業務コード(大文字)
|
protected static String |
REPLACE_STRING_JOB_ARG
置換文字列:引数.
|
protected static int |
REPLACE_STRING_JOB_ARG_MAX
置換文字列:引数の最大個数.
|
protected static String |
REPLACE_STRING_PREFIX
置換文字列接頭語
|
protected static String |
REPLACE_STRING_SUFFIX
置換文字列接尾語
|
protected QueryDAO |
sysQueryDAO
システム用queryDAO定義(ステータス参照・更新用).
|
protected static String |
SYSTEM_DATASOURCE_QUERY_DAO
システム用queryDAO定義(ステータス参照・更新用)取得用キー.
|
protected static String |
SYSTEM_DATASOURCE_TRANSACTION_MANAGER
システム用transactionManager定義(ステータス参照・更新用)取得用キー.
|
protected static String |
SYSTEM_DATASOURCE_UPDATE_DAO
システム用updateDAO定義(ステータス参照・更新用)取得用キー.
|
protected org.springframework.transaction.PlatformTransactionManager |
sysTransactionManager
システム用transactionManager定義(ステータス参照・更新用).
|
protected UpdateDAO |
sysUpdateDAO
システム用updateDAO定義(ステータス参照・更新用).
|
修飾子 | コンストラクタと説明 |
---|---|
protected |
AbstractBatchExecutor()
コンストラクタ
|
修飾子とタイプ | メソッドと説明 |
---|---|
protected boolean |
argumentCopy(Object from,
Object to,
String field)
引数フィールド(1~20)コピー.
|
protected void |
closeApplicationContext(org.springframework.context.ApplicationContext context)
ApplicationContextをクローズする.
|
protected BLogicParam |
convertBLogicParam(BatchJobData jobRecord)
バッチジョブレコードデータをBLogicParamに変換する
|
BLogicResult |
executeBatch(BatchJobData jobRecord)
バッチ実行.
|
protected BLogicResult |
executeBatchClass(String blogicBeanName,
String exceptionHandlerBeanName,
BLogicParam param,
org.springframework.context.ApplicationContext context)
バッチクラス実行.
|
protected static org.springframework.context.ApplicationContext |
getApplicationContext(String... batchBeanFileName)
アプリケーションコンテキスト取得.
|
protected String |
getBeanFileName(String jobAppCd,
BatchJobData jobRecord)
Bean定義ファイル名取得.
|
protected String |
getBlogicBeanName(String jobAppCd)
実行するBLogicのBean名を取得する.
|
protected static String |
getDataSourceBeanFileName()
管理用Bean定義(データソース部)ファイル名を取得する。
|
protected org.springframework.context.ApplicationContext |
getDefaultApplicationContext()
システム用アプリケーションコンテキスト取得.
|
protected static String |
getDefaultBeanFileName()
管理用Bean定義(基本部)ファイル名を取得する。
|
protected String |
getDefaultExceptionHandlerBeanName()
デフォルトの例外ハンドラのBean名を取得する.
|
protected String |
getExceptionHandlerBeanName(String jobAppCd)
例外ハンドラのBean名を取得する.
|
protected Object |
getMethod(Object obj,
String methodName)
パラメータ設定.
|
QueryDAO |
getSysQueryDAO()
システム用queryDAO定義(ステータス参照・更新用)
|
org.springframework.transaction.PlatformTransactionManager |
getSysTransactionManager()
システム用transactionManager定義(ステータス参照・更新用)
|
UpdateDAO |
getSysUpdateDAO()
システム用updateDAO定義(ステータス参照・更新用)
|
protected String |
getThreadMessage()
スレッドグループとスレッド名を返すメソッド.
|
protected void |
init()
初期化
|
protected void |
initDefaultAppContext()
管理用に用いられるApplicationContextを初期化する.
|
protected void |
initDefaultErrorMessage()
エラーメッセージの初期化.
|
protected org.springframework.context.ApplicationContext |
initJobAppContext(String jobAppCd,
BatchJobData jobRecord)
ジョブ用ApplicationContextを初期化する.
|
protected void |
initSystemDatasourceDao()
システム共通で用いられるDAOをBean定義ファイルから取得する.
|
protected String |
replaceString(String value,
String jobAppCd,
BatchJobData jobRecord)
置換文字列を置換する
|
protected boolean |
setMethod(Object obj,
String methodName,
String argument)
パラメータ設定.
|
protected static final String ENV_JOB_BEAN_DEFINITION_PATH
protected static final int ENV_JOB_ARG_MAX
protected static final String ENV_BLOGIC_APP_STATUS
protected static final String SYSTEM_DATASOURCE_QUERY_DAO
protected static final String SYSTEM_DATASOURCE_UPDATE_DAO
protected static final String SYSTEM_DATASOURCE_TRANSACTION_MANAGER
protected static final String BEAN_DEFINITION_ADMIN_CLASSPATH_KEY
protected static final String BEAN_DEFINITION_DEFAULT
protected static final String BEAN_DEFINITION_DATASOURCE
protected static final String BEAN_DEFINITION_BUSINESS_CLASSPATH_KEY
protected static final String PROPERTY_BEAN_FILENAME_SUFFIX
protected static final String BEAN_MESSAGE_ACCESSOR_DEFAULT
protected static final String ENABLE_JOBCOMPONENT_ANNOTATION
protected static final String DEFAULT_BLOGIC_BEAN_NAME_SUFFIX
protected static final String DEFAULT_BLOGIC_EXCEPTION_HANDLER_BEAN_NAME_SUFFIX
protected static final String DEFAULT_BLOGIC_EXCEPTION_HANDLER_BEAN_NAME
protected static final String APPLICATION_CONTEXT
protected static final String REPLACE_STRING_JOB_APP_CD
protected static final String REPLACE_STRING_JOB_APP_CD_UPPER
protected static final String REPLACE_STRING_JOB_APP_CD_LOWER
protected static final int REPLACE_STRING_JOB_ARG_MAX
protected static final int ARGUMENT_COUNT
protected static ClassLoader cl
protected QueryDAO sysQueryDAO
protected UpdateDAO sysUpdateDAO
protected org.springframework.transaction.PlatformTransactionManager sysTransactionManager
protected org.springframework.context.ApplicationContext defaultApplicationContext
protected boolean enableJobComponentAnnotation
protected void init()
protected void initDefaultAppContext()
protected void initSystemDatasourceDao()
protected void initDefaultErrorMessage()
protected String getThreadMessage()
protected org.springframework.context.ApplicationContext initJobAppContext(String jobAppCd, BatchJobData jobRecord)
jobAppCd
- StringjobRecord
- BatchJobDataprotected void closeApplicationContext(org.springframework.context.ApplicationContext context)
context
- public BLogicResult executeBatch(BatchJobData jobRecord)
BatchExecutor
executeBatch
インタフェース内 BatchExecutor
jobRecord
- 実行するジョブレコードprotected BLogicParam convertBLogicParam(BatchJobData jobRecord)
jobRecord
- BatchJobDataprotected static String getDefaultBeanFileName()
protected static String getDataSourceBeanFileName()
protected BLogicResult executeBatchClass(String blogicBeanName, String exceptionHandlerBeanName, BLogicParam param, org.springframework.context.ApplicationContext context)
blogicBeanName
- ビジネスロジックBean名exceptionHandlerBeanName
- 例外ハンドラBean名param
- ビジネスロジックパラメータcontext
- コンテキストprotected boolean argumentCopy(Object from, Object to, String field)
from
- コピー元インスタンスto
- コピー先インスタンスfield
- フィールド名protected boolean setMethod(Object obj, String methodName, String argument)
obj
- 対象インスタンスmethodName
- メソッド名argument
- 引数protected Object getMethod(Object obj, String methodName)
obj
- 対象インスタンスmethodName
- メソッド名protected static org.springframework.context.ApplicationContext getApplicationContext(String... batchBeanFileName)
batchBeanFileName
- Bean定義ファイル名protected String getBeanFileName(String jobAppCd, BatchJobData jobRecord)
jobAppCd
- ジョブアプリケーションコードjobRecord
- BatchJobDataprotected String replaceString(String value, String jobAppCd, BatchJobData jobRecord)
value
- 入力文字列jobAppCd
- ジョブアプリケーションコードjobRecord
- BatchJobDataprotected String getBlogicBeanName(String jobAppCd)
jobAppCd
- ジョブアプリケーションコードprotected String getExceptionHandlerBeanName(String jobAppCd)
jobAppCd
- ジョブアプリケーションコードprotected String getDefaultExceptionHandlerBeanName()
protected org.springframework.context.ApplicationContext getDefaultApplicationContext()
public QueryDAO getSysQueryDAO()
public UpdateDAO getSysUpdateDAO()
public org.springframework.transaction.PlatformTransactionManager getSysTransactionManager()
Copyright © 2014 NTT DATA Corporation.