ExecuteSQLStatement 2025.5.31.15¶

捆绑包¶

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

对数据库执行 SQL DDL 或 DML 语句。该处理器允许根据 FlowFile 属性对表达式语言进行评估，以便对每个 FlowFile 的 SQL 进行参数化。

database、delete、insert、jdbc、openflow、sql、update

REQUIRED

false

属性	描述
连接池服务	用于获取数据库连接的连接池服务
最大批处理大小	单次批处理中可处理的最大 FlowFiles 数量
最大内容引用大小	如果 SQL 属性引用 ${flowfile_content}，则此属性指定允许读入内存的 FlowFile 的最大大小。如果 FlowFile 大于此值，则将 FlowFile 路由到 failure。如果 SQL 属性未引用 ${flowfile_content}，则此值没有任何作用。
SQL	要执行的 SQL 语句。SQL 可以使用表达式语言来引用属性。在这种情况下，处理器将使用参数重写查询，以避免 SQL 注入攻击。引用表达式语言时，整个值必须是单个表达式。例如，`INSERT INTO TABLE X (name) VALUES ('${name}')` 有效，但 `INSERT INTO TABLE X (name) VALUES ('Mr. ${name}')` 无效，因为是在字符串值中使用表达式语言。SQL 也可以引用 `${flowfile_content}`，以便引用 FlowFileas UTF-8 编码文本的内容。

名称	描述
failure	无法执行 SQL 语句
success	SQL 语句已成功执行