Amazon® Aurora® などの Postgres リレーショナルデータベースで構造化クエリ言語 (SQL) 操作をチェーンの一部として実行するには、Postgres 接続コマンドを含むステップを追加します。
これらのコマンドを有効にするには、IT 管理者がまずPostgres コネクタ を作成します。
createの実行
CREATE 文を実行するには、Execute Create コマンドを使用します。
プロパティ
| プロパティ |
詳細 |
| SQLテキスト/ファイル |
実行するSQLテキストまたはファイルを入力します。 |
出力
なし
終了コード
| コード |
タイプ |
詳細 |
| 0 |
成功 |
成功 |
| 1 |
エラー |
無効な入力 |
| 3 |
エラー |
コマンドの実行に失敗 |
クエリの実行
SELECT クエリを実行し、その結果をカンマ区切り値（CSV）ファイルとして受け取るには、Execute Query コマンドを使用する。
プロパティ
| プロパティ |
詳細 |
| SQLテキスト/ファイル |
実行するSQLテキストまたはファイルを入力します。 |
| 区切り記号 |
CSV出力で使用する区切り文字を選択します。 |
| プレビュー結果 |
返された行のプレビューを見るには、このボックスをチェックします。 |
出力
| 出力 |
出力タイプ |
| レコード数 |
整数 |
| 結果セット（CSV） |
ファイル |
終了コード
| コード |
タイプ |
詳細 |
| 0 |
成功 |
成功 |
| 1 |
エラー |
無効な入力 |
| 3 |
エラー |
コマンドの実行に失敗 |
SQLの実行
SQLコマンドを実行するには、Execute SQL コマンドを使用します。結果セットがあれば、ファイル出力として利用できる。
プロパティ
| プロパティ |
詳細 |
| SQLテキスト/ファイル |
実行するSQLテキストまたはファイルを入力します。 |
出力
| 出力 |
出力タイプ |
| レコード数 |
整数 |
| 結果セット（CSV） |
ファイル |
| 記録更新 |
整数 |
終了コード
| コード |
タイプ |
詳細 |
| 0 |
成功 |
成功 |
| 1 |
エラー |
無効な入力 |
| 3 |
エラー |
コマンドの実行に失敗 |
アップデートの実行
UPDATE ステートメントを実行するには、Execute Update コマンドを使用します。
プロパティ
| プロパティ |
詳細 |
| SQLテキスト/ファイル |
実行するSQLテキストまたはファイルを入力します。 |
出力
終了コード
| コード |
タイプ |
詳細 |
| 0 |
成功 |
成功 |
| 1 |
エラー |
無効な入力 |
| 3 |
エラー |
コマンドの実行に失敗 |
テーブル定義の取得
テーブルの詳細（カラム、主キー、外部キーを含む）を JSON として取得するには、Get Table Definition コマンドを使用します。
プロパティ
| プロパティ |
詳細 |
| テーブル |
定義を取得するテーブルを入力する。 |
出力
終了コード
| コード |
タイプ |
詳細 |
| 0 |
成功 |
成功 |
| 1 |
エラー |
無効な入力が行われた |
| 3 |
エラー |
コマンドの実行に失敗 |
レコードの挿入
INSERT ステートメントを実行するには、Insert Records コマンドを使用する。データのソースは、複数行のテキストまたはCSVファイルです。
プロパティ
| プロパティ |
詳細 |
| テーブル |
レコードを挿入するテーブルを入力します。 |
| CSVデータソース |
テーブルに挿入するCSVファイルを入力します。CSVファイルの列は、Columns で指定した順序と同じでなければならない。 |
| 区切り記号 |
CSV データソース で使用する区切り記号を選択します。 |
| ファイル |
CSV データ・ソース がファイルの場合は、このボックスにチェックを入れます。 |
| ヘッダーを含む |
CSV データソース の最初の行がヘッダーの場合は、このボックスにチェックを入れます。 |
| 列 |
CSV データソース が入力する列のリストを、CSV データソース と同じ順序で入力します。 |
| 価値テンプレート |
INSERT コマンドのカスタム値宣言を入力する。? で値を示す。?の数は、ターゲットのフィールド数と一致させる。自動生成する場合は空白のままにしてください。 |
出力
| 出力 |
出力タイプ |
| レコード数 |
整数 |
| 結果セット（CSV） |
ファイル |
| 挿入された記録 |
整数 |
終了コード
| コード |
タイプ |
詳細 |
| 0 |
成功 |
成功 |
| 1 |
エラー |
無効な入力 |
| 3 |
エラー |
コマンドの実行に失敗 |
レコードのアップサート
UPSERT ステートメントを実行するには、Upsert Records コマンドを使用する。既存のレコードの一意キーがデータ・ソース内のレコードの一意キーと一致する場合、コマンドはレコード を更新し、そうでない場合は、レコード を挿入する。
プロパティ
| プロパティ |
詳細 |
| ターゲット・テーブル |
レコードをアップサートするテーブルを入力します。 |
| ステージングテーブル（自動生成） |
ターゲット・テーブルにアップサートされるレコードを一時的に保持するテーブルの名前を入力する。 注： 既存のテーブルを使用しないでください。 コマンドは自動的にテーブルを作成し、upsert中にこのテーブルを削除します。 |
| ユニークなカラム |
各レコードに固有の値を含む列のリストを入力します。これらのカラムがステージング・テーブルとターゲット・テーブルの両方のレコード間で一致する場合、コマンドは、レコードを 更新する。そうでない場合、、レコードを 挿入する。 |
| CSVデータソース |
ターゲット・テーブルにアップサートする複数行のテキストまたはCSVファイルを入力します。このデータソースのカラムは、Columns と同じ順序でなければならない。 |
| 区切り記号 |
CSV データソース で使用する区切り記号を選択します。 |
| ファイル |
CSV データ・ソース が CSV ファイルの場合、このボックスにチェックを入れます。 |
| ヘッダーを含む |
CSVデータ・ソース がヘッダー行で始まる場合は、このボックスにチェックを入れます。 |
| 列 |
CSV データソースと同じ順序で、CSV データソース が入力する列のリストを入力します。 |
| 価値テンプレート |
UPSERT 文のカスタム値を入力します。? で値を示す。?の数は、ターゲットのフィールド数と一致させる。自動生成する場合は空白のままにしてください。 |
出力
| 出力 |
出力タイプ |
| 記録更新 |
整数 |
| SQLエラー |
JSON |
終了コード
| コード |
タイプ |
詳細 |
| 0 |
成功 |
成功 |
| 1 |
エラー |
無効な入力が行われた |
| 3 |
エラー |
コマンドの実行に失敗 |