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