/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JSYejbECK0181B001TPDA * ソースファイル名：JSYejbECK0181B001TPDA.java * 作成者 ：EK909308 * 日付 ：2011年10月17日 *＜機能概要＞ * SQLFacility * テンプレートDBアクセス部品です。 *＜修正履歴＞ * バージョン 修正日 修正者 修正内容 * ｖ1.00.00 * ********************************************************************************/ package eo.ejb.cbs.sqlf; import com.fujitsu.futurity.model.base.CAANMsg; import com.fujitsu.futurity.model.base.CAANSQLFacility; import com.fujitsu.futurity.model.base.CAANRuntimeException; import com.fujitsu.futurity.model.base.CAANJDBCUtil; import com.fujitsu.futurity.model.ejb.common.JSYejbConnection; import com.fujitsu.futurity.model.ejb.common.JSYejbLog; import com.fujitsu.futurity.model.ejb.common.StatusCodes; import com.fujitsu.futurity.model.ejb.common.fw.TemplateDBAccessHandler; import com.fujitsu.futurity.model.ejb.common.fw.AgentDispatchContext; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import eo.common.constant.JPCModelConstant; import eo.ejb.cbs.cbsmsg.ECK0181B001CBSMsg; import eo.ejb.cbs.cbsmsg.ECK0181B001CBSMsg1List; import eo.ejb.cbm.entity.CK0181ETMsg; import eo.ejb.common.JKKejbPagingUtil; import eo.ejb.common.JZMModelCommon; /** * * テンプレートDBアクセス部品　ECK0181B001_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/ public class JSYejbECK0181B001TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{ /** * コンストラクタ */ public JSYejbECK0181B001TPDA() { } /** * ECK0181B001_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @return void */ public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){ // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt_Count = null; PreparedStatement pstmt_Page = null; // リザルトセット ResultSet rsltQuery_Count = null; ResultSet rsltQuery_Page = null; /******************** * SQL文の作成 ********************/ try{ //コネクション取得 con1 = JSYejbConnection.getConnection(CK0181ETMsg.getTableName()); // バインド変数設定値保持用領域 ArrayList arrayParam = new ArrayList(); // SQL文の作成(件数取得用) // (1) StringBuffer sql_BuffCount = new StringBuffer(); sql_BuffCount.append(" SELECT ") .append(" COUNT(*) AS CNT "); // SQL文の作成(ページングヘッダ) // (2) StringBuffer sql_BuffPageHeader = new StringBuffer(); sql_BuffPageHeader.append("SELECT * ") .append("FROM ( ") .append(" SELECT ALL_SELECT.*, ROWNUM AS LINE ") .append(" FROM ( "); // SQL文_基本部1 // (3) StringBuffer sql_BuffBase1 = new StringBuffer(); sql_BuffBase1.append(" SELECT CK0181.MANSION_OWNR_ID ") .append(" ,CK0181.MANSION_OWNR_NM ") .append(" ,CK0181.MANSION_OWNR_KANA ") .append(" ,CK0181.MANS_OWNR_SBT_CD ") .append(" ,CK0181.MANSION_OWNR_AD_CD ") .append(" ,CK0181.MANSION_OWNR_PCD ") .append(" ,CK0181.MANSION_OWNR_STATE_FSTNM ") .append(" ,CK0181.MANSION_OWNR_CITY_FSTNM ") .append(" ,CK0181.MANSION_OWNR_OAZTSU_FSTNM ") .append(" ,CK0181.MANSION_OWNR_AZCHO_FSTNM ") .append(" ,CK0181.MANSION_OWNR_BNCHIGO ") .append(" ,CK0181.MANSION_OWNR_RRKS_MEMO "); // SQL文_基本部2 // (4) StringBuffer sql_BuffBase2 = new StringBuffer(); sql_BuffBase2.append(" FROM CK_T_MANSION_OWNR CK0181 "); // SQL文_個別部1 // (5) StringBuffer sql_BuffUni1 = new StringBuffer(); if ( "1".equals( inMsg.getObject(ECK0181B001CBSMsg.FUNC_CODE).toString() ) ) { sql_BuffUni1.append(" WHERE CK0181.MK_FLG = '0' "); // サービスIF入力値：マンションオーナーIDが入力された場合 if(!inMsg.isNull(ECK0181B001CBSMsg.KEY_MANSION_OWNR_ID)) { // SQL文の結合 sql_BuffUni1.append(" AND CK0181.MANSION_OWNR_ID = ? "); // バインド変数設定リストの更新 arrayParam.add(inMsg.getObject(ECK0181B001CBSMsg.KEY_MANSION_OWNR_ID)); } // サービスIF入力値：マンションオーナー名が入力された場合 if(!inMsg.isNull(ECK0181B001CBSMsg.KEY_MANSION_OWNR_NM)) { // SQL文の結合 sql_BuffUni1.append(" AND CK0181.MANSION_OWNR_NM LIKE ? "); // エスケープ付与 sql_BuffUni1.append(JZMModelCommon.ESCAPE_SQL_STRING); // LIKE検索文字列置き換え処理後、バインド変数設定リストの更新 arrayParam.add("%" + JZMModelCommon.replaceLikeValue(inMsg.getObject(ECK0181B001CBSMsg.KEY_MANSION_OWNR_NM)) + "%"); } // サービスIF入力値：マンションオーナーカナ名が入力された場合 if(!inMsg.isNull(ECK0181B001CBSMsg.KEY_MANSION_OWNR_KANA)) { // SQL文の結合 sql_BuffUni1.append(" AND CK0181.MANSION_OWNR_KANA LIKE ? "); // エスケープ付与 sql_BuffUni1.append(JZMModelCommon.ESCAPE_SQL_STRING); // LIKE検索文字列置き換え処理後、バインド変数設定リストの更新 arrayParam.add("%" + JZMModelCommon.replaceLikeValue(inMsg.getObject(ECK0181B001CBSMsg.KEY_MANSION_OWNR_KANA)) + "%"); } // サービスIF入力値：マンションオーナー都道府県名が入力された場合 if(!inMsg.isNull(ECK0181B001CBSMsg.KEY_MANSION_OWNR_STATE_FSTNM)) { // SQL文の結合 sql_BuffUni1.append(" AND CK0181.MANSION_OWNR_STATE_FSTNM = ? "); // バインド変数設定リストの更新 arrayParam.add(inMsg.getObject(ECK0181B001CBSMsg.KEY_MANSION_OWNR_STATE_FSTNM)); } // サービスIF入力値：マンションオーナー市区町村名が入力された場合 if(!inMsg.isNull(ECK0181B001CBSMsg.KEY_MANSION_OWNR_CITY_FSTNM)) { // SQL文の結合 sql_BuffUni1.append(" AND CK0181.MANSION_OWNR_CITY_FSTNM LIKE ? "); // エスケープ付与 sql_BuffUni1.append(JZMModelCommon.ESCAPE_SQL_STRING); // LIKE検索文字列置き換え処理後、バインド変数設定リストの更新 arrayParam.add("%" + JZMModelCommon.replaceLikeValue(inMsg.getObject(ECK0181B001CBSMsg.KEY_MANSION_OWNR_CITY_FSTNM)) + "%"); } // サービスIF入力値：マンションオーナー大字通称名が入力された場合 if(!inMsg.isNull(ECK0181B001CBSMsg.KEY_MANSION_OWNR_OAZTSU_FSTNM)) { // SQL文の結合 sql_BuffUni1.append(" AND CK0181.MANSION_OWNR_OAZTSU_FSTNM LIKE ? "); // エスケープ付与 sql_BuffUni1.append(JZMModelCommon.ESCAPE_SQL_STRING); // LIKE検索文字列置き換え処理後、バインド変数設定リストの更新 arrayParam.add("%" + JZMModelCommon.replaceLikeValue(inMsg.getObject(ECK0181B001CBSMsg.KEY_MANSION_OWNR_OAZTSU_FSTNM)) + "%"); } // サービスIF入力値：マンションオーナー字丁目名が入力された場合 if(!inMsg.isNull(ECK0181B001CBSMsg.KEY_MANSION_OWNR_AZCHO_FSTNM)) { // SQL文の結合 sql_BuffUni1.append(" AND CK0181.MANSION_OWNR_AZCHO_FSTNM LIKE ? "); // エスケープ付与 sql_BuffUni1.append(JZMModelCommon.ESCAPE_SQL_STRING); // LIKE検索文字列置き換え処理後、バインド変数設定リストの更新 arrayParam.add("%" + JZMModelCommon.replaceLikeValue(inMsg.getObject(ECK0181B001CBSMsg.KEY_MANSION_OWNR_AZCHO_FSTNM)) + "%"); } // サービスIF入力値：マンションオーナー番地号が入力された場合 if(!inMsg.isNull(ECK0181B001CBSMsg.KEY_MANSION_OWNR_BNCHIGO)) { // SQL文の結合 sql_BuffUni1.append(" AND CK0181.MANSION_OWNR_BNCHIGO LIKE ? "); // エスケープ付与 sql_BuffUni1.append(JZMModelCommon.ESCAPE_SQL_STRING); // LIKE検索文字列置き換え処理後、バインド変数設定リストの更新 arrayParam.add("%" + JZMModelCommon.replaceLikeValue(inMsg.getObject(ECK0181B001CBSMsg.KEY_MANSION_OWNR_BNCHIGO)) + "%"); } } // SQL文_ORDER BY部 // (6) StringBuffer sql_BuffOrder = new StringBuffer(); sql_BuffOrder.append(" ORDER BY CK0181.MANSION_OWNR_ID ASC "); // SQL文の作成(ページングフッタ) // (7) StringBuffer sql_BuffPageFooter = new StringBuffer(); sql_BuffPageFooter.append(" ) ALL_SELECT ") .append(" ) PAGE_SELECT ") .append(" WHERE PAGE_SELECT.LINE BETWEEN ? AND ? ") .append(" ORDER BY PAGE_SELECT.LINE ASC "); // SQL文の組立て(件数取得用) (1) + (4) + (5) StringBuffer sql_getCount = new StringBuffer(); sql_getCount.append(sql_BuffCount) .append(sql_BuffBase2) .append(sql_BuffUni1); // prepareStatementにSQL文をセット pstmt_Count = con1.prepareStatement(sql_getCount.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_getCount); // バインド変数設定順制御用変数 int iParamCntr = 0; // PreparedStatementの指定されたパラメータカラムに 指定された値を設定 if ( "1".equals( inMsg.getString(ECK0181B001CBSMsg.FUNC_CODE) ) ) { for(iParamCntr = 0; iParamCntr < arrayParam.size(); iParamCntr++) { // バインド変数に設定 CAANJDBCUtil.setParam(pstmt_Count, (iParamCntr + 1), arrayParam.get(iParamCntr)); } } // ResultSetの取得 rsltQuery_Count = pstmt_Count.executeQuery(); // 総検索件数を取得する Long iDataCnt = 0L; if (rsltQuery_Count.next()) { iDataCnt = rsltQuery_Count.getLong("CNT"); } // 表示件数 Long iDispNum = inMsg.getStringAsLong(ECK0181B001CBSMsg.DISPLAY_NUM); // 表示ページ数 Long iDispPage = inMsg.getStringAsLong(ECK0181B001CBSMsg.DISPLAY_PAGE_NUM); // 最大取得件数 long lMaxNum = inMsg.getStringAsLong(ECK0181B001CBSMsg.MAX_SEARCH_NUM); // 総ページ数 String strMaxPage = JKKejbPagingUtil.calcTotalPage(iDataCnt, iDispNum); // 共通部に値を設定する // 総検索件数 inMsg.set(ECK0181B001CBSMsg.TOTAL_SEARCH_NUM, String.valueOf(iDataCnt)); // 総ページ数 inMsg.set(ECK0181B001CBSMsg.TOTAL_PAGE_NUM, strMaxPage); // データ取得件数が0件の場合エラー if (0L == iDataCnt) { inMsg.set(ECK0181B001CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_ZERO); return; } // 最大取得件数を超えた場合エラー if (iDataCnt > lMaxNum) { inMsg.set(ECK0181B001CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_OVERMAX); return; } // SQL文の組立て(項目取得・ページング用)(2) + (3) + (4) + (5) + (6) + (7) StringBuffer sql_getPage = new StringBuffer(); sql_getPage.append(sql_BuffPageHeader) .append(sql_BuffBase1) .append(sql_BuffBase2) .append(sql_BuffUni1) .append(sql_BuffOrder) .append(sql_BuffPageFooter); // prepareStatementにSQL文をセット pstmt_Page = con1.prepareStatement(sql_getPage.toString()); // ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_getPage); // 検索対象を算出する long[] iPages = JKKejbPagingUtil.calcSearchRows(iDispPage, iDispNum); long iRowSta = iPages[0]; long iRowEnd = iPages[1]; // PreparedStatementの指定されたパラメータカラムに 指定された値を設定 if ( "1".equals( inMsg.getString(ECK0181B001CBSMsg.FUNC_CODE))) { // パラメータの設定 for(iParamCntr = 0; iParamCntr < arrayParam.size(); iParamCntr++) { // バインド変数に設定 CAANJDBCUtil.setParam(pstmt_Page, (iParamCntr + 1), arrayParam.get(iParamCntr)); } // パラメータの設定(検索開始行を指定) CAANJDBCUtil.setParam(pstmt_Page, ++iParamCntr, iRowSta); // パラメータの設定(検索終了行を指定) CAANJDBCUtil.setParam(pstmt_Page, ++iParamCntr, iRowEnd); } // ResultSetの取得 rsltQuery_Page = pstmt_Page.executeQuery(); // ECK0181B001CBSMsgの明細にセットする項目 String[] msgKeyList1 = { ECK0181B001CBSMsg1List.MANSION_OWNR_ID , ECK0181B001CBSMsg1List.MANSION_OWNR_NM , ECK0181B001CBSMsg1List.MANSION_OWNR_KANA , ECK0181B001CBSMsg1List.MANS_OWNR_SBT_CD , ECK0181B001CBSMsg1List.MANSION_OWNR_AD_CD , ECK0181B001CBSMsg1List.MANSION_OWNR_PCD , ECK0181B001CBSMsg1List.MANSION_OWNR_STATE_FSTNM , ECK0181B001CBSMsg1List.MANSION_OWNR_CITY_FSTNM , ECK0181B001CBSMsg1List.MANSION_OWNR_OAZTSU_FSTNM , ECK0181B001CBSMsg1List.MANSION_OWNR_AZCHO_FSTNM , ECK0181B001CBSMsg1List.MANSION_OWNR_BNCHIGO , ECK0181B001CBSMsg1List.MANSION_OWNR_RRKS_MEMO }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery_Page,msgKeyList1,"eo.ejb.cbs.cbsmsg.ECK0181B001CBSMsg1List",0); // 取得結果が0件の場合は表示ページ該当なしエラー if (0L == outMsg1.length) { inMsg.set(ECK0181B001CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_NODATA); return; } // inMsg(CBSMsg)に明細をセット inMsg.set("ECK0181B001CBSMsg1List", outMsg1); } catch(SQLException e) { inMsg.set(ECK0181B001CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // 資源の解放 try{ if(rsltQuery_Count != null){ rsltQuery_Count.close(); } if(rsltQuery_Page != null){ rsltQuery_Page.close(); } if(pstmt_Count != null){ pstmt_Count.close(); } if(pstmt_Page != null){ pstmt_Page.close(); } if(con1 != null){ closeConnection(con1); } }catch(SQLException e){ inMsg.set(ECK0181B001CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } }