ExecuteSQLStatement 2025.10.2.19¶

Bundle¶

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

Beschreibung¶

Führt eine SQL DDL- oder DML-Anweisung für eine Datenbank aus. Dieser Prozessor ermöglicht es, Ausdruckssprache mit FlowFile-Attributen auszuwerten, um die SQL für jedes FlowFile zu parametrisieren.

Tags¶

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

Eingabeanforderung¶

REQUIRED

Unterstützt sensible dynamische Eigenschaften¶

false

Eigenschaften¶

Eigenschaft	Beschreibung
Connection Pooling Service	Der Verbindungs-Pooling-Dienst, der verwendet wird, um eine Verbindung zur Datenbank herzustellen
Max Batch Size	Die maximale Anzahl von FlowFiles, die in einem einzigen Batch verarbeitet werden können
Max Content Reference Size	Wenn die SQL-Eigenschaft auf ${flowfile_content} verweist, gibt diese Eigenschaft die maximale Größe des FlowFile an, die in den Speicher eingelesen werden darf. Wenn das FlowFile größer als dieser Wert ist, wird das FlowFile an die Beziehung „failure“ weitergeleitet. Wenn die SQL-Eigenschaft nicht auf ${flowfile_content} verweist, hat dieser Wert keine Auswirkungen.
SQL	Die SQL-Anweisung, die ausgeführt werden soll. SQL kann die Ausdruckssprache verwenden, um auf Attribute zu verweisen. In diesem Fall schreibt der Prozessor die Abfrage mithilfe von Parametern neu, um SQL-Angriffe durch Einschleusung von Befehlen zu vermeiden. Wenn Sie auf die Ausdruckssprache verweisen, muss der gesamte Wert ein einzelner Ausdruck sein. Beispiel: `INSERT INTO TABLE X (Name) VALUES ( '${Name}')` ist gültig, aber `INSERT INTO TABLE X (Name) VALUES ( 'Frau ${Name}')` nicht, da die Ausdruckssprache innerhalb eines Zeichenfolgenwerts verwendet wird. SQL kann auch auf `${flowfile_content}` verweisen, um auf den Inhalt des FlowFile als UTF-8 kodierter Text zu verweisen.

Beziehungen¶

Name	Beschreibung
failure	Die SQL-Anweisung konnte nicht ausgeführt werden
success	Die SQL-Anweisung wurde erfolgreich ausgeführt