これらのプロパティは、標準ジョブのフレームワークで実行されているtDB2BulkExecを設定するために使われます。
標準のtDB2BulkExecコンポーネントは、データベースファミリーに属しています。
このフレームワーク内のコンポーネントは、すべてのTalend製品で使用できます。
基本設定
| データベース |
目的のデータベースタイプをリストから選択し、[Apply] (適用)をクリックします。 |
|
[Property type] (プロパティタイプ) |
[Built-in] (組み込み)と[Repository] (リポジトリー)のいずれかです。 |
|
|
[Built-In] (組み込み): 一元的に保存されるプロパティデータはありません。 |
|
|
[Repository] (リポジトリー): プロパティが保管されるリポジトリーファイルを選択します。後続フィールドは、取得されたデータを使用して自動的に入力されます。 |
|
[Use an existing connection] (既存の接続を使用) |
定義済みの接続の詳細を再利用する場合は、このチェックボックスをオンにして、[Component List] (コンポーネントリスト)ドロップダウンリストから、目的の接続コンポーネントを選択します。 注: ジョブに親ジョブと子ジョブが含まれている時は、親ジョブと子ジョブの間の既存の接続を共有したい場合(たとえば、親ジョブで作成した接続を子ジョブと共有するなど)には、次のように実行します。
ジョブレベル全体でデータベース接続を共有する方法の例は、データベース接続を共有をご覧ください。 |
|
[Host] (ホスト) |
データベースサーバーのIPアドレス |
|
[Port] (ポート) |
データベースサーバーのリスニングポート番号。 |
|
[Database] (データベース) |
データベースの名前 |
|
[Table Schema] (テーブルスキーマ) |
DBスキーマの名前。 |
|
[Username] (ユーザー名)と[Password] (パスワード) |
データベースユーザー認証データ。 パスワードを入力するためには、パスワードフィールドの横にある[...]ボタンをクリックし、ポップアップダイアログボックスにパスワードを二重引用符で囲んで入力して[OK]をクリックし、設定を保存します。 |
|
[Table] (テーブル) |
書き込まれるテーブルの名前。一度に書き込みができるテーブルは1つだけです。 |
|
[Action on table] (テーブルでのアクション) |
定義済みのテーブルで、次のオペレーションの1つを実行できます。 [None] (なし): 操作は行われません。 [Drop and create table] (ドロップしてテーブルを作成): テーブルが削除され、再作成されます。 [Create table] (テーブルを作成): テーブルが存在しないため、作成されます。 [Create table if not exists] (テーブルが存在しない場合は作成): テーブルが存在しない場合は作成されます。 [Drop table if exists and create] (テーブルが存在する場合はドロップして作成): テーブルが既に存在する場合は削除されて再作成されます。 [Clear table] (テーブルをクリア): テーブルの内容が削除されます。 |
|
[Schema] (スキーマ)と[Edit schema] (スキーマを編集) |
スキーマとは行の説明のことです。処理して次のコンポーネントに渡すフィールド(カラム)数を定義します。Sparkジョブを作成する場合、フィールドの命名時は予約語のlineを避けます。 |
|
|
[Built-In] (組み込み): このコンポーネントに対してのみスキーマを作成し、ローカルに保管します。[Basic settings] (基本設定)タブにあるコンポーネントスキーマの詳細は、[Basic settings] (基本設定)をご覧ください。 |
|
|
[Repository] (リポジトリー): スキーマは作成済みで、リポジトリーに保管されているので、再利用できます。[Basic settings] (基本設定)タブにあるコンポーネントスキーマの詳細は、[Basic settings] (基本設定)をご覧ください。 |
|
スキーマを変更するには[Edit schema] (スキーマを編集)をクリックします。現在のスキーマがリポジトリータイプの場合は、3つのオプションを利用できます。
|
|
|
[Use Ingest Command] (取り込みコマンドの使用) |
このチェックボックスを選択すると、INGESTコマンドを使ってデータをDB2に取り込むことができます。取り込みコマンドの詳細は、http://www.ibm.com/developerworks/data/library/techarticle/dm-1304ingestcmdとhttps://www-01.ibm.com/support/knowledgecenter/SSEPGG_10.1.0/com.ibm.db2.luw.admin.cmd.doc/doc/r0057198.html?cp=SSEPGG_10.1.0%2F3-5-2-4-59をご覧ください。 |
|
[Load From] (ロード元) |
入力するデータのソースを選択します。
このリストは、[Use Ingest Command] (取り込みコマンドを使う)チェックボックスがオンの場合にのみ使えます。 |
| [Data File] (データファイル) | ロードするファイルの名前。 注: このファイルは、[Host] (ホスト)フィールドのURIで指定されたマシン上に置かれているため、データベースサーバーと同じマシン上にある必要があります。
[Load From] (ロード元)ドロップダウンリストから[PIPE] (パイプ)または[FOLDER] (フォルダー)が選択されている場合、このフィールドは表示されません。 |
|
[Data File/Named Pipe] (データファイル/名前付きパイプ) |
データのロード元であるファイルの名前、または名前付きパイプ。このコンポーネントは、DB2テーブルにデータをロードする時にデータファイルと名前付きパイプをサポートします。DB2システムプロシージャーであるSYSPROC.ADMIN_CMDを呼び出すことで、LOADコマンドを使ってデータをロードします。詳細は、LOAD command using the ADMIN_CMD procedureをご覧ください。 注:
[Use Ingest Command] (取り込みコマンドを使う)が選択されている時は、このフィールドは表示されません。 |
|
[Pipe Name] (パイプ名) |
パイプの名前を入力します。 このフィールドは、[Load From] (ロード元)ドロップダウンリストから[PIPE] (パイプ)が選択されている場合にのみ使えます。 |
|
フォルダー |
ロードするファイルを保持するフォルダーへのパスを指定します。 このフィールドは、[Load From] (ロード元)ドロップダウンリストから[FOLDER] (フォルダー)が選択されている場合にのみ使えます。 |
|
[Action on data] (データでのアクション) |
定義済みテーブルのデータで、次の操作の1つを実行できます。
[Delete] (削除)と[Merge] (マージ)は、[Use Ingest Command] (取り込みコマンドを使う)チェックボックスがオンの場合にのみ使えます。 |
|
[File Glob Pattern] (ファイルGlobパターン) |
ロードするファイルのグローバル式を指定します。 このフィールドは、[Load From] (ロード元)ドロップダウンリストから[FOLDER] (フォルダー)が選択されている場合にのみ使えます。 |
|
[Where Clause] (Where句) |
WHERE句を入力して、処理するデータをフィルタリングします。 このフィールドは、[Action on Data] (データ操作)ドロップダウンリストで[update] (アップデート)または[delete] (削除)を選択している場合にのみ使えます。 |
|
[Custom Insert Values Clause] (カスタム挿入値句) |
このチェックボックスをオンにして、表示された[Insert Values Clause] (値の挿入句)フィールドに、[insert] (挿入)操作のVALUES句を入力します。 このチェックボックスは、[Use Ingest Command] (取り込みコマンドを使う)チェックボックスがオンで、[Action on Data] (データに対するアクション)ドロップダウンリストから[insert] (挿入)が選択されている場合にのみ使えます。 |
|
[Custom Update Set Clause] (カスタムアップデート設定句) |
このチェックボックスをオンにし、[Set Mapping] (マッピングの設定)テーブルに入力して、[update] (アップデート)操作のSET句を指定します。 このチェックボックスは、[Use Ingest Command] (取り込みコマンドを使う)チェックボックスがオンで、[Action on Data] (データに対するアクション)ドロップダウンリストから[update] (アップデート)が選択されている場合にのみ使えます。 |
|
[Set Mapping] (マッピングの設定) |
このテーブルを完成して、[update] (アップデート)操作のSET節を指定します。
このテーブルは、[Custom Update Set Clause] (カスタムアップデート設定句)チェックボックスがオンの場合にのみ使えます。 |
|
[Merge Clause] (マージ句) |
[merge] (マージ)操作にMERGE句を指定します。 このテーブルは、[Use Ingest Command] (取り込みコマンドを使う)チェックボックスがオンで、[Action on Data] (データに対するアクション)ドロップダウンリストから[merge] (マージ)が選択されている場合にのみ使えます。 |
|
[Content Format] (コンテンツフォーマット) |
入力ファイルのフォーマットとして、[Delimited] (区切り)または[Positional] (固定長ファイル)を選択します。 このリストは、[Use Ingest Command] (取り込みコマンドを使う)チェックボックスがオンの場合にのみ使えます。 |
|
[Delimited By] (区切り) |
区切り付きファイルのフィールドを区切る文字を入力します。 このフィールドは、[Content Format] (コンテンツフォーマット)ドロップダウンリストから[Delimited] (区切り)が選択されている場合にのみ使えます。 |
|
[Optionally Enclosed By] (オプションで囲む) |
区切り付きファイル内の文字列を囲む文字を入力します。 このフィールドは、[Content Format] (コンテンツフォーマット)ドロップダウンリストから[Delimited] (区切り)が選択されている場合にのみ使えます。 |
|
[Fixed Length] (固定長) |
固定長ファイルのレコードの長さ(バイト単位)を入力します。 このフィールドは、[Content Format] (コンテンツフォーマット)ドロップダウンリストから[Positional] (固定長ファイル)が選択されている場合にのみ使えます。 |
|
[Mapping] (マッピング) |
このテーブルを完成して、ソースカラムとDB2テーブルカラムの間のマッピング関係を指定します。
このテーブルは、[Use Ingest Command] (取り込みコマンドを使う)チェックボックスがオンの場合にのみ使えます。 |
|
[Script Generated Folder] (スクリプト生成フォルダー) |
スクリプトファイルの作成先となるディレクトリーを指定します。 このフィールドは、[Use Ingest Command] (取り込みコマンドを使う)チェックボックスがオンの場合にのみ使えます。 |
詳細設定
|
[Additional JDBC parameters] (追加のJDBCパラメーター) |
作成するデータベース接続の接続の追加プロパティを指定します。 注:
エンコーディングパラメーターの設定はこのフィールドで行います。 |
|
[Field terminated by] (フィールド区切り) |
フィールドを区切る文字、文字列、または正規表現。 |
|
[Date Format] (日付形式) |
このフィールドを使って、月と日の順序を定義します。 |
|
[Time Format] (時刻の形式) |
このフィールドを使って、時、分、秒の順序を定義します。 |
|
[Timestamp Format] (タイムスタンプ形式) |
このフィールドを使って、日付と時刻の順序を定義します。 |
|
[Remove load pending] (ロードペンディングを削除) |
ボックスをオンにすると、一括ロード後に"保留中"ステータスでブロックされたテーブルのブロックが解除されます。 |
|
[Load options] (ロードオプション) |
[+]をクリックするとデータロードオプションを追加できます。 [Parameter] (パラメーター): ローディングパラメーターをリストから選択します。 [Value] (値): 選択したパラメーターに値を入力します。 |
|
[tStat Catcher Statistics] (tStatキャッチャー統計) |
このチェックボックスを選択すると、コンポーネントレベルでログデータを収集できます。 |
グローバル変数
|
グローバル変数 |
NB_LINE: 処理された行の数。これはAfter変数で、整数を返します。 NB_LINE_UPDATED: アップデートされた行の数。これはAfter変数で、整数を返します。 NB_LINE_INSERTED: 挿入された行の数。これはAfter変数で、整数を返します。 NB_LINE_DELETED: 削除された行の数。これはAfter変数で、整数を返します。 QUERY: 処理されたクエリーステートメント。これはAfter変数で、文字列を返します。 ERROR_MESSAGE: エラーが発生した時にコンポーネントによって生成されるエラーメッセージ。これはAfter変数で、文字列を返します。この変数はコンポーネントにこのチェックボックスが存在し、[Die on error] (エラー発生時に強制終了)がオフになっている場合のみ機能します。 Flow変数はのコンポーネントの実行中に機能し、After変数はコンポーネントの実行後に機能します。 フィールドまたは式に変数を入力する場合は、Ctrl + スペースを押して変数リストにアクセスし、使用する変数を選択します。 変数の詳細は、コンテキストと変数を使用をご覧ください。 |
使用方法
|
使用ルール |
この専用コンポーネントにより、DB2のクエリー処理のパフォーマンスと柔軟性が向上します。 |
|
[Dynamic settings] (ダイナミック設定) |
[+]ボタンをクリックしてテーブルに行を追加し、[Code] (コード)フィールドにコンテキスト変数を入力して、ジョブ内で計画した複数の接続からデータベース接続をダイナミックに選択します。この機能は、データストラクチャーが同じでデータベースが異なるデータベーステーブルにアクセスする必要がある場合、特に、Talend Studioを介さずにジョブをデプロイおよび実行する必要がある時など、ジョブの設定を変更できない環境で作業している場合に役立ちます。 [Dynamic settings] (ダイナミック設定)テーブルは、[Basic settings] (基本設定)ビューで[Use an existing connection] (既存の接続を使用)チェックボックスがオンになっている場合のみ利用できます。ダイナミックパラメーターを定義すると、[Basic settings] (基本設定)ビューの[Component List] (コンポーネントリスト)ボックスは利用できなくなります。 ダイナミックパラメーターの定義法を示すユースケースについては、コンテキストベースのダイナミック接続によってデータベースからデータを読み取りと、ダイナミックにロードされた接続パラメーターを使って異なるMySQLデータベースからデータを読み取りをご覧ください。ダイナミック設定とコンテキスト変数の詳細は、ダイナミックスキーマとコンテキストグループを作成し、その中でコンテキスト変数を定義をご覧ください。 |