ExecuteSQLStatement 2025.10.2.19

Pacote

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

Descrição

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.

Tags

database, delete, insert, jdbc, openflow, sql, update

Requisito de entrada

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais

falso

Propriedades

Propriedade

Descrição

Serviço de pool de conexões

O serviço de pool de conexões usado para obter uma conexão com o banco de dados

Tamanho máximo do lote

O número máximo de FlowFiles a ser processado em um único lote

Tamanho de referência do conteúdo máximo

Se a propriedade SQL fizer referência a ${flowfile_content}, essa propriedade especificará o tamanho máximo do FlowFile que pode ser lido na memória. Se o FlowFile for maior que esse valor, o FlowFile será encaminhado para falha. Se a propriedade SQL não fizer referência a ${flowfile_content}, esse valor não terá efeito.

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.

Relações

Nome

Descrição

failure

A instrução SQL não pôde ser executada

success

A instrução SQL foi executada com sucesso