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.Locale;
021    import java.util.Map;
022    
023    import org.opengion.fukurou.db.DBUtil;
024    import org.opengion.fukurou.db.Transaction;                     // 5.5.2.6 (2012/05/25)
025    import org.opengion.fukurou.util.ErrorMessage;
026    import org.opengion.fukurou.util.FileUtil;
027    import org.opengion.fukurou.util.FixLengthData;
028    import org.opengion.fukurou.util.StringUtil;
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_TABLE は、TableFilter インターフェースを継承した、DBTableModel 処?の
036     * 実?ラスです?
037     *
038     * ここでは、テーブル?の検索結果より、GF05 の??ブルカラ?義??ブルから
039     * ?な??を取得し、テーブル作?スクリプトを作?します?
040     * 出力ファイルは、テーブル名?S.sql" と?命名規則で作?します?
041     * 検索では?SYSTEM_ID,TBLSYU,TABLE_NAME,NAME_JA,TABLESPACE_NAME,INITIAL_EXTENT,NEXT_EXTENT,COMMENTS)
042     * の?を取得する?があります?
043     *
044     * パラメータは、tableFilterタグの keys, vals にそれぞれ記述するか?BODY 部にCSS形式で記述します?
045     * 【パラメータ?
046     *  {
047     *       DIR : {@BASE_DIR}/sql/01_TABLE ;    出力ファイルの基準フォル???)
048     *       XML : false ;                            XML出力を行うかど?[true/false]を指定しま?初期値:false)?
049     *  }
050     *
051     * @og.formSample
052     * ●形式?
053     *      select SYSTEM_ID,TBLSYU,TABLE_NAME,NAME_JA,TABLESPACE_NAME,INITIAL_EXTENT,NEXT_EXTENT,COMMENTS from GF05
054     * 
055     *      ?<og:tableFilter classId="TABLE" keys="DIR,XML" vals='"{@BASE_DIR}/sql/01_TABLE,"' />
056     *
057     *      ② <og:tableFilter classId="TABLE" >
058     *               {
059     *                   DIR : {@BASE_DIR}/sql/01_TABLE ;
060     *                   XML : false ;
061     *               }
062     *         </og:tableFilter>
063     *
064     * @og.rev 4.0.0.0 (2005/08/31) 新規作?
065     * @og.rev 5.6.6.0 (2013/07/05) keys の整合?チェ?を追?
066     *
067     * @version  0.9.0  2000/10/17
068     * @author   Kazuhiko Hasegawa
069     * @since    JDK1.1,
070     */
071    public class TableFilter_TABLE extends AbstractTableFilter {
072            //* こ?プログラ??VERSION??を設定します?       {@value} */
073            private static final String VERSION = "5.6.6.2 (2013/07/19)" ;
074    
075            /**
076             * keys の整合?チェ?を行うための初期設定を行います?
077             *
078             * @og.rev 5.6.6.1 (2013/07/12) keys の整合?チェ?対?
079             *
080             * @param       keysMap keys の整合?チェ?を行うための Map
081             */
082            @Override
083            protected void init( final Map<String,String> keysMap ) {
084                    keysMap.put( "DIR"      , "出力ファイルの基準フォル???)"                                                );
085                    keysMap.put( "XML"      , "XML出力を行うかど?[true/false]を指?初期値:false)"      );
086            }
087    
088            private static final String[] DBKEY = {"SYSTEM_ID","TBLSYU","TABLE_NAME","NAME_JA",
089                                                            "TABLESPACE_NAME","INITIAL_EXTENT","NEXT_EXTENT","COMMENTS" };
090    
091            // 5.1.1.0 (2009/12/01) ??タのアクセス用の配?番号のID?private ?protected にします?
092            /** ??タのアクセス用の配?番号 {@value} */
093            protected static final int SYSTEM_ID            = 0;
094            /** ??タのアクセス用の配?番号 {@value} */
095            protected static final int TBLSYU                       = 1;
096            /** ??タのアクセス用の配?番号 {@value} */
097            protected static final int TABLE_NAME           = 2;
098            /** ??タのアクセス用の配?番号 {@value} */
099            protected static final int NAME_JA                      = 3;
100            /** ??タのアクセス用の配?番号 {@value} */
101            protected static final int TABLESPACE_NAME      = 4;
102            /** ??タのアクセス用の配?番号 {@value} */
103            protected static final int INITIAL_EXTENT       = 5;
104            /** ??タのアクセス用の配?番号 {@value} */
105            protected static final int NEXT_EXTENT          = 6;
106            /** ??タのアクセス用の配?番号 {@value} */
107            protected static final int COMMENTS                     = 7;
108    
109            private static final String GF05_SEL = "SELECT CLM,SEQNO,NAME_JA,CLS_NAME,USE_LENGTH,DATA_DEFAULT,NOT_NULL,'' AS OPTS"
110                                                                                            + " FROM GF05"
111                                                                                            + " WHERE SYSTEM_ID=? AND TBLSYU=? AND TABLE_NAME=?"
112                                                                                            + " AND   FGJ='1'"
113                                                                                            + " ORDER BY SEQNO" ;
114    
115            /** ??タのアクセス用の配?番号 {@value} */
116            protected static final int GF05_CLM                     = 0;
117            /** ??タのアクセス用の配?番号 {@value} */
118            protected static final int GF05_SEQNO           = 1;
119            /** ??タのアクセス用の配?番号 {@value} */
120            protected static final int GF05_NAME_JA         = 2;
121            /** ??タのアクセス用の配?番号 {@value} */
122            protected static final int GF05_CLS_NAME        = 3;
123            /** ??タのアクセス用の配?番号 {@value} */
124            protected static final int GF05_USE_LENGTH      = 4;
125            /** ??タのアクセス用の配?番号 {@value} */
126            protected static final int GF05_DATA_DEFAULT= 5;
127            /** ??タのアクセス用の配?番号 {@value} */
128            protected static final int GF05_NOT_NULL        = 6;
129            /** ??タのアクセス用の配?番号 {@value} */
130            protected static final int GF05_OPTIONS         = 7;
131    
132    //      private static final String ENCODE = "Windows-31J" ;
133            private static final String ENCODE = "UTF-8" ; // 4.3.6.6 (2009/05/15)
134    //      private static final String CR     = HybsSystem.CR ;    // 5.1.1.0 (2009/12/01) CR 定義をAbstractTableFilterで行う?
135    
136            private static final String CMNT  = "************************************************************************" ;
137    
138            private static final int X = FixLengthData.X ;          // type 定数
139            private static final int S = FixLengthData.S ;          // type 定数
140            private static final int K = FixLengthData.K ;          // type 定数
141            private static final int T = FixLengthData.T ;          // addLen 定数
142            private static final int T2= FixLengthData.T2 ;         // addLen 定数
143    
144            /** ?定数  */
145            protected static final String XML_START_TAG     = "<?xml version='1.0' encoding='UTF-8'?>" + CR + "<ROWSET tableName='xxx'>";
146            protected static final String XML_END_TAG       = "</ROWSET>";
147            protected static final String EXEC_START_TAG= "<EXEC_SQL>";
148            protected static final String EXEC_END_TAG      = "</EXEC_SQL>";
149    
150            /** XML形式かど? */
151            protected boolean               isXml                           = false; // 4.3.7.0 (2009/06/01)
152    
153            /**
154             * DBTableModel処?実行します?
155             *
156             * @og.rev 3.8.7.0 (2006/12/15) アクセスログ取得?為,ApplicationInfoオブジェクトを設?
157             * @og.rev 4.0.0.0 (2007/11/28) メソ?の戻り?をチェ?します?
158             * @og.rev 4.3.7.0 (2009/06/01) トリガー、SEQUENCE作?機?、XML出力機?追?
159             * @og.rev 5.1.1.0 (2009/12/01) XML_START_TAG に、tableName をセ?します?
160             * @og.rev 5.1.9.0 (2010/08/01) Transaction 対?
161             * @og.rev 5.5.2.6 (2012/05/25) protected変数を?private化したため?getterメソ?で取得するよ?変更
162             * @og.rev 5.6.6.0 (2013/07/05) FixLengthData の簡易コンストラクタを使用
163             *
164             * @return      実行結果の??ブルモ?
165             */
166            public DBTableModel execute() {
167                    DBTableModel table = getDBTableModel();         // 5.5.2.6 (2012/05/25) インターフェースにgetterメソ?追?
168    
169                    isXml = StringUtil.nval( getValue( "XML" ), false );
170    
171                    int[] clmNo = getTableColumnNo( DBKEY );
172                    int rowCnt = table.getRowCount();
173    
174                    File dir = new File( getValue( "DIR" ) );
175                    if( ! dir.exists() && ! dir.mkdirs() ) {
176                            String errMsg = "??フォル?作?できませんでした?" + dir + "]" ;
177                            // 4.3.4.4 (2009/01/01)
178                            throw new HybsSystemException( errMsg );
179                    }
180    
181                    // カン?カラ?クラス,(,桁数,),初期値,NOT_NULL,拡張機?,コメント開?行番号,名称,コメント終?
182                    // 5.6.6.0 (2013/07/05) FixLengthData の簡易コンストラクタを使用
183    //              FixLengthData fixData = new FixLengthData(10);
184    
185                    // カン?カラ?クラス,(,桁数,),初期値,NOT_NULL,拡張機?,コメント開?行番号,名称,コメント終?
186                    int[] addLen = new int[] { 0,T,0,0,0,T2,T,T,T2,0,1,T,0 };       // ?ータ間?スペ?ス
187                    int[] type   = new int[] { X,X,X,X,S,X, X,X,X, X,S,K,X };       // ?ータの種別 X:半?S:空白前埋?K:全角混在
188    //              fixData.setAddLength( addLen );
189    //              fixData.setType( type );
190                    FixLengthData fixData = new FixLengthData( addLen,type );
191    
192                    String[] data  = null;
193                    Transaction tran = getTransaction();    // 5.5.2.6 (2012/05/25)
194                    for( int row=0; row<rowCnt; row++ ) {
195                            String tableName = null;
196                            try {
197                                    data  = table.getValues( row );
198                                    String systemId = data[clmNo[SYSTEM_ID]];
199                                    String tblsyu   = data[clmNo[TBLSYU]];
200                                    tableName               = data[clmNo[TABLE_NAME]];
201    
202                                    PrintWriter writer = FileUtil.getPrintWriter( new File( dir,tableName + ( isXml ? "S.xml" : "S.sql" ) ),ENCODE );
203    
204                                    if( isXml ) { writer.println( XML_START_TAG.replace( "xxx",tableName ) ); }             // 5.1.1.0 (2009/12/01) tableName をセ?
205                                    writer.print( makeHeadLine( clmNo,data ) );
206    
207                                    String[] vals = new String[] { systemId,tblsyu,tableName };
208    //                              String[][] gf05 = DBUtil.dbExecute( GF05_SEL,vals,appInfo );
209                                    String[][] gf05 = DBUtil.dbExecute( GF05_SEL,vals,tran );       // 5.1.9.0 (2010/08/01) Transaction 対?
210    
211                                    String uniqName = null;
212                                    fixData.clear();
213                                    // 値セ??まず?、最大長を求める?がある?
214                                    for( int i=0; i<gf05.length; i++ ) {
215                                            String[] outData = makeLineList( gf05[i],i==0 );
216                                            fixData.addListData( outData );
217    
218                                            // 4.3.7.0 (2009/06/01)
219                                            if( "UNIQ".equalsIgnoreCase( gf05[i][GF05_CLM] ) || "UNIQSEQ".equalsIgnoreCase( gf05[i][GF05_CLM] ) ) {
220                                                    uniqName = gf05[i][GF05_CLM].toUpperCase( Locale.JAPAN );
221                                            }
222                                    }
223                                    // 固定長化:最大長であわせた??を?力します?
224                                    for( int i=0; i<gf05.length; i++ ) {
225                                            writer.println( fixData.getFixData( i ) );
226                                    }
227                                    writer.println( makeEndLine( clmNo,data ) );
228    
229                                    // 4.3.7.0 (2009/06/01) UNIQ?のSEQとトリガーを作?
230                                    if( uniqName != null ) {
231                                            writer.println( makeUniqSeq( clmNo,data ) );
232                                            writer.println( makeUniqTrig( clmNo,data, uniqName ) );
233                                    }
234    
235                                    if( isXml ) { writer.println( XML_END_TAG ); }
236                                    writer.close();
237                            }
238                            catch( RuntimeException ex ) {
239                                    ErrorMessage errMessage = makeErrorMessage( "TableFilter_TABLE Error",ErrorMessage.NG );
240    //                              errMessage.addMessage( row+1,ErrorMessage.NG,"TABLE",ex.getMessage() );
241                                    errMessage.addMessage( row+1,ErrorMessage.NG,"TABLE",ex.toString() );
242                                    errMessage.addMessage( row+1,ErrorMessage.NG,"TABLE",StringUtil.array2csv( data ) );
243                                    errMessage.addMessage( row+1,ErrorMessage.NG,"TABLE","TABLE=[" + tableName + "]" );
244                                    // BAT から呼び出す?合があるため、標準エラー出力にも情報を?しておきます?
245                                    System.out.println( errMessage );
246                            }
247                    }
248    
249                    return table;
250            }
251    
252            /**
253             * ヘッ??部??処?実行します?
254             *
255             * @og.rev 5.6.6.0 (2013/07/05) FixLengthData の簡易コンストラクタを使用
256             * @og.rev 5.6.6.2 (2013/07/19) EXEC_START_TAG の付け忘れ
257             *
258             * @param       clmNo   カラ?号配?
259             * @param       data    ?行?の??タ配?
260             *
261             * @return      ヘッ??部????
262             */
263            protected String makeHeadLine( final int[] clmNo,final String[] data ) {
264                    final String TBL_NAME = data[clmNo[TABLE_NAME]];
265    
266                    String LINE1 = TBL_NAME + " ( " + data[clmNo[NAME_JA]] + " )" ;
267                    String LINE2 = data[clmNo[COMMENTS]] ;
268                    String LINE3 = "Created : " + HybsSystem.getDate() ;
269    
270                    // 5.6.6.0 (2013/07/05) FixLengthData の簡易コンストラクタを使用
271    //              FixLengthData fixData = new FixLengthData(3);
272    
273                    int[] addLen = new int[] { 0,0,0 };     // ?ータ間?スペ?ス
274                    int[] type   = new int[] { X,K,X };     // ?ータの種別 X:半?S:空白前埋?K:全角混在
275    //              fixData.setAddLength( addLen );
276    //              fixData.setType( type );
277                    FixLengthData fixData = new FixLengthData( addLen,type );
278    
279                    String[][] outData = new String[][] {
280                            { "/**",        CMNT ,  "**/" },
281                            { "/* ",        LINE1,  " */" },
282                            { "/* ",        LINE2,  " */" },
283                            { "/* ",        LINE3,  " */" },
284                            { "/**",        CMNT ,  "**/" },
285                    };
286    
287                    fixData.addAllListData( outData );
288    
289    //              for( int i=0; i<outData.length; i++ ) {
290    //                      fixData.addListData( outData[i] );
291    //              }
292    
293    //              StringBuilder buf = new StringBuilder();
294    //              if( isXml ) { buf.append( EXEC_START_TAG ).append( CR ); }
295    //              for( int i=0; i<outData.length; i++ ) {
296    //                      buf.append( fixData.getFixData( i ) ).append( CR );
297    //              }
298    
299                    StringBuilder buf = new StringBuilder();
300                    fixData.getAllFixData( buf );
301    
302                    if( isXml ) { buf.append( EXEC_START_TAG ).append( CR ); }                      // 5.6.6.2 (2013/07/19) 出力忘れ
303    
304                    buf.append( "CREATE TABLE " ).append( TBL_NAME ).append( " (" ).append( CR );
305    
306                    return buf.toString();
307            }
308    
309            /**
310             * ?部?カラ?義)の処?実行します?
311             * カン?カラ?クラス,(,桁数,),初期値,NOT_NULL,拡張機?,コメント開?行番号,名称,コメント終?
312             * の?配?にセ?します?
313             *
314             * @og.rev 5.5.1.9 (2012/04/18) useLen.length=0対?
315             * @param       data    ?行?の??タ配?
316             * @param       first   ??の行かど?[true:??/false:それ以降]
317             *
318             * @return      ?部?カラ?義)配?
319             */
320            protected String[] makeLineList( final String[] data,final boolean first ) {
321                    // カン?カラ?クラス(桁数),初期値,NOT_NULL,独自拡張,行番号,名称,終?
322                    String[] outData = new String[13];
323                    String clsName = data[GF05_CLS_NAME];
324    
325                    outData[0] = ( first ) ? "   " : " , " ;                                // 0:カン?
326                    outData[1] = data[GF05_CLM] ;                                                   // 1:カラ?
327    
328                    if( clsName.startsWith( "CLOB" ) || clsName.startsWith( "DATE" ) ) {
329                            data[GF05_USE_LENGTH] = null;
330                    }
331                    String useLen = data[GF05_USE_LENGTH];
332    //              if( useLen != null && ! useLen.equals( "0" ) ) {
333                    if( useLen != null && ! useLen.equals( "0" ) && useLen.length() > 0 ) { // 5.5.1.9 (2012/04/18)
334    //                      outData[2] = clsName + "(" + useLen + ")" ;                     // 2:クラス(桁数)
335                            outData[2] = clsName ;                                                          // 2:クラス
336                            outData[3] = " ( " ;                                                            // 3:(
337                            outData[4] = useLen ;                                                           // 4:桁数
338                            outData[5] = " )" ;                                                                     // 5:)
339                    }
340                    else {
341                            outData[2] = clsName ;                                                          // NUMBER型?桁数?なし?ケース
342                    }
343    
344                    String def = data[GF05_DATA_DEFAULT];
345                    if( def != null && def.length() > 0 ) {
346                            String comma = ( clsName.indexOf( "CHAR" ) >= 0 ) ? "'" : "" ;
347                            outData[6] = "DEFAULT " + comma + def + comma ;         // 6:初期値
348                    }
349    
350                    String notNull = data[GF05_NOT_NULL];
351                    if( notNull != null && notNull.equals( "1" ) ) {
352                            outData[7] = "NOT NULL" ;                                                       // 7:NOT_NULL
353                    }
354    
355                    String options = data[GF05_OPTIONS];
356                    if( options != null ) {
357                            outData[8] = options    ;                                                       // 8:拡張機?
358                    }
359    
360                    String nameJA = data[GF05_NAME_JA] ;                                    // 名称
361                    if( nameJA != null ) {
362                            outData[9]  = "/* " ;                                                           // 9:コメント開?
363                            outData[10] = data[GF05_SEQNO] ;                                        // 10:行番号
364                            outData[11] = nameJA ;                                                          // 11:名称
365                            outData[12] = "*/" ;                                                            // 12:コメント終?
366                    }
367    
368                    return outData ;
369            }
370    
371            /**
372             * 定義の??部??処?実行します?
373             *
374             * @param       clmNo   カラ?号配?
375             * @param       data    ?行?の??タ配?
376             *
377             * @return      定義の??部?
378             */
379            protected String makeEndLine( final int[] clmNo,final String[] data ) {
380                    StringBuilder buf = new StringBuilder();
381    
382                    buf.append( ")" ).append( CR );
383                    buf.append( "TABLESPACE " ).append( data[clmNo[TABLESPACE_NAME]] ).append( CR );
384                    buf.append( "STORAGE( INITIAL " ).append(  data[clmNo[INITIAL_EXTENT]] );
385                    buf.append( "K NEXT " ).append(  data[clmNo[NEXT_EXTENT]] );
386                    buf.append( "K PCTINCREASE 0 )" );
387    
388                    if( isXml )     { buf.append( CR ).append( EXEC_END_TAG ); }
389                    else            { buf.append( ";" ); }
390    
391                    return buf.toString();
392            }
393    
394            /**
395             * ユニ?クシーケンスの作?処?実行します?
396             *
397             * @og.rev 5.1.9.0 (2010/08/01) シーケンス名を[TABLE_NAME]S00に変更
398             *
399             * @param       clmNo   カラ?号配?
400             * @param       data    ?行?の??タ配?
401             *
402             * @return      ユニ?クシーケンス
403             */
404            protected String makeUniqSeq( final int[] clmNo,final String[] data ) {
405                    StringBuilder buf = new StringBuilder();
406    
407                    buf.append( CR );
408                    if( isXml ) { buf.append( EXEC_START_TAG ).append( CR ); }
409    
410                    // 5.1.9.0 (2010/08/01) シーケンス名を[TABLE_NAME]S00に変更
411    //              buf.append( "CREATE SEQUENCE " ).append( data[clmNo[TABLE_NAME]] ).append( "S01 " ).append( CR );
412                    buf.append( "CREATE SEQUENCE " ).append( data[clmNo[TABLE_NAME]] ).append( "S00 " ).append( CR );
413                    buf.append( "  INCREMENT BY 1 START WITH 1 MAXVALUE 999999999 CYCLE NOCACHE" );
414    //              buf.append( "INCREMENT BY 1 ");
415    //              buf.append( "START WITH 1 " );
416    //              buf.append( "MAXVALUE 999999999 " );
417    //              buf.append( "CYCLE NOCACHE" );
418    
419                    if( isXml )     { buf.append( CR ).append( EXEC_END_TAG ); }
420                    else            { buf.append( ";" ); }
421    
422                    return buf.toString();
423            }
424    
425            /**
426             * ユニ?クシーケンスと関連付けるトリガの作?処?実行します?
427             *
428             * @og.rev 5.1.9.0 (2010/08/01) トリガー名を[TABLE_NAME]T00に変更
429             *
430             * @param       clmNo   カラ?号配?
431             * @param       data    ?行?の??タ配?
432             * @param   uniqName    ユニ?クトリガ?
433             *
434             * @return      ユニ?クシーケンスと関連付けるトリガ
435             */
436            protected String makeUniqTrig( final int[] clmNo,final String[] data, final String uniqName ) {
437                    final String TBL_NAME = data[clmNo[TABLE_NAME]] ;
438                    StringBuilder buf = new StringBuilder();
439    
440                    buf.append( CR );
441                    if( isXml ) { buf.append( EXEC_START_TAG ).append( CR ); }
442    
443                    // 5.1.9.0 (2010/08/01) トリガー名を[TABLE_NAME]T00に変更
444    //              buf.append( "CREATE OR REPLACE TRIGGER " ).append( TBL_NAME ).append( "T01 " ).append( CR );
445                    buf.append( "CREATE OR REPLACE TRIGGER " ).append( TBL_NAME ).append( "T00 " ).append( CR );
446                    buf.append( "  BEFORE INSERT ON ").append( TBL_NAME ).append( CR );
447                    buf.append( "  FOR EACH ROW " ).append( CR );
448                    buf.append( "  BEGIN " ).append( CR );
449                    // 5.1.9.0 (2010/08/01) シーケンス名を[TABLE_NAME]S00に変更
450    //              buf.append( "SELECT " ).append( TBL_NAME ).append( "S01.NEXTVAL INTO :NEW." )
451                    buf.append( "    SELECT " ).append( TBL_NAME ).append( "S00.NEXTVAL INTO :NEW." )
452                            .append( uniqName ).append( " FROM DUAL; " ).append( CR );
453                    buf.append( "  END; " ).append( CR );
454    
455                    if( isXml )     { buf.append( EXEC_END_TAG ); }
456                    else            { buf.append( "/" ); }
457    
458                    return buf.toString();
459            }
460    }