SpringBoot中Transactional注解未按预期执行事务回滚问题

我有一个基于JdbcTemplate和PostgreSQL的SpringBoot REST应用，某个接口需要以原子事务执行——任意操作失败则全部回滚，但实际运行中事务未按预期工作：

• 在标注了事务注解的方法中，先执行UPDATE Orders SET PersonId = NULL WHERE OrderID = 123（因PersonId可空执行成功）
• 接着执行UPDATE Reservations SET PersonId = NULL WHERE ReservationID = 123（因PersonId非空约束抛出异常）
• 但第一个更新操作未回滚，Orders表的PersonID仍为NULL

尝试切换为Spring的@Transactional(rollbackFor = Exception.class)注解后，问题仍未解决，希望通过注解式事务边界的方案解决。

复现代码 #

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;
import javax.transaction.Transactional;

@Repository
public class DeletionRepository {

    @Autowired
    protected JdbcTemplate jdbcTemplate;

    @Transactional(rollbackOn = Exception.class)
    public int deleteWithCascade() {
        int status = 0;

        // 此操作成功，因为PersonId字段允许为空
        status = jdbcTemplate.update("UPDATE Orders SET PersonId = NULL WHERE OrderID = 123");

        // 此操作触发完整性约束异常，因为PersonId字段为NOT NULL
        status = jdbcTemplate.update("UPDATE Reservations SET PersonId = NULL WHERE ReservationID = 123");

        // 因上述异常，此处代码不会执行
        status = jdbcTemplate.update("DELETE FROM Persons WHERE PersonID = 'ABC123");
        return status;
    }
}

抛出的异常信息 #

[UPDATE Reservations SET PersonId = NULL WHERE ReservationID = 123]; ERROR: null value in column "personid" violates not-null constraint
  Detail: Failing row contains (123, hotel room, null).; nested exception is org.postgresql.util.PSQLException: ERROR: null value in column "personid" violates not-null constraint
  Detail: Failing row contains (123, hotel room, null).

测试数据SQL #

CREATE TABLE Persons (personID varchar(45) NOT NULL, LastName varchar(255) NOT NULL, FirstName varchar(255), Age int, PRIMARY KEY (personID));
INSERT INTO Persons (personID, LastName, FirstName, Age) values ('ABC123', 'Jones', 'Janet', 35);

CREATE TABLE Orders (OrderID int NOT NULL, OrderNumber int NOT NULL, PersonID varchar(45), PRIMARY KEY (OrderID), FOREIGN KEY (PersonID) REFERENCES Persons(PersonID));
INSERT INTO Orders (OrderID, OrderNumber, PersonID) values (123, 456, 'ABC123');

CREATE TABLE Reservations (ReservationID int NOT NULL, ReservationDetail varchar(255), PersonID varchar(45) NOT NULL, PRIMARY KEY (ReservationID), FOREIGN KEY (PersonID) REFERENCES Persons(PersonID));
INSERT INTO Reservations (ReservationID, ReservationDetail, PersonID) values (123, 'hotel room', 'ABC123');

更新尝试（未解决） #

切换为Spring的@Transactional(rollbackFor = Exception.class)注解后，事务仍未回滚：

import org.springframework.transaction.annotation.Transactional;

@Repository
public class DeletionRepository {

    @Autowired
    protected JdbcTemplate jdbcTemplate;

    @Transactional(rollbackFor = Exception.class)
    public int deleteWithCascade() {
        int status = 0;
        // 后续操作同前
    }
}

解决方案及排查要点 #

1. 统一使用Spring的事务注解 #

确保代码中只导入org.springframework.transaction.annotation.Transactional，不要混用javax.transaction.Transactional。Spring的事务管理基于自身AOP实现，javax注解需要额外配置才能生效，混用会导致事务逻辑异常。

2. 确认事务代理生效 #

• 确保SpringBoot主类上添加了@EnableTransactionManagement（SpringBoot自动配置默认会启用，但显式声明可避免配置遗漏）
• 避免自调用问题：如果deleteWithCascade方法被同一个类的其他方法直接调用，Spring的AOP代理不会触发，事务不生效。必须通过外部Bean调用该方法，或者通过Spring上下文获取当前Bean进行调用。

3. 检查数据库连接的自动提交配置 #

确保数据库连接URL未开启自动提交，否则每个JdbcTemplate操作都会立即提交，事务失效。在application.yml或application.properties中确认：

spring.datasource.url=jdbc:postgresql://localhost:5432/your_db?autoCommit=false

（PostgreSQL JDBC驱动默认autoCommit为true，需手动设置为false）

4. 确保异常未被内部捕获 #

如果方法内部用try-catch块捕获了异常且未重新抛出，Spring的事务拦截器无法感知异常，不会触发回滚。必须让异常向上抛出到事务拦截器中。

修正后的示例代码 #

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Transactional;

@Repository
public class DeletionRepository {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    // 使用Spring官方事务注解，指定回滚所有Exception类型
    @Transactional(rollbackFor = Exception.class)
    public int deleteWithCascade() {
        int status = 0;

        status = jdbcTemplate.update("UPDATE Orders SET PersonId = NULL WHERE OrderID = 123");
        status = jdbcTemplate.update("UPDATE Reservations SET PersonId = NULL WHERE ReservationID = 123");
        status = jdbcTemplate.update("DELETE FROM Persons WHERE PersonID = 'ABC123'");
        
        return status;
    }
}

内容的提问来源于stack exchange，提问作者Timothy Clotworthy