在大型关系型数据库中,有一组为了完成特定功能的 SQL 语句集被称为存储过程(Stored Procedure),它是数据库中的对象。
JDBC 使用 CallableStatement 对象,完成对存储过程的操作。
CallableStatement 通过 Connection.prepareCall(String sql) 方法创建。
与 PreparedStatement 相似,提供了一系列的 setXxx(int index, Xxx value) 来支持存储过程的入参传递。
同样的,不确定数据类型,可以通过 setObject() 方法来传入数据。
另外,存储过程是可以有输出的,通过 registerOutParameter(int parameterIndex, int sqlType) 方法来注册输出项。
假设现在有如下存储过程定义:
create procedure add_pro(a int, b int, out sum int) begin set sum = a + b; end
通过如下代码调用:
package com.gerrard.executor; import com.gerrard.constants.ErrorCode; import com.gerrard.exception.JdbcSampleException; import com.gerrard.util.Connector; import com.gerrard.util.DriverLoader; import java.sql.CallableStatement; import java.sql.Connection; import java.sql.SQLException; import java.sql.Types; public final class SqlExecutorCallableStatement { /* create procedure add_pro(a int, b int, out sum int) begin set sum = a + b; end */ public static void callProcedure() { DriverLoader.loadSqliteDriver(); try (Connection conn = Connector.getSqlConnection(); CallableStatement cstmt = conn.prepareCall("{call add_pro(?, ?)}")) { cstmt.setObject(1, "1"); cstmt.setObject(2, "2"); cstmt.registerOutParameter(3, Types.INTEGER); cstmt.execute(); System.out.println("Result:" + cstmt.getObject(3)); } catch (SQLException e) { throw new JdbcSampleException(ErrorCode.CALL_PROCEDURE_FAILURE, e.getMessage()); } } public static void main(String[] args) { callProcedure(); } }
不过,SQLite 数据库的代码,是不支持存储过程的: