ExecuteSQLStatement 2025.10.2.19¶

Bundle¶

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

Description¶

Exécutez une instruction SQL DDL ou DML sur une base de données. Ce processeur permet d’évaluer le langage d’expression par rapport aux attributs FlowFile afin de paramétrer l’instruction SQL pour chaque 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	L’instruction SQL à exécuter. L’instruction SQL peut utiliser le langage d’expression pour référencer des attributs. Dans ce cas, le processeur réécrira la requête en utilisant des paramètres afin d’éviter les attaques par injection SQL. Lors de la référence au langage d’expression, la valeur entière doit être une seule expression. Par exemple, `INSERT INTO TABLE X (nom) VALUES ('${nom}')` est valide, mais `INSERT INTO TABLE X (nom) VALUES ('M. ${nom}')` ne l’est pas, car le langage d’expression est utilisé dans une valeur de chaîne. L’instruction SQL peut également faire référence à `${flowfile_contenu}` afin de référencer le contenu du FlowFile comme texte codé en UTF-8.

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