Java Web 基础：数据库连接与操作指南

引言 / 什么是 JDBC

在 Java Web 开发中，数据库是存储和管理数据的核心组件。无论是用户信息、订单数据还是系统配置，几乎所有业务逻辑都依赖数据库的支持。而 JDBC（Java Database Connectivity） 作为 Java 标准 API，提供了统一的接口来连接和操作不同数据库（如 MySQL、Oracle、PostgreSQL 等），是 Java 开发者必须掌握的基础技能。

本文将通过实战案例，详细讲解如何使用 JDBC 完成数据库连接、SQL 语句执行（增删改查）及结果集处理，帮助你快速上手 Java Web 中的数据库操作。

准备工作

在开始之前，请确保满足以下条件：

1. JDK 环境：安装 JDK 8 或更高版本（推荐 JDK 11+）。
2. 数据库：安装 MySQL 或其他支持 JDBC 的数据库，并创建测试数据库和表。
3. JDBC 驱动：下载对应数据库的 JDBC 驱动（如 MySQL 的 mysql-connector-java.jar）。
4. 开发工具：推荐使用 IntelliJ IDEA 或 Eclipse。

提示：若使用 Maven 项目，可直接在 pom.xml 中添加依赖：

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.28</version>
</dependency>

基础操作：JDBC 连接与 SQL 执行

步骤一：加载驱动并建立连接

JDBC 操作的第一步是加载数据库驱动并建立连接。以下是连接 MySQL 的示例代码：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class JdbcDemo {
    public static void main(String[] args) {
        // 数据库连接信息
        String url = "jdbc:mysql://localhost:3306/test_db?useSSL=false&serverTimezone=UTC";
        String username = "root";
        String password = "123456";

        try {
            // 1. 加载驱动（JDBC 4.0+ 可自动加载，此步可省略）
            Class.forName("com.mysql.cj.jdbc.Driver");

            // 2. 建立连接
            Connection connection = DriverManager.getConnection(url, username, password);
            System.out.println("数据库连接成功！");

            // 后续操作...
            connection.close(); // 关闭连接
        } catch (ClassNotFoundException e) {
            System.out.println("驱动加载失败：" + e.getMessage());
        } catch (SQLException e) {
            System.out.println("连接失败：" + e.getMessage());
        }
    }
}

关键参数说明：

• url：格式为 jdbc:数据库类型://主机:端口/数据库名?参数。
• username/password：数据库账号和密码。

提示：生产环境中建议将连接信息配置在属性文件（如 db.properties）中，避免硬编码。

步骤二：执行 SQL 语句（增删改查）

JDBC 通过 Statement 或 PreparedStatement 执行 SQL 语句。以下是四种常见操作的示例：

1. 查询数据（SELECT）

import java.sql.*;

public class SelectDemo {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/test_db";
        String sql = "SELECT id, name, age FROM users WHERE age > ?";

