javax.persistence.TransactionRequiredException: 当前线程中没有可用的带有实际事务的EntityManager。

我使用Hibernate创建了我的第一个Spring MVC项目。我的DAO层使用JPA EntityManager与数据库进行交互。

GenericDao.java:

@Repository

public abstract class GenericDao implements GeneralDao {

private Class className;

public GenericDao(Class className) {

this.className = className;

}

@PersistenceContext

private EntityManager entityManager;

public EntityManager getEntityManager() {

return entityManager;

}

@Override

public void add(T object) {

try {

getEntityManager().persist(object);

} catch (HibernateException e) {

throw new DaoException(ErrorMessage.ADD_ENTITY_FAIL, e);

}

}

@Override

public void update(T object) {

try {

getEntityManager().merge(object);

} catch (HibernateException e) {

throw new DaoException(ErrorMessage.UPDATE_ENTITY_FAIL, e);

}

}

@Override

public void remove(T object) {

try {

getEntityManager().remove(object);

} catch (HibernateException e) {

throw new DaoException(ErrorMessage.REMOVE_ENTITY_FAIL, e);

}

}

@Override

public T getById(int id) {

try {

return getEntityManager().find(this.className, id);

} catch (HibernateException e) {

throw new DaoException(ErrorMessage.GET_BY_ID_ENTITY_FAIL, e);

}

}

public abstract List getAll() throws DaoException;

}

GenericService.java

@Service

public abstract class GenericService implements GeneralService {

private static Logger logger = Logger.getLogger(GenericService.class);

@Autowired

private GenericDao dao;

@Transactional

@Override

public void add(T object) throws ServiceException {

try {

dao.add(object);

} catch (DaoException e) {

logger.debug(e);

throw new ServiceException(e.getMessage());

}

}

@Transactional

@Override

public void update(T object) throws ServiceException {

try {

dao.update(object);

} catch (DaoException e) {

logger.debug(e);

throw new ServiceException(e.getMessage());

}

}

@Transactional

@Override

public void remove(T object) throws ServiceException {

try {

dao.remove(object);

} catch (DaoException e) {

logger.debug(e);

throw new ServiceException(e.getMessage());

}

}

@Transactional(readOnly = true)

@Override

public T getById(int id) throws ServiceException {

try {

return dao.getById(id);

} catch (DaoException e) {

logger.debug(e);

throw new ServiceException(e.getMessage());

}

}

@Transactional(readOnly = true)

@Override

public List getAll() throws ServiceException {

try {

return dao.getAll();

} catch (DaoException e) {

logger.debug(e);

throw new ServiceException(e.getMessage());

}

}

}

UserServiceImpl.java:

@Service

public class UserServiceImpl extends GenericService implements UserService {

private static Logger logger = Logger.getLogger(UserServiceImpl.class);

@Autowired

private UserDao userDao;

@Transactional

@Override

public String checkUser(String userLogin, String userPassword) throws ServiceException {

String namePage = "errorAuthorization";

List userList;

try {

userList = userDao.getByLoginAndPassword(userLogin, userPassword);

} catch (DaoException e) {

logger.debug(e);

throw new ServiceException(e.getMessage());

}

if(userList.size() != 0) {

return UserRoleChecker.defineUserPage(userList.get(0));

}

return namePage;

}

@Transactional

@Override

public void addUser(String userLogin, String userPassword, String userMail) throws ServiceException {

Role role = new Role(0L, RoleType.USER);

User user = new User(0L, userLogin, userPassword, userMail, role);

add(user);

}

}

UserController.java:

@Controller

public class UserController {

private static String className = UserController.class.getName();

private static Logger logger = Logger.getLogger(UserController.class.getName());

@Autowired

private UserService userService;

@RequestMapping(value = "/check_user", method = RequestMethod.POST)

public ModelAndView authorizationUser(HttpServletRequest request, HttpServletResponse response) {

ModelAndView modelAndView = new ModelAndView();

String returnPage;

try {

returnPage = userService.checkUser(request.getParameter(RequestParameter.USER_LOGIN), request.getParameter(RequestParameter.USER_PASSWORD));

} catch (ServiceException e) {

logger.debug(e);

returnPage = ErrorHandler.returnErrorPage(e.getMessage(), className);

}

modelAndView.setViewName(returnPage);

return modelAndView;

}

@RequestMapping(value = "/add_user", method = RequestMethod.POST)

public ModelAndView registrationUser(HttpServletRequest request, HttpServletResponse response) {

ModelAndView modelAndView = new ModelAndView();

String returnPage = Page.SUCCESSFUL_REGISTRATION;

try {

userService.addUser(request.getParameter(RequestParameter.USER_LOGIN), request.getParameter(RequestParameter.USER_PASSWORD), request.getParameter(RequestParameter.USER_MAIL));

} catch (ServiceException e) {

logger.debug(e);

returnPage = ErrorHandler.returnErrorPage(e.getMessage(), className);

}

modelAndView.setViewName(returnPage);

return modelAndView;

}

}

root-context.xml:

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xmlns:p="http://www.springframework.org/schema/p"

xmlns:c="http://www.springframework.org/schema/c"

xmlns:context="http://www.springframework.org/schema/context"

xmlns:util="http://www.springframework.org/schema/util"

xmlns:jdbc="http://www.springframework.org/schema/jdbc" xmlns:tx="http://www.springframework.org/schema/tx"

xsi:schemaLocation="http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-3.1.xsd

http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd

http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd

http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc.xsd

http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">