[Java] DBのPROCEDUREを実行する

JDBCを使用してデータベースのPROCEDURE（プロシージャ）を実行するサンプルです。
以下のサンプルでは、Oracleデータベースを対象としています。

サンプルソース

接続するデータベース情報は以下の通りとします。

＜DB情報＞
　・データベース：オラクル
　・IP：127.0.0.1（localhost）
　・ポート番号：1521
　・SID：testdb
　・ログインID：user01
　・ログインパスワード：password

＜対象プロシージャ＞
　INSERT_TBL(NUMBER a, CHAR b, VARHCAR2 c)
　※テーブルに引数a、b、cをINSERTするオラクルプロシージャとする。
　　（自作プロシージャ）

例）オラクルプロシージャ「INSERT_TBL」を実行する

import java.sql.DriverManager;
import java.sql.Connection;
import java.sql.CallableStatement;

public class DBProcedureExecSample {

    public static void main(String[] args) throws Exception{

        //変数定義
        Connection conn = null;
        CallableStatement cs = null;

        //DB接続情報を設定する
        String path = "jdbc:oracle:thin:@127.0.0.1:1521:testdb";  //接続パス
        String id = "user01";    //ログインID
        String pw = "password";  //ログインパスワード

        //プロシージャを定義する
        String sql = "{call INSERT_TBL(?, ?, ?)}";

        try {
            //JDBCドライバをロードする
            Class.forName("oracle.jdbc.driver.OracleDriver");

            //DBへのコネクションを作成する
            conn = DriverManager.getConnection(path, id, pw);
            conn.setAutoCommit(false);  //オートコミットはオフ

            //実行するProcedureを指定してパラメータをセットする
            cs = conn.prepareCall(sql);
            cs.setInt(1, 100);
            cs.setString(2, "A");
            cs.setString(3, "BBB");

            //Procedureを実行する
            cs.executeUpdate();

            //コミットする
            conn.commit();

        } catch (Exception ex) {
            //例外発生時の処理
            conn.rollback();       //ロールバックする
            ex.printStackTrace();  //エラー内容をコンソールに出力する

        } finally {
            //クローズ処理
            if (cs != null) cs.close();
            if (conn != null) conn.close();
        }

    }

}

import java.sql.DriverManager;

import java.sql.Connection;

import java.sql.CallableStatement;

public class DBProcedureExecSample {

public static void main(String[] args) throws Exception{

//変数定義

Connection conn = null;

CallableStatement cs = null;

//DB接続情報を設定する

String path = "jdbc:oracle:thin:@127.0.0.1:1521:testdb"; //接続パス

String id = "user01"; //ログインID

String pw = "password"; //ログインパスワード

//プロシージャを定義する

String sql = "{call INSERT_TBL(?, ?, ?)}";

try {

//JDBCドライバをロードする

Class.forName("oracle.jdbc.driver.OracleDriver");

//DBへのコネクションを作成する

conn = DriverManager.getConnection(path, id, pw);

conn.setAutoCommit(false); //オートコミットはオフ

//実行するProcedureを指定してパラメータをセットする

cs = conn.prepareCall(sql);

cs.setInt(1, 100);

cs.setString(2, "A");

cs.setString(3, "BBB");

//Procedureを実行する

cs.executeUpdate();

//コミットする

conn.commit();

} catch (Exception ex) {

//例外発生時の処理

conn.rollback(); //ロールバックする

ex.printStackTrace(); //エラー内容をコンソールに出力する

} finally {

//クローズ処理

if (cs != null) cs.close();

if (conn != null) conn.close();

}

（結果）: java -cp ./;ojdbc8.jar DBProcedureExecSample プロシージャ実行が完了しました。

事前にオラクルのJDBCドライバを用意しておく必要があります。
（ここの例では「ojdbc8.jar」）

サンプルソース

例）オラクルプロシージャ「INSERT_TBL」を実行する

関連項目