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    }