ExecuteSQLStatement 2025.10.2.19

バンドル

com.snowflake.openflow.runtime | runtime-database-processors-nar

説明

データベースに対して SQL DDL または DML ステートメントを実行します。このプロセッサーは、 SQL を各 FlowFile に対してパラメーター化するために、 FlowFile の属性に対して式言語を評価することができます。

タグ

データベース、削除、挿入、jdbc、オープンフロー、SQL、更新

入力要件

REQUIRED

機密動的プロパティをサポート

false

プロパティ

プロパティ

説明

接続プーリングサービス

データベースへの接続を取得するために使用される接続プーリングサービス。

最大バッチサイズ

1バッチで処理する FlowFiles の最大数。

最大コンテンツリファレンスサイズ

SQL プロパティが ${flowfile_content} をリファレンスしている場合、このプロパティは、メモリに読み込み可能な FlowFile の最大サイズを指定します。FlowFile がこの値より大きい場合、 FlowFile は失敗にルーティングされます。SQL プロパティが ${flowfile_content} をリファレンスしていない場合、この値は影響しません。

SQL

実行する SQL ステートメント。SQL は、属性を参照するために式言語を使用することができます。この場合、 SQL インジェクション攻撃を避けるために、プロセッサーはパラメーターを使ってクエリを書き換えます。式言語を参照する場合は、値全体が1つの式でなければなりません。例えば、 INSERT INTO TABLE X (name) VALUES ( '${name}') は有効ですが、 INSERT INTO TABLE X (name) VALUES ( 'Mr. ${name}') は、文字列値の中で式言語が使われているため、有効ではありません。SQL は、 ${flowfile_content} を参照し、 FlowFile の内容を UTF-8でエンコードされたテキストとして参照することもできます。

リレーションシップ

名前

説明

failure

SQL ステートメントを実行できませんでした。

success

SQL ステートメントは正常に実行されました。