/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名：eo顧客基幹システム * モジュール名：JSYejbEZM0081B014TPDA * ソースファイル名：JSYejbEZM0081B014TPDA.java * 作成者：EK908588 * 日付：2011年06月06日 *＜機能概要＞ * SQLFacility * テンプレートDBアクセス部品です。 *＜修正履歴＞ * バージョン修正日修正者修正内容 * ｖ1.00.00 * v23.00.00 2016/03/18 FJ) 謝【OM-2016-0000682】対応 * ********************************************************************************/ package eo.ejb.cbs.sqlf; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import com.fujitsu.futurity.model.base.CAANJDBCUtil; import com.fujitsu.futurity.model.base.CAANMsg; import com.fujitsu.futurity.model.base.CAANRuntimeException; import com.fujitsu.futurity.model.base.CAANSQLFacility; 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.AgentDispatchContext; import com.fujitsu.futurity.model.ejb.common.fw.TemplateDBAccessHandler; import eo.common.constant.JPCModelConstant; import eo.ejb.cbm.entity.ZM0081ETMsg; import eo.ejb.cbs.cbsmsg.EZM0081B014CBSMsg; import eo.ejb.cbs.cbsmsg.EZM0081B014CBSMsg1List; /** * * テンプレートDBアクセス部品　EZM0081B014_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/ public class JSYejbEZM0081B014TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{ /** * コンストラクタ */ public JSYejbEZM0081B014TPDA() { } /** * EZM0081B014_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @return void */ public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){ // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt = null; // リザルトセット ResultSet rsltQuery = null; /******************** * SQL文の作成 ********************/ try{ //コネクション取得 con1 = JSYejbConnection.getConnection(ZM0081ETMsg.getTableName()); /* ++++++++++ v1.0.0 追加開始 ++++++++++ */ // 総検索件数の取得 // SQL文_基本部1 StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT ") .append(" COUNT(*) AS CNT ") .append(" FROM ") .append(" ZM_M_AD JUSHO "); // SQL文_個別部1 if ( "1".equals( inMsg.getObject(EZM0081B014CBSMsg.FUNC_CODE).toString() ) ) { sql_Buff.append(" WHERE ") .append(" JUSHO.AD_CD >= ? ") .append(" AND ") .append(" JUSHO.AD_CD <= ? ") .append(" AND ") .append(" JUSHO.RSV_APLY_YMD = ") .append(" (SELECT MAX(JUSHO_02.RSV_APLY_YMD) AS RSV_APLY_YMD_MAX ") .append(" FROM ZM_M_AD JUSHO_02 ") .append(" WHERE JUSHO_02.AD_CD = JUSHO.AD_CD ") // OM-2016-0000682 MOD START // .append(" AND JUSHO_02.MK_FLG = '0') "); .append(" AND JUSHO_02.MK_FLG = '0') ") .append(" AND ") .append(" JUSHO.MK_FLG = '0' "); // OM-2016-0000682 MOD END } //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // PreparedStatementの指定されたパラメータカラムに指定された値を設定 if ( "1".equals( inMsg.getString(EZM0081B014CBSMsg.FUNC_CODE) ) ) { // パラメータの設定(ＫＥＹ＿開始住所コードを指定) CAANJDBCUtil.setParam(pstmt, 1, inMsg.getObject(EZM0081B014CBSMsg.KEY_STA_AD_CD)); // パラメータの設定(ＫＥＹ＿終了住所コードを指定) CAANJDBCUtil.setParam(pstmt, 2, inMsg.getObject(EZM0081B014CBSMsg.KEY_END_AD_CD)); } // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // EZM0081B999CBSMsgの明細にセットする項目 String[] msgKeyList1 = { EZM0081B014CBSMsg.TOTAL_SEARCH_NUM }; rsltQuery.next(); mapMessage(rsltQuery, msgKeyList1, inMsg); // 検索件数が0件の場合、エラーフラグに"1"を設定して処理終了 if (0 == (Integer.parseInt(inMsg.getString(EZM0081B014CBSMsg.TOTAL_SEARCH_NUM)))) { inMsg.set(EZM0081B014CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_ZERO); return; } // 検索件数が最大検索件数を超えた場合、エラーフラグに"2"を設定して処理終了 if (Integer.parseInt(inMsg.getString(EZM0081B014CBSMsg.MAX_SEARCH_NUM)) < (Integer.parseInt(inMsg.getString(EZM0081B014CBSMsg.TOTAL_SEARCH_NUM)))) { inMsg.set(EZM0081B014CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_OVERMAX); return; } if(rsltQuery != null){ rsltQuery.close(); } if(pstmt != null){ pstmt.close(); } // データの取得 // SQL文_基本部1 sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT ") .append(" JUSHO.AD_CD, ") .append(" JUSHO.GENE_ADD_DTM, ") .append(" JUSHO.PCD, ") .append(" JUSHO.STATE_NM, ") .append(" JUSHO.CITY_NM, ") .append(" JUSHO.OAZTSU_NM, ") .append(" JUSHO.AZCHO_NM ") .append(" FROM ") .append(" ZM_M_AD JUSHO "); // SQL文_個別部1 if ( "1".equals( inMsg.getObject(EZM0081B014CBSMsg.FUNC_CODE).toString() ) ) { sql_Buff.append(" WHERE ") .append(" JUSHO.AD_CD >= ? ") .append(" AND ") .append(" JUSHO.AD_CD <= ? ") .append(" AND ") .append(" JUSHO.RSV_APLY_YMD = ") .append(" (SELECT MAX(JUSHO_02.RSV_APLY_YMD) AS RSV_APLY_YMD_MAX ") .append(" FROM ZM_M_AD JUSHO_02 ") .append(" WHERE JUSHO_02.AD_CD = JUSHO.AD_CD ") // OM-2016-0000682 MOD START // .append(" AND JUSHO_02.MK_FLG = '0') "); .append(" AND JUSHO_02.MK_FLG = '0') ") .append(" AND ") .append(" JUSHO.MK_FLG = '0' "); // OM-2016-0000682 MOD END } sql_Buff.append(" ORDER BY JUSHO.AD_CD "); /* ++++++++++ v1.0.0 追加終了 ++++++++++ */ //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // PreparedStatementの指定されたパラメータカラムに指定された値を設定 if ( "1".equals( inMsg.getString(EZM0081B014CBSMsg.FUNC_CODE) ) ) { // パラメータの設定(ＫＥＹ＿開始住所コードを指定) CAANJDBCUtil.setParam(pstmt, 1, inMsg.getObject(EZM0081B014CBSMsg.KEY_STA_AD_CD)); // パラメータの設定(ＫＥＹ＿終了住所コードを指定) CAANJDBCUtil.setParam(pstmt, 2, inMsg.getObject(EZM0081B014CBSMsg.KEY_END_AD_CD)); } // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // EZM0081B014CBSMsgの明細にセットする項目 String[] msgKeyList2 = { EZM0081B014CBSMsg1List.AD_CD , EZM0081B014CBSMsg1List.GENE_ADD_DTM , EZM0081B014CBSMsg1List.PCD , EZM0081B014CBSMsg1List.STATE_NM , EZM0081B014CBSMsg1List.CITY_NM , EZM0081B014CBSMsg1List.OAZTSU_NM , EZM0081B014CBSMsg1List.AZCHO_NM }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList2,"eo.ejb.cbs.cbsmsg.EZM0081B014CBSMsg1List",0); // inMsg(CBSMsg)に明細をセット inMsg.set("EZM0081B014CBSMsg1List", outMsg1); } catch(SQLException e) { inMsg.set(EZM0081B014CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // 資源の解放 try{ if(rsltQuery != null){ rsltQuery.close(); } if(pstmt != null){ pstmt.close(); } if(con1 != null){ closeConnection(con1); } }catch(SQLException e){ inMsg.set(EZM0081B014CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } }