Zum Inhalt springen

Datenbankfunktionen in Jitterbit Studio

Datenbankfunktionen bieten Zugriff auf grundlegende Datenbankinteraktionen.

CacheLookup

Deklaration

string CacheLookup(string databaseId, string sql)

Syntax

CacheLookup(<databaseId>, <sql>)

Erforderliche Parameter

  • databaseId: Ein String-Verweis auf eine Datenbankverbindung im aktuellen Projekt
  • sql: Der SQL-Befehl, der gegen die Datenbank ausgeführt werden soll

Beschreibung

Diese Funktion ist identisch mit DBLookup, mit dem Unterschied, dass die erste Abfrage die Informationen zwischenspeichert und nachfolgende Abfragen diesen Cache verwenden, anstatt die Datenbank wiederholt abzufragen. Der Cache ist für die Dauer der Operationenkette, in der er aufgerufen wird, gültig.

Wenn für die im sql angegebene Abfrage keine Zeilen zurückgegeben werden, gibt die Funktion null zurück.

Die globale Jitterbit-Variable $jitterbit.scripting.db.rows_affected wird von dieser Methode nicht gesetzt.

Die in diesem Funktionsaufruf verwendete Datenbank muss als Datenbankverbindung im aktuellen Projekt definiert sein. Weitere Informationen finden Sie in den Anweisungen zum Einfügen von Endpunkten im Abschnitt Endpunkte in Jitterbit Script.

Eine Alternative zum Caching ist die Verwendung der Funktionen Set und Get.

Hinweis

Endpunkte, die mit dieser Funktion erstellt wurden, sind in Endpunktnutzungsberichten enthalten und zählen zu Ihrer Lizenz.

Beispiele

// Abfrage in einer Datenbank mit einer SQL-Zeichenfolge
CacheLookup("<TAG>endpoint:database/My Database</TAG>",
    "SELECT ORDER_TYPE FROM PO_HEADER WHERE PO_NUMBER=1");

CallStoredProcedure

Deklaration

type CallStoredProcedure(string databaseId, string spName, type resultSet[, string inputOutputVariable,...])

Syntax

CallStoredProcedure(<databaseId>, <spName>, <resultSet>[, <inputOutputVariable>,...])

Erforderliche Parameter

  • databaseId: Ein String-Verweis auf einen Datenbankverbindungspfad im aktuellen Projekt
  • spName: Die auszuführende gespeicherte Prozedur auf dem Datenbankserver
  • resultSet: Eine globale Variable zur Speicherung des vom Datenbankserver zurückgegebenen Ergebnisses, falls zutreffend. (Siehe Anmerkungen unten).

Optionale Parameter

  • inputOutputVariable: Ein Eingabe- oder Ausgabeparameter, der an die gespeicherte Prozedur übergeben wird; diese Parameter werden je nach Signatur der gespeicherten Prozedur hinzugefügt

Beschreibung

Ruft die gespeicherte Prozedur spName unter Verwendung der Verbindungsinformationen auf, die durch die Datenbankverbindung identifiziert werden, die durch databaseId angegeben ist.

Falls zutreffend, ist das zurückgegebene resultSet ein zweidimensionales Array von Strings. Wenn die gespeicherte Prozedur kein resultSet zurückgibt oder wenn ein ODBC-Treiber verwendet wird, wird dieses Argument ignoriert.

Für Anwendungsfälle, die nicht durch die Funktion CallStoredProcedure abgedeckt sind, verwenden Sie stattdessen die Funktion DBExecute.

Hinweis

Bei Microsoft SQL Server-Datenbanken ruft diese Funktion gespeicherte Prozeduren im Standard-Datenbankbesitzer (dbo) Schema auf. Um gespeicherte Prozeduren in anderen Schemata aufzurufen, verwenden Sie die Funktion DBExecute.

Vorsicht

Der Parameter resultSet wird derzeit nur von JDBC-Datenbanktreibern unterstützt. Bei Verwendung von ODBC gibt resultSet immer null zurück.

Die verbleibenden optionalen Parameter werden verwendet, um Eingabe- und Ausgabeargumente an das gespeicherte Verfahren zu übergeben. Die Anzahl der erforderlichen Argumente hängt von der Signatur des gespeicherten Verfahrens ab.

Eingabeargumente können ein fest codierter Wert, der Wert einer Quelle oder der Wert einer Berechnung oder Formel sein. Ausgabeargumente (einschließlich des resultSet) werden durch Referenz als "$name" angegeben, wobei "name" der Name der globalen Variablen ist, die den Ausgabewert halten wird. Der Rückgabewert und der Typ der Funktion sind der Rückgabewert und der Typ des gespeicherten Verfahrens.

Die in diesem Funktionsaufruf verwendete Datenbank muss als Datenbankverbindung im aktuellen Projekt definiert sein. Weitere Informationen finden Sie in den Anweisungen zum Einfügen von Endpunkten im Abschnitt Endpoints in Jitterbit Script.

Hinweis

Mit dieser Funktion erstellte Endpunkte sind in endpoint usage reporting enthalten und zählen zu Ihrer Lizenz.

Beispiele

Beispiel 1: Aufruf eines gespeicherten Verfahrens ohne Ergebnisset

// Calls a stored procedure "MyStoredProcedure",
// which takes one input variable, one output
// variable, and ignores the result set.
// "Input" is the name of the source global
// variable that provides the input and
// "output" is the name of the global variable
// used to store the output:
CallStoredProcedure("<TAG>endpoint:database/My Oracle Database</TAG>",
    "MyStoredProcedure", 0, Input, $output);

// The value of the output parameter can be
// accessed by either $output or Get("output")

Beispiel 2: Aufruf eines gespeicherten Verfahrens mit Ergebnisset

// Calls a stored procedure "GetValues", which
// takes two input variables and returns a
// result set.
// The result set is returned as the
// two-dimensional array $result.
// The result can be accessed by using either
// $result or Get("result"):
CallStoredProcedure("<TAG>endpoint:database/My Oracle Database</TAG>",
    "GetValues", $result, Input1, Input2);

Beispiel 3: Aufruf eines gespeicherten Verfahrens, das auf einen Oracle-Objekttyp zugreift

Verwendung von Oracle-Objekt- und Record-Typen

Jitterbit unterstützt Oracle-Objekttypen für die Arbeit mit Oracle-Datenbanken bei Verwendung des Oracle JDBC-Treibers. Oracle-Objekttypen sind ähnlich wie Oracle-Record-Typen, die in Jitterbit aufgrund mangelnder Unterstützung durch Oracle nicht unterstützt werden.

Warnung

Um Oracle-Objekttypen zu verwenden, müssen Sie den Oracle JDBC-Treiber verwenden. Der Oracle ODBC-Treiber unterstützt weder Oracle-Objekttypen noch Oracle-Record-Typen.

Um auf Oracle Record Types mit dem Oracle JDBC-Treiber zuzugreifen, können Sie ein "Wrapper"-Stored Procedure in Ihrer Oracle-Datenbank erstellen, das auf einen Oracle Record Type zugreifen und ihn konvertieren kann. Verwenden Sie dann die Funktion CallStoredProcedure in Jitterbit, um das Wrapper-Verfahren aufzurufen und die Konvertierung zu und von einem Oracle Object Type durchzuführen.

Hinweis

Weitere Informationen zu den Unterschieden zwischen Oracle Record Types und Oracle Object Types finden Sie in der Dokumentation von Oracle. Siehe Record Variable Declaration und Using PL/SQL With Object Types der Oracle Database Release 18-Dokumentation für weitere Informationen.

Das folgende Beispiel beschreibt, wie Sie Oracle Objects in einer CallStoredProcedure-Funktion auf einfache Weise verwenden können.

Oracle-Typdefinitionen

Eine Oracle Object Type-Definition folgt diesem Muster:

Oracle Object Type (Supported)
CREATE OR REPLACE TYPE example_customer_details AS OBJECT
(status NUMBER
,party_id NUMBER
,account_id VARCHAR
);

Eine Oracle Record Type-Definition folgt diesem Muster:

Oracle Record Type (Not Supported)
CREATE TYPE example_customer_details IS RECORD
(status NUMBER
,party_id NUMBER
,account_id VARCHAR
);
Beispielschritte

