Spring Boot 2.7.5执行更新查询遇TransactionRequiredException问题求助

核心问题分析 #

你遇到的javax.persistence.TransactionRequiredException本质是执行更新/删除操作时未开启事务。虽然你尝试在Repository接口和方法上添加@Transactional，但受Spring代理机制限制，这些注解并未生效。Spring Boot 2.7.5属于稳定版本，不存在1.2.5版本中那种Repository事务注解失效的已知问题，问题出在事务注解的作用范围或调用逻辑上。

修复方案 #

1. 将事务注解移到业务服务层 #

Spring Data JPA的Repository接口由动态代理生成，直接在其上添加@Transactional可能无法被正确拦截。建议创建业务服务类，在调用Repository的方法上添加@Transactional：

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class PersonService {
    private final PersonRepo personRepo;

    public PersonService(PersonRepo personRepo) {
        this.personRepo = personRepo;
    }

    @Transactional
    public void batchUpdatePersonStatus(String targetStatus) {
        personRepo.updatePersonStatusToActive(targetStatus);
    }
}

之后在PeopleApplication中注入PersonService，调用batchUpdatePersonStatus方法，而非直接调用Repository的方法。

2. 修正原生SQL的Schema路径 #

你的实体类指定了schema = "APP_OWNER"，但原生SQL中未带上schema，部分数据库可能因默认schema不匹配导致查询异常，修改Repository的SQL语句：

@Modifying
@Query(value = "UPDATE APP_OWNER.PERSON SET STATUS = 'ACTIVE' WHERE STATUS = :status", nativeQuery = true)
void updatePersonStatusToActive(@Param("status") String status);

3. 避免在ApplicationRunner中直接调用Repository #

从堆栈信息看，你是在PeopleApplication.run方法中执行更新操作，ApplicationRunner的执行时机处于Spring上下文初始化后期，此时Repository的事务代理可能未完全生效。将业务逻辑移到被Spring管理的Bean（如@Service、@Component）中，确保事务代理能正常拦截方法调用。

4. 检查事务管理器配置 #

如果自定义了EntityManagerFactory或PlatformTransactionManager，需确保配置正确：

• 数据源指向正确的数据库
• JPA属性（如hibernate.transaction.jta.platform）配置符合当前环境
• 多数据源场景下，需通过@Transactional("transactionManagerName")指定对应事务管理器

调整后的Repository代码 #

去掉Repository方法上的@Transactional，保留必要注解即可：

import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.CrudRepository;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;

@Repository
public interface PersonRepo extends CrudRepository<Person, String> {
        
    @Modifying
    @Query(value = "UPDATE APP_OWNER.PERSON SET STATUS = 'ACTIVE' WHERE STATUS = :status", nativeQuery = true)
    void updatePersonStatusToActive(@Param("status") String status);
}

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