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 }