Schritt 1: Erstellen des Objekts Um Oracle Object Types zu verwenden, erstellen Sie zunächst das Objekt in der Oracle-Datenbank:

Create Object
CREATE OR REPLACE TYPE example_customer_details AS OBJECT
(status                    NUMBER
,party_id                  NUMBER
,account_id                VARCHAR
);

Schritt 2: Erstellen des Pakets Erstellen Sie als Nächstes das Paket als Funktion in der Oracle-Datenbank:

Create Package
CREATE OR REPLACE PACKAGE example AS
  FUNCTION processcustomer(custin IN example_customer_details, new_account_number IN VARCHAR) RETURN example_customer_details;
END example;

Schritt 3: Erstellen des Paketkörpers Erstellen Sie als Nächstes den Paketkörper als Funktion in der Oracle-Datenbank:

Create Package Body
CREATE OR REPLACE PACKAGE BODY example AS
FUNCTION processcustomer(custin IN example_customer_details, new_account_number IN varchar) RETURN example_customer_details
  IS
  custout example_customer_details;
  BEGIN
     custout := example_customer_details(
     custin.status + 1,
     custin.party_id,
     new_account_number
     );
     return custout;
END;
END example;

Schritt 4: Aufrufen des Stored Procedures in Jitterbit Jetzt sind Sie bereit, das Stored Procedure processcustomer von Jitterbit aus mit der Funktion CallStoredProcedure aufzurufen. Dieses Beispielskript zeigt, wie Sie ein Objekt an die Funktion CallStoredProcedure übergeben können. Sie können auch Objekte aus einem Stored Procedure als Rückgabe- oder Ausgabewerte auf ähnliche Weise übergeben.

Jitterbit-Skript erstellen
<trans>
$cust = dict();
$cust["status"] = 1;
$cust["party_id"] = 10;
$cust["account_id"] = "2341";
db = "<TAG>endpoint:database/My Oracle Database</TAG>";
$custout = CallStoredProcedure(db, "EXAMPLE.PROCESSCUSTOMER", "", $cust, "NA0233");
r = "Status: " + $custout["STATUS"] +
" Party ID: " + $custout["PARTY_ID"] +
" Account ID: " + $custout["ACCOUNT_ID"];
WriteToOperationLog("Resulting object: " + r);
</trans>

Hinweis

Im Beispiel erwartet die processcustomer-Funktion in Oracle zwei Parameter: das benutzerdefinierte Objekt (example_customer_details) und eine VARCHAR (new_account_number). Im obigen Beispiel stellt das Wörterbuch $cust das benutzerdefinierte Objekt dar, und NA0233 repräsentiert die VARCHAR.

Vorsicht

Bei der Ausgabe sind die Eigenschaftsnamen des Datentyps großschreibungssensitiv und somit in Großbuchstaben. Bei Eingabeobjekten sind die Eigenschaftsnamen nicht großschreibungssensitiv.

DBCloseConnection

Deklaration

void DBCloseConnection(string databaseId)

Syntax

DBCloseConnection(<databaseId>)

Erforderliche Parameter

  • databaseId: Ein String-Verweis auf eine Datenbankverbindung im aktuellen Projekt

Beschreibung

Bestätigt die aktuelle Transaktion und schließt die Datenbankverbindung.

Die in diesem Funktionsaufruf verwendete Datenbank muss als Datenbankverbindung im aktuellen Projekt definiert sein. Weitere Informationen finden Sie in den Anweisungen zum Einfügen von Endpunkten im Abschnitt Endpunkte in Jitterbit Script.

Hinweis

Endpunkte, die mit dieser Funktion erstellt wurden, sind in Endpunktnutzungsberichten enthalten und zählen zu Ihrer Lizenz.

Beispiele

// Schließen einer Datenbankverbindung
DBCloseConnection("<TAG>endpoint:database/My Database</TAG>");

DBExecute

Deklaration

array DBExecute(string databaseId, string sql)

int DBExecute(string databaseId, string sql, string outputVariable,...)

Syntax

DBExecute(<databaseId>, <sql>)

DBExecute(<databaseId>, <sql>, <outputVariable>,...)

