Gespeicherte Prozedur ausführen

In diesem Beispiel wird gezeigt, wie eine gespeicherte Prozedur ausgeführt wird, wenn Sie eine Datenbankverbindung verwenden. Für dieses Beispiel wird vorausgesetzt, dass Sie mit den folgenden Konzepten vertraut sind:

Alle in einer Datenbankverbindung gespeicherten Prozeduren werden als Aktionen im Connector-Task: 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. Es ist notwendig, in der Kundennummer über die p_customer_id-Eingabevariable an und gibt den Fehlerwert name und email in den Ausgabevariablen p_name und p_email.

Angenommen, Sie möchten den Namen und die E-Mail-ID des Kunden mit customer_id=1001 abrufen. müssen Sie die folgenden Schritte 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-Aufgabe hinzu.
  4. Klicken Sie im Bereich Konfiguration auf Aufgabe konfigurieren, um den Bereich Connector-Aufgabe konfigurieren zu öffnen.
  5. Konfigurieren Sie die Aufgabe „Connectors“ so, dass die in Schritt 1 erstellte Verbindung verwendet wird.
    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 Type (Typ) mit den Werten angezeigt. Entities und Actions. Alle gespeicherten Prozeduren werden unter Aktionen aufgeführt.

    2. Wählen Sie Aktionen > get_customer_info.
    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 auf connectorInputPayload. im Abschnitt Task Input.
  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 Testen, um die Integration auszuführen.

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

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