java调用mysql存储过程

在 Java 中调用 MySQL 存储过程主要借助 JDBC（Java Database Connectivity），这是 Java 访问数据库的标准 API。
原理概述
Java 调用 MySQL 存储过程的核心原理是利用 JDBC 与 MySQL 数据库建立连接，然后通过特定的 SQL 语句调用存储过程，最后处理存储过程返回的结果。整个过程可以分为以下几个关键步骤：
详细步骤及原理

1. 加载 JDBC 驱动
   在 Java 程序中要访问 MySQL 数据库，首先需要加载 MySQL 的 JDBC 驱动程序。驱动程序是一个实现了 JDBC 接口的类库，它提供了与 MySQL 数据库进行通信的底层机制。

try {
    // 加载 MySQL JDBC 驱动
    Class.forName("com.mysql.cj.jdbc.Driver");
} catch (ClassNotFoundException e) {
    e.printStackTrace();
}

2 . 建立数据库连接
使用 DriverManager 类的 getConnection() 方法建立与 MySQL 数据库的连接。需要提供数据库的 URL、用户名和密码。

String url = "jdbc:mysql://localhost:3306/your_database";
String username = "your_username";
String password = "your_password";
try {
    // 建立数据库连接
    Connection connection = DriverManager.getConnection(url, username, password);
} catch (SQLException e) {
    e.printStackTrace();
}

3 . 创建调用存储过程的对象
使用 Connection 对象的 prepareCall() 方法创建一个 CallableStatement 对象，该对象用于调用存储过程。

try {
    // 创建调用存储过程的对象
    CallableStatement callableStatement = connection.prepareCall("{call your_stored_procedure(?, ?)}");
} catch (SQLException e) {
    e.printStackTrace();
}

4 . 设置存储过程的参数
如果存储过程有输入参数，需要使用 CallableStatement 对象的 setXXX() 方法设置这些参数。

try {
    // 设置输入参数
    callableStatement.setString(1, "input_value");
    callableStatement.setInt(2, 123);
} catch (SQLException e) {
    e.printStackTrace();
}

5 . 注册存储过程的输出参数（如果有）
如果存储过程有输出参数，需要使用 CallableStatement 对象的 registerOutParameter() 方法注册这些参数。

try {
    // 注册输出参数
    callableStatement.registerOutParameter(3, java.sql.Types.VARCHAR);
} catch (SQLException e) {
    e.printStackTrace();
}

6 . 执行存储过程
使用 CallableStatement 对象的 execute() 或 executeQuery()、executeUpdate() 方法执行存储过程。

try {
    // 执行存储过程
    boolean hasResultSet = callableStatement.execute();
} catch (SQLException e) {
    e.printStackTrace();
}

7 . 处理存储过程的结果
如果存储过程返回结果集，可以使用 ResultSet 对象来处理；如果有输出参数，可以使用 CallableStatement 对象的 getXXX() 方法获取输出参数的值。

try {
    if (hasResultSet) {
        ResultSet resultSet = callableStatement.getResultSet();
        while (resultSet.next()) {
            // 处理结果集
            String columnValue = resultSet.getString("column_name");
        }
    }
    // 获取输出参数的值
    String outputValue = callableStatement.getString(3);
} catch (SQLException e) {
    e.printStackTrace();
}

8 . 关闭资源
使用完数据库连接、CallableStatement 对象和 ResultSet 对象后，需要关闭它们以释放资源。

try {
    if (resultSet != null) resultSet.close();
    if (callableStatement != null) callableStatement.close();
    if (connection != null) connection.close();
} catch (SQLException e) {
    e.printStackTrace();
}