Required parameters

  • databaseId: Ein String-Verweis auf eine Datenbankverbindung im aktuellen Projekt
  • sql: Der SQL-Befehl, der gegen die Datenbank ausgeführt werden soll
  • outputVariable: (Zweite Form) Ein Ausgabewert, der den in dem SQL-Befehl zurückgegebenen Feldern zugeordnet ist. Zusätzliche Argumente können nach Bedarf angegeben werden.

Description

Führt eine SQL-Anweisung auf einer Datenbank aus und gibt die Ergebnisse zurück.

Wenn die SQL-Anweisung ein Ergebnisset erzeugt, gibt es zwei Möglichkeiten, die Daten abzurufen:

  • Wenn nur die beiden erforderlichen Parameter (erste Form) angegeben werden, gibt die Funktion das vollständige Datensatzset als Array von Zeilen zurück.

    Sie können dann eine While()-Schleife verwenden, um über die Zeilen zu iterieren und Get() zu verwenden, um die Daten abzurufen. Wenn keine Zeilen zurückgegeben werden, gibt die Methode ein leeres Array zurück (Length($arr) == 0).

  • Wenn zusätzlich zu den beiden erforderlichen Parametern Ausgabewerte angegeben werden (zweite Form), werden die Werte der Felder der ersten Zeile zurückgegeben.

    Übergeben Sie die Namen der globalen Variablen in Anführungszeichen als Parameter nach den ersten beiden Parametern. Der Wert des ersten Feldes der ersten Zeile wird in die globale Variable geschrieben, die als dritter Parameter übergeben wird, das zweite Feld der ersten Zeile in den vierten Parameter und so weiter. Alternativ können die globalen Variablen durch Voranstellen eines $-Zeichens, wie z.B. $output, als Referenz übergeben werden.

    Der Rückgabewert ist in diesem Fall die Anzahl der zurückgegebenen Datensätze; entweder 1 (wenn Datensätze gefunden wurden) oder 0 (wenn keine zurückgegeben wurden).

Die zurückgegebenen Datenwerte sind immer Strings. Binärdaten werden als ihre hexadezimale String-Darstellung zurückgegeben.

Die in diesem Funktionsaufruf verwendete Datenbank muss als Datenbankverbindung im aktuellen Projekt definiert sein. Weitere Informationen finden Sie in den Anweisungen zum Einfügen von Endpunkten im Abschnitt Endpoints in Jitterbit Script.

Hinweis

Endpunkte, die mit dieser Funktion erstellt werden, sind in der Endpunktnutzungsberichterstattung enthalten und zählen zu Ihrer Lizenz.

Verwandte Jitterbit-Variablen

  • Wenn diese Methode erfolgreich abgeschlossen wird, enthält $jitterbit.scripting.db.rows_affected die Anzahl der von der Abfrage betroffenen Zeilen.
  • Wenn ein JDBC-Treiber verwendet wird, um eine Verbindung zu einer Datenbank herzustellen, setzen Sie jitterbit.scripting.db.search.rowset auf true, bevor Sie die Funktion aufrufen, um sicherzustellen, dass Aufrufe an eine gespeicherte Prozedur, die mehrere Ergebnisse zurückgibt, das erste nicht leere Datensatzset anstelle eines leeren Sets zurückgeben.
  • Um die Anweisung in einer Transaktion auszuführen, setzen Sie die Variablen $jitterbit.scripting.db.auto_commit=false und $jitterbit.scripting.db.transaction=true in einem Skript vor dem Aufruf. Die Transaktion wird am Ende einer erfolgreichen Transformation festgeschrieben. Wenn beide Variablen (auto_commit und transaction) auf true gesetzt werden, führt dies zu einem Fehler.
  • Setzen Sie $jitterbit.scripting.db.max_rows, um die Anzahl der zurückzugebenden Datensätze zu begrenzen. Der Standardwert beträgt 10.000 Zeilen.

Beispiele

Beispiel 1: Ausführen und Werte in einem Array abrufen

// Results of the SQL select as an array

t = "<TAG>endpoint:database/My Database</TAG>";

rows = DBExecute(t, "SELECT ORDER_TYPE, ORDER_AMOUNT FROM PO_HEADER WHERE PO_NUMBER = 1");

