Spring-boot & hibernate，使用事务

Posted 2023-02-26

【中文标题】Spring-boot & hibernate，使用事务

【英文标题】：Spring-boot & hibernate, using transaction

【发布时间】：2014-11-20 20:36:47

【问题描述】：

我正在尝试使用 spring-boot 和休眠。 当我使用存储库时它工作得很好，但我试图让一个 Hibernate 会话来创建一个 DAO，而这个 DAO 不是事务的一部分。

这是测试代码：

Application.java

@Configuration
@ComponentScan
@EnableAutoConfiguration
@EnableTransactionManagement
public class Application implements CommandLineRunner 

    @Autowired
    private UserBusiness userBusiness;

    @Autowired
    @Bean(name="sessionFactory")
    public SessionFactory sessionFactory(HibernateEntityManagerFactory factory) 
        return factory.getSessionFactory();
           

    @Override
    public void run(String... arg0) throws Exception 
        try 
            userBusiness.createAdminUsers();
         catch (Exception e) 
            e.printStackTrace();
        

        System.out.println(userBusiness.listAll());
    

    public static void main(String[] args) 
        SpringApplication.run(Application.class, args).close();
    

UserBusinessImpl.java：

@Service
public class UserBusinessImpl implements UserBusiness 

    @Autowired
    private UserRepository userRepository;

    @Autowired
    private UserDao userDao;

    @Transactional(rollbackFor=Exception.class)
    public void createAdminUsers() throws Exception 
        userRepository.save(new User("User1", "u1", "123"));
        userRepository.save(new User("User2", "u2", "123"));
        userDao.test();
        throw new Exception("Rollback");
    

    public List<User> listAll() 
        return userRepository.findAll();
    

UserRepository.java

public interface UserRepository extends JpaRepository<User, Long> 

用户道：

@Repository
public class UserDao 

    @Autowired
    private SessionFactory sessionFactory;

    public void teste() 
        //current session does not exists and throws org.hibernate.HibernateException: No CurrentSessionContext configured!
//        sessionFactory.getCurrentSession().save(new User("testDao", "dao", "123"));
        sessionFactory.openSession().save(new User("testDao", "dao", "123"));
    

当我尝试 getCurrentSession() 时，它会抛出一个错误。 并且 openSession() 与我的事务分离，因此当业务抛出和异常时，Dao 保存不会回滚。其他两个插入被回滚。

在 DAO 中获取 currentSession 的正确方法是什么？

更新： 如果我执行 sessionFactory.openSession() 它不会给出任何异常，但它不是事务的一部分。

如果我尝试使用 sessionFactory.getCurrentSession() 那就是堆栈跟踪：

org.hibernate.HibernateException: No CurrentSessionContext configured!
2014-09-26 11:00:28.488 TRACE 20938 --- [           main] .s.t.s.TransactionSynchronizationManager : Bound value [org.springframework.data.jpa.repository.support.CrudMethodMetadataPostProcessor$DefaultCrudMethodMetadata@ff80080] for key [public abstract java.util.List org.springframework.data.jpa.repository.JpaRepository.findAll()] to thread [main]
2014-09-26 11:00:28.488 DEBUG 20938 --- [           main] o.s.orm.jpa.JpaTransactionManager        : Creating new transaction with name [org.springframework.data.jpa.repository.support.SimpleJpaRepository.findAll]: PROPAGATION_REQUIRED,ISOLATION_DEFAULT,readOnly; ''
2014-09-26 11:00:28.489 DEBUG 20938 --- [           main] o.s.orm.jpa.JpaTransactionManager        : Opened new EntityManager [org.hibernate.jpa.internal.EntityManagerImpl@62e8dbb0] for JPA transaction
    at org.hibernate.internal.SessionFactoryImpl.getCurrentSession(SessionFactoryImpl.java:1010)
    at org.sparta.hibernatetest.UserDao.teste(UserDao.java:35)
    at org.sparta.hibernatetest.business.UserBusinessImpl.createAdminUsers(UserBusinessImpl.java:44)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:606)
    at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:317)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:190)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
    at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:98)
    at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:262)
    at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:95)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:207)
    at com.sun.proxy.$Proxy48.createAdminUsers(Unknown Source)
    at org.sparta.hibernatetest.Application.run(Application.java:33)
    at org.springframework.boot.SpringApplication.runCommandLineRunners(SpringApplication.java:677)
    at org.springframework.boot.SpringApplication.afterRefresh(SpringApplication.java:695)
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:321)
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:952)
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:941)
    at org.sparta.hibernatetest.Application.main(Application.java:42)

【问题讨论】：

你遇到了什么异常，发布完整的堆栈跟踪

getCurrentSession() 只能在事务的边界上工作，没有它就无法工作。所以基本上让你的方法成为交易的一部分。但我想知道为什么您已经有一个可以使用 JPA 进行保存的存储库，那么为什么您甚至需要一个普通的 SessionFactory。

我不需要使用 DAO 进行保存。我将保存在 DAO 中作为示例。但我想要的是能够编写将直接访问 Hibernate 的 DAO，使我能够编写自己的 Criterias，这由 @Transactional 管理

【参考方案1】：

你可以使用

entityManager.persist(new User("testDao", "dao", "123"))

（和其他 EntityManager 方法）而不是直接使用 Hibernate Session。

【参考方案2】：

试试这个：

@Repository
public class UserDao 

   @PersistenceContext
   EntityManager entityManager;

   protected Session getCurrentSession()  
      return entityManager.unwrap(Session.class);
   

   public void test() 
      Session session = getCurrentSession();
      session().save(new User("testDao", "dao", "123"));