Exécuter une procédure stockée
Cet exemple montre comment exécuter une procédure stockée lorsque vous utilisez une connexion à une 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 de connecteur
- Integration Connectors
- Procédures stockées de base de données
Toutes les procédures stockées dans une connexion à une base de données vous sont exposées en tant qu'actions dans la tâche de connecteur. Une action est une fonction de première classe mise à la disposition de l'intégration via l'interface du connecteur. Les actions vous permettent de modifier une ou plusieurs entités, et de les modifier d'un connecteur à l'autre. Toutefois, il est possible qu'un connecteur ne prenne en charge 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
- Base de données Oracle
- PostgreSQL
- SQL Server
- MariaDB
- AlloyDB
- Snowflake
- Redshift
Exemple
Supposons que vous disposiez d'une base de données MySQL comportant la procédure stockée suivante, qui récupère les informations sur 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 prend le numéro client via 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
. Vous devez effectuer les tâches suivantes:
- Créez une connexion à votre base de données MySQL.
- Ouvrez ou créez une intégration.
- Ajoutez la tâche Connecteurs à votre intégration.
- Dans la section Configuration, cliquez sur Configurer la tâche pour ouvrir le volet Configurer la tâche du connecteur.
- Configurez la tâche "Connecteurs" pour utiliser la connexion créée à l'étape 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
etActions
. Toutes les procédures stockées seront listées dans Actions. - Sélectionnez Actions > get_customer_info.
- Cliquez sur Terminé pour terminer la configuration de la connexion et fermer le volet.
- Dans la colonne Connexion, sélectionnez la connexion requise dans la liste des connexions disponibles.
- Cliquez sur l'élément de tâche
Connectors
, puis surconnectorInputPayload
dans la sectionTask Input
. - Spécifiez la charge utile JSON suivante dans le champ
Default Value
:{ "customer_id": 1001 }
- Cliquez sur le bouton Tester dans la barre d'outils de l'éditeur d'intégrations pour exécuter l'intégration.
Si l'intégration s'exécute correctement, l'élément
connectorOutputPayload
a une charge utile JSON semblable à celle-ci:{ "name": "John", "email": "john@test.com" }