// The value of the database column ORDER_TYPE
// can then be accessed with
// Get($rows, $i, 0)
// where $i is the 0-based count of the row you
// want retrieved..

Beispiel 2: Ausführen und Werte in übergebenen referenzierten globalen Variablen abrufen

// Results of the SQL select will be in the
// $custName and $custAddr global variables:

t = "<TAG>endpoint:database/My Database</TAG>";

DBExecute(t,
  "SELECT CustomerName, CustomerAddress FROM Customers WHERE CustomerId = " + $custId,
  $custName, $custAddr);

// The value of the database column CustomerName
// can then be accessed with either
// Get("custName")
// or
// $custName

Beispiel 3: Ausführen und Werte in übergebenen benannten globalen Variablen abrufen

// Results of the SQL select will be in the
// OrderType and OrderAmount global variables:

t = "<TAG>endpoint:database/My Database</TAG>";

DBExecute(t, "SELECT ORDER_TYPE, ORDER_AMOUNT FROM PO_HEADER WHERE PO_NUMBER = 1",
  "OrderType", "OrderAmount");

// The value of the database column ORDER_TYPE
// can then be accessed with either
// Get("OrderType")
// or
// $OrderType

Beispiel 4: Eine gespeicherte Prozedur ausführen

// An alternative to the CallStoredProcedure function.
// Configurable procedure definition as a variable:

$sql = "BEGIN
MyStoredProcedure;
END;";

DBExecute("<TAG>Sources/myDBTarget</TAG>", $sql);

DBLoad

Deklaration

void DBLoad(string source, string target, int mode, string tablename, string columnNames[, string columnKeynames, int skipLines, string dateFormat, string datetimeFormat])

Syntax

DBLoad(<source>, <target>, <mode>, <tablename>, <columnNames>[, <columnKeynames>, <skipLines>, <dateFormat>, <datetimeFormat>])

Erforderliche Parameter

  • source: Ein String-Verweis auf einen Pfad zu einer Aktivität, die mit einem Dateityp-Endpunkt im aktuellen Projekt verbunden ist, der eine einzelne Datei im CSV-Format ist
  • target: Ein String-Verweis auf einen Pfad zu einer Datenbankaktivität, die mit einem Datenbankendpunkt im aktuellen Projekt verbunden ist
  • mode: Eine Ganzzahl; einer von 1 (upsert), 2 (einfügen) oder 3 (aktualisieren)
  • tablename: Die Tabelle in der Ziel-Datenbank
  • columnNames: Eine durch Kommas getrennte Liste von Spaltennamen
  • columnKeynames: Eine durch Kommas getrennte Liste von Spaltennamen, die den Aktualisierungsschlüssel bilden. Erforderlich, wenn der Modus nicht 2 ist.

Optionale Parameter

  • skipLines: Anzahl der Zeilen, die am Anfang der Datei ignoriert werden sollen (wird verwendet, um Kopfzeilen zu überspringen)
  • dateFormat: Gibt das Format von Datumsfeldern an, wie z. B. "Date" in Oracle-Datenbanken
  • datetimeFormat: Gibt das Format von Datums- und Zeitfeldern an, wie z. B. "TimeStamp" in Oracle-Datenbanken

Beschreibung

Nimmt eine Quelle (eine einzelne Datei im CSV-Format) und lädt die Daten in eine angegebene Tabelle in einer Ziel-Datenbank.

Der Parameter columnKeynames wird nicht verwendet, wenn nur eingefügt wird (mode=2) und kann in diesem Fall weggelassen werden.

Quelle und Ziel

Die Quelle, die in diesem Funktionsaufruf verwendet wird, muss als Aktivität definiert sein, die mit einem Dateityp-Endpunkt im aktuellen Projekt verbunden ist. Dazu gehören konfigurierte File Share-, FTP-, HTTP-, Local Storage- und Temporary Storage-Aktivitäten. Die erste Datei, die aus dieser Quelle zurückgegeben wird, wird verwendet.

Das Ziel, das in diesem Funktionsaufruf verwendet wird, muss als Datenbankaktivität definiert sein, die mit einem Datenbankendpunkt im aktuellen Projekt verbunden ist.

Für weitere Informationen siehe die Anweisungen zum Einfügen von Endpunkten im Abschnitt Endpunkte in Jitterbit Script.

