JDBC에서 CallableStatement를 사용해 저장 프로시저를 호출하는 방법

JDBC에서 CallableStatement로 저장 프로시저 호출하기

SQL 저장 프로시저는 CallableStatement 인터페이스를 사용하여 호출할 수 있습니다. CallableStatement에는 입력 매개변수, 출력 매개변수 또는 이 둘을 모두 포함할 수 있습니다.

CallableStatement 객체는 Connection 인터페이스의 prepareCall() 메서드를 통해 생성합니다. 이 메서드는 저장 프로시저를 호출하는 쿼리 문자열을 인자로 받고, 그 결과로 CallableStatement 객체를 반환합니다.

예를 들어 데이터베이스에 myProcedure라는 이름의 프로시저가 있다면 다음과 같이 CallableStatement를 준비할 수 있습니다.

//CallableStatement 준비
CallableStatement cstmt = con.prepareCall("{call myProcedure(?, ?, ?)}");

이후 CallableStatement 인터페이스가 제공하는 setter 메서드로 플레이스홀더(?)에 값을 지정하고, execute() 메서드를 호출해 프로시저를 실행하면 됩니다.

cstmt.setString(1, "Raghav");
cstmt.setInt(2, 3000);
cstmt.setString(3, "Hyderabad");
cstmt.execute();

만약 프로시저에 전달할 입력 값이 없다면, CallableStatement를 준비한 뒤 곧바로 실행하기만 하면 됩니다.

CallableStatement cstmt = con.prepareCall("{call myProcedure()}");
cstmt.execute();

참고: 출력 매개변수 처리

저장 프로시저가 결과값을 반환하는 경우(OUT 파라미터), 실행 전에 registerOutParameter() 메서드로 해당 위치와 SQL 타입을 미리 등록한 후, execute() 호출 이후에 getXxx() 메서드로 값을 읽어올 수 있습니다.

실전 예제

MySQL 데이터베이스에 다음과 같은 데이터를 담고 있는 Dispatches 테이블이 있다고 가정해 보겠습니다.

+--------------+------------------+------------------+----------------+
| Product_Name | Date_Of_Dispatch | Time_Of_Dispatch | Location       |
+--------------+------------------+------------------+----------------+
| KeyBoard     | 1970-01-19       | 08:51:36         | Hyderabad      |
| Earphones    | 1970-01-19       | 05:54:28         | Vishakhapatnam |
| Mouse        | 1970-01-19       | 04:26:38         | Vijayawada     |
+--------------+------------------+------------------+----------------+

그리고 이 테이블의 값을 조회하는 myProcedure 프로시저가 아래와 같이 생성되어 있다고 합시다.

Create procedure myProcedure ()
-> BEGIN
-> SELECT * FROM Dispatches;
-> END //

JDBC 예제 코드

다음은 앞서 만든 저장 프로시저를 JDBC 프로그램으로 호출하는 전체 예제입니다.

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
public class CallingProcedure {
    public static void main(String args[]) throws SQLException {
       // 드라이버 등록
       DriverManager.registerDriver(new com.mysql.jdbc.Driver());

       // 데이터베이스 연결
       String mysqlUrl = "jdbc:mysql://localhost/sampleDB";
       Connection con = DriverManager.getConnection(mysqlUrl, "root", "password");
       System.out.println("Connection established......");

       // CallableStatement 준비
       CallableStatement cstmt = con.prepareCall("{call myProcedure()}");

       // 결과 조회
       ResultSet rs = cstmt.executeQuery();
       while(rs.next()) {
           System.out.println("Product Name: "+rs.getString("Product_Name"));
           System.out.println("Date of Dispatch: "+rs.getDate("Date_Of_Dispatch"));
           System.out.println("Time of Dispatch: "+rs.getTime("Time_Of_Dispatch"));
           System.out.println("Location: "+rs.getString("Location"));
           System.out.println();
       }
   }
}

실행 결과

Connection established......
Product Name: KeyBoard
Date of Dispatch: 1970-01-19
Time of Dispatch: 08:51:36
Location: Hyderabad

Product Name: Earphones
Date of Dispatch: 1970-01-19
Time of Dispatch: 05:54:28
Location: Vishakhapatnam

Product Name: Mouse
Date of Dispatch: 1970-01-19
Time of Dispatch: 04:26:38
Location: Vijayawada