        try (Connection conn = DriverManager.getConnection(url, "root", "123456");
             PreparedStatement pstmt = conn.prepareStatement(sql)) {

            // 设置参数（防止 SQL 注入）
            pstmt.setInt(1, 18);

            // 执行查询
            ResultSet rs = pstmt.executeQuery();

            // 处理结果集
            while (rs.next()) {
                int id = rs.getInt("id");
                String name = rs.getString("name");
                int age = rs.getInt("age");
                System.out.printf("ID: %d, Name: %s, Age: %d%n", id, name, age);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

2. 插入数据（INSERT）

String insertSql = "INSERT INTO users (name, age) VALUES (?, ?)";
try (PreparedStatement pstmt = conn.prepareStatement(insertSql)) {
    pstmt.setString(1, "张三");
    pstmt.setInt(2, 25);
    int rows = pstmt.executeUpdate(); // 返回受影响的行数
    System.out.println("插入成功，影响行数：" + rows);
}

3. 更新数据（UPDATE）

String updateSql = "UPDATE users SET age = ? WHERE name = ?";
try (PreparedStatement pstmt = conn.prepareStatement(updateSql)) {
    pstmt.setInt(1, 30);
    pstmt.setString(2, "张三");
    int rows = pstmt.executeUpdate();
    System.out.println("更新成功，影响行数：" + rows);
}

4. 删除数据（DELETE）

String deleteSql = "DELETE FROM users WHERE id = ?";
try (PreparedStatement pstmt = conn.prepareStatement(deleteSql)) {
    pstmt.setInt(1, 1);
    int rows = pstmt.executeUpdate();
    System.out.println("删除成功，影响行数：" + rows);
}

重要提示：

• 使用 PreparedStatement 替代 Statement 可防止 SQL 注入。
• 通过 try-with-resources 自动关闭资源（Connection、Statement、ResultSet）。

进阶技巧

技巧一：批量操作提升性能

当需要执行大量相似 SQL 时（如批量插入），使用 addBatch() 和 executeBatch() 可显著提升性能：

String batchInsertSql = "INSERT INTO users (name, age) VALUES (?, ?)";
try (PreparedStatement pstmt = conn.prepareStatement(batchInsertSql)) {
    for (int i = 0; i < 100; i++) {
        pstmt.setString(1, "用户" + i);
        pstmt.setInt(2, 20 + i);
        pstmt.addBatch(); // 添加到批处理

        // 每 50 条执行一次
        if (i % 50 == 0) {
            pstmt.executeBatch();
        }
    }
    pstmt.executeBatch(); // 执行剩余批处理
}

技巧二：事务管理

事务确保一组操作要么全部成功，要么全部失败。示例：

Connection conn = null;
try {
    conn = DriverManager.getConnection(url, "root", "123456");
    conn.setAutoCommit(false); // 关闭自动提交

    // 操作1：扣款
    String deductSql = "UPDATE accounts SET balance = balance - ? WHERE user_id = ?";
    PreparedStatement deductStmt = conn.prepareStatement(deductSql);
    deductStmt.setDouble(1, 100);
    deductStmt.setInt(2, 1);
    deductStmt.executeUpdate();

    // 操作2：存款
    String depositSql = "UPDATE accounts SET balance = balance + ? WHERE user_id = ?";
    PreparedStatement depositStmt = conn.prepareStatement(depositSql);
    depositStmt.setDouble(1, 100);
    depositStmt.setInt(2, 2);
    depositStmt.executeUpdate();

    conn.commit(); // 提交事务
} catch (SQLException e) {
    if (conn != null) {
        try {
            conn.rollback(); // 回滚事务
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
    }
    e.printStackTrace();
} finally {
    if (conn != null) {
        try {
            conn.setAutoCommit(true); // 恢复自动提交
            conn.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

技巧三：结果集元数据处理

通过 ResultSetMetaData 获取结果集的列信息（如列名、类型）：

ResultSet rs = pstmt.executeQuery("SELECT * FROM users");
ResultSetMetaData metaData = rs.getMetaData();
int columnCount = metaData.getColumnCount();

for (int i = 1; i <= columnCount; i++) {
    System.out.printf("列%d: %s (%s)%n",
            i,
            metaData.getColumnName(i),
            metaData.getColumnTypeName(i));
}

常见问题

Q：JDBC 连接池如何使用？
A：生产环境建议使用连接池（如 HikariCP、Druid）管理连接。示例配置 HikariCP：

HikariConfig config = new HikariConfig();
config.setJdbcUrl("jdbc:mysql://localhost:3306/test_db");
config.setUsername("root");
config.setPassword("123456");
config.setMaximumPoolSize(10); // 最大连接数

try (HikariDataSource ds = new HikariDataSource(config);
     Connection conn = ds.getConnection()) {
    // 执行操作...
}

Q：如何处理数据库中的日期类型？
A：使用 java.sql.Date 或 java.sql.Timestamp 类型，并通过 PreparedStatement.setDate() 设置参数：

java.util.Date utilDate = new java.util.Date();
java.sql.Date sqlDate = new java.sql.Date(utilDate.getTime());
pstmt.setDate(1, sqlDate);

Q：JDBC 和 ORM 框架（如 MyBatis、Hibernate）的区别？
A：JDBC 是底层 API，需要手动编写 SQL；ORM 框架通过对象映射简化操作，但性能开销较大。初学者建议先掌握 JDBC，再学习 ORM。

小结

本文通过代码示例和实战技巧，系统讲解了 JDBC 的核心用法，包括数据库连接、SQL 执行、结果集处理及事务管理。掌握这些知识后，你可以独立完成 Java Web 中的基础数据库操作。下一步建议：

1. 尝试在项目中集成连接池（如 HikariCP）。
2. 学习使用 JDBC 封装工具类，减少重复代码。
3. 探索更高级的 ORM 框架（如 MyBatis）。

数据库是后端开发的基石，持续练习和优化代码是提升能力的关键！