Warnung

Die DBLoad()-Funktion funktioniert nur bei Datenbankaktivitäten, die mit einem Datenbankendpunkt unter Verwendung eines JDBC-Treibers verbunden sind.

Hinweis

Endpunkte, die mit dieser Funktion erstellt wurden, sind in der Endpunktnutzungsberichterstattung enthalten und zählen zu Ihrer Lizenz.

Beispiele

// Using the file returned from the source
// "FTP Files", this example upserts (mode=1)
// into the table "MyTable" on the database
// target "myDatabase". "FTP Files" is
// expected to be a CSV file that contains data
// for the columns "ID,Col1,Col2,Col3".
// The update key (used to decide whether to
// update or insert) will be on the column "ID".
// The first line of the CSV file will be
// ignored as it is a header:

DBLoad("<TAG>activity:ftp/FTP Endpoint/ftp_read/FTP Files</TAG>",
    "<TAG>activity:database/Database Endpoint/database_insert/myDatabase</TAG>",
    1, "MyTable", "ID,Col1,Col2,Col3", "ID", 1);

DBLookup

Deklaration

string DBLookup(string databaseId, string sql)

Syntax

DBLookup(<databaseId>, <sql>)

Erforderliche Parameter

  • databaseId: Ein String-Verweis auf eine Datenbankverbindung im aktuellen Projekt
  • sql: Der SQL-Befehl, der gegen die Datenbank ausgeführt werden soll

Beschreibung

Führt eine SQL-Anweisung auf einer Datenbank aus und gibt das erste Feld des ersten Ergebnisses zurück, das den angegebenen Kriterien entspricht.

Der zurückgegebene Datenwert ist immer ein String. Binärdaten werden als ihre hexadezimale String-Darstellung zurückgegeben. Wenn für die angegebene Abfrage keine Zeilen zurückgegeben werden, gibt die Funktion null zurück.

Die globale Jitterbit-Variable $jitterbit.scripting.db.rows_affected wird von dieser Methode nicht gesetzt.

Für komplexere Abfragen, bei denen Sie mehr als einen Wert oder eine Zeile abrufen möchten, verwenden Sie die Funktionen DBLookupAll oder DBExecute.

Datenbank-ID

Die in diesem Funktionsaufruf verwendete Datenbank muss als Datenbankverbindung im aktuellen Projekt definiert sein. Weitere Informationen finden Sie in den Anweisungen zum Einfügen von Endpunkten im Abschnitt Endpunkte in Jitterbit Script.

Hinweis

Endpunkte, die mit dieser Funktion erstellt wurden, sind in der Endpunktnutzungsberichterstattung enthalten und zählen zu Ihrer Lizenz.

Beispiele

// Returns the first field of the first result
// from running the SQL query
result = DBLookup("<TAG>endpoint:database/My Database</TAG>",
    "SELECT ORDER_TYPE FROM PO_HEADER WHERE PO_NUMBER=1");

DBLookupAll

Deklaration

array DBLookupAll(string databaseId, string sql)

Syntax

DBLookupAll(<databaseId>, <sql>)

Erforderliche Parameter

  • databaseId: Ein String-Verweis auf eine Datenbankverbindung im aktuellen Projekt
  • sql: Der SQL-Befehl, der gegen die Datenbank ausgeführt werden soll

Beschreibung

Führt eine SQL-Anweisung auf einer Datenbank aus und gibt die Ergebnisse zurück, die den angegebenen Kriterien entsprechen.

Die zurückgegebenen Daten werden immer als zweidimensionales Array von Strings zurückgegeben. Binärdaten werden als hexadezimale String-Darstellung zurückgegeben. Wenn für die angegebene Abfrage keine Zeilen zurückgegeben werden, gibt die Funktion ein leeres Array zurück.

Die globale Jitterbit-Variable $jitterbit.scripting.db.rows_affected wird von dieser Methode nicht gesetzt.

Die in diesem Funktionsaufruf verwendete Datenbank muss als Datenbankverbindung im aktuellen Projekt definiert sein. Weitere Informationen finden Sie in den Anweisungen zum Einfügen von Endpunkten im Abschnitt Endpunkte in Jitterbit Script.

