Gespeicherte Prozedur ausführen

Dieses Beispiel zeigt, wie Sie eine gespeicherte Prozedur ausführen, wenn Sie eine Datenbankverbindung verwenden. In diesem Beispiel wird davon ausgegangen, dass Sie mit den folgenden Konzepten vertraut sind:

Alle in einer Datenbankverbindung gespeicherten Prozeduren werden als Aktionen in der Connector-Aufgabe angezeigt. Eine Aktion ist eine Funktion der ersten Klasse, die der Integration über die Connector-Oberfläche zur Verfügung gestellt wird. Mit Aktionen können Sie Änderungen an einer oder mehreren Entitäten vornehmen. Die Aktionen sind von Connector zu Connector unterschiedlich. Es ist jedoch möglich, dass ein Connector keine Aktionen unterstützt. In diesem Fall ist die Actions-Liste leer.

Die folgenden Connectors unterstützen gespeicherte Prozeduren:

Beispiel

Angenommen, Sie haben eine MySQL-Datenbank mit der folgenden gespeicherten Prozedur, die die Informationen eines Kunden aus der Tabelle customers abruft:

CREATE PROCEDURE get_customer_info
(IN p_customer_id INT, OUT p_name VARCHAR(50), OUT p_email VARCHAR(255))
BEGIN
    SELECT name, email INTO p_name, p_email
    FROM customers
    WHERE id = p_customer_id;
END

Diese gespeicherte Prozedur gibt den Namen und die E-Mail-Adresse des angegebenen Kunden zurück. Die Kundennummer akzeptiert die Kundennummer über die Eingabevariable p_customer_id und gibt den Namen und die E-Mail-Adresse in den Ausgabevariablen p_name bzw. p_email zurück.

Wenn Sie nun den Namen und die E-Mail-ID des Kunden mit customer_id=1001 abrufen möchten, müssen Sie die folgenden Aufgaben ausführen:

  1. Verbindung zu Ihrer MySQL-Datenbank herstellen
  2. Öffnen oder erstellen Sie eine neue Integration.
  3. Fügen Sie der Integration die Connectors-Task hinzu.
  4. Klicken Sie im Abschnitt Konfiguration auf Aufgabe konfigurieren, um den Bereich Connector-Aufgabe konfigurieren zu öffnen.
  5. Konfigurieren Sie die Aufgabe „Connectors“ so, dass die Verbindung verwendet wird, die Sie in Schritt 1 erstellt haben.
    1. Wählen Sie in der Spalte Verbindung die gewünschte Verbindung aus der Liste der verfügbaren Verbindungen aus.

      Nachdem Sie eine Verbindung ausgewählt haben, wird die Spalte Typ mit den Werten Entities und Actions angezeigt. Alle gespeicherten Prozeduren werden unter Aktionen aufgeführt.

    2. Wählen Sie Actions > get_customer_info aus.
    3. Klicken Sie auf Fertig, um die Verbindungskonfiguration abzuschließen und den Bereich zu schließen.
  6. Klicken Sie auf das Aufgabenelement Connectors und dann im Abschnitt Task Input auf connectorInputPayload.
  7. Geben Sie die folgende JSON-Nutzlast im Feld Default Value an: 
    {
"customer_id": 1001
}
  8. Klicken Sie in der Symbolleiste des Integrationseditors auf die Schaltfläche Test (Testen), um die Integration auszuführen.

    Wenn die Integration erfolgreich ausgeführt wird, hat die vairable connectorOutputPayload eine JSON-Nutzlast ähnlich der folgenden:

    {
"name": "John",
"email": "john@test.com"
}