Java JDBC 数据库连接

0. 学习目标（可验证）#

• 能说出原生 JDBC 的 5 个核心步骤
• 能写出 DriverManager 获取 Connection 的代码
• 能说明 PreparedStatement 为什么能防 SQL 注入
• 能用 try-with-resources 正确关闭 Connection / Statement / ResultSet

1. 一句话理解#

JDBC 是 Java 访问数据库的”官方插座”：DriverManager 插上驱动，Connection 建立管道，Statement / PreparedStatement 递 SQL，ResultSet 收结果。MyBatis、JPA 这些 ORM 只是在它外面包了一层。

2. 完整可运行示例：五步走#

// 1. 加载驱动（JDBC 4.0+ 可以省略，驱动 jar 会自动注册）
Class.forName("com.mysql.cj.jdbc.Driver");

// 2-5. 连接 -> 预编译 SQL -> 绑定参数 -> 执行
try (Connection conn = DriverManager.getConnection(
        "jdbc:mysql://localhost:3306/library?useSSL=false&serverTimezone=Asia/Shanghai",
        "root", "123456");
     PreparedStatement ps = conn.prepareStatement(
        "INSERT INTO user(name, age) VALUES(?, ?)")) {
    ps.setString(1, "张三");          // 绑定第 1 个占位符
    ps.setInt(2, 20);                 // 绑定第 2 个占位符
    int rows = ps.executeUpdate();    // 执行写入，返回影响行数
    System.out.println("影响行数: " + rows);
}   // try-with-resources 自动逆序关闭 ps 与 conn

拆解讲解：

1. DriverManager.getConnection 返回一个物理连接，jdbc:mysql:// 是协议头，后面依次是主机、端口、库名。
2. PreparedStatement 用 ? 占位、setXxx 绑定参数，参数永远不会拼进 SQL 字符串，因此天然防 SQL 注入。
3. executeUpdate() 用于增删改，返回受影响行数；查询用 executeQuery()（见下一节）。
4. 用 try-with-resources 包裹资源，无论成功失败都会自动关闭，避免连接耗尽。

3. 查询并遍历 ResultSet#

String sql = "SELECT id, name, age FROM user WHERE age > ?";
try (Connection conn = DriverManager.getConnection(url, user, pwd);
     PreparedStatement ps = conn.prepareStatement(sql)) {
    ps.setInt(1, 18);
    try (ResultSet rs = ps.executeQuery()) {   // ResultSet 也要关闭
        while (rs.next()) {                    // 移动到下一行，没有则返回 false
            int id = rs.getInt("id");
            String name = rs.getString("name");
            System.out.println(id + " " + name);
        }
    }
}

拆解讲解：rs.next() 既是”移动到下一行”也是”还有没有下一行”的判断；getXxx("列名") 按列名取值，也可以用下标 getXxx(1)。

4. 常见陷阱#

建立连接#

基本写法：DriverManager 获取连接 DriverManager.getConnection("<url>", "<用户>", "<密码>");

// 建立数据库连接
Connection conn = DriverManager.getConnection(
    "jdbc:mysql://localhost:3306/db", "root", "pwd");

基本写法：使用 Properties DriverManager.getConnection(<url>, <properties>);

// 通过 Properties 传参
Properties p = new Properties();
p.setProperty("user", "root");
p.setProperty("password", "pwd");
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost/db", p);

Statement 执行 SQL#

基本写法：创建 Statement <connection>.createStatement();

// 创建静态 SQL 执行器
Statement st = conn.createStatement();

基本写法：执行查询 <statement>.executeQuery("<sql>");

// 执行查询并返回结果集
ResultSet rs = st.executeQuery("SELECT * FROM user");

基本写法：执行更新 <statement>.executeUpdate("<sql>");

// 执行 INSERT/UPDATE/DELETE
int rows = st.executeUpdate("DELETE FROM user WHERE id=1");

PreparedStatement 参数化#

基本写法：创建预编译语句 <connection>.prepareStatement("<sql>");

// 预编译防 SQL 注入
PreparedStatement ps = conn.prepareStatement(
    "SELECT * FROM user WHERE id = ?");

基本写法：设置参数 <ps>.setInt(<位置>, <值>);

