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.fukurou.process;
017    
018    import org.opengion.fukurou.util.Argument;
019    import org.opengion.fukurou.util.SystemParameter;
020    import org.opengion.fukurou.util.LogWriter;
021    import org.opengion.fukurou.util.HybsEntry ;
022    import org.opengion.fukurou.util.Closer;
023    import org.opengion.fukurou.model.Formatter;
024    import org.opengion.fukurou.db.ConnectionFactory;
025    
026    import java.util.Map ;
027    import java.util.LinkedHashMap ;
028    
029    import java.sql.Connection;
030    import java.sql.PreparedStatement;
031    import java.sql.ParameterMetaData;
032    import java.sql.SQLException;
033    
034    /**
035     * Process_DBMerge は、UPDATE と INSERT を指定し ??タベ?スを追?新
036     * する、ChainProcess インターフェースの実?ラスです?
037     * 上?プロセスチェインの??タは上流から下流へと渡されます?)から
038     * 受け取っ?LineModel を?に、DBTableModel 形式ファイルを?力します?
039     *
040     * ??タベ?ス接続?等?、ParamProcess のサブクラス(Process_DBParam)に
041     * 設定された接?Connection)を使用します?
042     *
043     * 引数??中にスペ?スを含??合?、ダブルコー??ション("") で括って下さ??
044     * 引数??の ?』?前後には、スペ?スは挟めません。??key=value の様に
045     * 繋げてください?
046     *
047     * SQL?は、{@DATE.YMDH}等?シス?変数が使用できます?
048     *
049     * @og.formSample
050     *  Process_DBMerge -dbid=DBGE -insertTable=GE41
051     *
052     *   [ -dbid=DB接続ID           ] ??-dbid=DBGE (? Process_DBParam の -configFile で?す?DBConfig.xml ファイルで規?
053     *   [ -update=検索SQL?       ] ??-update="UPDATE GE41 SET NAME_JA = [NAME_JA],LABEL_NAME = [LABEL_NAME]
054     *                                         WHERE SYSTEM_ID = [SYSTEM_ID] AND CLM = [CLM]"
055     *   [ -updateFile=登録SQL?ァ??? ] ??-updateFile=update.sql
056     *                                ??  -update ?-updateFile が指定されな??合?、エラーです?
057     *   [ -update_XXXX=固定?      ] ??-update_SYSTEM_ID=GE
058     *                                     SQL?の{@XXXX}??を指定?固定?で置き換えます?
059     *                                     WHERE SYSTEM_ID='{@SYSTEM_ID}' ?WHERE SYSTEM_ID='GE'
060     *   [ -insertTable=登録???゙ルID ] ??INSERT??する?合?不要?INSERT する場合???ブルID
061     *   [ -insert=検索SQL?       ] ??-insert="INSERT INTO GE41 (SYSTEM_ID,CLM,NAME_JA,LABEL_NAME)
062     *                                         VALUES ([SYSTEM_ID],[CLM],[NAME_JA],[LABEL_NAME])"
063     *   [ -insertFile=登録SQL?ァ??? ] ??-insertFile=insert.sql
064     *                                ??  -insert ?-insertFile ??-table が指定されな??合?、エラーです?
065     *   [ -insert_XXXX=固定?      ] ??-insert_SYSTEM_ID=GE
066     *                                     SQL?の{@XXXX}??を指定?固定?で置き換えます?
067     *                                     WHERE SYSTEM_ID='{@SYSTEM_ID}' ?WHERE SYSTEM_ID='GE'
068     *   [ -const_XXXX=固定?       ] ??-const_FGJ=1
069     *                                     LineModel のキー(const_ に続く??)の値に、固定?を設定します?
070     *                                     キーが異なれ?、?のカラ?を指定できます?
071     *   [ -commitCnt=commit処?定] ???数毎にコミットを発行します?0 の場合?、終?でコミットしません?
072     *   [ -display=[false/true]    ] ??結果を標準?力に表示する(true)かしな?false)?初期値:false[表示しない])
073     *   [ -debug=[false/true]      ] ??????を標準?力に表示する(true)かしな?false)?初期値:false[表示しない])
074     *
075     * @version  4.0
076     * @author   Kazuhiko Hasegawa
077     * @since    JDK5.0,
078     */
079    public class Process_DBMerge extends AbstractProcess implements ChainProcess {
080            private static final String UPDATE_KEY  = "update_" ;
081            private static final String INSERT_KEY  = "insert_" ;
082            private static final String CNST_KEY    = "const_" ;
083    
084            private Connection      connection      = null;
085            private PreparedStatement insPstmt      = null ;
086            private PreparedStatement updPstmt      = null ;
087            private ParameterMetaData insPmeta      = null ;        // 5.1.2.0 (2010/01/01) setObject に、Type を渡す?(PostgreSQL対?
088            private ParameterMetaData updPmeta      = null ;        // 5.1.2.0 (2010/01/01) setObject に、Type を渡す?(PostgreSQL対?
089            private boolean useParamMetaData        = false;        // 5.1.2.0 (2010/01/01) setObject に、Type を渡す?(PostgreSQL対?
090    
091            private String          dbid            = null;
092            private String          insert          = null;
093            private String          update          = null;
094            private String          insertTable     = null;
095            private int[]           insClmNos       = null;         // insert 時?ファイルのヘッ??のカラ?号
096            private int[]           updClmNos       = null;         // update 時?ファイルのヘッ??のカラ?号
097            private int                     commitCnt       = 0;            // コミットするまとめ件数
098            private boolean         display         = false;        // 表示しな?
099            private boolean         debug           = false;        // 5.7.3.0 (2014/02/07) ????
100    
101            private String[]        cnstClm         = null;         // 固定?を設定するカラ?
102            private int[]           cnstClmNos      = null;         // 固定?を設定するカラ?号
103            private String[]        constVal        = null;         // カラ?号に対応した固定?
104    
105            private boolean         firstRow        = true;         // ??の?目
106            private int                     count           = 0;
107            private int                     insCount        = 0;
108            private int                     updCount        = 0;
109    
110            private static final Map<String,String> mustProparty   ;          // ?プロパティ???チェ?用 Map
111            private static final Map<String,String> usableProparty ;          // ?プロパティ?整合?チェ? Map
112    
113            static {
114                    mustProparty = new LinkedHashMap<String,String>();
115    
116                    usableProparty = new LinkedHashMap<String,String>();
117                    usableProparty.put( "dbid",     "Process_DBParam の -configFile で?す?DBConfig.xml ファイルで規? );
118                    usableProparty.put( "update",   "更新SQL?sql or sqlFile ??)" +
119                                                                            CR + "? \"UPDATE GE41 " +
120                                                                            CR + "SET NAME_JA = [NAME_JA],LABEL_NAME = [LABEL_NAME] " +
121                                                                            CR + "WHERE SYSTEM_ID = [SYSTEM_ID] AND CLM = [CLM]\"" );
122                    usableProparty.put( "updateFile",       "更新SQLファイル(sql or sqlFile ??)? update.sql" );
123                    usableProparty.put( "update_",          "SQL?の{&#064;XXXX}??を指定?固定?で置き換えます?" +
124                                                                            CR + "WHERE SYSTEM_ID='{&#064;SYSTEM_ID}' ?WHERE SYSTEM_ID='GE'" );
125                    usableProparty.put( "insert",                   "登録SQL?sql or sqlFile ??)" +
126                                                                            CR + "? \"INSERT INTO GE41 " +
127                                                                            CR + "(SYSTEM_ID,CLM,NAME_JA,LABEL_NAME) " +
128                                                                            CR + "VALUES ([SYSTEM_ID],[CLM],[NAME_JA],[LABEL_NAME])\"" );
129                    usableProparty.put( "insertFile",               "登録SQLファイル(sql or sqlFile ??)? insert.sql" );
130                    usableProparty.put( "insertTable",      "INSERT する場合???ブルID SQL??する?合?不要?" );
131                    usableProparty.put( "insert_",          "SQL?の{&#064;XXXX}??を指定?固定?で置き換えます?" +
132                                                                            CR + "WHERE SYSTEM_ID='{&#064;SYSTEM_ID}' ?WHERE SYSTEM_ID='GE'" );
133                    usableProparty.put( "const_",   "LineModel のキー(const_ に続く??)の値に、固定?? +
134                                                                            CR + "設定します?キーが異なれ?、?のカラ?を指定できます?" +
135                                                                            CR + "? -sql_SYSTEM_ID=GE" );
136                    usableProparty.put( "commitCnt",        "?数毎にコミットを発行します?" +
137                                                                            CR + "0 の場合?、終?でコミットしません(初期値: 0)" );
138                    usableProparty.put( "display",  "結果を標準?力に表示する(true)かしな?false)? +
139                                                                                    CR + "(初期値:false:表示しな?" );
140                    usableProparty.put( "debug",    "????を標準?力に表示する(true)かしな?false)? +
141                                                                                    CR + "(初期値:false:表示しな?" );                // 5.7.3.0 (2014/02/07) ????
142            }
143    
144            /**
145             * ?ォルトコンストラクター?
146             * こ?クラスは、動??されます??ォルトコンストラクターで?
147             * super クラスに対して、?な初期化を行っておきます?
148             *
149             */
150            public Process_DBMerge() {
151                    super( "org.opengion.fukurou.process.Process_DBMerge",mustProparty,usableProparty );
152            }
153    
154            /**
155             * プロセスの初期化を行います?初めに??、呼び出されます?
156             * 初期処?ファイルオープン??オープン?に使用します?
157             *
158             * @og.rev 5.1.2.0 (2010/01/01) setObject に ParameterMetaData の getParameterType を渡す?(PostgreSQL対?
159             * @og.rev 5.3.8.0 (2011/08/01) useParamMetaData ?ConnectionFactory経由で取得?(PostgreSQL対?
160             *
161             * @param   paramProcess ??タベ?スの接続???などを持って?オブジェク?
162             */
163            public void init( final ParamProcess paramProcess ) {
164                    Argument arg = getArgument();
165    
166                    insertTable     = arg.getProparty("insertTable");
167                    update          = arg.getFileProparty("update","updateFile",false);
168                    insert          = arg.getFileProparty("insert","insertFile",false);
169                    commitCnt       = arg.getProparty("commitCnt",commitCnt);
170                    display         = arg.getProparty("display",display);
171                    debug           = arg.getProparty("debug",debug);                               // 5.7.3.0 (2014/02/07) ????
172    //              if( debug ) { println( arg.toString() ); }                      // 5.7.3.0 (2014/02/07) ????
173    
174                    dbid            = arg.getProparty("dbid");
175                    connection      = paramProcess.getConnection( dbid );
176                    // 5.1.2.0 (2010/01/01) setObject に ParameterMetaData の getParameterType を渡す?(PostgreSQL対?
177    //              useParamMetaData = ApplicationInfo.useParameterMetaData( connection );
178                    useParamMetaData = ConnectionFactory.useParameterMetaData( dbid );      // 5.3.8.0 (2011/08/01)
179    
180                    if( insert == null && insertTable == null ) {
181                            String errMsg = "insert また?、insertFile を指定しな??合?、insertTable を??してください?;
182                            throw new RuntimeException( errMsg );
183                    }
184    
185                    if( insert != null && insertTable != null ) {
186                            String errMsg = "insert また?、insertFile と、insertTable は、両方同時に?できません?"
187                                                                     + insert + "],[" + insertTable + "]";
188                            throw new RuntimeException( errMsg );
189                    }
190    
191                    // 3.8.0.1 (2005/06/17) {@DATE.XXXX} 変換処??追?
192                    // {@DATE.YMDH} などの??を?yyyyMMddHHmmss 型?日付に置き換えます?
193                    // SQL?? {@XXXX} ??の固定?への置き換?
194                    HybsEntry[] entry       =arg.getEntrys(UPDATE_KEY);             // 配?
195                    SystemParameter sysParam = new SystemParameter( update );
196                    update = sysParam.replace( entry );
197    
198                    if( insert != null ) {
199                            entry   =arg.getEntrys(INSERT_KEY);             // 配?
200                            sysParam = new SystemParameter( insert );
201                            insert = sysParam.replace( entry );
202                    }
203    
204                    HybsEntry[] cnstKey = arg.getEntrys( CNST_KEY );                // 配?
205                    int csize       = cnstKey.length;
206                    cnstClm         = new String[csize];
207                    constVal        = new String[csize];
208                    for( int i=0; i<csize; i++ ) {
209                            cnstClm[i]  = cnstKey[i].getKey();
210                            constVal[i] = cnstKey[i].getValue();
211                    }
212            }
213    
214            /**
215             * プロセスの終?行います??に??、呼び出されます?
216             * 終???ファイルクローズ??クローズ?に使用します?
217             *
218             * @og.rev 4.0.0.0 (2007/11/27) commit,rollback,remove 処?追?
219             * @og.rev 5.1.2.0 (2010/01/01) insPmeta , updPmeta のクリア
220             *
221             * @param   isOK ト?タルで、OK?たかど?[true:成功/false:失敗]
222             */
223            public void end( final boolean isOK ) {
224                    boolean flag1 = Closer.stmtClose( updPstmt );
225                    updPstmt = null;
226                    boolean flag2 = Closer.stmtClose( insPstmt );
227                    insPstmt = null;
228    
229                    insPmeta        = null ;        // 5.1.2.0 (2010/01/01)
230                    updPmeta        = null ;        // 5.1.2.0 (2010/01/01)
231    
232                    // close に失敗して?のに commit しても良??か?
233                    if( isOK ) {
234                            Closer.commit( connection );
235                    }
236                    else {
237                            Closer.rollback( connection );
238                    }
239                    ConnectionFactory.remove( connection,dbid );
240    
241                    if( ! flag1 ) {
242                            String errMsg = "update ス??トメントをクローズ出来ません? + CR
243                                                            + " update=[" + update + "] , commit=[" + isOK + "]" ;
244                            throw new RuntimeException( errMsg );
245                    }
246    
247                    if( ! flag2 ) {
248                            String errMsg = "insert ス??トメントをクローズ出来ません? + CR
249                                                            + " insert=[" + insert + "] , commit=[" + isOK + "]" ;
250                            throw new RuntimeException( errMsg );
251                    }
252            }
253    
254            /**
255             * 引数の LineModel を??るメソ?です?
256             * 変換処?? LineModel を返します?
257             * 後続??行わな?????タのフィルタリングを行う場?は?
258             * null ??タを返します?つまり?null ??タは、後続??行わな?
259             * フラグの代わりにも使用して?す?
260             * なお?変換処?? LineModel と、オリジナルの LineModel が?
261             * 同?、コピ?(クローン)か?、各処?ソ??決めて?す?
262             * ドキュメントに明記されて???合?、副作用が問題になる?合??
263             * ???とに自?コピ?(クローン)して下さ??
264             *
265             * @og.rev 5.1.2.0 (2010/01/01) setObject に ParameterMetaData の getParameterType を渡す?(PostgreSQL対?
266             * @og.rev 5.3.8.0 (2011/08/01) useParamMetaData  setNull 対?PostgreSQL対?
267             * @og.rev 5.7.2.2 (2014/01/24) SQL実行エラーを少し詳細に出力します?
268             *
269             * @param       data ラインモ? オリジナルのLineModel
270             *
271             * @return      処?換後?LineModel
272             */
273            public LineModel action( final LineModel data ) {
274                    count++ ;
275                    int updCnt = 0;
276                    try {
277                            if( firstRow ) {
278                                    makePrepareStatement( insertTable,data );
279    
280                                    int size   = cnstClm.length;
281                                    cnstClmNos = new int[size];
282                                    for( int i=0; i<size; i++ ) {
283                                            cnstClmNos[i] = data.getColumnNo( cnstClm[i] );
284                                    }
285    
286                                    firstRow = false;
287                                    if( display ) { println( data.nameLine() ); }           // 5.7.3.0 (2014/02/07) ????
288                            }
289    
290                            // 固定?置き換え??
291                            for( int j=0; j<cnstClmNos.length; j++ ) {
292                                    data.setValue( cnstClmNos[j],constVal[j] );
293                            }
294    
295                            // 5.1.2.0 (2010/01/01) setObject に ParameterMetaData の getParameterType を渡す?(PostgreSQL対?
296                            if( useParamMetaData ) {
297                                    for( int i=0; i<updClmNos.length; i++ ) {
298                                            int type = updPmeta.getParameterType( i+1 );
299                                            // 5.3.8.0 (2011/08/01) setNull 対?
300    //                                      updPstmt.setObject( i+1,data.getValue(updClmNos[i]),type );
301                                            Object val = data.getValue(updClmNos[i]);
302                                            if( val == null || ( val instanceof String && ((String)val).isEmpty() ) ) {
303                                                    updPstmt.setNull( i+1, type );
304                                            }
305                                            else {
306                                                    updPstmt.setObject( i+1, val, type );
307                                            }
308                                    }
309                            }
310                            else {
311                                    for( int i=0; i<updClmNos.length; i++ ) {
312                                            updPstmt.setObject( i+1,data.getValue(updClmNos[i]) );
313                                    }
314                            }
315    
316                            updCnt = updPstmt.executeUpdate();
317                            if( updCnt == 0 ) {
318                                    // 5.1.2.0 (2010/01/01) setObject に ParameterMetaData の getParameterType を渡す?(PostgreSQL対?
319                                    if( useParamMetaData ) {
320                                            for( int i=0; i<insClmNos.length; i++ ) {
321                                                    int type = insPmeta.getParameterType( i+1 );
322                                                    // 5.3.8.0 (2011/08/01) setNull 対?
323    //                                              insPstmt.setObject( i+1,data.getValue(insClmNos[i]),type );
324                                                    Object val = data.getValue(insClmNos[i]);
325                                                    if( val == null || ( val instanceof String && ((String)val).isEmpty() ) ) {
326                                                            insPstmt.setNull( i+1, type );
327                                                    }
328                                                    else {
329                                                            insPstmt.setObject( i+1, val, type );
330                                                    }
331                                            }
332                                    }
333                                    else {
334                                            for( int i=0; i<insClmNos.length; i++ ) {
335                                                    insPstmt.setObject( i+1,data.getValue(insClmNos[i]) );
336                                            }
337                                    }
338                                    int insCnt = insPstmt.executeUpdate();
339                                    if( insCnt == 0 ) {
340                                            String errMsg = "?件も追?れませんでした?" + data.getRowNo() + "]件目" + CR
341                                                                    + " insert=[" + insert + "]" + CR
342                                                                    + " data=[" + data.dataLine() + "]" + CR ;      // 5.7.2.2 (2014/01/24) エラー時に??タも?力します?
343                                            throw new RuntimeException( errMsg );
344                                    }
345                                    insCount++ ;
346                            }
347                            else if( updCnt > 1 ) {
348                                    String errMsg = "??" + updCnt + ")が同時に更新されました?" + data.getRowNo() + "]件目" + CR
349                                                            + " update=[" + update + "]" + CR
350                                                            + " data=[" + data.dataLine() + "]" + CR ;      // 5.7.2.2 (2014/01/24) エラー時に??タも?力します?
351                                    throw new RuntimeException( errMsg );
352                            }
353                            else {
354                                    updCount ++ ;
355                            }
356    
357                            if( commitCnt > 0 && ( count%commitCnt == 0 ) ) {
358                                    Closer.commit( connection );
359                            }
360    //                      if( display ) { printKey( count,updCnt,data ); }
361                            if( display ) { println( data.dataLine() ); }                   // 5.7.3.0 (2014/02/07) ????
362                    }
363                    catch (SQLException ex) {
364                            String errMsg = "登録処?エラーが発生しました?" + data.getRowNo() + "]件目" + CR
365                                                    + ((updCnt == 1) ?
366                                                                    " update=[" + update + "]"
367                                                            :       " insert=[" + insert + "]" + CR
368                                                                    + " insertTable=[" + insertTable + "]" )
369                                                    + CR
370                                                    + "errCode=[" + ex.getErrorCode() + "] State=[" + ex.getSQLState() + "]" + CR
371                                                    + "data=[" + data.dataLine() + "]" + CR ;       // 5.7.2.2 (2014/01/24) エラー時に??タも?力します?
372                            throw new RuntimeException( errMsg,ex );
373                    }
374                    return data;
375            }
376    
377            /**
378             * ?で使用する PreparedStatement を作?します?
379             * 引数?? SQL また?、LineModel から作?した SQL より構築します?
380             *
381             * @og.rev 5.1.2.0 (2010/01/01) setObject に ParameterMetaData の getParameterType を渡す?(PostgreSQL対?
382             * @og.rev 5.7.2.2 (2014/01/24) SQL実行エラーを少し詳細に出力します?
383             *
384             * @param       table   処?象の??ブルID
385             * @param       data ラインモ? 処?象のLineModel
386             */
387            private void makePrepareStatement( final String table,final LineModel data ) {
388                    if( insert == null ) {
389                            StringBuilder buf = new StringBuilder();
390                            String[] names = data.getNames();
391                            int size = names.length;
392    
393                            buf.append( "INSERT INTO " ).append( table ).append( " (" );
394                            buf.append( names[0] );
395                            for( int i=1; i<size; i++ ) {
396                                    buf.append( "," ).append( names[i] );
397                            }
398                            buf.append( " ) VALUES ( ?" );
399                            for( int i=1; i<size; i++ ) {
400                                    buf.append( ",?" );
401                            }
402                            buf.append( " )" );
403                            insert = buf.toString();
404    
405                            // カラ?号を設定します?
406                            insClmNos = new int[size];
407                            for( int i=0; i<size; i++ ) {
408                                    insClmNos[i] = i;
409                            }
410                    }
411                    else {
412                            Formatter format = new Formatter( data );
413                            format.setFormat( insert );
414                            insert = format.getQueryFormatString();
415                            insClmNos = format.getClmNos();
416                    }
417    
418                    Formatter format = new Formatter( data );
419                    format.setFormat( update );
420                    update = format.getQueryFormatString();
421                    updClmNos = format.getClmNos();
422    
423                    try {
424                            insPstmt = connection.prepareStatement( insert );
425                            updPstmt = connection.prepareStatement( update );
426                            // 5.1.2.0 (2010/01/01) setObject に ParameterMetaData の getParameterType を渡す?(PostgreSQL対?
427                            if( useParamMetaData ) {
428                                    insPmeta = insPstmt.getParameterMetaData();
429                                    updPmeta = updPstmt.getParameterMetaData();
430                            }
431                    }
432                    catch (SQLException ex) {
433                            // 5.7.2.2 (2014/01/24) SQL実行エラーを少し詳細に出力します?
434                            String errMsg = "PreparedStatement を取得できませんでした? + CR
435                                                    + "errMsg=[" + ex.getMessage() + "]" + CR
436                                                    + "errCode=[" + ex.getErrorCode() + "] State=[" + ex.getSQLState() + "]" + CR
437                                                    + "insert=[" + insert + "]" + CR
438                                                    + "update=[" + update + "]" + CR
439                                                    + "table=[" + table + "]" + CR
440                                                    + "nameLine=[" + data.nameLine() + "]" + CR
441                                                    + "data=[" + data.dataLine() + "]" + CR ;
442                            throw new RuntimeException( errMsg,ex );
443                    }
444            }
445    
446            /**
447             * 画面出力用のフォーマットを作?します?
448             *
449             * @og.rev 5.7.3.0 (2014/02/07) 表示方法?変更のため、?
450             *
451             * @param       rowNo   ??タ読み取り件数
452             * @param       updCnt  更新件数
453             * @param       data ラインモ?
454             */
455    //      private void printKey( final int rowNo , final int updCnt , final LineModel data ) {
456    //              StringBuilder buf = new StringBuilder();
457    //
458    //              if( updCnt > 0 ) { buf.append( "UPDATE " ); }
459    //              else                     { buf.append( "INSERT " ); }
460    //
461    //              buf.append( "row=[" ).append( rowNo ).append( "] : " );
462    //              for( int i=0; i < updClmNos.length; i++ ) {
463    //                      if( i == 0 ) { buf.append( "key: " ); }
464    //                      else         { buf.append( " and " );  }
465    //                      buf.append( data.getName( updClmNos[i] ) );
466    //                      buf.append( " = " );
467    //                      buf.append( data.getValue( updClmNos[i] ) );
468    //              }
469    //
470    //              println( buf.toString() );
471    //      }
472    
473            /**
474             * プロセスの処?果のレポ?ト表現を返します?
475             * 処??ログラ?、?力件数、?力件数などの??です?
476             * こ???をそのまま、標準?力に出すことで、結果レポ?トと出来るよ?
477             * 形式で出してください?
478             *
479             * @return   処?果のレポ??
480             */
481            public String report() {
482                    String report = "[" + getClass().getName() + "]" + CR
483                                    + TAB + "DBID         : " + dbid + CR
484                                    + TAB + "Input  Count : " + count + CR
485                                    + TAB + "Update Count : " + updCount + CR
486                                    + TAB + "Insert Count : " + insCount ;
487    
488                    return report ;
489            }
490    
491            /**
492             * こ?クラスの使用方法を返します?
493             *
494             * @return      こ?クラスの使用方?
495             */
496            public String usage() {
497                    StringBuilder buf = new StringBuilder();
498    
499                    buf.append( "Process_DBMerge は、UPDATE と INSERT を指定し ??タベ?スを追?新"                    ).append( CR );
500                    buf.append( "する、ChainProcess インターフェースの実?ラスです?"                                                  ).append( CR );
501                    buf.append( "上?プロセスチェインの??タは上流から下流へと渡されます?)から"                   ).append( CR );
502                    buf.append( "受け取っ?LineModel を?に、データベ?スの存在チェ?を行い?                              ).append( CR );
503                    buf.append( "下流への処?振り?けます?"                                                                                                   ).append( CR );
504                    buf.append( CR );
505                    buf.append( "??タベ?ス接続?等?、ParamProcess のサブクラス(Process_DBParam)に"                    ).append( CR );
506                    buf.append( "設定された接?Connection)を使用します?"                                                                               ).append( CR );
507                    buf.append( CR );
508                    buf.append( "引数??中に空白を含??合?、ダブルコー??ション(\"\") で括って下さ??" ).append( CR );
509                    buf.append( "引数??の ?』?前後には、空白は挟めません。??key=value の様に"             ).append( CR );
510                    buf.append( "繋げてください?                                                                                                                              ).append( CR );
511                    buf.append( CR );
512                    buf.append( "SQL?は、{@DATE.YMDH}等?シス?変数が使用できます?"                                          ).append( CR );
513                    buf.append( CR ).append( CR );
514                    buf.append( getArgument().usage() ).append( CR );
515    
516                    return buf.toString();
517            }
518    
519            /**
520             * こ?クラスは、main メソ?から実行できません?
521             *
522             * @param       args    コマンド引数配?
523             */
524            public static void main( final String[] args ) {
525                    LogWriter.log( new Process_DBMerge().usage() );
526            }
527    }