Spring 3.2.1中Hibernate FlushMode事务外设置失效问题求助

问题背景 #

使用Spring 3.2.1时，默认FlushModeType.AUTO导致持久化对象前的操作触发意外持久化；尝试将FlushMode改为COMMIT，但事务外设置完全无效——即使调用entityManager.setFlushMode(FlushModeType.COMMIT)后，getFlushMode()返回仍为AUTO。此外，imagesRepository.save(imageDB)执行后，后续对对象的修改会自动触发额外持久化，希望通过显式操作控制提交时机。

核心原因 #

1. Spring管理的EntityManager是代理对象，事务外的EntityManager未绑定到事务上下文，Spring会在事务启动时重置FlushMode为默认值。
2. 当对象通过save()进入EntityManager管理状态后，FlushModeType.AUTO下，任何对对象的修改都会在触发查询或事务提交前自动flush到数据库，导致“额外持久化”。

解决方案 #

1. 全局设置FlushMode为COMMIT #

针对Spring 3.2.1，可通过EntityManagerFactory配置全局生效：

• XML配置：

  <bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean">
      <!-- 数据源、实体扫描等其他配置 -->
      <property name="jpaProperties">
          <props>
              <!-- 针对Hibernate实现 -->
              <prop key="org.hibernate.flushMode">COMMIT</prop>
              <!-- 通用JPA标准属性（部分实现支持） -->
              <!-- <prop key="javax.persistence.flushMode">COMMIT</prop> -->
          </props>
      </property>
  </bean>
  

• Java配置：

  @Bean
  public LocalContainerEntityManagerFactoryBean entityManagerFactory() {
      LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
      em.setDataSource(dataSource());
      em.setPackagesToScan("com.yourpackage.entity");
      em.setJpaVendorAdapter(new HibernateJpaVendorAdapter());
      
      Properties props = new Properties();
      props.setProperty("org.hibernate.flushMode", "COMMIT");
      em.setJpaProperties(props);
      
      return em;
  }
  

2. 事务内设置FlushMode #

事务外设置会被Spring覆盖，需在@Transactional方法内设置或通过注解属性指定：

• 方法内显式设置：

  @Transactional
  public void processImages() {
      entityManager.setFlushMode(FlushModeType.COMMIT);
      // 调用insertImageToDB等业务方法
  }
  

• 通过@Transactional属性指定（Spring 3.1+支持）：

  @Transactional(flushMode = FlushModeType.COMMIT)
  public void processImages() {
      // 业务逻辑
  }
  

3. 避免save后的自动持久化 #

当FlushMode设为COMMIT后，只有事务提交时才会flush；若需更精细控制，可在save()后将对象从EntityManager中分离：

private void insertImageToDB(String imagePath, Map<String, ImageMetaData> imageNameToMetaData, int numOfImages, int currentImage) {
    try {
        ImageDB imageDB = new ImageDB();
        imageDB.setGcsFullPath(imagePath);
        imageDB.setStatus(PENDING);

        setImageMetaData(imagePath, imageNameToMetaData, imageDB);

        imagesRepository.save(imageDB);
        entityManager.detach(imageDB); // 分离后，后续修改不会自动同步到数据库
        logger.debug("processed {}/{} images", currentImage, numOfImages);
    } catch (Exception e) {
        logger.error("failed to save image {}", imagePath, e);
    }
}

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