JDBCのCallableStatementでストアドプロシージャを呼び出す方法を解説

JavaのJDBCでは、CallableStatementインターフェースを使用することで、SQLのストアドプロシージャを呼び出すことができます。CallableStatementには、入力パラメータ、出力パラメータ、あるいはその両方を持たせることが可能です。

CallableStatementオブジェクトの作成方法

CallableStatement（インターフェース）のオブジェクトは、ConnectionインターフェースのprepareCall()メソッドを使って生成します。このメソッドは、ストアドプロシージャを呼び出すためのクエリ文字列を受け取り、CallableStatementオブジェクトを返します。

例えば、データベース内にmyProcedureという名前のプロシージャが存在する場合、以下のようにCallableStatementを準備できます。

// CallableStatementの準備
CallableStatement cstmt = con.prepareCall("{call myProcedure(?, ?, ?)}");

次に、CallableStatementインターフェースが提供するセッターメソッドを使ってプレースホルダ（?）に値を設定し、execute()メソッドで呼び出しを実行します。

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

プロシージャに入力パラメータが必要ない場合は、CallableStatementを準備してそのまま実行するだけで済みます。

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

実行例：テーブルとストアドプロシージャの準備

ここでは、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

このように、prepareCall()でプロシージャを指定し、必要に応じてパラメータを設定したうえでexecuteQuery()やexecute()を呼び出すだけで、JDBCから簡単にストアドプロシージャを実行できます。結果セットが必要な場合はexecuteQuery()、戻り値がない場合はexecute()を使い分けるとよいでしょう。