SQL语言怎样在Java中调用存储过程 SQL语言与JDBC交互的实战技巧

get_user_info(IN user_id INT, OUT user_name VARCHAR(100))

import java.sql.*;

public class StoredProcedureCaller {

    // 数据库连接信息，实际应用中这些通常放在配置文件里
    private static final String DB_URL = "jdbc:mysql://localhost:3306/mydatabase?useSSL=false&serverTimezone=UTC";
    private static final String USER = "your_user";
    private static final String PASS = "your_password";

    public static void main(String[] args) {
        // 使用try-with-resources确保资源自动关闭，这是最佳实践
        try (Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);
             // 准备CallableStatement，语法通常是 "{call procedure_name(?, ?, ...)}"
             CallableStatement cstmt = conn.prepareCall("{call get_user_info(?, ?)}")) {

            // 1. 设置输入参数
            int userId = 101;
            cstmt.setInt(1, userId); // 第一个问号对应user_id

            // 2. 注册输出参数
            // 对于OUT参数，需要指定其JDBC类型，以便JDBC知道如何从数据库获取并映射到Java类型
            cstmt.registerOutParameter(2, Types.VARCHAR); // 第二个问号对应user_name

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

            // 4. 获取输出参数的值
            String userName = cstmt.getString(2);
            System.out.println("查询用户ID: " + userId + ", 得到的用户名: " + userName);

            // 如果存储过程返回结果集（例如内部包含SELECT语句），需要处理ResultSet
            // 比如存储过程是 "{call get_active_users()}"
            // boolean hasResults = cstmt.execute(); // 如果这里再次执行，会覆盖之前的操作
            // 如果存储过程既有OUT参数又有结果集，通常会先处理OUT参数，再通过getResultSet()获取
            // 举个例子，如果get_user_info还返回了一个结果集
            // if (cstmt.getMoreResults()) { // 判断是否有更多结果集（或直接使用execute()的返回值）
            //     try (ResultSet rs = cstmt.getResultSet()) {
            //         while (rs.next()) {
            //             // 处理结果集中的每一行数据
            //             System.out.println("额外信息: " + rs.getString("some_column"));
            //         }
            //     }
            // }

        } catch (SQLException se) {
            // 错误处理至关重要，打印详细信息有助于排查问题
            System.err.println("数据库操作失败，错误码: " + se.getErrorCode() + ", SQL状态: " + se.getSQLState());
            se.printStackTrace();
            // 实际应用中，这里可能会抛出自定义异常或记录到日志系统
        }
    }
}

Types

IN

OUT

VARCHAR

String

DECIMAL

NUMERIC

double

BigDecimal

java.sql.Types

DATE

Types.TIMESTAMP

cstmt.getString(index)

cstmt.getInt(index)

Integer

int

cstmt.wasNull()

getXxx

SELECT

cstmt.execute()

true

cstmt.getMoreResults()

try-catch-finally

catch

printStackTrace()

getErrorCode()

getSQLState()

Connection

Statement

ResultSet

AutoCloseable

// 使用try-with-resources的示例，这是我推荐的写法
try (Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);
     CallableStatement cstmt = conn.prepareCall("{call get_user_info(?, ?)}")) {

    cstmt.setInt(1, 101);
    cstmt.registerOutParameter(2, Types.VARCHAR);
    cstmt.execute();
    String userName = cstmt.getString(2);
    System.out.println("用户名: " + userName);

    // 如果存储过程可能返回结果集，这里可以继续处理
    // 注意：如果 execute() 返回的是 false，表示没有结果集或更新计数
    // 如果返回 true，表示有结果集
    // 也可以通过 cstmt.getMoreResults() 循环处理多个结果集
    // if (cstmt.getMoreResults()) {
    //     try (ResultSet rs = cstmt.getResultSet()) {
    //         while (rs.next()) {
    //             // 处理结果集中的数据
    //         }
    //     }
    // }

} catch (SQLException se) {
    System.err.println("数据库操作失败，错误码: " + se.getErrorCode() + ", SQL状态: " + se.getSQLState());
    se.printStackTrace();
    // 可以在这里根据错误码或状态进行更细致的业务逻辑处理，例如回滚事务、通知管理员等
}