Für fortgeschrittenere Abfragen, bei denen Sie direkt in globale Variablen abrufen möchten, verwenden Sie die Funktion DBExecute.

Hinweis

Endpunkte, die mit dieser Funktion erstellt wurden, sind in Endpunktnutzungsberichten enthalten und zählen zu Ihrer Lizenz.

Beispiele

// Gibt das Ergebnis der Ausführung der SQL-Abfrage zurück
result = DBLookupAll("<TAG>endpoint:database/My Database</TAG>",
    "SELECT ORDER_TYPE FROM PO_HEADER WHERE PO_NUMBER=1");

DBRollbackTransaction

Deklaration

void DBRollbackTransaction(string databaseId)

Syntax

DBRollbackTransaction(<databaseId>)

Erforderliche Parameter

  • databaseId: Ein String-Verweis auf eine Datenbankverbindung im aktuellen Projekt

Beschreibung

Rollback der aktuellen Transaktion und Schließen der Datenbankverbindung.

Die in diesem Funktionsaufruf verwendete Datenbank muss als Datenbankverbindung im aktuellen Projekt definiert sein. Weitere Informationen finden Sie in den Anweisungen zum Einfügen von Endpunkten im Abschnitt Endpoints in Jitterbit Script.

Hinweis

Endpunkte, die mit dieser Funktion erstellt wurden, sind in Endpoint-Nutzungsberichten enthalten und zählen zu Ihrer Lizenz.

Beispiele

// Rollback der aktuellen Transaktion
DBRollbackTransaction("<TAG>endpoint:database/My Database</TAG>");

DBWrite

Deklaration

void DBWrite(string source, string target, int mode, string tablename, string columnNames[, string columnKeynames, int skipLines, string dateFormat, string datetimeFormat])

Syntax

DBWrite(<source>, <target>, <mode>, <tablename>, <columnNames>[, <columnKeynames>, <skipLines>, <dateFormat>, <datetimeFormat>])

Beschreibung

Ein Alias für die Funktion DBLoad. Siehe DBLoad für Details.

Hinweis

Endpunkte, die mit dieser Funktion erstellt wurden, sind in Endpoint-Nutzungsberichten enthalten und zählen zu Ihrer Lizenz.

SetDBInsert

Declaration

void SetDBInsert()

Syntax

SetDBInsert()

Description

Überschreibt die aktuelle Einstellung des Einfüge-/Aktualisierungsmodus auf "einfügen" für den aktuellen Datensatz. Der Rückgabewert ist null.

Examples

// Setzt den Einfüge-/Aktualisierungsmodus auf "einfügen"
// für den aktuellen Datensatz
SetDBInsert();

SetDBUpdate

Declaration

void SetDBUpdate()

Syntax

SetDBUpdate()

Description

Überschreibt die aktuelle Einstellung des Einfüge-/Aktualisierungsmodus auf "aktualisieren" für den aktuellen Datensatz. Der Rückgabewert ist null.

Examples

// Setzt den Einfüge-/Aktualisierungsmodus auf "aktualisieren"
// für den aktuellen Datensatz
SetDBUpdate();

SQLEscape

Declaration

string SQLEscape(string unescapedSQL[, bool escapeBackslash])

Syntax

SQLEscape(<unescapedSQL>[, <escapeBackslash>])

Required parameters

  • unescapedSQL: Ein SQL-String, der escaped werden soll

