如何将 Spring 事务管理与 Hibernate 集成？

Question

我一直在尝试使用 HibernateTransactionManager 来管理我的服务层中的事务，但它不起作用。 Java class 创建 PlatformTransactionManager 的配置：

@Configuration
@EnableTransactionManagement
@PropertySource("classpath:hibernateConfig.properties")
public class HibernateConfig {

    @Value("${hibernate.dialect}")
    private String dialect;

    //Other hibernate properties 

    @Autowired
    private DataSource dataSource;

    private Properties hibernateProperties() {
        Properties hibernateProperties = new Properties();

        hibernateProperties.put("hibernate.dialect", dialect);
        //Other hibernate properties removed here for brevity 

        return hibernateProperties;
    }

    @Bean
    @DependsOn("dataSource")
    public SessionFactory sessionFactory() throws IOException {
        LocalSessionFactoryBean  sessionFactoryBean =
                new LocalSessionFactoryBean();

        sessionFactoryBean.setDataSource(dataSource);
        sessionFactoryBean.setPackagesToScan("com.ldp.vigilantBean.domain");
        sessionFactoryBean.setHibernateProperties(hibernateProperties());
        sessionFactoryBean.afterPropertiesSet();

        return sessionFactoryBean.getObject();
    }

    @Bean
    @DependsOn("sessionFactory")
    public PlatformTransactionManager platformTransactionManager() throws IOException {
        HibernateTransactionManager txManager = new HibernateTransactionManager();
        txManager.setSessionFactory(sessionFactory());
        txManager.afterPropertiesSet();

        return txManager;
    }
}

稍后在此方法调用中有两次调用持久层，最后抛出一个运行时异常。所以我希望回滚这两个对存储库的调用。

@Override
    @Transactional(rollbackFor = { RuntimeException.class })
    public boolean removeCartItem(Long cartItemId) {

        Cart cart = getCartOutOfContext();

        Optional<CartItem> optCartItemToRemove =
                cart.getCartItems()
                    .stream()
                    .filter(cartItem -> cartItem.getCartItemId().equals(cartItemId))
                    .findAny();

        if (optCartItemToRemove.isPresent()) {

            CartItem cartItemToRemove = optCartItemToRemove.get();

            //There is a bug with PersistentSet in Hibernate that makes
            //using .contains() and .remove() methods of Set interface unpredictable.
            //This is a workaround: reset the whole set.
            cart.setCartItems(
                cart.getCartItems().stream()
                                   .filter(cartItem -> !cartItem.equals(cartItemToRemove))
                                   .collect(Collectors.toSet())
            );

            Optional<Product> optProduct =
                    productRetrievalRepository.getProductById(cartItemToRemove.getProduct().getProductId());
            if (!optProduct.isPresent())
                throw new IllegalArgumentException("Specified product not found");
            Product productToRemove = optProduct.get();
            productToRemove.setUnitsInOrder(productToRemove.getUnitsInOrder() - cartItemToRemove.getQuantity());
            //First call
            productAlterRepository.updateProduct(productToRemove);

            //Second call
            cartRepository.updateCart(cart);
            if (true) throw new RuntimeException("An exception to check transactions");

            return true;
        } else
            return false;

    }

用于管理产品的存储库：

@Repository
class ProductAlterRepositoryImpl implements ProductAlterRepository {

    private SessionFactory sessionFactory;

    public ProductAlterRepositoryImpl(
            @Autowired
            SessionFactory sessionFactory) {

       this.sessionFactory = sessionFactory;
    }

    @Override
    public Optional<Product> updateProduct(Product product) {

        try (Session session = sessionFactory.openSession()) {

            session.getTransaction().begin();

            session.merge(product);

            session.getTransaction().commit();
        }

        return Optional.of(product);

    }
}

我不明白为什么在我的服务方法中抛出 RuntimException 之前所做的更改没有回滚：我使用相同的会话工厂来初始化 Platform Transaction Manager 并通过我的存储库中的 Session 进行更改。另外，我的记录器中有这一行

*** LOG4J *** HHH000490: Using JtaPlatform implementation: [org.hibernate.engine.transaction.jta.platform.internal.NoJtaPlatform]

如果我是对的，当只使用一种资源（在我的例子中是 Hibernate 存储库）时，您不需要像 Atomikos 这样的全局事务提供程序。我认为应该有 3 个事务：一个外部（服务调用）和 2 个内部（到存储库）。这个想法是，如果一个内部事务失败，它应该导致外部事务回滚，这意味着对存储库的所有两个调用都将被回滚。

Answer 1

在 updateProduct(Product) 内部，除了服务级别的声明之外，您还再次打开了程序化事务。所以它会忽略 Spring 容器管理的事务管理器并单独使用它自己的。能否请您删除它并重试。

如何将 Spring 事务管理与 Hibernate 集成？

How can I integrate Spring transaction management with Hibernate?

java

spring

hibernate

spring-transactions