    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;
    022
    023import org.opengion.fukurou.util.HybsEntry ;
    024import org.opengion.fukurou.db.ConnectionFactory;
    025
    026import java.util.Set ;
    027import java.util.HashSet ;
    028import java.util.Map ;
    029import java.util.LinkedHashMap ;
    030
    031import java.sql.Connection;
    032import java.sql.Statement;
    033import java.sql.ResultSet;
    034import java.sql.SQLException;
    035
    036/**
    037 * Process_BulkQueryは、データベースから読み取った内容を、一括処理する、
    038 * FirstProcess と、ChainProcess のインターフェースを両方持った、実装クラスです。
    039 * ParamProcess のサブクラス(Process_DBParam)にセットしたり、加工したりします。
    040 *
    041 * このクラスは、上流から、下流への処理は、１度しか実行されません。
    042 * FirstProcess の検索結果は、Set オブジェクトとして、Process_DBParam に渡します。
    043 * ChainProcess は、その結果を取り出し、自分自身の処理結果と合せて加工します。
    044 *
    045 * FirstProcess では、-action は、query のみです。
    046 *   query は、指定のSQL文を実行し、結果のSetをParamProcessに設定します。
    047 * ChainProcess では、-action は、query、bulkSet、minus、intersect が指定できます。
    048 *   query     は、上記と同じです。
    049 *   minus     は、先のSetから、SQL文の実行結果を引き算し、結果Setを再設定します。
    050 *   intersect は、先のSetから、SQL文の実行結果と重複する結果Setを再設定します。
    051 *   bulkSet   は、先のSetを取り出し、SQL文に加味して処理します。
    052 * 流れ的には、query で検索し、minusまたはintersect でSetオブジェクトを加工し、bulkSet で
    053 * 利用します。例えば、ORACLEから、ユニークキーのSetを作成し、SQLServerのユニークキーを
    054 * minusした結果を、ORACLEからDELETEすれば、不要なデータを削除するなどの処理が実行可能になります。
    055 * また、単純に、query だけを、チェインすれば、単発のUPDATE文を実行することが可能です。
    056 *
    057 * データベース接続先等は、ParamProcess のサブクラス(Process_DBParam)に
    058 * 設定された接続(Connection)を使用します。
    059 * DBID は、Process_DBParam の -configFile で指定する DBConfig.xml ファイルを使用します。
    060 *
    061 * 引数文字列中にスペースを含む場合は、ダブルコーテーション("") で括って下さい。
    062 * 引数文字列の 『=』の前後には、スペースは挟めません。必ず、-key=value の様に
    063 * 繋げてください。
    064 *
    065 * SQL文には、{&#064;DATE.YMDH}等のシステム変数が使用できます。
    066 *
    067 * @og.formSample
    068 *  Process_BulkQuery -action=query -dbid=DBGE -sql="select KEY from TABLE_X"
    069 *
    070 *     -action=処理方法(必須)      ： 実行する処理方法を指定します
    071 *                                       -action=query     単なるSQL文を実行します。
    072 *                                       -action=bulkSet   実行したSQL文の結果を、Set&lt;String&gt; オブジェクトに設定します。
    073 *                                       -action=minus     Set&lt;String&gt; オブジェクトと、ここでの実行結果の差分をとります。
    074 *                                       -action=plus      Set&lt;String&gt; オブジェクトと、ここでの実行結果の加算をします。
    075 *                                       -action=intersect Set&lt;String&gt; オブジェクトと、ここでの実行結果の積分をとります。
    076 *   [ -dbid=DB接続ID             ] ： -dbid=DBGE (例: Process_DBParam の -configFile で指定する DBConfig.xml ファイルで規定)
    077 *   [ -sql=検索SQL文             ] ： -sql="select * from GEA08"
    078 *   [ -sqlFile=検索SQLファイル   ] ： -sqlFile=select.sql
    079 *                                       -sql= を指定しない場合は、ファイルで必ず指定してください。
    080 *   [ -sql_XXXX=固定値           ] ： -sql_SYSTEM_ID=GE
    081 *                                       SQL文中の{&#064;XXXX}文字列を指定の固定値で置き換えます。
    082 *                                       WHERE SYSTEM_ID='{&#064;SYSTEM_ID}' ⇒ WHERE SYSTEM_ID='GE'
    083 *   [ -bulkKey=XXXX              ] ： -bulkKey=XXXX
    084 *                                       SQL文中の{&#064;XXXX}文字列をProcess_BulkQuery等で取得した値で置き換えます。
    085 *                                       WHERE SYSTEM_ID IN ( {&#064;XXXX} ) ⇒ WHERE SYSTEM_ID IN ( 'AA','BB','CC' )
    086 *   [ -bulkType=NUM|STR          ] ： -bulkType=STR
    087 *                                     Bulkの値を文字列に変換する場合に、数字型か、文字型を指定します。
    088 *                                     数字型では、AA,BB,CC とし、文字型では、'AA','BB','CC' に変換します(初期値:STR)。
    089 *   [ -fetchSize=1000            ] ：フェッチする行数(初期値:1000)
    090 *   [ -display=[false/true]      ] ：結果を標準出力に表示する(true)かしない(false)か(初期値:false[表示しない])
    091 *   [ -debug=[false/true]        ] ：デバッグ情報を標準出力に表示する(true)かしない(false)か(初期値:false[表示しない])
    092 *
    093 * @og.rev 5.3.4.0 (2011/04/01) 新規追加
    094 * @version  4.0
    095 * @author   Kazuhiko Hasegawa
    096 * @since    JDK5.0,
    097 */
    098public class Process_BulkQuery extends AbstractProcess implements FirstProcess , ChainProcess {
    099        private static final int    MAX_BULK_SET        = 500 ;         // ORACLE の制約が 1000 なので。
    100
    101        private static final String ACT_QUERY           = "query" ;
    102        private static final String ACT_BULKSET         = "bulkSet" ;
    103        private static final String ACT_MINUS           = "minus" ;
    104        private static final String ACT_PLUS            = "plus" ;                      // 6.3.1.1 (2015/07/10) 追加
    105        private static final String ACT_INTERSECT       = "intersect" ;
    106
    107        private static final String[] ACTION_LST = { ACT_QUERY,ACT_BULKSET,ACT_MINUS,ACT_PLUS,ACT_INTERSECT };
    108
    109//      /** 6.9.3.0 (2018/03/26) データ検索時のフェッチサイズ  {@value} */
    110//      private static final int DB_FETCH_SIZE = 1001 ;
    111
    112        private String          actionCmd       ;                                       // SQL結果を加工(query:実行、minus:引き算、intersect:重複分)
    113        private String          dbid            ;                                       // メインDB接続ID
    114
    115        private String          bulkKey         ;
    116        private boolean         bulkType        = true;                         // true:STR , false:NUM
    117
    118        private int                     sqlCount        ;                                       // SQL文の処理件数
    119        private int                     setCount        ;                                       // 取り出したSetの件数
    120        private int                     outCount        ;                                       // マージ後のSetの件数
    121
    122        private int                     fetchSize       = 1000;
    123        private boolean         display         ;                                       // 表示しない
    124        private boolean         debug           ;                                       // デバッグ情報
    125        private boolean         firstTime       = true;                         // 最初の一回目
    126
    127        /** staticイニシャライザ後、読み取り専用にするので、ConcurrentHashMap を使用しません。 */
    128        private static final Map<String,String> MUST_PROPARTY   ;               // ［プロパティ］必須チェック用 Map
    129        /** staticイニシャライザ後、読み取り専用にするので、ConcurrentHashMap を使用しません。 */
    130        private static final Map<String,String> USABLE_PROPARTY ;               // ［プロパティ］整合性チェック Map
    131
    132        static {
    133                MUST_PROPARTY = new LinkedHashMap<>();
    134                MUST_PROPARTY.put( "action",    "実行する処理方法を指定します。(query|minus|plus|intersect)" );
    135
    136                USABLE_PROPARTY = new LinkedHashMap<>();
    137                USABLE_PROPARTY.put( "dbid",            "Process_DBParam の -configFile で指定する DBConfig.xml ファイルで規定" );
    138                USABLE_PROPARTY.put( "sql",             "検索SQL文(sql or sqlFile 必須)例: \"select * from GEA08\"" );
    139                USABLE_PROPARTY.put( "sqlFile", "検索SQLファイル(sql or sqlFile 必須)例: select.sql" );
    140                USABLE_PROPARTY.put( "sql_",            "SQL文中の{&#064;XXXX}文字列を指定の固定値で置き換えます。" +
    141                                                                        CR + "WHERE SYSTEM_ID='{&#064;SYSTEM_ID}' ⇒ WHERE SYSTEM_ID='GE'" );
    142                USABLE_PROPARTY.put( "dbid2",   "DB接続ID2 例: Process_DBParam の -configFile で指定する DBConfig.xml ファイルで規定" );
    143                USABLE_PROPARTY.put( "sql2",            "検索SQL文2(sql or sqlFile 必須)例: \"select * from GEA08\"" );
    144                USABLE_PROPARTY.put( "sqlFile2",        "検索SQLファイル2(sql or sqlFile 必須)例: select.sql" );
    145                USABLE_PROPARTY.put( "sql2_",   "SQL文2中の{&#064;XXXX}文字列を指定の固定値で置き換えます。" +
    146                                                                        CR + "WHERE SYSTEM_ID='{&#064;SYSTEM_ID}' ⇒ WHERE SYSTEM_ID='GE'" );
    147                USABLE_PROPARTY.put( "bulkKey",         "SQL文中の{&#064;XXXX}文字列をProcess_BulkQuery等で取得した値で置き換えます。" +
    148                                                                        CR + "WHERE SYSTEM_ID IN ( {&#064;XXXX} ) ⇒ WHERE SYSTEM_ID IN ( 'AA','BB','CC' )" );
    149                USABLE_PROPARTY.put( "bulkType",                "Bulkの値を文字列に変換する場合に、文字型か、数字型を指定します。" +
    150                                                                        CR + "数字型では、AA,BB,CC とし、文字型では、'AA','BB','CC' に変換します。(初期値:STR)" );
    151                USABLE_PROPARTY.put( "fetchSize","フェッチする行数 (初期値:1000)" );
    152                USABLE_PROPARTY.put( "display", "結果を標準出力に表示する(true)かしない(false)か" +
    153                                                                                CR + "(初期値:false:表示しない)" );
    154                USABLE_PROPARTY.put( "debug",   "デバッグ情報を標準出力に表示する(true)かしない(false)か" +
    155                                                                                CR + "(初期値:false:表示しない)" );
    156        }
    157
    158        /**
    159         * デフォルトコンストラクター。
    160         * このクラスは、動的作成されます。デフォルトコンストラクターで、
    161         * super クラスに対して、必要な初期化を行っておきます。
    162         *
    163         */
    164        public Process_BulkQuery() {
    165                super( "org.opengion.fukurou.process.Process_BulkQuery",MUST_PROPARTY,USABLE_PROPARTY );
    166        }
    167
    168        /**
    169         * プロセスの初期化を行います。初めに一度だけ、呼び出されます。
    170         * 初期処理(ファイルオープン、ＤＢオープン等)に使用します。
    171         *
    172         * @og.rev 5.3.9.0 (2011/09/01) 1000件を超えた場合の処理を追加
    173         * @og.rev 6.3.1.1 (2015/07/10) plus アクションの追加
    174         *
    175         * @param   paramProcess データベースの接続先情報などを持っているオブジェクト
    176         */
    177        public void init( final ParamProcess paramProcess ) {
    178                final Argument arg = getArgument();
    179
    180                actionCmd       = arg.getProparty( "action"             , null , ACTION_LST );
    181
    182                fetchSize       = arg.getProparty( "fetchSize"  , fetchSize );
    183                display         = arg.getProparty( "display"    , display );
    184                debug           = arg.getProparty( "debug"              , debug );
    185
    186                dbid            = arg.getProparty( "dbid");
    187                String sql      = arg.getFileProparty( "sql"    , "sqlFile",true );
    188                if( debug ) { println( "入力SQL:" + sql ); }
    189
    190                final HybsEntry[] entry =arg.getEntrys( "sql_" );               //配列
    191                final SystemParameter sysParam = new SystemParameter( sql );
    192                sql = sysParam.replace( entry );
    193                if( debug ) { println( "変換SQL:" + sql ); }
    194
    195                if( ACT_BULKSET.equalsIgnoreCase( actionCmd ) ) {
    196                        bulkKey         = arg.getProparty( "bulkKey" );
    197                        final String bkType = arg.getProparty( "bulkType" );
    198                        if( bkType != null ) { bulkType = "STR".equalsIgnoreCase( bkType ); }   // 初期値が true なので、null チャックは外せません。
    199
    200                        final Set<String> setData = paramProcess.getBulkData();
    201                        if( debug ) { println( setData.toString() ); }
    202                        setCount = setData.size();
    203
    204                        if( setCount > 0 ) {
    205                                // 5.3.9.0 (2011/09/01) 1000件を超えた場合の処理を追加
    206                                final String[] sqls = makeBulkQuery( sql,bulkKey,bulkType,setData );
    207                                for( int i=0; i<sqls.length; i++ ) {
    208                                        if( debug ) { println( "BulkSQL:" + sqls[i] ); }
    209                                        createSetData( paramProcess, dbid, sqls[i] );
    210                                }
    211                        }
    212                }
    213                else if( ACT_QUERY.equalsIgnoreCase( actionCmd ) ) {
    214                        final Set<String> setData2 = createSetData( paramProcess, dbid, sql );
    215                        if( debug ) { println( setData2.toString() ); }
    216                        setCount = setData2.size();
    217                        outCount = setCount;
    218                        paramProcess.setBulkData( setData2 );
    219                }
    220                else {
    221                        final Set<String> setData  = paramProcess.getBulkData();
    222                        final Set<String> setData2 = createSetData( paramProcess, dbid, sql );
    223                        setCount = setData2.size();
    224
    225                        if( ACT_MINUS.equalsIgnoreCase( actionCmd ) ) {
    226                                setData.removeAll( setData2 );
    227                        }
    228                        else if( ACT_PLUS.equalsIgnoreCase( actionCmd ) ) {                     // 6.3.1.1 (2015/07/10)
    229                                setData.addAll( setData2 );
    230                        }
    231                        else if( ACT_INTERSECT.equalsIgnoreCase( actionCmd ) ) {
    232                                setData.retainAll( setData2 );
    233                        }
    234                        outCount = setData.size();
    235                        if( debug ) { println( setData.toString() ); }
    236                        paramProcess.setBulkData( setData );
    237                }
    238        }
    239
    240        /**
    241         * プロセスの終了を行います。最後に一度だけ、呼び出されます。
    242         * 終了処理(ファイルクローズ、ＤＢクローズ等)に使用します。
    243         *
    244         * @param   isOK トータルで、OKだったかどうか [true:成功/false:失敗]
    245         */
    246        public void end( final boolean isOK ) {
    247                // 何もありません。
    248        }
    249
    250        /**
    251         * このデータの処理において、次の処理が出来るかどうかを問い合わせます。
    252         * この呼び出し１回毎に、次のデータを取得する準備を行います。
    253         *
    254         * @return      処理できる:true / 処理できない:false
    255         */
    256        @Override       // FirstProcess
    257        public boolean next() {
    258                return firstTime;
    259        }
    260
    261        /**
    262         * 引数の LineModel を処理するメソッドです。
    263         * 変換処理後の LineModel を返します。
    264         * 後続処理を行わない場合(データのフィルタリングを行う場合)は、
    265         * null データを返します。つまり、null データは、後続処理を行わない
    266         * フラグの代わりにも使用しています。
    267         * なお、変換処理後の LineModel と、オリジナルの LineModel が、
    268         * 同一か、コピー(クローン)かは、各処理メソッド内で決めています。
    269         * ドキュメントに明記されていない場合は、副作用が問題になる場合は、
    270         * 各処理ごとに自分でコピー(クローン)して下さい。
    271         *
    272         * @param       data    オリジナルのLineModel
    273         *
    274         * @return      処理変換後のLineModel
    275         */
    276//      @SuppressWarnings(value={"unchecked"})
    277        @Override       // ChainProcess
    278        public LineModel action( final LineModel data ) {
    279                return data ;
    280        }
    281
    282        /**
    283         * 最初に、 行データである LineModel を作成します
    284         * FirstProcess は、次々と処理をチェインしていく最初の行データを
    285         * 作成して、後続の ChainProcess クラスに処理データを渡します。
    286         *
    287         * @param       rowNo   処理中の行番号
    288         *
    289         * @return      処理変換後のLineModel
    290         */
    291        @Override       // FirstProcess
    292        public LineModel makeLineModel( final int rowNo ) {
    293                firstTime = false;              // 一度しか処理しないため、false を設定する。
    294
    295                final LineModel model = new LineModel();
    296
    297                model.setRowNo( rowNo );
    298
    299                return model;
    300        }
    301
    302        /**
    303         * 内部で使用する Set オブジェクトを作成します。
    304         * Exception 以外では、必ず Set<String> オブジェクトを返します。
    305         *
    306         * @og.rev 5.3.9.0 (2011/09/01) 1000件を超えた場合の処理を追加
    307         * @og.rev 6.4.2.1 (2016/02/05) try-with-resources 文で記述。
    308         *
    309         * @param   paramProcess        データベースの接続先情報などを持っているオブジェクト
    310         * @param   dbid                        接続先ID
    311         * @param   sql                         実行するSQL文(検索系)
    312         *
    313         * @return      実行結果から取り出した、最初のカラムのみを集めた Setオブジェクト
    314         * @throws RuntimeException データベース処理ができなかった場合。
    315         */
    316        private Set<String> createSetData( final ParamProcess paramProcess, final String dbid, final String sql ) {
    317                final Set<String> data = new HashSet<>();
    318
    319                Connection connection   = null;
    320
    321                try {
    322                        connection = paramProcess.getConnection( dbid );
    323                        // 6.4.2.1 (2016/02/05) try-with-resources 文
    324                        try( Statement stmt = connection.createStatement() ) {
    325                                if( fetchSize > 0 ) { stmt.setFetchSize( fetchSize ); }
    326                                if( stmt.execute( sql ) ) {                     // true:検索系 , false:更新系
    327                                        try( ResultSet resultSet = stmt.getResultSet() ) {
    328                                                while( resultSet.next() ) {
    329                                                        sqlCount++ ;
    330                                                        final String str = resultSet.getString(1);
    331                                                        if( display ) { println( str ); }
    332                                                        data.add( str );
    333                                                }
    334                                        }
    335                                }
    336                                else {
    337                                        sqlCount += stmt.getUpdateCount();
    338                                }
    339                        }
    340                }
    341                catch( final SQLException ex) {
    342                        final String errMsg = "SQL を実行できませんでした。" + CR
    343                                                + "errMsg=[" + ex.getMessage() + "]" + CR
    344                                                + "errorCode=[" + ex.getErrorCode() + "] State=[" + ex.getSQLState() + "]" + CR
    345                                                + "DBID=" + dbid + CR
    346                                                + "SQL =" + sql ;
    347
    348                        throw new OgRuntimeException( errMsg,ex );
    349                }
    350                finally {
    351
    352                        ConnectionFactory.remove( connection,dbid );
    353                }
    354                return data;
    355        }
    356
    357        /**
    358         * 内部で使用する Set オブジェクトを作成します。
    359         * Exception 以外では、必ず Set<String[]> オブジェクトを返します。
    360         *
    361         * @og.rev 5.3.9.0 (2011/09/01) 1000件を超えた場合の処理を追加
    362         *
    363         * @param       sql                     オリジナルのSQL文
    364         * @param       bulkKey         一括処理で置き換えるキー文字列
    365         * @param       bulkType        文字型(true)か、数字型(false)を指定
    366         * @param   setData             一括処理の元となるSetオブジェクト
    367         *
    368         * @return      オリジナルのSQL文 に 一括処理の文字列と置換したSQL文の配列
    369         */
    370        private String[] makeBulkQuery( final String sql, final String bulkKey, final boolean bulkType,final Set<String> setData ) {
    371                String[] sqls = new String[ setData.size()/MAX_BULK_SET + 1 ];
    372                int idx = 0;
    373                int cnt = 0;
    374
    375                final StringBuilder buf = new StringBuilder( BUFFER_MIDDLE );
    376                String bulkVal = null;
    377                if( bulkType ) {                        // 文字列の場合
    378                        for( final String key : setData ) {
    379                                cnt++;
    380                                buf.append( ",'" ).append( key ).append( '\'' );
    381                                if( cnt >= MAX_BULK_SET ) {
    382                                        bulkVal = buf.substring( 1 );           // 先頭のコロンをはずす
    383                                        sqls[idx++] = sql.replace( "{@" + bulkKey + "}" ,bulkVal );
    384                                        cnt = 0;
    385                                        buf.setLength(0);                                       // 6.1.0.0 (2014/12/26) refactoring
    386                                }
    387                        }
    388                        if( cnt > 0 ) {                 // きっちりで終わらない場合
    389                                bulkVal = buf.substring( 1 );   // 先頭のコロンをはずす
    390                                sqls[idx] = sql.replace( "{@" + bulkKey + "}" ,bulkVal );
    391                        }
    392                }
    393                else {                                          // 数字の場合
    394                        for( final String key : setData ) {
    395                                cnt++;
    396                                buf.append( ',' ).append( key );                // 6.0.2.5 (2014/10/31) char を append する。
    397                                if( cnt >= MAX_BULK_SET ) {
    398                                        bulkVal = buf.substring( 1 );           // 先頭のコロンをはずす
    399                                        sqls[idx++] = sql.replace( "{@" + bulkKey + "}" ,bulkVal );
    400                                        cnt = 0;
    401                                        buf.setLength(0);                                       // 6.1.0.0 (2014/12/26) refactoring
    402                                }
    403                        }
    404                        if( cnt > 0 ) {                 // きっちりで終わらない場合
    405                                bulkVal = buf.substring( 1 );                   // 先頭のコロンをはずす
    406                                sqls[idx] = sql.replace( "{@" + bulkKey + "}" ,bulkVal );
    407                        }
    408                }
    409
    410                return sqls;
    411        }
    412
    413        /**
    414         * プロセスの処理結果のレポート表現を返します。
    415         * 処理プログラム名、入力件数、出力件数などの情報です。
    416         * この文字列をそのまま、標準出力に出すことで、結果レポートと出来るような
    417         * 形式で出してください。
    418         *
    419         * @return   処理結果のレポート
    420         */
    421        public String report() {
    422                // 7.2.9.5 (2020/11/28) PMD:Consider simply returning the value vs storing it in local variable 'XXXX'
    423                return "[" + getClass().getName() + "]" + CR
    424//              final String report = "[" + getClass().getName() + "]" + CR
    425                                + TAB + "Action    : " + actionCmd      + CR
    426                                + TAB + "DBID      : " + dbid           + CR
    427                                + TAB + "sqlCount  : " + sqlCount       + CR
    428                                + TAB + "setCount  : " + setCount       + CR
    429                                + TAB + "outCount  : " + outCount ;
    430
    431//              return report ;
    432        }
    433
    434        /**
    435         * このクラスの使用方法を返します。
    436         *
    437         * @return      このクラスの使用方法
    438         * @og.rtnNotNull
    439         */
    440        public String usage() {
    441                final StringBuilder buf = new StringBuilder( 1200 )
    442                        .append( "Process_BulkQueryは、データベースから読み取った内容を、一括処理するために、"               ).append( CR )
    443                        .append( "ParamProcess のサブクラス(Process_DBParam)にセットしたり、加工したりする"                  ).append( CR )
    444                        .append( "FirstProcess と、ChainProcess のインターフェースを両方持った、実装クラスです。" ).append( CR )
    445                        .append( CR )
    446                        .append( "このクラスは、上流から、下流への処理は、１度しか実行されません。"                                     ).append( CR )
    447                        .append( "FirstProcess の検索結果は、Set オブジェクトとして、Process_DBParam に渡します。"     ).append( CR )
    448                        .append( "ChainProcess は、その結果を取り出し、自分自身の処理結果と合せて加工します。"         ).append( CR )
    449                        .append( CR )
    450                        .append( "FirstProcess では、-action は、query のみです。"                                                                        ).append( CR )
    451                        .append( "  query は、指定のSQL文を実行し、結果のSetをParamProcessに設定します。"                     ).append( CR )
    452                        .append( "ChainProcess では、-action は、query、bulkSet、minus、intersect が指定できます。"     ).append( CR )
    453                        .append( "  query     は、上記と同じです。"                                                                                                       ).append( CR )
    454                        .append( "  minus     は、先のSetから、SQL文の実行結果を引き算し、結果Setを再設定します。"   ).append( CR )
    455                        .append( "  intersect は、先のSetから、SQL文の実行結果と重複する結果Setを再設定します。"    ).append( CR )
    456                        .append( "  bulkSet   は、先のSetを取り出し、SQL文に加味して処理します。"                                     ).append( CR )
    457                        .append( CR )
    458                        .append( "流れ的には、query で検索し、minusまたはintersect でSetオブジェクトを加工し、"           ).append( CR )
    459                        .append( "bulkSet で利用します。例えば、ORACLEから、ユニークキーのSetを作成し、"                  ).append( CR )
    460                        .append( "SQLServerのユニークキーをminusした結果を、ORACLEからDELETEすれば、不要な"                    ).append( CR )
    461                        .append( "データを削除するなどの処理が実行可能になります。また、単純に、query だけを、"            ).append( CR )
    462                        .append( "チェインすれば、単発のUPDATE文を実行することが可能です。"                                                      ).append( CR )
    463                        .append( CR )
    464                        .append( "データベース接続先等は、ParamProcess のサブクラス(Process_DBParam)に"                    ).append( CR )
    465                        .append( "設定された接続(Connection)を使用します。"                                                                           ).append( CR )
    466                        .append( CR )
    467                        .append( "引数文字列中に空白を含む場合は、ダブルコーテーション(\"\") で括って下さい。"    ).append( CR )
    468                        .append( "引数文字列の 『=』の前後には、空白は挟めません。必ず、-key=value の様に"           ).append( CR )
    469                        .append( "繋げてください。"                                                                                                                             ).append( CR )
    470                        .append( CR )
    471                        .append( "SQL文には、{@DATE.YMDH}等のシステム変数が使用できます。"                                          ).append( CR )
    472                        .append( CR ).append( CR )
    473                        .append( getArgument().usage() ).append( CR );
    474
    475                return buf.toString();
    476        }
    477
    478        /**
    479         * このクラスは、main メソッドから実行できません。
    480         *
    481         * @param       args    コマンド引数配列
    482         */
    483        public static void main( final String[] args ) {
    484                LogWriter.log( new Process_BulkQuery().usage() );
    485        }
    486}