12. 如何在Java中使用CallableStatement调用MySQL的存储过程？

PangHu大约 3 分钟

在Java中，使用CallableStatement可以方便地调用数据库中的存储过程。CallableStatement是JDBC API中的一个接口，用于调用存储在数据库中的预编译的SQL存储过程。

调用存储过程的步骤

建立数据库连接：首先，使用DriverManager获取数据库连接。
创建CallableStatement对象：使用Connection对象的prepareCall()方法来创建CallableStatement对象。
设置输入参数：如果存储过程需要输入参数，可以使用CallableStatement的setXXX方法来设置参数。
注册输出参数：如果存储过程有输出参数，需要使用CallableStatement的registerOutParameter()方法注册输出参数。
执行存储过程：使用CallableStatement的execute()方法执行存储过程。
获取输出参数的值：如果有输出参数，可以使用CallableStatement的getXXX方法来获取结果。
关闭资源：最后，关闭CallableStatement和数据库连接。

代码示例

假设我们有一个MySQL存储过程getEmployeeInfo，它接收一个员工ID作为输入参数，并返回该员工的姓名和薪水。

存储过程定义如下：

DELIMITER //

CREATE PROCEDURE getEmployeeInfo(IN emp_id INT, OUT emp_name VARCHAR(50), OUT emp_salary DOUBLE)
BEGIN
    SELECT name, salary INTO emp_name, emp_salary
    FROM employees
    WHERE id = emp_id;
END //

DELIMITER ;

接下来，我们使用Java代码来调用这个存储过程。

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

public class CallableStatementExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/testdb";
        String username = "root";
        String password = "password";
        
        Connection conn = null;
        CallableStatement cstmt = null;

        try {
            // 获取数据库连接
            conn = DriverManager.getConnection(url, username, password);

            // 调用存储过程getEmployeeInfo
            String sql = "{CALL getEmployeeInfo(?, ?, ?)}";
            cstmt = conn.prepareCall(sql);

            // 设置输入参数
            cstmt.setInt(1, 101); // 假设我们要查询员工ID为101的信息

            // 注册输出参数
            cstmt.registerOutParameter(2, java.sql.Types.VARCHAR); // emp_name
            cstmt.registerOutParameter(3, java.sql.Types.DOUBLE);  // emp_salary

            // 执行存储过程
            cstmt.execute();

            // 获取输出参数的值
            String empName = cstmt.getString(2);
            double empSalary = cstmt.getDouble(3);

            System.out.println("Employee Name: " + empName);
            System.out.println("Employee Salary: " + empSalary);

        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if (cstmt != null) {
                    cstmt.close();
                }
                if (conn != null) {
                    conn.close();
                }
            } catch (SQLException closeException) {
                closeException.printStackTrace();
            }
        }
    }
}

代码解释

创建CallableStatement对象：String sql = "{CALL getEmployeeInfo(?, ?, ?)}";中，我们使用了prepareCall方法，并传入了存储过程的调用语句。{CALL getEmployeeInfo(?, ?, ?)}表示调用存储过程getEmployeeInfo，它有三个参数，两个输出参数和一个输入参数。
设置输入参数：cstmt.setInt(1, 101);设置了第一个参数的值为101，这个参数是员工的ID。
注册输出参数：我们使用cstmt.registerOutParameter注册了两个输出参数，分别是员工的姓名和薪水。
执行存储过程：cstmt.execute();执行存储过程。
获取输出参数的值：cstmt.getString(2);和cstmt.getDouble(3);分别获取了存储过程返回的员工姓名和薪水。

总结

通过CallableStatement，我们可以轻松地在Java应用程序中调用MySQL的存储过程，这对于处理复杂的数据库操作非常有用。使用这种方式，可以使代码更简洁，并提高数据库操作的效率。