使用 JDBC（Java Database Connectivity）操作数据库的基本步骤可以总结为以下几个关键步骤。JDBC 是 Java 语言中与数据库交互的 API，允许开发人员通过标准的接口操作数据库。
1.加载数据库驱动程序
在使用 JDBC 操作数据库之前，首先需要加载数据库的驱动程序，通常使用 Class.forName() 来动态加载对应数据库的驱动程序类。
| Class.forName("com.mysql.cj.jdbc.Driver"); // 以 MySQL 为例 |
注意：在较新版本的 JDBC 中，如果你使用的是 Java 6 以上，部分驱动程序（例如 MySQL 驱动）可以自动加载，无需手动调用 Class.forName()。但是建议保留。
2.创建数据库连接
使用 DriverManager.getConnection() 方法建立与数据库的连接。该方法需要提供数据库的 URL、用户名和密码。URL 格式通常为：
| jdbc:<database_type>://<host>:<port>/<database_name>?useSSL=false&serverTimezone=UTC |
例如连接 MySQL 数据库的 URL 可能是：
| String url = "jdbc:mysql://localhost:3306/testdb?useSSL=false&serverTimezone=UTC"; String username = "root"; String password = "password"; Connection conn = DriverManager.getConnection(url, username, password); |
3.创建SQL语句对象
通过 Connection 对象创建用于执行 SQL 的 Statement 或 PreparedStatement 对象。使用 Statement 可以执行静态的 SQL 语句，而 PreparedStatement 则用于执行动态的、参数化的 SQL 语句。
使用 Statement：
| Statement stmt = conn.createStatement(); |
使用 PreparedStatement：
| String sql = "SELECT * FROM users WHERE age > ?"; PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setInt(1, 18); // 设置 SQL 中的参数 |
4.执行SQL语句
使用 Statement 或 PreparedStatement 来执行 SQL 语句。根据 SQL 语句的类型（查询、更新、插入或删除），调用不同的方法。
4.1.执行查询操作 (SELECT)
1）使用 executeQuery() 方法
2）返回 ResultSet 对象
| ResultSet rs = stmt.executeQuery("SELECT * FROM users"); |
4.2.执行更新操作 (INSERT、UPDATE、DELETE)
1）使用 executeUpdate() 方法
2）返回受影响的行数
| int rows = stmt.executeUpdate("INSERT INTO users (name, age) VALUES ('John', 25)"); |
4.3.执行任意 SQL（包括 DDL 语句，如创建表等）
1）使用 execute() 方法
2）返回 boolean 值，指示是否返回 ResultSet
| boolean isResultSet = stmt.execute("CREATE TABLE new_table (id INT, name VARCHAR(50))"); |
5.处理查询结果
对于查询操作，ResultSet 对象包含查询的结果集。通过 ResultSet 提供的各种方法（如 next()、getString()、getInt() 等），可以逐行读取数据。
| while (rs.next()) { int id = rs.getInt("id"); String name = rs.getString("name"); int age = rs.getInt("age"); System.out.println("ID: " + id + ", Name: " + name + ", Age: " + age); } |
6.关闭资源
操作完成后，必须关闭各种数据库资源（ResultSet、Statement、PreparedStatement、Connection）以释放内存和数据库连接。
| rs.close(); // 关闭结果集 stmt.close(); // 关闭 Statement conn.close(); // 关闭数据库连接 |
7.JDBC 操作数据库的完整示例
| package com.me.mengu.java.base.db; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class JDBCExample { public static void main(String[] args) { // 数据库连接信息 String url = "jdbc:mysql://localhost:3306/testdb?useSSL=false&serverTimezone=UTC"; String username = "root"; String password = "password"; // 声明 Connection、Statement 和 ResultSet Connection conn = null; Statement stmt = null; ResultSet rs = null; try { // 1. 加载 MySQL 驱动程序 Class.forName("com.mysql.cj.jdbc.Driver"); // 2. 建立连接 conn = DriverManager.getConnection(url, username, password); // 3. 创建 SQL 语句 stmt = conn.createStatement(); // 4. 执行查询语句 String sql = "SELECT id, name, age FROM users"; rs = stmt.executeQuery(sql); // 5. 处理结果集 while (rs.next()) { int id = rs.getInt("id"); String name = rs.getString("name"); int age = rs.getInt("age"); System.out.println("ID: " + id + ", Name: " + name + ", Age: " + age); } } catch (SQLException e) { e.printStackTrace(); } catch (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(); } } } } |
