动态创建Spring Data JPA仓库无法保存数据问题排查

问题核心 #

动态创建JPA仓库（非Spring静态Bean配置）时，数据查询功能正常，但保存操作完全失效：

• 直接调用save()无数据持久化，无SQL输出
• 事务模板内执行保存仍不生效
• 调用saveAndFlush()抛出jakarta.persistence.TransactionRequiredException，提示无事务正在进行，即使事务管理器与EntityManager来自同一EntityManagerFactory

业务限制：无法通过Spring注解或静态@Bean配置EntityManagerFactory、EntityManager及事务管理器，数据源需在运行时根据业务规则实时确定。

根因分析 #

1. EntityManager未绑定事务上下文：手动创建的EntityManager默认不会关联到Spring事务的ThreadLocal上下文，导致事务管理器无法识别该EntityManager，保存操作处于非事务状态，JPA仅缓存变更但不提交。
2. 动态仓库与事务脱节：Spring Data JPA仓库依赖绑定了事务的EntityManager执行写操作，若仓库使用的EntityManager未加入当前事务，写操作不会触发SQL提交，甚至抛出事务缺失异常。
3. 事务模板未关联正确的EntityManager：事务模板启动的事务，若没有和仓库使用的EntityManager绑定，事务实际未覆盖到保存操作。

针对性解决方案 #

1. 确保EntityManager关联到当前事务 #

在事务执行块内，需让EntityManager加入当前事务，再基于此EntityManager创建动态仓库：

// 步骤1：根据业务规则动态获取数据源，创建EntityManagerFactory
Map<String, Object> props = new HashMap<>();
props.put("javax.persistence.jdbc.url", getDynamicDbUrl());
props.put("javax.persistence.jdbc.user", getDynamicDbUser());
props.put("javax.persistence.jdbc.password", getDynamicDbPwd());
EntityManagerFactory emf = Persistence.createEntityManagerFactory("dynamicPU", props);

// 步骤2：基于同一EntityManagerFactory创建事务管理器和事务模板
JpaTransactionManager txManager = new JpaTransactionManager(emf);
TransactionTemplate txTemplate = new TransactionTemplate(txManager);

// 步骤3：在事务内执行保存操作
txTemplate.execute(status -> {
    // 获取EntityManager并加入当前事务
    EntityManager em = emf.createEntityManager();
    try {
        em.joinTransaction();
        
        // 动态创建仓库，传入绑定事务的EntityManager
        MyEntityRepository repo = RepositoryFactorySupport.getRepository(
            MyEntityRepository.class,
            JpaEntityInformationSupport.getEntityInformation(MyEntity.class, em),
            em
        );
        
        // 执行保存，此时会触发SQL提交
        MyEntity entity = new MyEntity();
        entity.setName("test");
        repo.saveAndFlush(entity);
        return null;
    } finally {
        em.close();
    }
});

2. 修复saveIt()方法 #

直接调用save()失效是因为无事务上下文，必须将保存操作包裹在事务中，确保EntityManager参与事务，变更才能被提交。

3. 修复saveItInTransaction()方法 #

事务模板内操作失效的原因是仓库使用的EntityManager未绑定到事务。需在事务块内创建EntityManager并调用em.joinTransaction()，再基于该EntityManager创建仓库，确保事务覆盖保存操作。

4. 修复saveItInTransactionAndFlush()方法 #

抛出事务缺失异常的核心是仓库的EntityManager未处于活动事务中。按照上述步骤，让EntityManager加入当前事务后再创建仓库，saveAndFlush()即可正常执行。

关键注意事项 #

• 动态创建EntityManagerFactory时，需根据数据源类型配置正确的事务类型（如RESOURCE_LOCAL用于本地事务）。
• 事务执行完毕后必须关闭EntityManager，避免数据库连接泄漏。
• 动态创建仓库时，优先使用Spring Data JPA的RepositoryFactorySupportAPI，确保仓库与EntityManager的关联正确性。

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