001 /* 002 * Copyright (c) 2009 The openGion Project. 003 * 004 * Licensed under the Apache License, Version 2.0 (the "License"); 005 * you may not use this file except in compliance with the License. 006 * You may obtain a copy of the License at 007 * 008 * http://www.apache.org/licenses/LICENSE-2.0 009 * 010 * Unless required by applicable law or agreed to in writing, software 011 * distributed under the License is distributed on an "AS IS" BASIS, 012 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, 013 * either express or implied. See the License for the specific language 014 * governing permissions and limitations under the License. 015 */ 016 package org.opengion.plugin.table; 017 018 import java.io.File; 019 import java.io.PrintWriter; 020 import java.util.Map; 021 022 import org.opengion.fukurou.db.DBUtil; 023 import org.opengion.fukurou.db.Transaction; 024 import org.opengion.fukurou.util.ErrorMessage; 025 import org.opengion.fukurou.util.FileUtil; 026 import org.opengion.fukurou.util.FixLengthData; 027 import org.opengion.fukurou.util.StringUtil; 028 029 import org.opengion.hayabusa.common.HybsSystem; 030 import org.opengion.hayabusa.common.HybsSystemException; 031 import org.opengion.hayabusa.db.AbstractTableFilter; 032 import org.opengion.hayabusa.db.DBTableModel; 033 034 /** 035 * TableFilter_DBSRC_OUT は、TableFilter インターフェースを継承した、DBTableModel 処?の 036 * 実?ラスです? 037 * 038 * ここでは、オブジェクト?(GF82)の検索結果より、オブジェクト?細??ブル(GF83)から 039 * ?な??を取得し、各種オブジェクトソースを抜き?します? 040 * 出力ファイルは、オブジェクト名??.sql" と?命名規則で作?します? 041 * 042 * ここで、PACKAGE と、PACKAGE BODY が同じオブジェクト名の場合?同じファイルに追?append=true)されます? 043 * 本来は、??ォル?先に削除しておかな?、上書きされてしま?す? 044 * ここでは、フォル?除ではなく?できる?ローカル処?るよ?、PACKAGE の場合だけ? 045 * 先に、ファイルを削除する処?実行します? 046 * 047 * また?オブジェクトタイプによって、?力フォル?変える?合?、???してください? 048 * 以下?コメント?参?です?で、詳細は、jsp 側の抜?プログラ??仕様をご確認く??? 049 * 050 * view 04_VIEW 051 * function 05_SRC 052 * package 05_SRC 053 * package body 05_SRC 054 * procedure 05_SRC 055 * trigger 06_TRG 056 * 057 * オブジェクト?(GF82)の検索では?SYSTEM_ID,TBLSYU,OBJ_TYPE,OBJ_NAME,NAME_JA) 058 * の?を取得する?があります? 059 * 060 * パラメータは、tableFilterタグの keys, vals にそれぞれ記述するか?BODY 部にCSS形式で記述します? 061 * 【パラメータ? 062 * { 063 * DIR : {@BASE_DIR}/sql/05_SRC ; 出力ファイルの基準フォル???) 064 * XML : false ; XML出力を行うかど?[true/false]を指定しま?初期値:false)? 065 * } 066 * 067 * @og.formSample 068 * ●形式? 069 * select SYSTEM_ID,TBLSYU,OBJ_TYPE,OBJ_NAME,NAME_JA from GF82 070 * ?<og:tableFilter classId="DBSRC_OUT" keys="DIR" vals="{@BASE_DIR}/sql/05_SRC" /> 071 * 072 * ② <og:tableFilter classId="DBSRC_OUT" > 073 * { 074 * DIR : {@BASE_DIR}/sql/05_SRC ; 075 * XML : false ; 076 * } 077 * </og:tableFilter> 078 * 079 * @og.rev 5.6.7.0 (2013/07/27) 新規作? 080 * 081 * @version 0.9.0 2000/10/17 082 * @author Kazuhiko Hasegawa 083 * @since JDK1.1, 084 */ 085 public class TableFilter_DBSRC_OUT extends AbstractTableFilter { 086 //* こ?プログラ??VERSION??を設定します? {@value} */ 087 private static final String VERSION = "5.6.7.0 (2013/07/27)" ; 088 089 /** 090 * keys の整合?チェ?を行うための初期設定を行います? 091 * 092 * @param keysMap keys の整合?チェ?を行うための Map 093 */ 094 @Override 095 protected void init( final Map<String,String> keysMap ) { 096 keysMap.put( "DIR" , "出力ファイルの基準フォル???)" ); 097 keysMap.put( "XML" , "XML出力を行うかど?[true/false]を指?初期値:false)" ); 098 } 099 100 private static final String[] KEYS = new String[] { "SYSTEM_ID","TBLSYU","OBJ_TYPE","OBJ_NAME","NAME_JA" }; 101 102 private static final int SYSTEM_ID = 0; 103 private static final int TBLSYU = 1; 104 private static final int OBJ_TYPE = 2; 105 private static final int OBJ_NAME = 3; 106 private static final int NAME_JA = 4; 107 108 private static final String ENCODE = "UTF-8" ; 109 110 // オブジェクト?細??ブル(GF83) の検索SQL 111 private static final String GF83_SEL = "select NOLINE,SRC_TEXT" 112 + " from GF83" 113 + " where SYSTEM_ID=? and TBLSYU=? and OBJ_TYPE=? and OBJ_NAME=?" 114 + " and FGJ='1'" 115 + " order by NOLINE" ; 116 117 // 5.6.6.0 (2013/07/05) ヘッ??部作?用 118 private static final String CMNT = "************************************************************************" ; 119 120 private static final int X = FixLengthData.X ; // type 定数 121 private static final int K = FixLengthData.K ; // type 定数 122 123 /** 5.6.7.0 (2013/07/27) ?定数 */ 124 protected static final String XML_START_TAG = "<?xml version='1.0' encoding='UTF-8'?>" + CR + "<ROWSET tableName='xxx'>"; 125 protected static final String XML_END_TAG = "</ROWSET>"; 126 protected static final String EXEC_START_TAG= "<EXEC_SQL>"; 127 protected static final String EXEC_END_TAG = "</EXEC_SQL>"; 128 129 /** XML形式かど? */ 130 protected boolean isXml = false; // 5.6.7.0 (2013/07/27) 131 132 /** 133 * DBTableModel処?実行します? 134 * 135 * @return 処?果のDBTableModel 136 */ 137 public DBTableModel execute() { 138 DBTableModel table = getDBTableModel(); 139 140 isXml = StringUtil.nval( getValue( "XML" ), false ); 141 142 int[] clmNo = getTableColumnNo( KEYS ); 143 int rowCnt = table.getRowCount(); 144 145 File dir = new File( getValue( "DIR" ) ); 146 if( ! dir.exists() && !dir.mkdirs() ) { 147 String errMsg = "??フォル?作?できませんでした?" + dir + "]" ; 148 throw new HybsSystemException( errMsg ); 149 } 150 151 String[] data = null; 152 PrintWriter writer = null; 153 Transaction tran = getTransaction(); 154 155 for( int row=0; row<rowCnt; row++ ) { 156 String objType = null; 157 String objName = null; 158 try { 159 data = table.getValues( row ); 160 String systemId = data[clmNo[SYSTEM_ID]]; 161 String tblsyu = data[clmNo[TBLSYU]]; 162 objType = data[clmNo[OBJ_TYPE]]; 163 objName = data[clmNo[OBJ_NAME]]; 164 165 // パッケージの場合?、既存?ファイルを削除します?(PACKAGE BODY がappendされるた? 166 File objFile = new File( dir,objName + ( isXml ? ".xml" : ".sql" ) ); 167 if( "PACKAGE".equalsIgnoreCase( objType ) ) { 168 if( objFile.exists() && !objFile.delete() ) { 169 // こ?Exceptionは、catchでErrorMessageにセ?されます? 170 String errMsg = "??ファイルが削除できませんでした?" + objFile + "]" ; 171 throw new HybsSystemException( errMsg ); 172 } 173 } 174 175 // 出力ファイル名?、オブジェクト名と同じ 176 // PACKAGE と、PACKAGE BODY が同じオブジェクト名の場合?同じファイルに追?append=true)されます? 177 // writer = FileUtil.getPrintWriter( new File( dir,objName + ( isXml ? ".xml" : ".sql" ) ),ENCODE ); 178 writer = FileUtil.getPrintWriter( objFile,ENCODE,true ); 179 180 if( isXml ) { writer.println( XML_START_TAG ); } 181 writer.println( makeHeadLine( clmNo,data ) ); 182 183 // オブジェクト?細??ブル(GF83) の検索 184 String[] vals = new String[] { systemId,tblsyu,objType,objName }; 185 String[][] gf83 = DBUtil.dbExecute( GF83_SEL,vals,tran ); 186 if( gf83.length == 0 ) { 187 System.out.println( "OBJ_TYPE=[" + objType + "], OBJ_NAME=[" + objName + "] is Not Found!" ); 188 continue; 189 } 190 191 // ソースの出? 192 StringBuilder buf = new StringBuilder() ; 193 for( int j=0; j<gf83.length; j++ ) { 194 buf.append( gf83[j][1] ).append( CR ); 195 } 196 197 writer.print( buf.toString() ); 198 writer.println( makeEndLine( objName ) ); 199 if( isXml ) { writer.println( XML_END_TAG ); } 200 if( writer != null ) { writer.close(); } 201 } 202 catch( RuntimeException ex ) { 203 ErrorMessage errMessage = makeErrorMessage( "TableFilter_DBSRC_OUT Error",ErrorMessage.NG ); 204 errMessage.addMessage( row+1,ErrorMessage.NG,"SRC",ex.getMessage() ); 205 errMessage.addMessage( row+1,ErrorMessage.NG,"SRC",StringUtil.array2csv( data ) ); 206 errMessage.addMessage( row+1,ErrorMessage.NG,"SRC","OBJ_TYPE=[" + objType + "], OBJ_NAME=[" + objName + "]" ); 207 } 208 finally { 209 if( writer != null ) { writer.close(); } 210 } 211 } 212 213 return table; 214 } 215 216 /** 217 * ヘッ??として使用する??を作?します? 218 * 219 * @param clmNo カラ?号配? 220 * @param data ?行?の??タ配? 221 * 222 * @return ヘッ??として使用する?? 223 */ 224 protected String makeHeadLine( final int[] clmNo,final String[] data ) { 225 226 String LINE1 = "SYSTEM_ID : " + data[clmNo[SYSTEM_ID]] ; 227 String LINE2 = data[clmNo[OBJ_NAME]] + " ( " + data[clmNo[OBJ_TYPE]] + " )" ; 228 String LINE3 = "Created : " + HybsSystem.getDate() ; 229 230 int[] addLen = new int[] { 0,0,0 }; // ?ータ間?スペ?ス 231 int[] type = new int[] { X,K,X }; // ?ータの種別 X:半?S:空白前埋?K:全角混在 232 FixLengthData fixData = new FixLengthData( addLen,type ); 233 234 String[][] outData = new String[][] { 235 { "/**", CMNT , "**/" }, 236 { "/* ", LINE1, " */" }, 237 { "/* ", LINE2, " */" }, 238 { "/* ", LINE3, " */" }, 239 { "/**", CMNT , "**/" }, 240 }; 241 242 // 5.6.6.0 (2013/07/05) 簡易メソ?を利用 243 fixData.addAllListData( outData ); 244 245 StringBuilder buf = new StringBuilder(); 246 fixData.getAllFixData( buf ); 247 248 if( isXml ) { buf.append( EXEC_START_TAG ).append( CR ); } 249 buf.append( "CREATE OR REPLACE " ); 250 251 return buf.toString() ; 252 } 253 254 /** 255 * ??行に相当する文字?を作?します? 256 * 257 * @param objName オブジェクト名 258 * 259 * @return ??行に相当する文字? 260 */ 261 private String makeEndLine( final String objName ) { 262 263 StringBuilder buf = new StringBuilder(); 264 265 if( isXml ) { buf.append( CR ).append( EXEC_END_TAG ); } 266 else { buf.append( "/" ); } 267 268 return buf.toString() ; 269 } 270 }