DatabaseRecordSink

Beschreibung

Bietet einen Dienst zum Schreiben von Datensätzen unter Verwendung einer konfigurierten Datenbankverbindung.

Tags

connection, database, db, jdbc, record

Eigenschaften

In der folgenden Liste sind die erforderlichen Eigenschaften mit einem Sternchen (*) gekennzeichnet. Andere Eigenschaften werden als optional betrachtet. Die Tabelle zeigt auch alle Standardwerte und ob eine Eigenschaft die NiFi Expression Language unterstützt.

Display Name (Anzeigename)

API-Name

Standardwert

Zugelassene Werte

Beschreibung

Catalog Name

db-record-sink-catalog-name

Der Name des Katalogs, den die Anweisung aktualisieren soll. Dies gilt möglicherweise nicht für die Datenbank, die Sie aktualisieren. In diesem Fall lassen Sie das Feld leer.

Database Connection Pooling Service *

db-record-sink-dcbp-service

Der Controller Service, der verwendet wird, um eine Verbindung zur Datenbank zum Senden von Datensätzen herzustellen.

Max Wait Time *

db-record-sink-query-timeout

0 Sekunden

Die maximal erlaubte Zeit für eine laufende SQL-Anweisung. Null bedeutet, dass es kein Limit gibt. Eine maximale Zeit von weniger als 1 Sekunde entspricht Null.

Quote Column Identifiers

db-record-sink-quoted-identifiers

false

  • true

  • false

Wenn Sie diese Option aktivieren, werden alle Spaltennamen in Anführungszeichen gesetzt, sodass Sie reservierte Wörter als Spaltennamen in Ihren Tabellen verwenden können.

Quote Table Identifiers

db-record-sink-quoted-table-identifiers

false

  • true

  • false

Wenn Sie diese Option aktivieren, wird der Tabellenname in Anführungszeichen gesetzt, um die Verwendung von Sonderzeichen im Tabellennamen zu unterstützen.

Schema Name

db-record-sink-schema-name

Der Name des Schemas, zu dem die Tabelle gehört. Dies gilt möglicherweise nicht für die Datenbank, die Sie aktualisieren. In diesem Fall lassen Sie das Feld leer.

Table Name *

db-record-sink-table-name

Der Name der Tabelle, auf die sich die Anweisung auswirken soll.

Translate Field Names

db-record-sink-translate-field-names

true

  • true

  • false

Bei „true“ versucht der Prozessor, die Feldnamen in die entsprechenden Spaltennamen für die angegebene Tabelle zu übersetzen. Bei „false“ müssen die Feldnamen genau mit den Spaltennamen übereinstimmen, sonst wird die Spalte nicht aktualisiert

Unmatched Column Behavior

db-record-sink-unmatched-column-behavior

Fail on Unmatched Columns (Fehler bei nicht übereinstimmenden Spalten)

  • Ignore Unmatched Columns (Nicht übereinstimmende Spalten ignorieren)

  • Warn on Unmatched Columns (Warnung bei nicht übereinstimmenden Spalten)

  • Fail on Unmatched Columns (Fehler bei nicht übereinstimmenden Spalten)

Wenn ein eingehender Datensatz nicht über eine Feldzuordnung für alle Spalten der Datenbanktabelle verfügt, legt diese Eigenschaft fest, wie in diesem Fall vorgegangen werden soll.

Unmatched Field Behavior

db-record-sink-unmatched-field-behavior

Ignore Unmatched Fields (Nicht übereinstimmende Felder ignorieren)

  • Ignore Unmatched Fields (Nicht übereinstimmende Felder ignorieren)

  • Fail on Unmatched Fields (Fehler bei nicht übereinstimmenden Feldern)

Wenn ein eingehender Datensatz ein Feld enthält, das keiner Spalte der Datenbanktabelle zugeordnet werden kann, gibt diese Eigenschaft an, wie die Situation zu behandeln ist

Statusmanagement

Diese Komponente speichert keinen Status.

Eingeschränkt

Diese Komponente ist nicht eingeschränkt.

Hinweise zu Systemressourcen

Diese Komponente enthält keine Angaben zu den Systemressourcen.