首页 新手课堂正文

从零到精：JDBC操作MySQL的完整CRUD实战指南

admin 2026-02-07 阅读:17 评论:0
在Java企业级应用开发中，与数据库交互是核心技能，而JDBC（Java Database Connectivity）是这一技能的基石。掌握一套JDBC连接MySQL数据库完整增删改查代码，其核心价值远不止于实现数据存取，而在于深入理解数据...

在Java企业级应用开发中，与数据库交互是核心技能，而JDBC（Java Database Connectivity）是这一技能的基石。掌握一套JDBC连接MySQL数据库完整增删改查代码，其核心价值远不止于实现数据存取，而在于深入理解数据库连接的底层管理、SQL执行的生命周期、资源泄漏的防范以及事务控制的基本思想，这是后续学习任何ORM框架（如MyBatis、Hibernate）不可或缺的前提。本文将手把手带你从驱动加载到连接关闭，完成一套生产可用的CRUD模板。

一、 环境准备与项目搭建

从零到精：JDBC操作MySQL的完整CRUD实战指南

1. 引入MySQL驱动依赖 首先，你需要将MySQL的JDBC驱动jar包加入项目。以Maven项目为例，在`pom.xml`中添加： 


   <dependency>
       <groupId>mysql</groupId>
       <artifactId>mysql-connector-java</artifactId>
       <version>8.0.33</version> <!-- 请使用与MySQL服务匹配的版本 -->
   </dependency>
如果使用非Maven项目，需手动下载对应的`mysql-connector-java.jar`并添加到项目的构建路径中。

2. 创建数据库与测试表 在MySQL中执行以下SQL，准备测试环境： 


   CREATE DATABASE IF NOT EXISTS `jdbc_demo`;
   USE `jdbc_demo`;

CREATE TABLE user (
id INT PRIMARY KEY AUTO_INCREMENT,
name VARCHAR(50) NOT NULL,
email VARCHAR(100) UNIQUE NOT NULL,
age INT,
create_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);


INSERT INTO user (name, email, age) VALUES
('张三', 'zhangsan@example.com', 25),
('李四', 'lisi@example.com', 30);

二、 核心基石：编写数据库连接工具类

直接在每个方法中编写连接代码会导致大量重复和难以维护。最佳实践是封装一个工具类，集中管理数据库连接参数和获取连接的方法。这是JDBC连接MySQL数据库完整增删改查代码走向规范化的第一步。


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

public class JdbcUtil {
// 使用配置文件（如jdbc.properties）管理敏感信息，避免硬编码
private static final String DRIVER;
private static final String URL;
private static final String USER;
private static final String PASSWORD;


static {
    // 加载配置文件 
    ResourceBundle bundle = ResourceBundle.getBundle(“jdbc”);
    DRIVER = bundle.getString(“jdbc.driver”);
    URL = bundle.getString(“jdbc.url”);
    USER = bundle.getString(“jdbc.user”);
    PASSWORD = bundle.getString(“jdbc.password”);
    
    try {
        // 1. 注册驱动 (MySQL 8+ 可省略此步，但显式加载更清晰)
        Class.forName(DRIVER);
    } catch (ClassNotFoundException e) {
        throw new ExceptionInInitializerError(“加载数据库驱动失败！”);
    }
}

/**
 * 获取数据库连接
 * @return Connection 对象
 * @throws SQLException 
 */
public static Connection getConnection() throws SQLException {
    // 2. 建立连接 
    return DriverManager.getConnection(URL, USER, PASSWORD);
}

// 关闭资源的方法将在后面统一展示



}

对应的`src/main/resources/jdbc.properties`配置文件内容： 


jdbc.driver=com.mysql.cj.jdbc.Driver 
jdbc.url=jdbc:mysql://localhost:3306/jdbc_demo?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&useSSL=false
jdbc.user=你的用户名 
jdbc.password=你的密码
在鳄鱼java的项目规范中，将数据库配置外部化是强制要求，这提高了安全性和部署灵活性。

三、 模板与核心：增删改查的标准化实现