Optional parameters

  • escapeBackslash: Boolean-Flag, das angibt, ob Backslashes ("\") durch Verdopplung escaped werden sollen; Standard ist false

Description

Führt das notwendige Escaping von Literalstrings in einer SQL-Anweisung durch.

Strings, die als Zeichenkonstanten in einer SQL-Anweisung verwendet werden, verwenden ein einfaches Anführungszeichen (') als Trennzeichen; wenn die tatsächlichen Daten einfache Anführungszeichen enthalten, müssen diese durch zweimalige Angabe escaped werden. Diese Methode escaped einfache Anführungszeichen gemäß dem SQL-Standard, indem jedes einfache Anführungszeichen (') durch zwei einfache Anführungszeichen ('') ersetzt wird. Wenn auch Backslash-Zeichen escaped werden sollen, geben Sie den zweiten Parameter an und setzen Sie ihn auf true.

Beispiele

// In this example, the variable GUID needs to
// have any single quotes in it escaped
// (doubled); the resulting string is then
// enclosed in single quotes by the Quote
// function before being used in a DBLookup
// function:


DBLookup("<TAG>endpoint:database/My Database</TAG>",
    "SELECT ORDER FROM PO_HEADER WHERE PO_ID=" + Quote(SQLEscape(GUID)));

Unmap

Deklaration

void Unmap()

Syntax

Unmap()

Beschreibung

Für die Verwendung in Zuordnungen setzt diese Funktion ein Datenbankziel-Feld so, dass es als nicht zugeordnet behandelt wird. Der Rückgabewert ist null.

Beispiele

valueToInsert = DBLookup(....);
// If valueToInsert returned by a DBLookup is null, we want to treat
// this field as unmapped and we do not want to include it in the INSERT statement
// that is being generated for the DB target for this record:
If (valueToInsert == Null(), Unmap(), valueToInsert);

<SEQUENCE\>

Deklaration

<SEQUENCE>

Syntax

<SEQUENCE>

Beschreibung

Für die Verwendung in Zuordnungen mit Oracle-Datenbanken wird diese Funktion verwendet, wenn das Ziel Tabellen enthält, die durch eine Primärschlüssel/Fremdschlüssel-Beziehung verbunden sind. In diesem Fall sollte dies auf die Primärschlüssel abgebildet werden, die von der Oracle-Datenbank generiert werden.

Für Datenbanken, die nicht Oracle sind, verwenden Sie stattdessen die Funktion <SQLIDENTITY>.

Hinweis

In der Syntax für diese Funktion sind die kleiner ("<") und größer (">") Symbole Teil der Funktionssyntax.

Beispiele

Wenn <trans>-Tags vorhanden sind, sollte <SEQUENCE> außerhalb von ihnen platziert werden, wie folgt:

<trans>
</trans>
<SEQUENCE>

<SQLIDENTITY\>

Deklaration

<SQLIDENTITY>

Syntax

<SQLIDENTITY>

Beschreibung

Für die Verwendung in Zuordnungen mit Nicht-Oracle-Datenbanken wird diese Funktion verwendet, wenn das Ziel Tabellen enthält, die durch eine Primärschlüssel/Fremdschlüssel-Beziehung verbunden sind. In diesem Fall sollte dies auf die Primärschlüssel abgebildet werden, die von der Datenbank generiert werden, wie Identity in SQL Server oder Serial in PostgreSQL. Für Oracle-Datenbanken verwenden Sie stattdessen die Funktion <SEQUENCE>.

Hinweis

In der Syntax für diese Funktion sind die kleiner- ("<") und größer- (">") Symbole Teil der Funktionssyntax.

Beispiele

Wenn <trans>-Tags vorhanden sind, sollte <SQLIDENTITY> außerhalb von ihnen platziert werden, wie folgt:

<trans>
</trans>
<SQLIDENTITY>

<UDF\>

Deklaration

<UDF>string userDefinedFunction

Syntax

<UDF><userDefinedFunction>

Erforderliche Parameter

  • userDefinedFunction: Ein String, der einen Aufruf einer benutzerdefinierten Funktion definiert

Beschreibung

Fügt eine benutzerdefinierte Datenbankfunktion an den Anfang einer Formel hinzu. Das <UDF>-Präfix wird von dem Ausdruck entfernt, bevor er weitergegeben wird. Beachten Sie, dass öffnende und schließende <trans>-Tags verwendet werden können, um Teile des Funktionsaufrufs anzugeben, die von Jitterbit ausgewertet werden sollen, bevor der Ausdruck an eine Datenbank übergeben wird.

Hinweis

In der Syntax für diese Funktion sind die kleiner- ("<") und größer- (">") Symbole um <UDF> Teil der Funktionssyntax.

Beispiele

// The user-defined function geography::Point()
// is being called with parameters created by evaluating
// the Jitterbit Script enclosed by <trans> tags:

<UDF>geography::Point(<trans>json$Incidents$item.Latitude$ + ","
  + json$Incidents$item.Longitude$ + ",4326";</trans>)