ExecuteSQLStatement 2025.5.31.15

バンドル

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

説明

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

タグ

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

入力要件

REQUIRED

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

false

プロパティ

プロパティ

説明

接続プーリングサービス

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

最大バッチサイズ

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

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

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

SQL

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

リレーションシップ

名前

説明

failure

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

success

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