ExecuteSQLStatement 2025.10.2.19

Bundle

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

Beschreibung

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.

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

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.

Beziehungen

Name

Beschreibung

failure

Die SQL-Anweisung konnte nicht ausgeführt werden

success

Die SQL-Anweisung wurde erfolgreich ausgeführt