tDB2BulkExec標準プロパティ - 7.3

DB2

Version
7.3
Language
日本語 (日本)
Product
Talend Big Data
Talend Big Data Platform
Talend Data Fabric
Talend Data Integration
Talend Data Management Platform
Talend Data Services Platform
Talend ESB
Talend MDM Platform
Talend Open Studio for Big Data
Talend Open Studio for Data Integration
Talend Open Studio for ESB
Talend Real-Time Big Data Platform
Module
Talend Studio
Content
ジョブデザインと開発 > サードパーティーシステム > DBコンポーネント > DB2
データガバナンス > サードパーティーシステム > DBコンポーネント > DB2
データクオリティとプレパレーション > サードパーティーシステム > DBコンポーネント > DB2

このプロパティはStandardジョブフレームワークで実行されているtDB2BulkExecを設定するために使います。

Standard tDB2BulkExecコンポーネントはデータベースファミリーのコンポーネントです。

このフレームワーク内のコンポーネントは、すべてのTalend製品で使用できます。

注: このコンポーネントは、動的データベースコネクターの特定のバージョンです。データベース設定に関連するプロパティは、データベースタイプの選択に応じて異なります。動的データベースコネクターについては、動的データベースコンポーネントを参照してください。

基本設定

データベース

データベースのタイプをリストから選択し、[Apply] (適用)をクリックします。

[Property type] (プロパティタイプ)

[Built-in] (組み込み)または[Repository] (リポジトリー)のいずれかで次の設定を行います

 

[Built-in] (組み込み): プロパティデータは一元的に保管されません。

 

[Repository] (リポジトリー): プロパティが保管されるリポジトリーファイルを選択します。後続フィールドは、取得されたデータを使用して自動的に入力されます。

[Use an existing connection] (既存の接続を使用)

定義済みの接続の詳細を再利用するには、このチェックボックスをオンにして、[Component List] (コンポーネントリスト)で該当する接続コンポーネントをクリックします。

注: ジョブに親ジョブと子ジョブが含まれている時は、2つのレベルの間の既存の接続を共有する必要がな場合(たとえば、親ジョブで作成した接続を子ジョブと共有するなど)には、以下を実行する必要があります。
  1. 親レベルで、共有するデータベース接続を、そのデータベース接続そのものを作成する接続コンポーネントの[Basic settings] (基本設定)ビューに登録します。

  2. 子レベルで、登録済みのそのデータベース接続を読み取るために専用の接続コンポーネントを使用します。

ジョブレベルをまたがってデータベース接続を共有する方法の例は、『 Talend Studio ユーザーガイド』を参照してください。

[Host] (ホスト)

データベースサーバーのIPアドレス

[Port] (ポート)

DBサーバーのリスニングポート番号。

[Database] (データベース)

データベースの名前

[Table Schema] (テーブルスキーマ)

DBスキーマの名前。

[Username] (ユーザー名)[Password] (パスワード)

DBユーザー認証データ。

パスワードを入力するには、パスワードフィールドの横にある[...]ボタンをクリックし、ポップアップダイアログボックスにパスワードを二重引用符の間に入力し、[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] (組み込み): このコンポーネントに対してのみスキーマを作成し、ローカルに保管します。関連項目: Talend Studioユーザーガイドを参照してください。

 

[Repository] (リポジトリー): スキーマは作成済みで、リポジトリーに保管されているので、再利用できます。関連項目: Talend Studioユーザーガイドを参照してください。

 

スキーマを変更するには[Edit schema] (スキーマを編集)をクリックします。現在のスキーマがリポジトリータイプの場合は、3つのオプションを使用できます。

  • [View schema] (スキーマの表示): スキーマのみを表示する場合は、このオプションを選択します。

  • [Change to built-in property] (組み込みのプロパティに変更): ローカルで変更を行うためにスキーマを組み込みに変更する場合は、このオプションを選択します。

  • [Update repository connection] (リポジトリー接続を更新): リポジトリーに保存されているスキーマに変更を加え、変更後にそのコンテンツをすべてのジョブにプロパゲートするかどうかを決める場合は、このオプションを選択します。変更を現在のジョブにのみ反映する場合は、変更後、[No] (いいえ)を選択し、[Repository Content] (リポジトリーのコンテンツ)ウィンドウで再びこのスキーマのメタデータを選択します。

[Use Ingest Command] (取り込みコマンドの使用)

このチェックボックスをオンにすると、INGESTコマンドを使ってデータをDB2に取り込むことができます。取り込みコマンドの詳細は、http://www.ibm.com/developerworks/data/library/techarticle/dm-1304ingestcmdhttps://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] (ロード元)

入力するデータのソースを選択します。

  • [FILE] (ファイル): ファイルからデータをロードします。

  • [PIPE] (パイプ): パイプからデータをロードします。

  • [FOLDER] (フォルダー): フォルダー内の複数のファイルからデータをロードします。

このリストは、[Use Ingest Command] (取り込みコマンドを使う)チェックボックスがオンの場合にのみ使えます。

[Data File] (データファイル)

ロードするファイルの名前。

警告:

このファイルは、[Host] (ホスト)フィールドのURIで指定されたマシン上に置かれているため、データベースサーバーと同じマシン上にある必要があります。