接下来，我们将实现一个`UserDao`类，包含完整的CRUD操作。请特别注意其中的资源管理和异常处理。


import java.sql.*;
import java.util.ArrayList;
import java.util.List;

public class UserDao {


/**
 * 增（Create） - 插入用户
 * @param user 用户对象（假设有name, email, age属性）
 * @return 插入的行数，或生成的主键（根据需求）
 */
public int insert(User user) {
    String sql = “INSERT INTO user(name, email, age) VALUES(?, ?, ?)”;
    // 使用 try-with-resources 自动关闭 Connection, PreparedStatement 
    try (Connection conn = JdbcUtil.getConnection();
         PreparedStatement pstmt = conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS)) {
        
        pstmt.setString(1, user.getName()); // 参数索引从1开始
        pstmt.setString(2, user.getEmail());
        pstmt.setInt(3, user.getAge());
        
        int affectedRows = pstmt.executeUpdate(); // 执行更新 
        
        // 获取自增主键
        try (ResultSet generatedKeys = pstmt.getGeneratedKeys()) {
            if (generatedKeys.next()) {
                return generatedKeys.getInt(1); // 返回生成的主键ID 
            }
        }
        return affectedRows;
    } catch (SQLException e) {
        // 应转换为自定义的业务异常，此处简化处理
        throw new RuntimeException(“插入用户失败”, e);
    }
    // 无需手动关闭 conn 和 pstmt，try-with-resources 会自动处理
}

/**
 * 删（Delete） - 根据ID删除用户 
 * @param id 用户ID
 * @return 受影响的行数 
 */
public int deleteById(int id) {
    String sql = “DELETE FROM user WHERE id = ?”;
    try (Connection conn = JdbcUtil.getConnection();
         PreparedStatement pstmt = conn.prepareStatement(sql)) {
        
        pstmt.setInt(1, id);
        return pstmt.executeUpdate();
    } catch (SQLException e) {
        throw new RuntimeException(“删除用户失败”, e);
    }
}

/**
 * 改（Update） - 根据ID更新用户信息 
 * @param user 用户对象（需包含id）
 * @return 受影响的行数 
 */
public int update(User user) {
    String sql = “UPDATE user SET name=?, email=?, age=? WHERE id=?”;
    try (Connection conn = JdbcUtil.getConnection();
         PreparedStatement pstmt = conn.prepareStatement(sql)) {
        
        pstmt.setString(1, user.getName());
        pstmt.setString(2, user.getEmail());
        pstmt.setInt(3, user.getAge());
        pstmt.setInt(4, user.getId());
        
        return pstmt.executeUpdate();
    } catch (SQLException e) {
        throw new RuntimeException(“更新用户失败”, e);
    }
}

/**
 * 查（Retrieve） - 根据ID查询单个用户
 * @param id 用户ID 
 * @return User对象，未找到返回null
 */
public User selectById(int id) {
    String sql = “SELECT id, name, email, age, create_time FROM user WHERE id = ?”;
    try (Connection conn = JdbcUtil.getConnection();
         PreparedStatement pstmt = conn.prepareStatement(sql)) {
        
        pstmt.setInt(1, id);
        try (ResultSet rs = pstmt.executeQuery()) { // 嵌套try-with-resources关闭ResultSet
            if (rs.next()) {
                return extractUserFromResultSet(rs); // 封装结果集到对象 
            }
            return null;
        }
    } catch (SQLException e) {
        throw new RuntimeException(“查询用户失败”, e);
    }
}

/**
 * 查（Retrieve） - 查询所有用户 
 * @return 用户列表 
 */
public List<User> selectAll() {
    String sql = “SELECT id, name, email, age, create_time FROM user”;
    List<User> userList = new ArrayList<>();
    try (Connection conn = JdbcUtil.getConnection();
         PreparedStatement pstmt = conn.prepareStatement(sql);
         ResultSet rs = pstmt.executeQuery()) {
        
        while (rs.next()) {
            userList.add(extractUserFromResultSet(rs));
        }
        return userList;
    } catch (SQLException e) {
        throw new RuntimeException(“查询所有用户失败”, e);
    }
}

