ExecuteSQLStatement 2025.10.2.19

Bundle

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

Description

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.

Balises

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

Exigences en matière d’entrées

REQUIRED

Prend en charge les propriétés dynamiques sensibles

false

Propriétés

Propriété

Description

Service de pooling de connexions

Le service de pooling de connexions qui est utilisé pour obtenir une connexion à la base de données

Max Batch Size

Le nombre maximum de FlowFiles à traiter en un seul lot

Taille maximale de référence de contenu

Si la propriété SQL fait référence à ${flowfile_content}, cette propriété spécifie la taille maximale de FlowFile qui est autorisée à être lue en mémoire. Si le FlowFile est supérieur à cette valeur, le FlowFile sera routé vers l’échec. Si la propriété SQL ne fait pas référence à ${flowfile_content}, cette valeur n’a aucun effet.

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.

Relations

Nom

Description

failure

L’instruction SQL n’a pas pu être exécutée

success

L’instruction SQL a été exécutée avec succès