JDBC CallableStatement – ストアドプロシージャINパラメータの例
コードスニペットを使用して、JDBCの `CallableStatement`を介してOracleストアドプロシージャを呼び出す方法、およびJavaからストアドプロシージャにINパラメータを渡す方法を説明します。
….//insertDBUSER is stored procedure
String insertStoreProc = “{call insertDBUSER(?,?,?,?)}”;
callableStatement = dbConnection.prepareCall(insertStoreProc);
callableStatement.setInt(1, 1000);
callableStatement.setString(2, “mkyong”);
callableStatement.setString(3, “system”);
callableStatement.setDate(4, getCurrentDate());
callableStatement.executeUpdate();
=== JDBC CallableStatementの例 完全なJDBCの `CallableStatement`の例を参照してください。 === 1.ストアドプロシージャ Oracleデータベース内のストアド・プロシージャ。その後、JDBC経由で呼び出します。
CREATE OR REPLACE PROCEDURE insertDBUSER(
p
userid IN DBUSER.USER
ID%TYPE,
p
username IN DBUSER.USERNAME%TYPE,
p
createdby IN DBUSER.CREATED
BY%TYPE,
p
date IN DBUSER.CREATED__DATE%TYPE)
IS
BEGIN
INSERT INTO DBUSER ("USER__ID", "USERNAME", "CREATED__BY", "CREATED__DATE")
VALUES (p__userid, p__username,p__createdby, p__date);
COMMIT;
END;/….
2. CallableStatement経由でストアドプロシージャを呼び出します.
JDBCの例では、 `CallableStatement`を介してストアドプロシージャを呼び出します。
File:JDBC CallableStatement INパラメータExample.java
package com.mkyong.jdbc;
import java.sql.CallableStatement;
import java.sql.DriverManager;
import java.sql.Connection;
import java.sql.SQLException;
public class JDBCCallableStatementINParameterExample {
private static final String DB__DRIVER = "oracle.jdbc.driver.OracleDriver";
private static final String DB__CONNECTION = "jdbc:oracle:thin:@localhost:1521:MKYONG";
private static final String DB__USER = "user";
private static final String DB__PASSWORD = "password";
public static void main(String[]argv) {
try {
callOracleStoredProcINParameter();
} catch (SQLException e) {
System.out.println(e.getMessage());
}
}
private static void callOracleStoredProcINParameter() throws SQLException {
Connection dbConnection = null;
CallableStatement callableStatement = null;
String insertStoreProc = "{call insertDBUSER(?,?,?,?)}";
try {
dbConnection = getDBConnection();
callableStatement = dbConnection.prepareCall(insertStoreProc);
callableStatement.setInt(1, 1000);
callableStatement.setString(2, "mkyong");
callableStatement.setString(3, "system");
callableStatement.setDate(4, getCurrentDate());
//execute insertDBUSER store procedure
callableStatement.executeUpdate();
System.out.println("Record is inserted into DBUSER table!");
} catch (SQLException e) {
System.out.println(e.getMessage());
} finally {
if (callableStatement != null) {
callableStatement.close();
}
if (dbConnection != null) {
dbConnection.close();
}
}
}
private static Connection getDBConnection() {
Connection dbConnection = null;
try {
Class.forName(DB__DRIVER);
} catch (ClassNotFoundException e) {
System.out.println(e.getMessage());
}
try {
dbConnection = DriverManager.getConnection(
DB__CONNECTION, DB__USER,DB__PASSWORD);
return dbConnection;
} catch (SQLException e) {
System.out.println(e.getMessage());
}
return dbConnection;
}
private static java.sql.Date getCurrentDate() {
java.util.Date today = new java.util.Date();
return new java.sql.Date(today.getTime());
}
}
完了しました。上記のJDBCの例を実行すると、新しいレコードがストアドプロシージャ “` insertDBUSER` “を介してデータベースに挿入されます。