/**
 * 工具方法：从ResultSet中提取数据构建User对象 
 * @param rs ResultSet 
 * @return User对象 
 * @throws SQLException
 */
private User extractUserFromResultSet(ResultSet rs) throws SQLException {
    User user = new User();
    user.setId(rs.getInt(“id”));
    user.setName(rs.getString(“name”));
    user.setEmail(rs.getString(“email”));
    user.setAge(rs.getInt(“age”));
    user.setCreateTime(rs.getTimestamp(“create_time”));
    return user;
}



}

这份JDBC连接MySQL数据库完整增删改查代码模板清晰地展示了几个黄金法则：

1. 必须使用PreparedStatement：它通过预编译和参数绑定，从根本上防止了SQL注入攻击，同时提升了SQL执行效率。绝对禁止使用字符串拼接来构造SQL语句。

2. 必须使用try-with-resources管理资源：确保`Connection`、`PreparedStatement`和`ResultSet`这些实现了`AutoCloseable`接口的资源在任何情况下（包括异常）都能被正确关闭，避免连接泄漏导致数据库连接池耗尽。

3. 结果集到对象的映射：`extractUserFromResultSet`方法展示了手动ORM的过程，这是理解所有高级框架底层原理的关键。

四、 进阶：事务处理与连接池引入

1. 事务管理 对于需要原子性的一组操作（如转账），必须使用事务。 


   try (Connection conn = JdbcUtil.getConnection()) {
       conn.setAutoCommit(false); // 1. 开启事务（关闭自动提交）
       // 执行多个 insert/update/delete 操作 
       // ...
       conn.commit(); // 2. 提交事务
   } catch (SQLException e) {
       // conn.rollback(); // 3. 在catch块或finally块中回滚
       throw new RuntimeException(“事务执行失败”, e);
   }

2. 引入数据库连接池 上述例子中，每次操作都新建物理连接，性能极差。生产环境必须使用连接池，如HikariCP（目前性能最优）、Druid（功能强大）。以HikariCP为例： 


   // 在JdbcUtil中，用HikariDataSource替代DriverManager 
   HikariConfig config = new HikariConfig();
   config.setJdbcUrl(URL);
   config.setUsername(USER);
   config.setPassword(PASSWORD);
   private static final HikariDataSource dataSource = new HikariDataSource(config);
   public static Connection getConnection() throws SQLException {
       return dataSource.getConnection(); // 从池中获取连接 
   }
连接池负责管理连接的创建、复用和销毁，这是高并发应用的基石。在鳄鱼java的线上项目中，连接池是标准配置。

五、 总结：从原生JDBC到现代框架的桥梁

通过这套完整的JDBC连接MySQL数据库完整增删改查代码实战，我们不仅学会了如何操作数据库，更重要的是建立了对数据访问层的基本认知：连接管理、会话生命周期、资源安全释放和SQL执行。这正是理解MyBatis（它封装了JDBC）或Spring Data JPA（它抽象了JDBC）等框架内部运作的钥匙。

在鳄鱼java看来，一个Java开发者即使未来只使用高级框架，也必须扎实地走一遍原生JDBC的实践之路。这能让你在框架出现诡异问题时，有能力深入底层排查；在需要极致优化时，知道从何处着手。

现在，请你基于这个模板进行扩展：如何实现分页查询？如何批量插入以提升性能？当查询结果字段很多时，是否有更优雅的方式封装对象？理解基础，方能驾驭复杂。你的下一个挑战，或许是尝试用这套原生代码实现一个简单的ORM映射框架。

版权声明

本文仅代表作者观点，不代表百度立场。
本文系作者授权百度百家发表，未经许可，不得转载。

分享：

扫一扫在手机阅读、分享本文

上一篇：线程的脉搏：图解Java线程生命周期与状态流转的每一帧 下一篇：动态之眼：深入解析Java反射机制的原理与实战场景
相关阅读
admin

admin

