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.util.ErrorMessage;
023    import org.opengion.fukurou.util.FileUtil;
024    import org.opengion.fukurou.util.FixLengthData;
025    import org.opengion.fukurou.util.StringUtil;
026    import org.opengion.hayabusa.common.HybsSystem;
027    import org.opengion.hayabusa.common.HybsSystemException;
028    import org.opengion.hayabusa.db.AbstractTableFilter;
029    import org.opengion.hayabusa.db.DBTableModel;
030    import org.opengion.hayabusa.resource.ResourceFactory;
031    import org.opengion.hayabusa.resource.ResourceManager;
032    
033    /**
034     * TableFilter_DBARG_OUT は、TableFilter インターフェースを継承した、DBTableModel 処?の
035     * 実?ラスです?
036     *
037     * ここでは、テーブル?の検索結果より、GF81 のARG変数チェ???ブルから
038     * ?な??を取得し、ARG変数作?スクリプトを作?します?
039     * 出力ファイルは、オブジェクト名??.sql" と?命名規則で作?します?
040     * 検索では?SYSTEM_ID,TBLSYU,OBJ_NAME,SEQNO,CLM,CLM_NAME,CLS_NAME,USE_LENGTH,MAX_LENGTH,TABLE_NAME)
041     * の?を取得する?があります?
042     *
043     * パラメータは、tableFilterタグの keys, vals にそれぞれ記述するか?BODY 部にCSS形式で記述します?
044     * 【パラメータ?
045     *  {
046     *       DIR : {@BASE_DIR}/sql/07_ARG ;   出力ファイルの基準フォル???)
047     *       XML : false ;                         XML出力を行うかど?[true/false]を指定しま?初期値:false)?
048     *  }
049     *
050     * @og.formSample
051     * ●形式?
052     *      select SYSTEM_ID,TBLSYU,OBJ_NAME,SEQNO,CLM,CLM_NAME,CLS_NAME,USE_LENGTH,MAX_LENGTH,TABLE_NAME from GF81
053     *      ?<og:tableFilter classId="DBARG_OUT" keys="DIR" vals="{@BASE_DIR}/sql/07_ARG" />
054     *
055     *      ② <og:tableFilter classId="DBARG_OUT" >
056     *               {
057     *                   DIR : {@BASE_DIR}/sql/07_ARG ;
058     *                   XML : false ;
059     *               }
060     *         </og:tableFilter>
061     *
062     * @og.rev 5.6.6.0 (2013/07/05) keys の整合?チェ?を追?
063     *
064     * @version  0.9.0  2000/10/17
065     * @author   Kazuhiko Hasegawa
066     * @since    JDK1.1,
067     */
068    public class TableFilter_DBARG_OUT extends AbstractTableFilter {
069            //* こ?プログラ??VERSION??を設定します?       {@value} */
070            private static final String VERSION = "5.6.7.0 (2013/07/27)" ;
071    
072            /**
073             * keys の整合?チェ?を行うための初期設定を行います?
074             *
075             * @og.rev 5.6.6.1 (2013/07/12) keys の整合?チェ?対?
076             *
077             * @param       keysMap keys の整合?チェ?を行うための Map
078             */
079            @Override
080            protected void init( final Map<String,String> keysMap ) {
081                    keysMap.put( "DIR"      , "出力ファイルの基準フォル???)"                                                );
082                    keysMap.put( "XML"      , "XML出力を行うかど?[true/false]を指?初期値:false)"      );              // 5.6.7.0 (2013/07/27) xml対?
083            }
084    
085            // 5.6.6.0 (2013/07/05) 検索?を増やしておきます?
086    //      private static final String[] KEYS = new String[] { "OBJ_NAME","CLM","CLS_NAME","USE_LENGTH","CLM_NAME" };
087            private static final String[] KEYS = new String[] { "SYSTEM_ID","TBLSYU","OBJ_NAME","SEQNO","CLM","CLM_NAME","CLS_NAME","USE_LENGTH","MAX_LENGTH","TABLE_NAME" };
088    
089            private static final int SYSTEM_ID              = 0;
090            private static final int TBLSYU                 = 1;
091            private static final int OBJ_NAME               = 2;
092            private static final int SEQNO                  = 3;
093            private static final int CLM                    = 4;
094            private static final int CLM_NAME               = 5;
095            private static final int CLS_NAME               = 6;
096            private static final int USE_LENGTH             = 7;
097            private static final int MAX_LENGTH             = 8;
098            private static final int TABLE_NAME             = 9;
099    
100    //      private static final String ENCODE = "Windows-31J" ;
101            private static final String ENCODE = "UTF-8" ;                  // 5.6.7.0 (2013/07/27) sql?UTF-8 で出?
102    //      private static final String CR     = HybsSystem.CR ;    // 5.1.1.0 (2009/12/01) CR 定義をAbstractTableFilterで行う?
103    
104            // 5.6.6.0 (2013/07/05) ヘッ??部作?用
105            private static final String CMNT  = "************************************************************************" ;
106    
107            private static final int X = FixLengthData.X ;          // type 定数
108            private static final int S = FixLengthData.S ;          // type 定数
109            private static final int K = FixLengthData.K ;          // type 定数
110            private static final int T = FixLengthData.T ;          // addLen 定数
111            private static final int T3= FixLengthData.T3 ;         // addLen 定数
112    
113            /** 5.6.7.0 (2013/07/27) ?定数  */
114            protected static final String XML_START_TAG     = "<?xml version='1.0' encoding='UTF-8'?>" + CR + "<ROWSET tableName='xxx'>";
115            protected static final String XML_END_TAG       = "</ROWSET>";
116            protected static final String EXEC_START_TAG= "<EXEC_SQL>";
117            protected static final String EXEC_END_TAG      = "</EXEC_SQL>";
118    
119            /** XML形式かど? */
120            protected boolean               isXml                           = false; // 5.6.7.0 (2013/07/27) 
121    
122            private ResourceManager resource = null;                        // 5.6.6.0 (2013/07/05) ヘッ??用のリソース
123    
124            /**
125             * DBTableModel処?実行します?
126             *
127             * @og.rev 4.0.0.0 (2007/11/28) メソ?の戻り?をチェ?します?
128             * @og.rev 5.5.2.6 (2012/05/25) protected変数を?private化したため?getterメソ?で取得するよ?変更
129             * @og.rev 5.6.7.0 (2013/07/27) xml 出力対?
130             *
131             * @return 処?果のDBTableModel
132             */
133            public DBTableModel execute() {
134                    DBTableModel table = getDBTableModel();         // 5.5.2.6 (2012/05/25) インターフェースにgetterメソ?追?
135    
136                    isXml = StringUtil.nval( getValue( "XML" ), false );    // 5.6.7.0 (2013/07/27) xml 出力対?
137    
138                    int[]  clmNo = getTableColumnNo( KEYS );
139    
140                    File dir = new File( getValue( "DIR" ) );
141                    if( ! dir.exists() && !dir.mkdirs() ) {
142                            String errMsg = "??フォル?作?できませんでした?" + dir + "]" ;
143                            // 4.3.4.4 (2009/01/01)
144                            throw new HybsSystemException( errMsg );
145                    }
146    
147                    // カン?カラ?クラス,(,桁数,),記号(--),表示?名称
148                    // 5.6.6.0 (2013/07/05) FixLengthData の簡易コンストラクタを使用
149    //              FixLengthData fixData = new FixLengthData(6);
150    
151                    // 5.6.6.0 (2013/07/05) カラ??表示?出力します?
152    //              int[] addLen = new int[] { 1,5,5,1 };   // ?ータ間?スペ?ス
153    //              int[] type   = new int[] { X,X,X,K };   // ?ータの種別 X:半?S:空白前埋?K:全角混在
154    //              カン?カラ?クラス,(,桁数,),記号(--),表示?名称
155                    int[] addLen = new int[] { 0,T,0,0,0,T3,0,1,0 };        // ?ータ間?スペ?ス
156                    int[] type   = new int[] { X,X,X,X,S,X, X,S,K };        // ?ータの種別 X:半?S:空白前埋?K:全角混在
157    //              fixData.setAddLength( addLen );
158    //              fixData.setType( type );
159                    FixLengthData fixData = new FixLengthData( addLen,type );
160    
161                    String[] data  = null;
162                    String oldObjName  = null;
163    
164                    int rowCnt = table.getRowCount();
165                    for( int row=0; row<rowCnt; row++ ) {
166                            String objName = null;
167                            try {
168                                    data = table.getValues( row );
169                                    objName = data[clmNo[OBJ_NAME]];
170    
171                                    // 5.6.6.0 (2013/07/05) 初めに??作?しておきます?
172                                    if( resource == null ) {
173                                            String systemId = data[clmNo[SYSTEM_ID]];
174                                            resource = ResourceFactory.newInstance( systemId,"ja",false );
175                                    }
176    
177                                    boolean blk = ! objName.equals( oldObjName ) ;
178                                    if( row > 0 && blk ) {
179                                            // 5.6.7.0 (2013/07/27) xml 出力対?
180    //                                      PrintWriter writer = FileUtil.getPrintWriter( new File( dir,oldObjName + ".sql" ),ENCODE );
181                                            PrintWriter writer = FileUtil.getPrintWriter( new File( dir,oldObjName + ( isXml ? ".xml" : ".sql" ) ),ENCODE );
182                                            if( isXml ) { writer.println( XML_START_TAG ); }        // 5.6.7.0 (2013/07/27) xml 出力対?
183                                            writer.print( makeHeadLine( oldObjName ) );
184                                            writer.print( fixData.getAllFixData() );
185                                            writer.println( makeEndLine( oldObjName ) );
186                                            if( isXml ) { writer.println( XML_END_TAG ); }          // 5.6.7.0 (2013/07/27) xml 出力対?
187                                            writer.close();
188                                            fixData.clear();
189                                    }
190    
191                                    String[] outData = makeLineList( clmNo,data,blk );
192                                    fixData.addListData( outData );
193    
194                                    oldObjName = objName ;
195                            }
196                            catch( RuntimeException ex ) {
197                                    ErrorMessage errMessage = makeErrorMessage( "TableFilter_DBARG_OUT Error",ErrorMessage.NG );
198                                    errMessage.addMessage( row+1,ErrorMessage.NG,"ARG",ex.getMessage() );
199                                    errMessage.addMessage( row+1,ErrorMessage.NG,"ARG",StringUtil.array2csv( data ) );
200                                    errMessage.addMessage( row+1,ErrorMessage.NG,"ARG","OBJ_NAME=[" + objName + "]" );
201                            }
202                    }
203    
204                    // 常に、?り遅れて??タ出力して?為、最後???タを?力しておく?がある?
205                    // 5.6.7.0 (2013/07/27) xml 出力対?
206    //              PrintWriter writer = FileUtil.getPrintWriter( new File( dir,oldObjName + ".sql" ),ENCODE );
207                    PrintWriter writer = FileUtil.getPrintWriter( new File( dir,oldObjName + ( isXml ? ".xml" : ".sql" ) ),ENCODE );
208                    if( isXml ) { writer.println( XML_START_TAG ); }        // 5.6.7.0 (2013/07/27) xml 出力対?
209                    writer.print( makeHeadLine( oldObjName ) );
210                    writer.print( fixData.getAllFixData() );
211                    writer.println( makeEndLine( oldObjName ) );
212                    if( isXml ) { writer.println( XML_END_TAG ); }          // 5.6.7.0 (2013/07/27) xml 出力対?
213                    writer.close();
214                    fixData.clear();
215    
216                    return table;
217            }
218    
219            /**
220             * ヘッ??として使用する??を作?します?
221             *
222             * @og.rev 5.6.6.0 (2013/07/05) ヘッ??として???をセ?します?
223             * @og.rev 5.6.7.0 (2013/07/27) xml 出力対?
224             *
225             * @param       objName オブジェクト名
226             *
227             * @return      ヘッ??として使用する??
228             */
229            private String makeHeadLine( final String objName ) {
230                    // objName から、ARG を取り除???が?画面IDになる?ず?リソースから検索
231                    String gamenId = objName.substring( 0,objName.length()-3 );             // 3???ARG" ?
232                    String gamenNm = resource.getLabel( gamenId ) ;
233    
234                    String LINE1 = objName ;
235                    String LINE2 = gamenId + " ( " + gamenNm + " )" ;
236                    String LINE3 = "Created : " + HybsSystem.getDate() ;
237    
238                    int[] addLen = new int[] { 0,0,0 };     // ?ータ間?スペ?ス
239                    int[] type   = new int[] { X,K,X };     // ?ータの種別 X:半?S:空白前埋?K:全角混在
240                    FixLengthData fixData = new FixLengthData( addLen,type );
241    
242                    String[][] outData = new String[][] {
243                            { "/**",        CMNT ,  "**/" },
244                            { "/* ",        LINE1,  " */" },
245                            { "/* ",        LINE2,  " */" },
246                            { "/* ",        LINE3,  " */" },
247                            { "/**",        CMNT ,  "**/" },
248                    };
249    
250                    // 5.6.6.0 (2013/07/05) 簡易メソ?を利用
251                    fixData.addAllListData( outData );
252    
253    //              for( int i=0; i<outData.length; i++ ) {
254    //                      fixData.addListData( outData[i] );
255    //              }
256    
257    //              StringBuilder buf = new StringBuilder();
258    //              for( int i=0; i<outData.length; i++ ) {
259    //                      buf.append( fixData.getFixData( i ) ).append( CR );
260    //              }
261    
262                    StringBuilder buf = new StringBuilder();
263                    fixData.getAllFixData( buf );
264    
265    //              buf.append( "DROP TYPE "              ).append( objName ).append( "_ARRAY;"    ).append( CR );
266    
267                    if( isXml ) { buf.append( EXEC_START_TAG ).append( CR ); }                      // 5.6.7.0 (2013/07/27) xml 出力対?
268                    buf.append( "DROP TYPE " ).append( objName ).append( "_ARRAY" );
269                    if( isXml )     { buf.append( CR ).append( EXEC_END_TAG ).append( CR ); }                       // 5.6.7.0 (2013/07/27) xml 出力対?
270                    else            { buf.append( ";" ).append( CR ); }
271    
272                    if( isXml ) { buf.append( EXEC_START_TAG ).append( CR ); }                      // 5.6.7.0 (2013/07/27) xml 出力対?
273                    buf.append( "CREATE OR REPLACE TYPE " ).append( objName ).append( " AS OBJECT" ).append( CR );
274                    buf.append( " (" ).append( CR );
275    
276                    return buf.toString() ;
277            }
278    
279            /**
280             * ?に相当する文字?の配?を作?します?
281             * カン?カラ?クラス,(,桁数,),記号(--),表示?名称
282             *
283             * @og.rev 5.5.1.9 (2012/04/18) useLen.length=0対?
284             * @og.rev 5.6.6.0 (2013/07/05) カラ??表示?出力します?
285             *
286             * @param       clmNo   カラ?号配?
287             * @param       data    ?行?の入力データ配?
288             * @param       first   ??の行かど?[true:??/false:それ以降]
289             *
290             * @return      ?行?に相当する結果配?(カン?カラ?クラス(桁数),コメント記号,表示?名称)
291             */
292            private String[] makeLineList( final int[] clmNo,final String[] data,final boolean first ) {
293                    // カン?カラ?クラス(桁数),記号(--),表示?名称
294    //              String[] outData = new String[4];
295                    String[] outData = new String[9];                                       // 5.6.6.0 (2013/07/05) カラ??表示??
296    
297                    outData[0] = ( first ) ? "   " : " , " ;                        // 0:カン?
298                    outData[1] = data[clmNo[CLM]] ;                                         // 1:カラ?
299    
300                    String clsName = data[clmNo[CLS_NAME]];
301                    if( clsName.startsWith( "CLOB" ) || clsName.startsWith( "DATE" ) ) {
302                            data[clmNo[USE_LENGTH]] = null;
303                    }
304                    String useLen = data[clmNo[USE_LENGTH]];
305    //              if( useLen != null && ! useLen.equals( "0" ) ) {
306                    if( useLen != null && ! useLen.equals( "0" ) && useLen.length() > 0 ) { // 5.5.1.9 (2012/04/19)
307    //                      outData[2] = clsName + "(" + useLen + ")" ;             // 2:クラス(桁数)
308                            outData[2] = clsName ;                                                  // 2:クラス
309                            outData[3] = " ( " ;                                                    // 3:(
310                            outData[4] = useLen ;                                                   // 4:桁数
311                            outData[5] = " )" ;                                                             // 5:)
312                    }
313                    else {
314                            outData[2] = clsName ;                                                  // NUMBER型桁数オープン対応?ARGで使えるか不??
315                    }
316    
317                    String seqno  = data[clmNo[SEQNO]] ;                            // 表示?
318                    String nameJA = data[clmNo[CLM_NAME]] ;                         // 名称
319                    if( nameJA != null ) {
320                            outData[6] = "-- " ;                                                    // 3:コメント記号
321                            outData[7] = seqno ;                                                    // 4:表示?
322                            outData[8] = nameJA ;                                                   // 5:名称
323                    }
324    
325                    return outData ;
326            }
327    
328            /**
329             * ??行に相当する文字?を作?します?
330             *
331             * @og.rev 5.6.7.0 (2013/07/27) xml 出力対?
332             *
333             * @param       objName オブジェクト名
334             *
335             * @return      ??行に相当する文字?
336             */
337            private String makeEndLine( final String objName ) {
338    
339                    StringBuilder buf = new StringBuilder();
340    //              buf.append( "  ) ;" ).append( CR );
341                    buf.append( "  )"  );
342    
343                    if( isXml )     { buf.append( CR ).append( EXEC_END_TAG ).append( CR ); }       // 5.6.7.0 (2013/07/27) xml 出力対?
344                    else            { buf.append( ";" ).append( CR ).append( "/" ).append( CR ); }
345    //              buf.append( "/"     ).append( CR );
346                    buf.append( CR );
347    
348                    if( isXml ) { buf.append( EXEC_START_TAG ).append( CR ); }                              // 5.6.7.0 (2013/07/27) xml 出力対?
349                    buf.append( "CREATE OR REPLACE TYPE " ).append( objName ).append( "_ARRAY" );
350                    buf.append( " AS VARRAY(1000) OF "    ).append( objName );
351    //              buf..append( ";" ).append( CR );
352                    if( isXml )     { buf.append( CR ).append( EXEC_END_TAG ); }    // 5.6.7.0 (2013/07/27) xml 出力対?
353                    else            { buf.append( ";" ).append( CR ).append( "/" ); }
354    //              buf.append( "/" );
355    
356                    return buf.toString() ;
357            }
358    }