저장 프로시져 실행
이 예시에서는 데이터베이스 연결을 사용할 때 저장 프로시져를 실행하는 방법을 보여줍니다. 이 예시에서는 사용자가 다음에 익숙하다고 가정합니다.
- Application Integration을 사용하여 통합 만들기
- 커넥터 태스크
- Integration Connectors
- 데이터베이스 저장 프로시져
데이터베이스 연결에서 모든 저장 프로시져는 커넥터 태스크에서 조치로 노출됩니다. 조치는 커넥터 인터페이스를 통해 통합에 제공되는 첫 번째 클래스 함수입니다. 조치를 사용하면 항목을 변경할 수 있습니다. 조치는 커넥터마다 다릅니다. 하지만 커넥터가 조치를 지원하지 않을 수 있으며 이 경우 Actions
목록이 비어 있습니다.
다음 커넥터는 저장 프로시져를 지원합니다.
- BigQuery
- Cloud SQL - MySQL
- Cloud SQL - PostgreSQL
- Cloud SQL - SQL Server
- MySQL
- Oracle DB
- PostgreSQL
- SQL Server
- MariaDB
- AlloyDB
- Snowflake
- Redshift
예
customers
테이블에서 고객 정보를 가져오는 다음 저장 프로시져가 포함된 MySQL 데이터베이스가 있다고 가정해보세요.
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
이 저장 프로시져는 지정된 고객의 이름 및 이메일을 반환합니다. p_customer_id
입력 변수를 통해 고객 ID를 가져오고 각각 p_name
및 p_email
출력 변수에 이름과 이메일을 반환합니다.
이제 customer_id=1001
로 고객의 이름 및 이메일 ID를 가져온다고 가정하면 다음 태스크를 수행해야 합니다.
- MySQL 데이터베이스 연결을 만듭니다.
- 통합을 열거나 새로 만듭니다.
- 통합에 커넥터 태스크를 추가합니다.
- 구성 섹션에서 태스크 구성을 클릭하여 커넥터 태스크 구성 창을 엽니다.
- 1단계에서 만든 연결을 사용하도록 커넥터 태스크를 구성합니다.
- 연결 열에서 사용 가능한 연결 목록 중에서 필요한 연결을 선택합니다.
연결을 선택하면 유형 열이
Entities
및Actions
값과 함께 표시됩니다. 저장 프로시저가 작업에 나열됩니다. - 작업 > get_customer_info를 선택합니다.
- 완료를 클릭하여 연결 구성을 완료하고 창을 닫습니다.
- 연결 열에서 사용 가능한 연결 목록 중에서 필요한 연결을 선택합니다.
Connectors
태스크 요소를 클릭한 후Task Input
섹션에서connectorInputPayload
를 클릭합니다.Default Value
필드에 다음 JSON 페이로드를 지정합니다.{ "customer_id": 1001 }
- 통합 편집기 툴바에서 테스트 버튼을 클릭하여 통합을 실행합니다.
통합이 성공적으로 실행되면
connectorOutputPayload
변수에 다음과 비슷한 JSON 페이로드가 포함됩니다.{ "name": "John", "email": "john@test.com" }