ExecuteSQLStatement 2025.10.2.19¶

捆绑包¶

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

描述¶

Executes a SQL DDL or DML Statement against a database. This Processor allows Expression Language to be evaluated against FlowFile attributes in order to parameterize the SQL for each FlowFile.

标签¶

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

输入要求¶

REQUIRED

支持敏感的动态属性¶

false

属性¶

属性	描述
连接池服务	用于获取数据库连接的连接池服务
最大批处理大小	单次批处理中可处理的最大 FlowFiles 数量
最大内容引用大小	如果 SQL 属性引用 ${flowfile_content}，则此属性指定允许读入内存的 FlowFile 的最大大小。如果 FlowFile 大于此值，则将 FlowFile 路由到 failure。如果 SQL 属性未引用 ${flowfile_content}，则此值没有任何作用。
SQL	The SQL statement to execute. The SQL may make use of Expression Language to reference attributes. In this case, the Processor will rewrite the query using parameters in order to avoid SQL Injection attacks. When referencing Expression Language, the entire value must be a single Expression. For example, `INSERT INTO TABLE X (name) VALUES ( '${name}')` is valid, but `INSERT INTO TABLE X (name) VALUES ( 'Mr. ${name}')` is not because Expression Language is used within a String value. The SQL may also reference `${flowfile_content}` in order to reference the content of the FlowFile as UTF-8 encoded text.

关系¶

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