Exécuter une procédure stockée

Cet exemple montre comment exécuter une procédure stockée lorsque vous utilisez une connexion de base de données. Pour cet exemple, nous partons du principe que vous connaissez les concepts suivants :

• Créer des intégrations à l'aide d'Application Integration
• Tâche "Connecteurs"
• Integration Connectors
• Procédures stockées dans une base de données

Toutes les procédures stockées dans une connexion de base de données vous sont présentées sous forme d'actions dans la tâche "Connecteurs". Une action est une fonction de première classe mise à la disposition de l'intégration par le biais de l'interface du connecteur. Les actions vous permettent de modifier une ou plusieurs entités, et varient d'un connecteur à l'autre. Toutefois, il est possible qu'un connecteur n'accepte aucune action, auquel cas la liste Actions est vide.

Les connecteurs suivants sont compatibles avec les procédures stockées :

• BigQuery
• Cloud SQL – MySQL
• Cloud SQL – PostgreSQL
• Cloud SQL – SQL Server
• MySQL
• Oracle DB
• PostgreSQL
• SQL Server
• MariaDB
• AlloyDB
• Snowflake
• Redshift

Exemple

Supposons que vous disposiez d'une base de données MySQL. Elle contient la procédure stockée suivante qui obtient les informations d'un client à partir de la table customers :

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

Cette procédure stockée renvoie le nom et l'adresse e-mail du client spécifié. Elle récupère l'ID client à l'aide de la variable d'entrée p_customer_id, et renvoie le nom et l'adresse e-mail dans les variables de sortie p_name et p_email, respectivement.

Supposons maintenant que vous souhaitiez obtenir le nom et l'ID d'adresse e-mail du client avec customer_id=1001. Pour ce faire, vous devez effectuer les tâches suivantes :

1. Créez une connexion à votre base de données MySQL.
2. Ouvrez ou créez une intégration.
3. Ajoutez la tâche "Connecteurs" à votre intégration.
4. Dans la section Configuration, cliquez sur Configurer la tâche pour ouvrir le volet Configurer la tâche "Connecteurs".
5. Configurez la tâche "Connecteurs" pour qu'elle utilise la connexion que vous avez créée à l'étape 1.
   1. Dans la colonne Connexion, sélectionnez la connexion requise dans la liste des connexions disponibles.

      Une fois que vous avez sélectionné une connexion, la colonne Type s'affiche avec les valeurs Entities et Actions. Toutes les procédures stockées sont listées dans Actions.

   2. Sélectionnez Actions > get_customer_info.
   3. Cliquez sur OK pour terminer la configuration de la connexion et fermer le volet.
6. Cliquez sur l'élément de tâche Connectors, puis sur connectorInputPayload dans la section Task Input.
7. Spécifiez la charge utile JSON suivante dans le champ Default Value :

   {
   "customer_id": 1001
   }

8. Cliquez sur le bouton Tester dans la barre d'outils de l'éditeur d'intégration pour exécuter l'intégration.

   Si l'intégration aboutit, la variable connectorOutputPayload aura une charge utile JSON semblable à la suivante :

   {
   "name": "John",
   "email": "[e-mail]"
   }