一、JDBC 概述1.1 什么是 JDBCJDBCJava Database ConnectivityJava 数据库连接是 Java 语言操作关系型数据库的一套标准接口。它定义了一系列规范由各数据库厂商如 MySQL、Oracle、SQL Server提供对应的驱动实现。开发者只需面向 JDBC 接口编程无需关心底层数据库的具体实现实现 “一次编写到处运行”。1.2 JDBC 的本质官方定义的一套操作所有关系型数据库的规范接口。各数据库厂商提供的驱动包是这些接口的实现类。开发者使用 JDBC 接口编程实际执行的代码是驱动包中的实现类。1.3 JDBC 的好处跨数据库兼容更换数据库时只需更换驱动包和连接 URL业务代码无需修改。标准化 API所有数据库操作都遵循统一的接口规范学习成本低。稳定性高作为 Java 官方标准长期维护兼容性有保障。二、JDBC 快速入门2.1 开发步骤导入驱动包将 MySQL 驱动mysql-connector-java-x.x.x.jar添加到项目依赖中。注册驱动加载数据库驱动类。获取连接建立 Java 程序与数据库的连接。编写 SQL 语句定义要执行的数据库操作增删改查。获取执行对象创建 SQL 语句的执行对象。执行 SQL执行 SQL 语句并获取结果。处理结果对查询结果或影响行数进行处理。释放资源关闭连接、执行对象等资源。2.2 入门示例更新操作import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement; public class JdbcQuickStart { public static void main(String[] args) throws Exception { // 1. 注册驱动MySQL 5.0 可省略 Class.forName(com.mysql.cj.jdbc.Driver); // 2. 获取数据库连接 String url jdbc:mysql://localhost:3306/testdb?useSSLfalseserverTimezoneUTC; String username root; String password root; Connection conn DriverManager.getConnection(url, username, password); // 3. 获取执行对象 Statement stmt conn.createStatement(); // 4. 编写并执行 SQL更新账户余额 String sql UPDATE account SET money money - 200 WHERE id 1; int count stmt.executeUpdate(sql); // 5. 处理结果 System.out.println(影响行数 count); // 6. 释放资源逆序关闭 stmt.close(); conn.close(); } }三、JDBC 核心 API 详解3.1DriverManager驱动管理类注册驱动Class.forName(com.mysql.cj.jdbc.Driver);MySQL 5.0 驱动包中Driver类会自动注册无需手动调用。获取连接DriverManager.getConnection(url, username, password);URL 格式jdbc:mysql://主机地址:端口号/数据库名?参数示例jdbc:mysql://localhost:3306/testdb?useSSLfalseserverTimezoneUTC常用参数useSSLfalse关闭 SSL 验证、serverTimezoneUTC设置时区3.2Connection数据库连接对象获取 SQL 执行对象createStatement()创建普通Statement对象存在 SQL 注入风险。prepareStatement(String sql)创建预编译PreparedStatement对象推荐防注入。事务管理setAutoCommit(false)关闭自动提交开启事务。commit()提交事务。rollback()回滚事务。事务示例try { conn.setAutoCommit(false); // 开启事务 // 执行转账操作 stmt.executeUpdate(UPDATE account SET money money - 200 WHERE id 1); stmt.executeUpdate(UPDATE account SET money money 200 WHERE id 2); conn.commit(); // 提交事务 } catch (Exception e) { conn.rollback(); // 异常时回滚事务 e.printStackTrace(); } finally { // 释放资源 }3.3StatementSQL 执行对象executeUpdate(String sql)执行 DML增删改语句返回受影响行数。executeQuery(String sql)执行 DQL查询语句返回ResultSet结果集对象。3.4ResultSet结果集对象封装查询语句的执行结果提供遍历和获取数据的方法。常用方法next()将游标向下移动一行判断是否有数据。getInt(列名)/getInt(列索引)获取整数类型数据。getString(列名)/getString(列索引)获取字符串类型数据。getDouble(列名)/getDouble(列索引)获取小数类型数据。查询示例String sql SELECT id, name, money FROM account; ResultSet rs stmt.executeQuery(sql); // 遍历结果集 while (rs.next()) { int id rs.getInt(id); String name rs.getString(name); double money rs.getDouble(money); System.out.println(ID: id , 姓名: name , 余额: money); } rs.close(); // 释放结果集3.5PreparedStatement预编译执行对象解决Statement的 SQL 注入问题推荐使用。SQL 注入通过拼接用户输入恶意修改 SQL 语句例如 or 1 1。使用步骤编写带?占位符的 SQL 语句。创建PreparedStatement对象传入 SQL 语句。使用setXxx(参数索引, 值)方法为占位符赋值索引从 1 开始。执行 SQL 语句。防注入登录示例// 1. 带占位符的 SQL String sql SELECT * FROM user WHERE username ? AND password ?; // 2. 获取预编译对象 PreparedStatement pstmt conn.prepareStatement(sql); // 3. 为占位符赋值 pstmt.setString(1, username); pstmt.setString(2, password); // 4. 执行查询 ResultSet rs pstmt.executeQuery(); // 5. 判断是否存在用户 if (rs.next()) { System.out.println(登录成功); } else { System.out.println(用户名或密码错误); }四、综合实践JDBC 工具类与数据封装4.1 工具类JDBCUtils封装 JDBC 连接和释放资源的重复代码提高开发效率。import java.sql.*; public class JDBCUtils { // 数据库配置可从配置文件读取 private static final String URL jdbc:mysql://localhost:3306/testdb?useSSLfalseserverTimezoneUTC; private static final String USERNAME root; private static final String PASSWORD root; // 注册驱动 static { try { Class.forName(com.mysql.cj.jdbc.Driver); } catch (ClassNotFoundException e) { throw new RuntimeException(驱动加载失败, e); } } // 获取连接 public static Connection getConnection() throws SQLException { return DriverManager.getConnection(URL, USERNAME, PASSWORD); } // 释放资源 public static void close(Connection conn, Statement stmt, ResultSet rs) { try { if (rs ! null) rs.close(); if (stmt ! null) stmt.close(); if (conn ! null) conn.close(); } catch (SQLException e) { e.printStackTrace(); } } // 简化版释放无查询结果 public static void close(Connection conn, Statement stmt) { close(conn, stmt, null); } }4.2 数据封装示例查询账户列表import java.util.ArrayList; import java.util.List; public class Account { private int id; private String name; private double money; // 构造方法、getter/setter、toString public Account() {} public Account(int id, String name, double money) { this.id id; this.name name; this.money money; } // getter/setter 省略 Override public String toString() { return Account{id id , name name , money money }; } } // 查询方法 public ListAccount findAllAccounts() { ListAccount list new ArrayList(); Connection conn null; PreparedStatement pstmt null; ResultSet rs null; try { conn JDBCUtils.getConnection(); String sql SELECT id, name, money FROM account; pstmt conn.prepareStatement(sql); rs pstmt.executeQuery(); while (rs.next()) { int id rs.getInt(id); String name rs.getString(name); double money rs.getDouble(money); list.add(new Account(id, name, money)); } } catch (SQLException e) { e.printStackTrace(); } finally { JDBCUtils.close(conn, pstmt, rs); } return list; }五、核心记忆要点JDBC 流程注册驱动 → 获取连接 → 创建执行对象 → 执行 SQL → 处理结果 → 释放资源。连接 URLjdbc:mysql://主机:端口/数据库?参数必须配置时区和 SSL 参数。执行对象选择优先使用PreparedStatement避免 SQL 注入并提高性能。事务管理通过Connection的setAutoCommit(false)、commit()、rollback()实现事务控制。资源释放必须逆序关闭ResultSet→Statement→Connection建议使用try-finally或工具类统一处理。
JDBC概念
一、JDBC 概述1.1 什么是 JDBCJDBCJava Database ConnectivityJava 数据库连接是 Java 语言操作关系型数据库的一套标准接口。它定义了一系列规范由各数据库厂商如 MySQL、Oracle、SQL Server提供对应的驱动实现。开发者只需面向 JDBC 接口编程无需关心底层数据库的具体实现实现 “一次编写到处运行”。1.2 JDBC 的本质官方定义的一套操作所有关系型数据库的规范接口。各数据库厂商提供的驱动包是这些接口的实现类。开发者使用 JDBC 接口编程实际执行的代码是驱动包中的实现类。1.3 JDBC 的好处跨数据库兼容更换数据库时只需更换驱动包和连接 URL业务代码无需修改。标准化 API所有数据库操作都遵循统一的接口规范学习成本低。稳定性高作为 Java 官方标准长期维护兼容性有保障。二、JDBC 快速入门2.1 开发步骤导入驱动包将 MySQL 驱动mysql-connector-java-x.x.x.jar添加到项目依赖中。注册驱动加载数据库驱动类。获取连接建立 Java 程序与数据库的连接。编写 SQL 语句定义要执行的数据库操作增删改查。获取执行对象创建 SQL 语句的执行对象。执行 SQL执行 SQL 语句并获取结果。处理结果对查询结果或影响行数进行处理。释放资源关闭连接、执行对象等资源。2.2 入门示例更新操作import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement; public class JdbcQuickStart { public static void main(String[] args) throws Exception { // 1. 注册驱动MySQL 5.0 可省略 Class.forName(com.mysql.cj.jdbc.Driver); // 2. 获取数据库连接 String url jdbc:mysql://localhost:3306/testdb?useSSLfalseserverTimezoneUTC; String username root; String password root; Connection conn DriverManager.getConnection(url, username, password); // 3. 获取执行对象 Statement stmt conn.createStatement(); // 4. 编写并执行 SQL更新账户余额 String sql UPDATE account SET money money - 200 WHERE id 1; int count stmt.executeUpdate(sql); // 5. 处理结果 System.out.println(影响行数 count); // 6. 释放资源逆序关闭 stmt.close(); conn.close(); } }三、JDBC 核心 API 详解3.1DriverManager驱动管理类注册驱动Class.forName(com.mysql.cj.jdbc.Driver);MySQL 5.0 驱动包中Driver类会自动注册无需手动调用。获取连接DriverManager.getConnection(url, username, password);URL 格式jdbc:mysql://主机地址:端口号/数据库名?参数示例jdbc:mysql://localhost:3306/testdb?useSSLfalseserverTimezoneUTC常用参数useSSLfalse关闭 SSL 验证、serverTimezoneUTC设置时区3.2Connection数据库连接对象获取 SQL 执行对象createStatement()创建普通Statement对象存在 SQL 注入风险。prepareStatement(String sql)创建预编译PreparedStatement对象推荐防注入。事务管理setAutoCommit(false)关闭自动提交开启事务。commit()提交事务。rollback()回滚事务。事务示例try { conn.setAutoCommit(false); // 开启事务 // 执行转账操作 stmt.executeUpdate(UPDATE account SET money money - 200 WHERE id 1); stmt.executeUpdate(UPDATE account SET money money 200 WHERE id 2); conn.commit(); // 提交事务 } catch (Exception e) { conn.rollback(); // 异常时回滚事务 e.printStackTrace(); } finally { // 释放资源 }3.3StatementSQL 执行对象executeUpdate(String sql)执行 DML增删改语句返回受影响行数。executeQuery(String sql)执行 DQL查询语句返回ResultSet结果集对象。3.4ResultSet结果集对象封装查询语句的执行结果提供遍历和获取数据的方法。常用方法next()将游标向下移动一行判断是否有数据。getInt(列名)/getInt(列索引)获取整数类型数据。getString(列名)/getString(列索引)获取字符串类型数据。getDouble(列名)/getDouble(列索引)获取小数类型数据。查询示例String sql SELECT id, name, money FROM account; ResultSet rs stmt.executeQuery(sql); // 遍历结果集 while (rs.next()) { int id rs.getInt(id); String name rs.getString(name); double money rs.getDouble(money); System.out.println(ID: id , 姓名: name , 余额: money); } rs.close(); // 释放结果集3.5PreparedStatement预编译执行对象解决Statement的 SQL 注入问题推荐使用。SQL 注入通过拼接用户输入恶意修改 SQL 语句例如 or 1 1。使用步骤编写带?占位符的 SQL 语句。创建PreparedStatement对象传入 SQL 语句。使用setXxx(参数索引, 值)方法为占位符赋值索引从 1 开始。执行 SQL 语句。防注入登录示例// 1. 带占位符的 SQL String sql SELECT * FROM user WHERE username ? AND password ?; // 2. 获取预编译对象 PreparedStatement pstmt conn.prepareStatement(sql); // 3. 为占位符赋值 pstmt.setString(1, username); pstmt.setString(2, password); // 4. 执行查询 ResultSet rs pstmt.executeQuery(); // 5. 判断是否存在用户 if (rs.next()) { System.out.println(登录成功); } else { System.out.println(用户名或密码错误); }四、综合实践JDBC 工具类与数据封装4.1 工具类JDBCUtils封装 JDBC 连接和释放资源的重复代码提高开发效率。import java.sql.*; public class JDBCUtils { // 数据库配置可从配置文件读取 private static final String URL jdbc:mysql://localhost:3306/testdb?useSSLfalseserverTimezoneUTC; private static final String USERNAME root; private static final String PASSWORD root; // 注册驱动 static { try { Class.forName(com.mysql.cj.jdbc.Driver); } catch (ClassNotFoundException e) { throw new RuntimeException(驱动加载失败, e); } } // 获取连接 public static Connection getConnection() throws SQLException { return DriverManager.getConnection(URL, USERNAME, PASSWORD); } // 释放资源 public static void close(Connection conn, Statement stmt, ResultSet rs) { try { if (rs ! null) rs.close(); if (stmt ! null) stmt.close(); if (conn ! null) conn.close(); } catch (SQLException e) { e.printStackTrace(); } } // 简化版释放无查询结果 public static void close(Connection conn, Statement stmt) { close(conn, stmt, null); } }4.2 数据封装示例查询账户列表import java.util.ArrayList; import java.util.List; public class Account { private int id; private String name; private double money; // 构造方法、getter/setter、toString public Account() {} public Account(int id, String name, double money) { this.id id; this.name name; this.money money; } // getter/setter 省略 Override public String toString() { return Account{id id , name name , money money }; } } // 查询方法 public ListAccount findAllAccounts() { ListAccount list new ArrayList(); Connection conn null; PreparedStatement pstmt null; ResultSet rs null; try { conn JDBCUtils.getConnection(); String sql SELECT id, name, money FROM account; pstmt conn.prepareStatement(sql); rs pstmt.executeQuery(); while (rs.next()) { int id rs.getInt(id); String name rs.getString(name); double money rs.getDouble(money); list.add(new Account(id, name, money)); } } catch (SQLException e) { e.printStackTrace(); } finally { JDBCUtils.close(conn, pstmt, rs); } return list; }五、核心记忆要点JDBC 流程注册驱动 → 获取连接 → 创建执行对象 → 执行 SQL → 处理结果 → 释放资源。连接 URLjdbc:mysql://主机:端口/数据库?参数必须配置时区和 SSL 参数。执行对象选择优先使用PreparedStatement避免 SQL 注入并提高性能。事务管理通过Connection的setAutoCommit(false)、commit()、rollback()实现事务控制。资源释放必须逆序关闭ResultSet→Statement→Connection建议使用try-finally或工具类统一处理。
