Executar um procedimento armazenado

Este exemplo mostra como executar um procedimento armazenado quando você está usando uma conexão de banco de dados. O exemplo pressupõe que você esteja familiarizado com os seguintes conceitos:

• Como criar integrações usando o Application Integration
• Tarefa do conector
• Conectores de integração
• Procedimentos armazenados do banco de dados

Todos os procedimentos armazenados em uma conexão de banco de dados são expostos a você como ações na tarefa do conector. Uma ação é uma função de primeira classe disponibilizada para a integração por meio da interface do conector. As ações permitem fazer mudanças em uma ou mais entidades e variam de acordo com o conector. No entanto, é possível que o conector não ofereça suporte a nenhuma ação. Nesse caso, a lista Actions estará vazia.

Os seguintes conectores oferecem suporte a procedimentos armazenados:

• BigQuery
• Cloud SQL - MySQL
• Cloud SQL - PostgreSQL
• Cloud SQL – SQL Server
• MySQL
• Banco de dados Oracle
• PostgreSQL
• SQL Server
• MariaDB
• AlloyDB
• Snowflake
• Redshift

Exemplo

Considere que você tem um banco de dados MySQL com o seguinte procedimento armazenado, que extrai as informações de um cliente da tabela 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

Esse procedimento armazenado retorna o nome e o e-mail do cliente especificado. Ele recebe o ID do cliente pela variável de entrada p_customer_id e retorna o nome e o e-mail nas variáveis de saída p_name e p_email, respectivamente.

Agora, suponha que você queira receber o nome e o ID de e-mail do cliente com customer_id=1001. Para isso, você precisa fazer o seguinte:

1. Crie uma conexão com seu banco de dados MySQL.
2. Abra ou crie uma nova integração.
3. Adicione a tarefa Connectors à sua integração.
4. Na seção Configuração, clique em Configurar tarefa para abrir o painel Configurar tarefa do conector.
5. Configure a tarefa Connectors para usar a conexão criada na etapa 1.
   1. Na coluna Conexão, selecione a conexão necessária na lista de conexões disponíveis.

      Depois de selecionar uma conexão, a coluna Tipo aparece com os valores Entities e Actions. Todos os procedimentos armazenados serão listados em Ações.

   2. Selecione Ações > get_customer_info.
   3. Clique em Concluído para concluir a configuração da conexão e feche o painel.
6. Clique no elemento da tarefa Connectors e em connectorInputPayload na seção Task Input.
7. Especifique o seguinte payload JSON no campo Default Value:

   {
   "customer_id": 1001
   }

8. Clique no botão Testar na barra de ferramentas do editor de integração para executar a integração.

   Se a integração for executada corretamente, a variável connectorOutputPayload vai ter um payload JSON semelhante a este:

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