使用 Java 执行 SQL 语句和存储过程

使用 Java 执行 SQL 语句和存储过程，通常有两种主要的方式：使用 JDBC（Java Database Connectivity）或者通过框架如 Spring Data JPA、MyBatis 等。

1. 使用 JDBC 执行 SQL 语句

JDBC 是 Java 操作数据库的标准 API。以下是通过 JDBC 执行 SQL 语句的基本步骤：

加载数据库驱动程序。
获取数据库连接。
创建 Statement 或 PreparedStatement 对象。
执行 SQL 语句。
处理查询结果（如果有）。
关闭资源。

示例代码：执行普通的 SQL 查询

java">import java.sql.*;public class JdbcExample {public static void main(String[] args) {String url = "jdbc:mysql://localhost:3306/your_database";String user = "root";String password = "your_password";Connection conn = null;Statement stmt = null;ResultSet rs = null;try {// 1. 加载 JDBC 驱动程序Class.forName("com.mysql.cj.jdbc.Driver");// 2. 获取数据库连接conn = DriverManager.getConnection(url, user, password);// 3. 创建 Statement 对象stmt = conn.createStatement();// 4. 执行 SQL 查询String sql = "SELECT * FROM your_table";rs = stmt.executeQuery(sql);// 5. 处理查询结果while (rs.next()) {int id = rs.getInt("id");String name = rs.getString("name");System.out.println("ID: " + id + ", Name: " + name);}} catch (SQLException | ClassNotFoundException e) {e.printStackTrace();} finally {// 6. 关闭资源try {if (rs != null) rs.close();if (stmt != null) stmt.close();if (conn != null) conn.close();} catch (SQLException e) {e.printStackTrace();}}}
}

2. 使用 JDBC 执行存储过程

存储过程是预编译的 SQL 代码，可以被数据库直接调用。通过 JDBC 调用存储过程的步骤和执行普通 SQL 类似，但需要使用 CallableStatement 对象。

步骤：

加载数据库驱动程序。
获取数据库连接。
创建 CallableStatement 对象，传入存储过程的 SQL 语句。
设置存储过程的参数。
执行存储过程。
获取存储过程的输出结果。
关闭资源。

示例代码：调用存储过程

假设有一个存储过程如下：

sql">CREATE PROCEDURE getEmployeeInfo(IN emp_id INT)
BEGINSELECT * FROM employees WHERE id = emp_id;
END

Java 代码如下：

java">import java.sql.*;public class JdbcStoredProcedureExample {public static void main(String[] args) {String url = "jdbc:mysql://localhost:3306/your_database";String user = "root";String password = "your_password";Connection conn = null;CallableStatement stmt = null;ResultSet rs = null;try {// 1. 加载 JDBC 驱动程序Class.forName("com.mysql.cj.jdbc.Driver");// 2. 获取数据库连接conn = DriverManager.getConnection(url, user, password);// 3. 创建 CallableStatement 对象，调用存储过程String sql = "{CALL getEmployeeInfo(?)}";stmt = conn.prepareCall(sql);// 4. 设置存储过程的输入参数stmt.setInt(1, 123);  // 假设查询员工 ID 为 123 的员工信息// 5. 执行存储过程rs = stmt.executeQuery();// 6. 获取存储过程的结果while (rs.next()) {int id = rs.getInt("id");String name = rs.getString("name");System.out.println("ID: " + id + ", Name: " + name);}} catch (SQLException | ClassNotFoundException e) {e.printStackTrace();} finally {// 7. 关闭资源try {if (rs != null) rs.close();if (stmt != null) stmt.close();if (conn != null) conn.close();} catch (SQLException e) {e.printStackTrace();}}}
}

3. 使用 Spring JDBC 执行 SQL 语句

如果你使用 Spring 框架，可以通过 Spring 的 JDBC 模板简化操作。Spring JDBC 模板提供了更高级的封装，使得执行 SQL 操作更加简洁。

示例代码：使用 Spring JDBC 模板执行 SQL 查询

java">import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DriverManagerDataSource;public class SpringJdbcExample {public static void main(String[] args) {// 设置数据源DriverManagerDataSource dataSource = new DriverManagerDataSource();dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");dataSource.setUrl("jdbc:mysql://localhost:3306/your_database");dataSource.setUsername("root");dataSource.setPassword("your_password");// 创建 JdbcTemplate 对象JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);// 执行查询String sql = "SELECT * FROM your_table";jdbcTemplate.query(sql, (rs, rowNum) -> {int id = rs.getInt("id");String name = rs.getString("name");System.out.println("ID: " + id + ", Name: " + name);return null;});}
}

4. 使用 Spring JDBC 执行存储过程

Spring 也支持执行存储过程，可以通过 JdbcTemplate 或 SimpleJdbcCall 类来实现。

示例代码：使用 Spring 执行存储过程

java">import org.springframework.jdbc.core.SqlParameter;
import org.springframework.jdbc.core.simple.SimpleJdbcCall;
import org.springframework.jdbc.datasource.DriverManagerDataSource;import java.sql.Types;public class SpringStoredProcedureExample {public static void main(String[] args) {// 设置数据源DriverManagerDataSource dataSource = new DriverManagerDataSource();dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");dataSource.setUrl("jdbc:mysql://localhost:3306/your_database");dataSource.setUsername("root");dataSource.setPassword("your_password");// 创建 SimpleJdbcCall 对象SimpleJdbcCall jdbcCall = new SimpleJdbcCall(dataSource).withProcedureName("getEmployeeInfo")  // 存储过程名.declareParameters(new SqlParameter("emp_id", Types.INTEGER));// 执行存储过程jdbcCall.execute(123);  // 假设查询员工 ID 为 123 的信息}
}