Gespeicherte Prozedur ausführen

In diesem Beispiel wird gezeigt, 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 gespeicherten Prozeduren in einer Datenbankverbindung werden in der Connector-Aufgabe als Aktionen angezeigt. Eine Aktion ist eine Funktion erster Klasse, die über die Connector-Benutzeroberfläche für die Integration verfügbar gemacht wird. Mit Aktionen können Sie Änderungen an einer Entität oder Entitäten vornehmen und je nach Connector variieren. 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 abrufen:

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 für den angegebenen Kunden zurück. Er nimmt die Kundennummer über die Eingabevariable p_customer_id entgegen und gibt den Namen und die E-Mail-Adresse in den Ausgabevariablen p_name und p_email zurück.

Angenommen, Sie möchten den Namen und die E-Mail-ID des Kunden mit customer_id=1001 abrufen. Gehen Sie dazu so vor:

  1. Erstellen Sie eine Verbindung zu Ihrer MySQL-Datenbank.
  2. Öffnen oder erstellen Sie eine neue Integration.
  3. Fügen Sie der Integration die Connectors-Aufgabe hinzu.
  4. Klicken Sie im Bereich Konfiguration auf Aufgabe konfigurieren, um den Bereich Connector-Aufgabe konfigurieren zu öffnen.
  5. Konfigurieren Sie die Connectors-Aufgabe so, dass die Verbindung verwendet wird, die Sie in Schritt 1 erstellt haben.
    1. Wählen Sie in der Spalte Verbindung die erforderliche 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 Aktionen > 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 Bereich Task Input auf connectorInputPayload.
  7. Geben Sie die folgende JSON-Nutzlast in das Feld Default Value ein: 
    {
"customer_id": 1001
}
  8. Klicken Sie in der Symbolleiste des Integrationseditors auf die Schaltfläche Testen, um die Integration auszuführen.

    Wenn die Integration erfolgreich ausgeführt wird, hat die Variable connectorOutputPayload eine JSON-Nutzlast, die in etwa so aussieht:

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