*
* @author 富士通
*/
public class JBSbatZMphysicsDel extends JBSbatBusinessService
{
/**▼▼▼▼▼▼ツールから生成した宣言です 開始▼▼▼▼▼▼*/
/** テーブル(物理削除バッチ管理)*/
private static final String D_TBL_NAME_ZM_M_BTRIDELBAT_KNRI = "ZM_M_BTRIDELBAT_KNRI";
/** SQL定義キー(ZM_SELECT_001)*/
private static final String ZM_M_BTRIDELBAT_KNRI_ZM_SELECT_001 = "ZM_SELECT_001";
/** テーブルアクセスクラス(物理削除バッチ管理)*/
private JBSbatSQLAccess db_ZM_M_BTRIDELBAT_KNRI = null;
/** 削除するテーブルアクセスクラス */
private JBSbatSQLAccess db_DEL_TABLE = null;
/**▲▲▲▲▲▲ツールから生成した宣言です 終了▲▲▲▲▲▲*/
private static final String MK_FLG_JUDGE = "1";
/**
* エラーログ出力メッセージID
*/
private static final String ERR_LOG_MSG_ID = "EZMB0260AW";
/**
* 初期処理
* @param JBSbatCommonItem commonItem バッチ共通パラメータ電文
* @throws Exception
*/
public void initial(JBSbatCommonItem commonItem) throws Exception
{
/**▼▼▼▼▼▼業務サービスの初期処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した初期化のソースです 開始▼▼▼▼▼▼*/
// 共通パラメータを設定します
super.setCommonInfo(commonItem);
// DBアクセスクラスを生成します
db_ZM_M_BTRIDELBAT_KNRI = new JBSbatSQLAccess(commonItem, D_TBL_NAME_ZM_M_BTRIDELBAT_KNRI);
/**▲▲▲▲▲▲ツールから生成した初期化のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの初期処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 主処理
* @return JBSbatOutputItem 出力情報
* @throws Exception
*/
public JBSbatOutputItem execute() throws Exception
{
/**▼▼▼▼▼▼業務サービスの主処理を記述してください。▼▼▼▼▼▼*/
JBSbatCommonDBInterface delSettingInfo = new JBSbatCommonDBInterface();
//スキーマ名
String schemaName = null;
//基準項目
String fieldName = null;
//保存期間
String savePrd = null;
//無効フラグ判断用フラグ
String mkFlg = null;
//削除基準日
String stdDate = null;
/**
* 物理削除バッチ管理テーブルから削除するテーブルに関する情報を取得
*/
executeZM_M_BTRIDELBAT_KNRI_ZM_SELECT_001(null);
while( (delSettingInfo = db_ZM_M_BTRIDELBAT_KNRI.selectNext()) != null)
{
/**
* テーブル名取得
* 条件 カラム取得
*/
//スキーマ名
schemaName = delSettingInfo.getString(JBSbatZM_M_BTRIDELBAT_KNRI.NAIBU_SCHEMA_NM);
super.logPrint.printDebugLog("スキーマ名：" + schemaName);
//基準項目
fieldName = delSettingInfo.getString(JBSbatZM_M_BTRIDELBAT_KNRI.STDARD_KMK_NM);
super.logPrint.printDebugLog("基準項目：" + fieldName);
//保存期間
savePrd = delSettingInfo.getString(JBSbatZM_M_BTRIDELBAT_KNRI.SAVE_PRD);
super.logPrint.printDebugLog("保存期間：" + savePrd);
//無効フラグ判定用フラグ
mkFlg = delSettingInfo.getString(JBSbatZM_M_BTRIDELBAT_KNRI.MK_JDG_FLG);
super.logPrint.printDebugLog("無効フラグ判定用フラグ" + mkFlg);
/**
* SQL文の組み立て
*/
String sqlbuf = createSql(schemaName, fieldName, savePrd, mkFlg);
/**
* SQL文（delete）実行
*/
//削除用 DBアクセスクラス
db_DEL_TABLE = new JBSbatSQLAccess(commonItem,schemaName);
//PreparedStatement取得
PreparedStatement pstatmt = db_DEL_TABLE.createStatement(sqlbuf.toString());
try
{
//SQL文実行
pstatmt.executeUpdate();
//設定されたテーブル毎にコミット
super.commit();
}
catch(SQLException sqle)
{
//エラー処理
super.logPrint.printDebugLog( sqle.getMessage() );
//ログ出力
super.logPrint.printLogMsg(ERR_LOG_MSG_ID);
}
}
return null;
/**▲▲▲▲▲▲業務サービスの主処理を記述してください。▲▲▲▲▲▲*/
}
/**
* 業務サービス終了処理
* @throws Exception
*/
public void terminal() throws Exception
{
/**▼▼▼▼▼▼業務サービスの終了処理を記述してください。▼▼▼▼▼▼*/
/**▼▼▼▼▼▼ツールから生成した終了処理のソースです 開始▼▼▼▼▼▼*/
// DBアクセスクラスをクローズします
db_ZM_M_BTRIDELBAT_KNRI.close();
/**▲▲▲▲▲▲ツールから生成した終了処理のソースです 終了▲▲▲▲▲▲*/
/**▲▲▲▲▲▲業務サービスの終了処理を記述してください。▲▲▲▲▲▲*/
}
/**▼▼▼▼▼▼ツールから生成したメソッドです 開始▼▼▼▼▼▼*/
/**
* SQLKEY(ZM_SELECT_001)でDBアクセスを行います。
*
* 処理フロー
*
* 1.引数でバイント変数を設定します。*
* * 2.DBアクセスを実行します。
* * 3.メソッドの呼び出し方です。
* 引数: * param:順にバイント変数の値をparam配列に入れます。バイント変数は以下に説明します。 *
* @param param バイント変数の値配列。
* @throws Exception 業務サービス内で発生した例外全般。
*/
private void executeZM_M_BTRIDELBAT_KNRI_ZM_SELECT_001(Object[] param) throws Exception
{
// バイント変数のリストを生成します
JBSbatCommonDBInterface paramList = new JBSbatCommonDBInterface();
// DBアクセスを実行します
db_ZM_M_BTRIDELBAT_KNRI.selectBySqlDefine(paramList, ZM_M_BTRIDELBAT_KNRI_ZM_SELECT_001);
}
/**▲▲▲▲▲▲ツールから生成したメソッドです 終了▲▲▲▲▲▲*/
/**
* 物理削除 SQL文の作成を行います。
*
* @param schemaName 内部スキーマ名
* @param fieldName 基準フィールド名
* @param savePrd 削除基準日
* @param mkFlg 無効フラグ判定用フラグ
* @return String SQL文
*/
private String createSql(String schemaName, String fieldName, String savePrd, String mkFlg)
{
StringBuffer sqlBuff = new StringBuffer();
//SQL文作成
sqlBuff.append(" DELETE FROM ")
.append(" " + schemaName + " TBL ")
.append("WHERE ")
.append(" TO_DATE(" + commonItem.getOpeDate() + ") - TO_DATE( SUBSTR(TBL." + fieldName + " , 1 , 8 ) ) > " + savePrd);
if(MK_FLG_JUDGE.equals(mkFlg))
{
sqlBuff.append(" AND TBL.MK_FLG = '1'");
}
//デバックログ出力
super.logPrint.printDebugLog(sqlBuff.toString());
return sqlBuff.toString();
}
}