public class Process_DBReader extends AbstractProcess implements FirstProcess
Process_DBReaderは、データベースから読み取った内容を、LineModel に設定後、 下流に渡す、FirstProcess インターフェースの実装クラスです。 データベースから読み取った内容より、LineModelを作成し、下流(プロセス チェインは、チェインしているため、データは上流から下流へと渡されます。) に渡します。ここで指定できるのは、検索系SQL のみです。 データベース接続先等は、ParamProcess のサブクラス(Process_DBParam)に 設定された接続(Connection)を使用します。 引数文字列中にスペースを含む場合は、ダブルコーテーション("") で括って下さい。 引数文字列の 『=』の前後には、スペースは挟めません。必ず、-key=value の様に 繋げてください。 SQL文には、{@DATE.YMDH}等のシステム変数が使用できます。
Process_DBReader -dbid=DBGE -sql="select * from GEA08" [ -dbid=DB接続ID ] :-dbid=DBGE (例: Process_DBParam の -configFile で指定する DBConfig.xml ファイルで規定) [ -sql=検索SQL文 ] :-sql="select * from GEA08" [ -sqlFile=検索SQLファイル ] :-sqlFile=select.sql -sql= を指定しない場合は、ファイルで必ず指定してください。 [ -sql_XXXX=固定値 ] :-sql_SYSTEM_ID=GE SQL文中の{@XXXX}文字列を指定の固定値で置き換えます。 WHERE SYSTEM_ID='{@SYSTEM_ID}' ⇒ WHERE SYSTEM_ID='GE' [ -asClms=置換カラム名 ] :-asClms="FGJ:CDJ SEQ123:UNIQ" 元カラム名:新カラム名 のスペース区切り [ -fetchSize=100 ] :フェッチする行数(初期値:100) [ -display=[false/true]] :結果を標準出力に表示する(true)かしない(false)か(初期値:false[表示しない]) [ -debug=[false/true] ] :デバッグ情報を標準出力に表示する(true)かしない(false)か(初期値:false[表示しない])
BUFFER_LARGE, BUFFER_MIDDLE, CR, TAB
コンストラクタと説明 |
---|
Process_DBReader()
デフォルトコンストラクター。
|
修飾子とタイプ | メソッドと説明 |
---|---|
void |
end(boolean isOK)
プロセスの終了を行います。
|
void |
init(ParamProcess paramProcess)
プロセスの初期化を行います。
|
static void |
main(String[] args)
このクラスは、main メソッドから実行できません。
|
LineModel |
makeLineModel(int rowNo)
最初に、 行データである LineModel を作成します
FirstProcess は、次々と処理をチェインしていく最初の行データを
作成して、後続の ChainProcess クラスに処理データを渡します。
|
boolean |
next()
このデータの処理において、次の処理が出来るかどうかを問い合わせます。
|
String |
report()
プロセスの処理結果のレポート表現を返します。
|
String |
usage()
このクラスの使用方法を返します。
|
getArgument, logging, println, putArgument, putArgument, setLoggerProcess, throwException, throwException, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
logging, println, putArgument, putArgument, setLoggerProcess
public Process_DBReader()
public void init(ParamProcess paramProcess)
init
インタフェース内 HybsProcess
paramProcess
- データベースの接続先情報などを持っているオブジェクト5.7.2.2 (2014/01/24) SQL実行エラーを少し詳細に出力します。 |
5.7.2.3 (2014/01/31) asClms 追加 |
public void end(boolean isOK)
end
インタフェース内 HybsProcess
isOK
- トータルで、OKだったかどうか[true:成功/false:失敗]4.0.0.0 (2007/11/27) commit,rollback,remove 処理を追加 |
public boolean next()
next
インタフェース内 FirstProcess
5.7.2.2 (2014/01/24) SQL実行エラーを少し詳細に出力します。 |
public LineModel makeLineModel(int rowNo)
makeLineModel
インタフェース内 FirstProcess
rowNo
- 処理中の行番号5.7.2.2 (2014/01/24) SQL実行エラーを少し詳細に出力します。 |
public String report()
report
インタフェース内 HybsProcess
public String usage()
usage
インタフェース内 HybsProcess
public static void main(String[] args)
args
- コマンド引数配列Webアプリケーションフレームワーク openGionCopyright (c) 2009 The openGion Project.