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?の{@XXXX}??を指定?固定?で置き換えます?" +
124 CR + "WHERE SYSTEM_ID='{@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?の{@XXXX}??を指定?固定?で置き換えます?" +
132 CR + "WHERE SYSTEM_ID='{@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 }