Java 调用 DB2 存储过程指南
在Java应用程序中调用DB2存储过程,通常使用JDBC（Java Database Connectivity）来实现，以下是详细的步骤和示例代码：
基本步骤
- 加载DB2 JDBC驱动
- 建立数据库连接
- 创建CallableStatement对象
- 设置输入参数（如果有）
- 注册输出参数（如果有）
- 执行存储过程
- 处理结果
- 关闭资源
示例代码
准备工作
确保已添加DB2 JDBC驱动到项目中（Maven依赖）：
<dependency>
<groupId>com.ibm.db2</groupId>
<artifactId>jcc</artifactId>
<version>11.5.8.0</version>
</dependency>
简单示例（无参数）
import java.sql.*;
public class CallDB2Procedure {
public static void main(String[] args) {
Connection conn = null;
CallableStatement cstmt = null;
try {
// 1. 加载驱动
Class.forName("com.ibm.db2.jcc.DB2Driver");
// 2. 建立连接
String url = "jdbc:db2://localhost:50000/YOUR_DB_NAME";
String user = "username";
String password = "password";
conn = DriverManager.getConnection(url, user, password);
// 3. 创建CallableStatement
// 假设存储过程名为PROCEDURE_NAME，无参数
String sql = "{call PROCEDURE_NAME()}";
cstmt = conn.prepareCall(sql);
// 4. 执行存储过程
cstmt.execute();
System.out.println("存储过程执行成功");
} catch (ClassNotFoundException e) {
System.err.println("找不到DB2 JDBC驱动: " + e.getMessage());
} catch (SQLException e) {
System.err.println("SQL错误: " + e.getMessage());
} finally {
// 5. 关闭资源
try {
if (cstmt != null) cstmt.close();
if (conn != null) conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
带输入参数的存储过程
// 假设存储过程有一个输入参数
String sql = "{call PROCEDURE_WITH_IN(?)}";
cstmt = conn.prepareCall(sql);
// 设置输入参数
cstmt.setString(1, "input_value");
cstmt.execute();
带输出参数的存储过程
// 假设存储过程有一个输出参数
String sql = "{call PROCEDURE_WITH_OUT(?)}";
cstmt = conn.prepareCall(sql);
// 注册输出参数
cstmt.registerOutParameter(1, Types.VARCHAR);
// 执行存储过程
cstmt.execute();
// 获取输出参数
String result = cstmt.getString(1);
System.out.println("存储过程返回值: " + result);
同时有输入和输出参数的存储过程
// 假设存储过程有一个输入参数和一个输出参数
String sql = "{call PROCEDURE_WITH_IN_OUT(?, ?)}";
cstmt = conn.prepareCall(sql);
// 设置输入参数
cstmt.setString(1, "input_value");
// 注册输出参数
cstmt.registerOutParameter(2, Types.INTEGER);
// 执行存储过程
cstmt.execute();
// 获取输出参数
int outputValue = cstmt.getInt(2);
System.out.println("存储过程返回值: " + outputValue);
处理结果集（如果存储过程返回结果集）
String sql = "{call PROCEDURE_WITH_RESULT_SET()}";
cstmt = conn.prepareCall(sql);
// 执行存储过程
boolean hasResult = cstmt.execute();
// 处理结果集
if (hasResult) {
ResultSet rs = cstmt.getResultSet();
while (rs.next()) {
// 处理结果集
String column1 = rs.getString("COLUMN1");
int column2 = rs.getInt("COLUMN2");
System.out.println(column1 + ", " + column2);
}
rs.close();
}
注意事项
- 驱动版本：确保使用的DB2 JDBC驱动版本与数据库版本兼容
- 连接字符串：根据实际DB2配置调整连接字符串
- 参数类型：正确设置参数类型（使用Types类中的常量）
- 异常处理：妥善处理SQLException
- 资源关闭：确保关闭所有数据库资源（Connection, Statement, ResultSet等）
- 事务管理：根据需要处理事务
使用连接池（推荐）
在生产环境中,建议使用连接池（如DBCP, C3P0, HikariCP）来管理数据库连接：
// 使用HikariCP示例
HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:db2://localhost:50000/YOUR_DB_NAME");
config.setUsername("username");
config.setPassword("password");
config.setDriverClassName("com.ibm.db2.jcc.DB2Driver");
HikariDataSource ds = new HikariDataSource(config);
Connection conn = ds.getConnection();
// 使用conn执行存储过程...
// 关闭连接（实际是返回到连接池）
conn.close();
就是在Java中调用DB2存储过程的基本方法和示例,根据具体的存储过程定义，可能需要调整参数设置和结果处理方式。
