/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名 ：eo顧客基幹システム * モジュール名 ：JSYejbEKK0861B001TPDA * ソースファイル名：JSYejbEKK0861B001TPDA.java * 作成者 ：EK907441 * 日付 ：2011年10月18日 *＜機能概要＞ * 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.EKK0861B001CBSMsg; import eo.ejb.cbs.cbsmsg.EKK0861B001CBSMsg1List; import eo.ejb.cbm.entity.KK0861ETMsg; import eo.ejb.common.JKKModelCommon; import eo.ejb.common.JKKejbPagingUtil; import eo.ejb.common.JZMModelCommon; /** * * テンプレートDBアクセス部品　EKK0861B001_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/ public class JSYejbEKK0861B001TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{ /** * コンストラクタ */ public JSYejbEKK0861B001TPDA() { } /** * EKK0861B001_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(KK0861ETMsg.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 ") .append(" KK0861.MANSION_BUKKEN_NO ") .append(" , KK0861.MANSION_BUKKEN_CD ") .append(" , KK0871.OWNR_KEI_NO ") .append(" , KK0871.PID ") .append(" , KK0881.KAISEN_USE_KEI_NO ") .append(" , KK0881.MANSION_ID ") .append(" , KK0861.MANSION_NM ") .append(" , KK0861.MANSION_KANA ") .append(" , KK0861.MANSION_BUKKEN_PCD ") .append(" , KK0861.MANSION_BUKKEN_STATE_NM ") .append(" , KK0861.MANSION_BUKKEN_CITY_NM ") .append(" , KK0861.MANS_BUKKEN_OAZTSU_NM ") .append(" , KK0861.MANSION_BUKKEN_AZCHO_NM ") .append(" , KK0901.MANSION_SVC_MENU_NM ") .append(" , KK0911.MANSION_COURSE_NM ") .append(" , KK0921.MANSION_PLAN_NM ") .append(" , KK0891.KANYU_KEI_PAY_HOSHIKI_CD ") .append(" , KK0871.MANSION_SVC_MENU_CD ") .append(" , KK0881.MANSION_COURSE_CD ") .append(" , KK0891.MANSION_PLAN_CD ") .append(" , KK0861.MANSION_BUKKEN_BNCHIGO "); // SQL文_基本部2 // (4) StringBuffer sql_BuffBase2 = new StringBuffer(); sql_BuffBase2.append(" FROM ") .append(" KK_T_MANSION_BUKKEN KK0861 ") .append(" INNER JOIN KK_T_OWNR_KEI KK0871 ON KK0861.MANSION_BUKKEN_NO = KK0871.MANSION_BUKKEN_NO ") .append(" INNER JOIN KK_T_KAISEN_USE_KEI KK0881 ON KK0871.OWNR_KEI_NO = KK0881.OWNR_KEI_NO ") .append(" INNER JOIN KK_T_TK_HOSHIKI_KEI KK0891 ON KK0881.KAISEN_USE_KEI_NO = KK0891.KAISEN_USE_KEI_NO ") .append(" INNER JOIN KK_M_MANS_SVC_MENU KK0901 ON KK0871.MANSION_SVC_MENU_CD = KK0901.MANSION_SVC_MENU_CD ") .append(" INNER JOIN KK_M_MANSION_COURSE KK0911 ON KK0881.MANSION_COURSE_CD = KK0911.MANSION_COURSE_CD ") .append(" INNER JOIN KK_M_MANSION_PLAN KK0921 ON KK0891.MANSION_PLAN_CD = KK0921.MANSION_PLAN_CD "); // SQL文_個別部1 // (5) StringBuffer sql_BuffUni1 = new StringBuffer(); sql_BuffUni1.append(" WHERE ") .append(" KK0861.MK_FLG = '0' "); // サービスIF入力値：ＫＥＹ＿マンション物件番号が入力された場合 if(!inMsg.isNull(EKK0861B001CBSMsg.KEY_MANSION_BUKKEN_NO)) { // SQL文の結合 sql_BuffUni1.append(" AND KK0861.MANSION_BUKKEN_NO = ? "); // バインド変数設定リストの更新 arrayParam.add(inMsg.getObject(EKK0861B001CBSMsg.KEY_MANSION_BUKKEN_NO)); } // サービスIF入力値：ＫＥＹ＿マンション物件コードが入力された場合 if(!inMsg.isNull(EKK0861B001CBSMsg.KEY_MANSION_BUKKEN_CD)) { // SQL文の結合 sql_BuffUni1.append(" AND KK0861.MANSION_BUKKEN_CD = ? "); // バインド変数設定リストの更新 arrayParam.add(inMsg.getObject(EKK0861B001CBSMsg.KEY_MANSION_BUKKEN_CD)); } // サービスIF入力値：ＫＥＹ＿マンション物件番地号が入力された場合 if(!inMsg.isNull(EKK0861B001CBSMsg.KEY_MANSION_BUKKEN_BNCHIGO)) { // SQL文の結合 sql_BuffUni1.append(" AND KK0861.MANSION_BUKKEN_BNCHIGO LIKE ? "); // エスケープ付与 sql_BuffUni1.append(JZMModelCommon.ESCAPE_SQL_STRING); // バインド変数設定リストの更新 arrayParam.add("%" + JZMModelCommon.replaceLikeValue(inMsg.getObject(EKK0861B001CBSMsg.KEY_MANSION_BUKKEN_BNCHIGO)) + "%"); } // サービスIF入力値：ＫＥＹ＿マンション名が入力された場合 if(!inMsg.isNull(EKK0861B001CBSMsg.KEY_MANSION_NM)) { // SQL文の結合 sql_BuffUni1.append(" AND KK0861.MANSION_NM LIKE ? "); // エスケープ付与 sql_BuffUni1.append(JZMModelCommon.ESCAPE_SQL_STRING); // バインド変数設定リストの更新 arrayParam.add("%" + JZMModelCommon.replaceLikeValue(inMsg.getObject(EKK0861B001CBSMsg.KEY_MANSION_NM)) + "%"); } // サービスIF入力値：ＫＥＹ＿マンションカナ名が入力された場合 if(!inMsg.isNull(EKK0861B001CBSMsg.KEY_MANSION_KANA)) { // SQL文の結合 sql_BuffUni1.append(" AND KK0861.MANSION_KANA LIKE ? "); // エスケープ付与 sql_BuffUni1.append(JZMModelCommon.ESCAPE_SQL_STRING); // バインド変数設定リストの更新 arrayParam.add("%" + JZMModelCommon.replaceLikeValue(inMsg.getObject(EKK0861B001CBSMsg.KEY_MANSION_KANA)) + "%"); } // サービスIF入力値：ＫＥＹ＿マンション物件都道府県名が入力された場合 if(!inMsg.isNull(EKK0861B001CBSMsg.KEY_MANSION_BUKKEN_STATE_NM)) { // SQL文の結合 sql_BuffUni1.append(" AND KK0861.MANSION_BUKKEN_STATE_NM = ? "); // バインド変数設定リストの更新 arrayParam.add(inMsg.getObject(EKK0861B001CBSMsg.KEY_MANSION_BUKKEN_STATE_NM)); } // サービスIF入力値：ＫＥＹ＿マンション物件市区町村名が入力された場合 if(!inMsg.isNull(EKK0861B001CBSMsg.KEY_MANSION_BUKKEN_CITY_NM)) { // SQL文の結合 sql_BuffUni1.append(" AND KK0861.MANSION_BUKKEN_CITY_NM LIKE ? "); // エスケープ付与 sql_BuffUni1.append(JZMModelCommon.ESCAPE_SQL_STRING); // バインド変数設定リストの更新 arrayParam.add("%" + JZMModelCommon.replaceLikeValue(inMsg.getObject(EKK0861B001CBSMsg.KEY_MANSION_BUKKEN_CITY_NM)) + "%"); } // サービスIF入力値：ＫＥＹ＿マンション物件大字通称名が入力された場合 if(!inMsg.isNull(EKK0861B001CBSMsg.KEY_MANS_BUKKEN_OAZTSU_NM)) { // SQL文の結合 sql_BuffUni1.append(" AND KK0861.MANS_BUKKEN_OAZTSU_NM LIKE ? "); // エスケープ付与 sql_BuffUni1.append(JZMModelCommon.ESCAPE_SQL_STRING); // バインド変数設定リストの更新 arrayParam.add("%" + JZMModelCommon.replaceLikeValue(inMsg.getObject(EKK0861B001CBSMsg.KEY_MANS_BUKKEN_OAZTSU_NM)) + "%"); } // サービスIF入力値：ＫＥＹ＿マンション物件字丁目名が入力された場合 if(!inMsg.isNull(EKK0861B001CBSMsg.KEY_MANSION_BUKKEN_AZCHO_NM)) { // SQL文の結合 sql_BuffUni1.append(" AND KK0861.MANSION_BUKKEN_AZCHO_NM LIKE ? "); // エスケープ付与 sql_BuffUni1.append(JZMModelCommon.ESCAPE_SQL_STRING); // バインド変数設定リストの更新 arrayParam.add("%" + JZMModelCommon.replaceLikeValue(inMsg.getObject(EKK0861B001CBSMsg.KEY_MANSION_BUKKEN_AZCHO_NM)) + "%"); } // サービスIF入力値：ＫＥＹ＿Ｐ−ＩＤが入力された場合 if(!inMsg.isNull(EKK0861B001CBSMsg.KEY_PID)) { // SQL文の結合 sql_BuffUni1.append(" AND KK0871.PID = ? "); // バインド変数設定リストの更新 arrayParam.add(inMsg.getObject(EKK0861B001CBSMsg.KEY_PID)); } sql_BuffUni1.append(" AND KK0871.MK_FLG = '0' "); // サービスIF入力値：ＫＥＹ＿マンションIDが入力された場合 if(!inMsg.isNull(EKK0861B001CBSMsg.KEY_MANSION_ID)) { // SQL文の結合 sql_BuffUni1.append(" AND KK0881.MANSION_ID = ? "); // バインド変数設定リストの更新 arrayParam.add(inMsg.getObject(EKK0861B001CBSMsg.KEY_MANSION_ID)); } sql_BuffUni1.append(" AND KK0881.MK_FLG = '0' ") .append(" AND KK0891.MK_FLG = '0' ") .append(" AND (KK0901.MANSION_SVC_MENU_CD, KK0901.RSV_APLY_YMD || KK0901.GENE_ADD_DTM) = ") .append(" (SELECT KK0901_GENE.MANSION_SVC_MENU_CD, MAX(KK0901_GENE.RSV_APLY_YMD || KK0901_GENE.GENE_ADD_DTM) ") .append(" FROM KK_M_MANS_SVC_MENU KK0901_GENE ") .append(" WHERE KK0901_GENE.MANSION_SVC_MENU_CD = KK0901.MANSION_SVC_MENU_CD ") .append(" AND KK0901_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0901_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0901_GENE.MANSION_SVC_MENU_CD) ") .append(" AND (KK0911.MANSION_COURSE_CD, KK0911.RSV_APLY_YMD || KK0911.GENE_ADD_DTM) = ") .append(" (SELECT KK0911_GENE.MANSION_COURSE_CD, MAX(KK0911_GENE.RSV_APLY_YMD || KK0911_GENE.GENE_ADD_DTM) ") .append(" FROM KK_M_MANSION_COURSE KK0911_GENE ") .append(" WHERE KK0911_GENE.MANSION_COURSE_CD = KK0911.MANSION_COURSE_CD ") .append(" AND KK0911_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0911_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0911_GENE.MANSION_COURSE_CD) ") .append(" AND (KK0921.MANSION_PLAN_CD, KK0921.RSV_APLY_YMD || KK0921.GENE_ADD_DTM) = ") .append(" (SELECT KK0921_GENE.MANSION_PLAN_CD, MAX(KK0921_GENE.RSV_APLY_YMD || KK0921_GENE.GENE_ADD_DTM) ") .append(" FROM KK_M_MANSION_PLAN KK0921_GENE ") .append(" WHERE KK0921_GENE.MANSION_PLAN_CD = KK0921.MANSION_PLAN_CD ") .append(" AND KK0921_GENE.RSV_APLY_YMD <= ? ") .append(" AND KK0921_GENE.MK_FLG = '0' ") .append(" GROUP BY KK0921_GENE.MANSION_PLAN_CD) "); // バインド変数設定リストの更新 arrayParam.add(JKKModelCommon.getOpeDate(inMsg)); arrayParam.add(JKKModelCommon.getOpeDate(inMsg)); arrayParam.add(JKKModelCommon.getOpeDate(inMsg)); // SQL文_ORDER BY部 // (6) StringBuffer sql_BuffOrder = new StringBuffer(); sql_BuffOrder.append(" ORDER BY KK0871.PID ASC ") .append(" , KK0881.MANSION_ID ASC ") .append(" , KK0871.MANSION_SVC_MENU_CD ASC ") .append(" , KK0881.MANSION_COURSE_CD ASC ") .append(" , KK0891.MANSION_PLAN_CD 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の指定されたパラメータカラムに 指定された値を設定 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(EKK0861B001CBSMsg.DISPLAY_NUM); // 表示ページ数 Long iDispPage = inMsg.getStringAsLong(EKK0861B001CBSMsg.DISPLAY_PAGE_NUM); // 総ページ数 String strMaxPage = JKKejbPagingUtil.calcTotalPage(iDataCnt, iDispNum); // 共通部に値を設定する // 総検索件数 inMsg.set(EKK0861B001CBSMsg.TOTAL_SEARCH_NUM, String.valueOf(iDataCnt)); // 総ページ数 inMsg.set(EKK0861B001CBSMsg.TOTAL_PAGE_NUM, strMaxPage); // 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の指定されたパラメータカラムに 指定された値を設定 // パラメータの設定 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(); // EKK0861B001CBSMsgの明細にセットする項目 String[] msgKeyList1 = { EKK0861B001CBSMsg1List.MANSION_BUKKEN_NO , EKK0861B001CBSMsg1List.MANSION_BUKKEN_CD , EKK0861B001CBSMsg1List.OWNR_KEI_NO , EKK0861B001CBSMsg1List.PID , EKK0861B001CBSMsg1List.KAISEN_USE_KEI_NO , EKK0861B001CBSMsg1List.MANSION_ID , EKK0861B001CBSMsg1List.MANSION_NM , EKK0861B001CBSMsg1List.MANSION_KANA , EKK0861B001CBSMsg1List.MANSION_BUKKEN_PCD , EKK0861B001CBSMsg1List.MANSION_BUKKEN_STATE_NM , EKK0861B001CBSMsg1List.MANSION_BUKKEN_CITY_NM , EKK0861B001CBSMsg1List.MANS_BUKKEN_OAZTSU_NM , EKK0861B001CBSMsg1List.MANSION_BUKKEN_AZCHO_NM , EKK0861B001CBSMsg1List.MANSION_SVC_MENU_NM , EKK0861B001CBSMsg1List.MANSION_COURSE_NM , EKK0861B001CBSMsg1List.MANSION_PLAN_NM , EKK0861B001CBSMsg1List.KANYU_KEI_PAY_HOSHIKI_CD , EKK0861B001CBSMsg1List.MANSION_SVC_MENU_CD , EKK0861B001CBSMsg1List.MANSION_COURSE_CD , EKK0861B001CBSMsg1List.MANSION_PLAN_CD , EKK0861B001CBSMsg1List.MANSION_BUKKEN_BNCHIGO }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery_Page,msgKeyList1,"eo.ejb.cbs.cbsmsg.EKK0861B001CBSMsg1List",0); // 取得結果が0件の場合は表示ページ該当なしエラー if (0L == outMsg1.length) { inMsg.set(EKK0861B001CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_NODATA); return; } // inMsg(CBSMsg)に明細をセット inMsg.set("EKK0861B001CBSMsg1List", outMsg1); } catch(SQLException e) { inMsg.set(EKK0861B001CBSMsg.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(EKK0861B001CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } }