public class ImportExecuter extends Object
修飾子 | コンストラクタと説明 |
---|---|
protected |
ImportExecuter(ImportConfig config,
ImportOptions options,
Importer importer,
Transaction transaction)
新しい実行インスタンスを生成します。
|
修飾子とタイプ | メソッドと説明 |
---|---|
protected static String |
createDeleteSql(String tableName,
DatabaseColumn[] shiftColumns)
レコードを削除するためのSQLを生成します。
|
protected static String |
createInsertSql(String tableName,
DatabaseColumn[] shiftColumns)
レコードを追加するためのSQLを生成します。
|
protected static String |
createIsExistSelectSql(String tableName,
DatabaseColumn[] shiftColumns)
レコードの存在確認をするためのSQLを生成します。
|
protected static String |
createUpdateSql(String tableName,
DatabaseColumn[] shiftColumns)
レコードを更新するためのSQLを生成します。
|
protected byte[] |
getBinaryData(TextValue value)
カラムがバイナリ型の場合、フィールドに格納されているデータのバイト配列を取得します。
|
protected static Line |
getLine(Importer importer,
DatabaseColumn[] columns,
ImportOptions options)
1レコード分のデータをインポートファイルから取得します。
|
protected ImportListener |
getListener()
インポートリスナを取得します。
|
protected static int |
sleepImport(int importCount,
ImportOptions options)
定期的に処理を休止するかどうかを判定して、必要に応じて処理を一時休止します。
|
protected static DatabaseColumn[] |
sortColumns(Importer importer,
DatabaseColumn[] columns)
インポーターから取得されたフィールド名の配列の順番に従って、ソート済みカラム配列を取得します。
|
protected ImportExecuter(ImportConfig config, ImportOptions options, Importer importer, Transaction transaction)
config
- インポート設定options
- インポートユーザオプションimporter
- インポーターtransaction
- トランザクションprotected static String createDeleteSql(String tableName, DatabaseColumn[] shiftColumns)
tableName
- テーブル名shiftColumns
- ソート済みカラムの配列protected static String createInsertSql(String tableName, DatabaseColumn[] shiftColumns)
tableName
- テーブル名shiftColumns
- ソート済みカラムの配列protected static String createIsExistSelectSql(String tableName, DatabaseColumn[] shiftColumns)
tableName
- テーブル名shiftColumns
- ソート済みカラムの配列protected static String createUpdateSql(String tableName, DatabaseColumn[] shiftColumns)
tableName
- テーブル名shiftColumns
- ソート済みカラムの配列protected static Line getLine(Importer importer, DatabaseColumn[] columns, ImportOptions options) throws IOException, EOFException, ListenerDataSkipException, DataErrorException
importer
- インポーターcolumns
- データベースのカラム配列options
- インポートユーザオプションIOException
EOFException
ListenerDataSkipException
DataErrorException
protected static int sleepImport(int importCount, ImportOptions options)
importCount
- options
- protected static DatabaseColumn[] sortColumns(Importer importer, DatabaseColumn[] columns)
importer
- インポーターcolumns
- カラム配列protected byte[] getBinaryData(TextValue value)
value
- protected ImportListener getListener()
Copyright © 2012 NTT DATA INTRAMART CORPORATION