// 按位置设置整型参数
ps.setInt(1, 100);

基本写法：设置字符串参数 <ps>.setString(<位置>, <值>);

// 按位置设置字符串参数
ps.setString(1, "Alice");

基本写法：执行预编译查询 <ps>.executeQuery();

// 执行预编译查询
ResultSet rs = ps.executeQuery();

基本写法：执行预编译更新 <ps>.executeUpdate();

// 执行预编译更新
int rows = ps.executeUpdate();

ResultSet 遍历#

基本写法：遍历结果集 while (<rs>.next()) { <rs>.getX("<列>"); }

// 按列名读取结果
while (rs.next()) {
    int id = rs.getInt("id");
    String name = rs.getString("name");
}

基本写法：按索引取值 <rs>.getInt(<位置>);

// 按列位置取值
int id = rs.getInt(1);

基本写法：可滚动结果集 <connection>.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);

// 创建可前后滚动的结果集
Statement st = conn.createStatement(
    ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);

基本写法：跳转到指定行 <rs>.absolute(<行号>);

// 移动到绝对行
rs.absolute(5);

事务管理#

基本写法：关闭自动提交 <connection>.setAutoCommit(false);

// 开启手动事务
conn.setAutoCommit(false);

基本写法：提交事务 <connection>.commit();

// 提交当前事务
conn.commit();

基本写法：回滚事务 <connection>.rollback();

// 回滚当前事务
conn.rollback();

基本写法：设置保存点 <connection>.setSavepoint();

// 设置保存点
Savepoint sp = conn.setSavepoint();

基本写法：回滚到保存点 <connection>.rollback(<savepoint>);

// 回滚到指定保存点
conn.rollback(sp);

批处理#

基本写法：添加批处理 <ps>.addBatch();

// 添加到批处理
ps.setInt(1, 1); ps.addBatch();
ps.setInt(1, 2); ps.addBatch();

基本写法：执行批处理 <ps>.executeBatch();

// 执行批量操作
int[] counts = ps.executeBatch();

基本写法：清空批处理 <ps>.clearBatch();

// 清空批处理队列
ps.clearBatch();

获取自增主键#

基本写法：返回生成键 <connection>.prepareStatement(<sql>, Statement.RETURN_GENERATED_KEYS);

// 执行后获取自增主键
PreparedStatement ps = conn.prepareStatement(
    "INSERT INTO user(name) VALUES(?)", Statement.RETURN_GENERATED_KEYS);
ps.setString(1, "Alice");
ps.executeUpdate();
ResultSet keys = ps.getGeneratedKeys();
if (keys.next()) { long id = keys.getLong(1); }

连接池#

基本写法：HikariCP 配置 new HikariConfig(); new HikariDataSource(<config>);

// 配置 HikariCP 连接池
HikariConfig cfg = new HikariConfig();
cfg.setJdbcUrl("jdbc:mysql://localhost/db");
cfg.setUsername("root");
cfg.setPassword("pwd");
cfg.setMaximumPoolSize(10);
HikariDataSource ds = new HikariDataSource(cfg);
Connection conn = ds.getConnection();

try-with-resources 自动关闭#

基本写法：自动关闭资源 try (Connection c = ...; PreparedStatement p = ...) { }

// 自动关闭连接、语句、结果集
try (Connection c = ds.getConnection();
     PreparedStatement p = c.prepareStatement(sql)) {
    try (ResultSet rs = p.executeQuery()) {
        while (rs.next()) { }
    }
}

元数据查询#

基本写法：获取表元数据 <connection>.getMetaData().getTables(null, null, "<表名>", null);

// 查询数据库表信息
ResultSet rs = conn.getMetaData().getTables(null, null, "user", null);

基本写法：获取结果集元数据 <rs>.getMetaData().getColumnCount();

// 获取列数及列名
ResultSetMetaData md = rs.getMetaData();
int n = md.getColumnCount();
String name = md.getColumnName(1);

DataSource 与 JNDI#

基本写法：从 JNDI 获取 DataSource InitialContext.doLookup("java:comp/env/jdbc/db");

// 通过 JNDI 查找数据源
DataSource ds = InitialContext.doLookup("java:comp/env/jdbc/db");
Connection conn = ds.getConnection();