ExecuteSQLStatement 2025.5.31.15

Pacote

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

Descrição

Executa uma instrução SQL DDL ou DML em um banco de dados. Esse processador permite que a linguagem de expressão seja avaliada em relação aos atributos do FlowFile para parametrizar o SQL para cada 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

A instrução SQL a ser executada. O SQL pode usar a linguagem de expressão para fazer referência a atributos. Nesse caso, o processador reescreverá a consulta usando parâmetros para evitar ataques de injeção de SQL. Ao referenciar a linguagem de expressão, o valor inteiro deve ser uma expressão única. Por exemplo, INSERT INTO TABLE X (name) VALUES ('${name}') é válida, mas INSERT INTO TABLE X (name) VALUES ('Mr. ${name}') não é porque a linguagem de expressão é usada em um valor de cadeia de caracteres. O SQL também pode fazer referência a ${flowfile_content} para fazer referência ao conteúdo do texto codificado FlowFileas UTF-8.

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