ExecuteSQLStatement 2025.5.31.15

Bundle

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

Description

Exécute une instruction SQL DDL ou DML sur une base de données. Ce processeur permet d’évaluer la langue d’expression par rapport aux attributs de FlowFile afin de paramétrer 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. Le SQL peut utiliser la langue d’expression pour faire référence à des attributs. Dans ce casse-tête, le processeur réécrira la requête en utilisant des paramètres afin d’éviter les attaques par injection de SQL. Par exemple, INSERT INTO TABLE X (nom) VALUES (${name}) est valide, mais INSERT INTO TABLE X (nom) VALUES (M. ${name}) ne l’est pas parce que la langue d’expression est utilisée dans une valeur de chaîne. Le SQL peut également faire référence à ${flowfile_content} afin de référencer le contenu du texte codé FlowFileas 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