1752文章数 0评论数
最近文章
浏览更多
随机文章
热门文章

  • 多线程破局：KeyDB如何重塑Redis性能天花板？

    多线程破局：KeyDB如何重塑Redis性能天花板？
    在Redis以其卓越的性能和丰富的数据结构统治内存数据存储领域十余年后，其单线程事件循环模型在多核CPU成为标配的今天，逐渐显露出性能扩展的“阿喀琉斯之踵”。正是在此背景下，KeyDB多线程Redis替代方案现状成为了一个极具探讨价值的技术议题。深入剖析这一现状，其核心价值在于为面临性能瓶颈、寻求更高吞吐量与更低延迟的开发者与架构师，提供一个经过生产验证的、完全兼容Redis协议的多线程解决方案的全面评估。这不仅是关于一个“分支”项目的介绍，更是对“Redis单线程哲学”与“...

  • 拆解数据洪流：ShardingSphere分库分表实战全解析

    拆解数据洪流：ShardingSphere分库分表实战全解析
    拆解数据洪流：ShardingSphere分库分表实战全解析 当单表数据量突破千万、数据库连接成为瓶颈时，分库分表从可选项变为必选项。然而，如何在不重写业务逻辑的前提下，平滑、透明地实现数据水平拆分，是架构升级的核心挑战。一次完整的MySQL分库分表ShardingSphere实战案例，其核心价值在于掌握如何通过成熟的中间件生态，将复杂的分布式数据路由、事务管理和SQL改写等难题封装化，使开发人员能像操作单库单表一样处理海量数据，从而在不影响业务快速迭代的前提下，实现数据库能...

  • 提升可读性还是制造混乱？深度解析Java var的正确使用场景

    提升可读性还是制造混乱？深度解析Java var的正确使用场景
    自JDK 10引入以来，var关键字无疑是最具争议又最受开发者欢迎的语法特性之一。它允许编译器根据初始化表达式推断局部变量的类型，从而省略显式的类型声明。Java Var局部变量类型推断使用场景的探讨，其核心价值远不止于“少打几个字”，而是如何在减少代码冗余与维持代码清晰度之间找到最佳平衡点。理解其设计哲学和最佳实践，是避免滥用、真正发挥其提升开发效率和代码可读性作用的关键。本文将系统性地剖析var的适用边界、潜在陷阱及团队规范，为你提供一份清晰的“作战地图”。 一、var的...

  • ConcurrentHashMap线程安全实现原理：从1.7到1.8的进化与实战指南

    ConcurrentHashMap线程安全实现原理：从1.7到1.8的进化与实战指南
    在Java后端高并发场景中，线程安全的Map容器是保障数据一致性的核心组件。Hashtable因全表锁导致性能极低，Collections.synchronizedMap仅对HashMap做了简单的同步包装，无法满足万级以上并发需求。【ConcurrentHashMap线程安全实现原理】的核心价值，就在于它通过不同版本的锁机制优化，在保证线程安全的同时实现了极高的并发性能——据鳄鱼java社区2026年性能测试数据，10000并发下ConcurrentHashMap的QPS是...

  • 2026重庆房地产税最新政策解读：起征点31528元/㎡+免税面积180㎡，影响哪些购房者？

    2026重庆房地产税最新政策解读：起征点31528元/㎡+免税面积180㎡，影响哪些购房者？
    2026年重庆房地产税政策迎来新一轮调整，精准把握政策细节对购房者、多套房业主及投资者至关重要。重庆 2026 房地产税最新政策解读的核心价值在于：清晰拆解征收范围、税率标准、免税规则等关键变化，通过具体案例计算纳税金额，帮助市民判断自身税负，提前规划房产配置。据鳄鱼java房产数据平台统计，2026年重庆房产税起征点较2025年上调8.2%，政策调整后约65%的存量住房可享受免税或低税率优惠，而未及时了解政策的业主可能面临多缴税费风险。本文结合重庆市住建委2026年1月最新...
最近发表
标签列表

    Copyright 鳄鱼Java Rights Reserved.

    Powered By Z-BlogPHP  Theme By 老白编程