[Load From] (ロード元)ドロップダウンリストから[PIPE] (パイプ)または[FOLDER] (フォルダー)が選択されている場合、このフィールドは表示されません。

[Pipe Name] (パイプ名)

パイプの名前を入力します。

このフィールドは、[Load From] (ロード元)ドロップダウンリストから[PIPE] (パイプ)が選択されている場合にのみ使えます。

フォルダー

ロードするファイルを保持するフォルダーへのパスを指定します。

このフィールドは、[Load From] (ロード元)ドロップダウンリストから[FOLDER] (フォルダー)が選択されている場合にのみ使えます。

[Action on Data] (データへのアクション)

定義済みテーブルのデータで、次の操作の1つを実行できます。
  • [Insert] (挿入): 新しいレコードをテーブルに追加します。重複が見つかった場合、ジョブは停止されます。

  • [Replace] (置換): テーブルに新しいレコードを追加します。プライマリキーまたは一意なインデックスで、テーブル内の古いレコードに新しいレコードと同じ値のものがある場合は、新しいレコードが挿入される前に古いレコードが削除されます。

  • [Update] (更新): 既存のレコードを変更します。

  • [Delete] (削除): 入力データと一致するレコードを削除します。

  • [Merge] (マージ): 入力データをテーブルにマージします。

[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節を指定します。

  • [Column] (カラム): カラムの名前。デフォルトでは、[Column] (カラム)カラムのフィールドはスキーマ内のフィールドと同じです。

  • [Expression] (式): 対応するカラムの式。

このテーブルは、[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テーブルカラムの間のマッピング関係を指定します。

  • [Column] (カラム): カラムの名前。デフォルトでは、[Column] (カラム)カラムのフィールドはスキーマ内のフィールドと同じです。

  • Is Table Column: 対応するカラムがテーブルカラムである場合は、チェックボックスをオンにします。

  • [Start Position] (開始位置): 対応するカラムの開始位置。

  • [End Position] (終了位置): 対応するカラムの終了位置。

    [Start Position] (開始位置)カラムと[End Position] (終了位置)カラムは、[Content Format] コンテンツフォーマット)ドロップダウンリストから[Positional] (固定長ファイル)が選択されている場合にのみ使えます。

このテーブルは、[Use Ingest Command] (取り込みコマンドを使う)チェックボックスがオンの場合にのみ使えます。

[Script Generated Folder] (スクリプト生成フォルダー)

スクリプトファイルの作成先となるディレクトリーを指定します。

このフィールドは、[Use Ingest Command] (取り込みコマンドを使う)チェックボックスがオンの場合にのみ使えます。

詳細設定

[Additional JDBC parameters] (その他のJDBCパラメーター)

作成するDB接続の追加の接続プロパティを指定します。

注:

エンコーディングパラメーターの設定はこのフィールドで行います。

[Field terminated by] (フィールド区切り記号)

フィールドを区切る文字、文字列、または正規表現。

[Date Format] (日付形式)

このフィールドを使って、月と日の順序を定義します。

[Time Format] (時刻の形式)

このフィールドを使って、時、分、秒の順序を定義します。

[Timestamp Format] (タイムスタンプ形式)

このフィールドを使って、日付と時刻の順序を定義します。

[Remove load pending] (ロードペンディングを削除)

ボックスをオンにすると、一括ロード後に"保留中"ステータスでブロックされたテーブルのブロックが解除されます。

[Load options] (ロードオプション)

[+]をクリックするとデータロードオプションを追加できます。

[Parameter] (パラメーター): ローディングパラメーターをリストから選択します。

[Value] (値): 選択したパラメーターに値を入力します。

[tStat Catcher Statistics] (tStatキャッチャー統計)

このチェックボックスをオンにすると、コンポーネントレベルでログデータを収集できます。

グローバル変数

[Global Variables] (グローバル変数) 

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 + Spaceを押して変数リストにアクセスし、リストから使用する変数を選択します。

変数の詳細は、『 Talend Studio ユーザーガイド』を参照してください。

使用方法

使用ルール

この専用コンポーネントにより、DB2のクエリー処理のパフォーマンスと柔軟性が向上します。

[Dynamic settings] (ダイナミック設定)

[+]ボタンをクリックしてテーブルに行を追加し、[Code] (コード)フィールドにコンテキスト変数を入力して、ジョブ内で計画した複数の接続からデータベース接続をダイナミックに選択します。この機能は、データ構造が同じでデータベースが異なるデータベーステーブルにアクセスする必要がある場合、特に、Talend Studioを介さずにジョブをデプロイおよび実行する必要がある時など、ジョブの設定を変更できない環境で作業している場合に役立ちます。

[Dynamic settings] (動的設定)テーブルは、[Basic settings] (基本設定)ビューで[Use an existing connection] (既存の接続を使用)チェックボックスが選択されている場合にのみ使用できます。ダイナミックパラメーターを定義すると、[Basic settings] (基本設定)ビューの[Component List] (コンポーネントリスト)ボックスは使用できなくなります。

動的パラメーターの使用サンプルは、コンテキストベースの動的接続によるデータベースからのデータの読み取りおよび動的に読み込まれた接続パラメーターを使用した異なるMySQLデータベースからのデータの読み取りを参照してください。[Dynamic settings] (動的設定)とコンテキスト変数については、『Talend Studioユーザーガイド』を参照してください。