java - 改为配置 Spring 事务或 EJB CMT
问题描述
我尝试使用 Hibernate 配置 Spring Boot:
import javax.persistence.EntityManager;
import javax.persistence.EntityTransaction;
import org.datalis.plugin.database.dao.TerminalsService;
import org.datalis.plugin.database.models.TerminalsModel;
import org.hibernate.Session;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@Service
@Qualifier("terminalsService")
public class TerminalsDaoHibernate implements TerminalsService {
@Autowired
private EntityManager entityManager;
@Override
@Transactional
public TerminalsModel getTerminalToken(String terminalToken) throws Exception {
TerminalsModel terminal = null;
Session session = entityManager.unwrap(Session.class);
try {
entityManager.getTransaction().begin();
terminal = (TerminalsModel) session.get(TerminalsModel.class, terminalToken);
session.getTransaction().commit();
} catch (Exception e) {
e.printStackTrace();
session.getTransaction().rollback();
throw new Exception("Error");
}
return terminal;
}
}
但我得到这个错误:
14:47:34,323 ERROR [stderr] (default task-1) java.lang.IllegalStateException: Not allowed to create transaction on shared EntityManager - use Spring transactions or EJB CMT instead
14:47:34,323 ERROR [stderr] (default task-1) at org.springframework.orm.jpa.SharedEntityManagerCreator$SharedEntityManagerInvocationHandler.invoke(SharedEntityManagerCreator.java:255)
正确配置 @Transactional 的正确方法是什么?我需要使用 Transaction 是一种不同的方式吗?
解决方案
您正在使用@Transactional
并且仍在尝试手动启动事务。要么进行手动事务管理(即删除),要么通过删除手动事务管理代码来@Transactional
拥抱。@Transactional
@Override
@Transactional
public TerminalsModel getTerminalToken(String terminalToken) throws Exception {
TerminalsModel terminal = null;
Session session = entityManager.unwrap(Session.class);
return (TerminalsModel) session.get(TerminalsModel.class, terminalToken);
}
但是我不明白你为什么要在这里使用普通的 Hibernate 而不是 JPA。使用 JPA 可以实现相同的结果。
@Override
@Transactional
public TerminalsModel getTerminalToken(String terminalToken) throws Exception {
return entityManager.find(TerminalsModel.class, terminalToken);
}
一般来说,在 JPA API 的当前状态下,不需要使用普通的 Hibernate API over JPA。