在Spring Boot项目里接入MySQL并实现增删改查，基本流程并不复杂，但项目能否稳定运行，往往取决于一些容易忽略的配置细节。连接地址里漏写时区参数可能导致启动报错，连接池的最大连接数设置不合理会让并发请求排队，事务注解放在私有方法上完全不生效。本文会从依赖和配置开始，逐步完成一套可用的CRUD接口，并分享连接池、事务和异常排查方面的经验。
一、工程依赖与数据源配置
创建Spring Boot项目后，最先要处理的是MySQL驱动和持久层框架的选择。以Maven工程为例，如果采用Spring Data JPA，需要在pom.xml中加入<dependency>节点，引入spring-boot-starter-data-jpa和mysql-connector-j。MySQL驱动在8.x版本中已经由mysql-connector-java变更为mysql-connector-j，旧项目升级时需要注意坐标变化。引入JPA后，Spring Boot会自动配置EntityManagerFactory和事务管理器，无需再手动编写SessionFactory。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
<scope>runtime</scope>
</dependency>
接着在application.yml中配置数据源。这里的核心参数包括url、username、password和driver-class-name。MySQL 8建议显式指定驱动类com.mysql.cj.jdbc.Driver，并在连接串中追加serverTimezone=Asia/Shanghai和useSSL=false。serverTimezone如果不设置，部分驱动版本会因为无法识别本地时区而抛出异常。useSSL=false适合内网开发和测试环境，生产环境如果数据库启用了SSL，应保持默认并配置证书。
spring:
datasource:
url: jdbc:mysql://127.0.0.1:3306/spring_demo?useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Shanghai&useSSL=false&allowPublicKeyRetrieval=true
username: root
password: your_password
driver-class-name: com.mysql.cj.jdbc.Driver
jpa:
hibernate:
ddl-auto: update
show-sql: true
properties:
hibernate:
format_sql: true
需要特别说明的是，ddl-auto设为update可以让Hibernate根据实体自动维护表结构，适合开发阶段。但如果项目已经有一套严格的数据库变更流程，最好关闭自动建表，改为使用Flyway或Liquibase管理脚本。show-sql和format_sql会把Hibernate生成的SQL打印到控制台，排查慢查询时非常有用，不过生产环境建议关闭，避免日志量过大。
另一个容易踩坑的配置是allowPublicKeyRetrieval=true。当MySQL 8使用caching_sha2_password认证时，JDBC客户端如果在SSL关闭的情况下读取公钥，需要显式允许公钥检索，否则可能出现Public Key Retrieval is not allowed异常。开发环境可以加上该参数，生产环境则应优先使用安全连接或配置服务端证书。
二、实体映射与Repository增删改查
实体类负责把Java对象与数据库表对应起来。下面以用户表t_user为例，定义一个包含主键、用户名、邮箱和创建时间的实体。在主键字段上使用@GeneratedValue(strategy = GenerationType.IDENTITY)，MySQL自增主键在插入后会把生成的值回填到实体对象，这对后续返回接口数据很有帮助。
import javax.persistence.*;
import java.time.LocalDateTime;
@Entity
@Table(name = "t_user")
public class User {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Long id;
@Column(nullable = false, length = 50)
private String username;
@Column(nullable = false, unique = true, length = 100)
private String email;
@Column(name = "create_time")
private LocalDateTime createTime;
public User() {
}
public User(String username, String email) {
this.username = username;
this.email = email;
this.createTime = LocalDateTime.now();
}
// 省略getter和setter
}
Repository层可以直接继承JpaRepository，它已经内置了save、findById、findAll、deleteById等方法，大多数单表操作不需要手写SQL。如果需要按邮箱查询，可以声明一个方法名符合Spring Data规范的接口方法，框架会根据方法名自动生成查询语句。
import org.springframework.data.jpa.repository.JpaRepository;
public interface UserRepository extends JpaRepository<User, Long> {
User findByEmail(String email);
boolean existsByUsername(String username);
}
在Service层调用Repository即可完成增删改查。新增操作使用save，它会根据主键是否存在判断执行插入还是更新。批量保存时可以调用saveAll并传入列表，但要注意JPA默认的批量保存并不会自动合并成一条SQL，而是每条记录单独执行插入，只有配合hibernate.jdbc.batch_size等参数才能真正减少数据库往返次数。修改操作推荐先查询再更新字段，这样既能利用对象状态管理自动更新，也能避免update语句误更新未修改的列。
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
@Service
public class UserService {
private final UserRepository userRepository;
public UserService(UserRepository userRepository) {
this.userRepository = userRepository;
}
@Transactional
public User createUser(String username, String email) {
if (userRepository.existsByUsername(username)) {
throw new IllegalArgumentException("用户名已存在");
}
User user = new User(username, email);
return userRepository.save(user);
}
@Transactional(readOnly = true)
public User findById(Long id) {
return userRepository.findById(id)
.orElseThrow(() -> new IllegalArgumentException("用户不存在"));
}
@Transactional
public User updateEmail(Long id, String newEmail) {
User user = findById(id);
user.setEmail(newEmail);
return userRepository.save(user);
}
@Transactional
public void deleteUser(Long id) {
userRepository.deleteById(id);
}
@Transactional(readOnly = true)
public List<User> listAll() {
return userRepository.findAll();
}
}
上面的findById使用了orElseThrow来转换空结果，这样Controller层拿到的要么是有效对象，要么会抛出明确异常，避免后续出现空指针。查询类方法加上@Transactional(readOnly = true)可以让Hibernate放弃脏检查，减少不必要的性能消耗，同时数据库层也可能将只读事务调度到从库。
三、事务管理与连接池调优
Spring Boot默认已经开启了事务管理，但只有通过Spring代理调用的公共方法上的@Transactional才会生效。类内部自调用、私有方法上的事务注解，以及未被Spring管理的对象中调用这些方法，都会导致事务不生效。一个常见的错误是在Controller里直接调用Service的私有方法，或者在同一个Service类里用this调用另一个带事务注解的方法，此时事务管理器无法拦截。
事务回滚规则也值得注意。默认只对RuntimeException和Error进行回滚，受检异常不会触发回滚。如果业务需要捕获受检异常并回滚，可以在注解上显式写成@Transactional(rollbackFor = Exception.class)。另外，事务边界不宜包住耗时操作，例如发送HTTP请求、调用消息队列或导出文件，这些步骤放在事务外执行，否则会长时间占用数据库连接。
连接池是影响MySQL并发能力的关键。Spring Boot 2.x及之后默认使用HikariCP，它的参数都有明确含义。maximum-pool-size决定连接池能创建的最大连接数，并非越大越好，设置过大会让MySQL端线程数和内存占用上升，一般先根据数据库的max_connections和实例数量推算。minimum-idle控制池中保持的最小空闲连接，可以避免请求高峰时频繁建立物理连接。connection-timeout是客户端获取连接的等待上限，超过这个时间就会报错。
spring:
datasource:
hikari:
maximum-pool-size: 20
minimum-idle: 5
connection-timeout: 30000
idle-timeout: 600000
max-lifetime: 1800000
leak-detection-threshold: 10000
max-lifetime应短于MySQL的wait_timeout，否则连接池可能把已被MySQL关闭的连接返回给应用，导致Communications link failure。一般建议把max-lifetime设置为比数据库超时时间小几十秒。leak-detection-threshold开启连接泄漏检测后，如果连接被借出超过设定毫秒数仍未归还，日志会打印警告并给出调用栈，便于定位未释放连接的事务方法。
除了连接池，索引设计对增删改查的性能影响也很大。频繁按邮箱查询时，email列必须加唯一索引；批量插入时索引过多会降低写入速度，需要根据读写比例做取舍。SQL日志中如果出现全表扫描，可以通过explain分析执行计划，再决定是否增加联合索引或调整查询条件。
四、常见错误排查与最佳实践
实际开发中，CRUD接口经常遇到的第一类问题是SQL异常。例如实体字段增加后忘记更新数据库表，Hibernate可能抛出SQLSyntaxErrorException，提示Unknown column。此时先检查ddl-auto是否生效，或者是否已经执行了最新的DDL脚本。另一类是唯一约束冲突，当插入重复邮箱时，异常会包装成DataIntegrityViolationException，Service层可以捕获该异常并转换为业务友好的提示。
连接池相关错误通常表现为间歇性失败。比如应用启动后空闲一段时间，第一次请求报错，但紧接着又恢复正常，大概率是连接池保留了已经失效的连接。可以检查max-lifetime和MySQLwait_timeout的关系，并在连接URL中加入autoReconnect=true，但要注意这个参数只对4.x旧驱动有效，MySQL 8驱动已经移除自动重连，正确做法仍然是控制连接生命周期和开启连接有效性检查。HikariCP会自动执行isValid校验，因此不需要像DBCP那样配置validationQuery。
接口设计上，增删改操作应返回统一的响应结构，至少包含状态码、消息和数据，便于前端处理。Controller层不要直接操作Repository，应通过Service封装业务规则，例如用户名是否重复、邮箱格式是否合法、删除前是否需要检查关联数据。对于大量数据的删除或更新，避免一次提交几十万条记录，可以分页处理，每批提交一次事务，减少binlog和undo压力。
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.web.bind.annotation.*;
import java.util.List;
@RestController
@RequestMapping("/users")
public class UserController {
private final UserService userService;
public UserController(UserService userService) {
this.userService = userService;
}
@PostMapping
public User create(@RequestBody UserRequest request) {
return userService.createUser(request.getUsername(), request.getEmail());
}
@GetMapping("/{id}")
public User get(@PathVariable Long id) {
return userService.findById(id);
}
@PutMapping("/{id}")
public User update(@PathVariable Long id, @RequestBody UserRequest request) {
return userService.updateEmail(id, request.getEmail());
}
@DeleteMapping("/{id}")
public void delete(@PathVariable Long id) {
userService.deleteUser(id);
}
@GetMapping
public List<User> list(@RequestParam int page, @RequestParam int size) {
Page<User> userPage = userService.listByPage(PageRequest.of(page, size));
return userPage.getContent();
}
}
最后一个建议是把SQL日志和慢查询日志结合起来排查性能问题。开发环境可以打开show-sql，但不要只依赖控制台输出，应同步观察MySQL的slow_query_log。对于执行频繁的查询，优先使用联合索引和覆盖索引，减少回表。事务方法尽量精简，连接池参数结合压测结果调整，不要照搬网上模板。Spring Boot连接MySQL的增删改查虽然基础，但把这些配置和边界理清后，项目在后续迭代中会稳定很多。
Spring BootMySQL增删改查修改时间：2026-09-22 03:06:41