如何在提交期间捕获SQLExceptions？

Question

使用Spring

@Repository
public class UserDAOImpl implements UserDAO {

    @PersistenceContext
    EntityManager em;

    @Override
        public void createUserRole(String role) throws RoleAlreadyExistsException {
            try {
                UserRole userRole = new UserRole(role);
                em.persist(userRole);
            } catch (Exception e) {
                throw new RoleAlreadyExistsException();
            }
        }
}

我的服务：

@Service("userService")
public class UserService 
    @Transactional
        public void createUserRole(String role) throws RoleAlreadyExistsException {
            userDao.createUserRole(role);
        }
}

后来我实现了一些逻辑：

try{
     userService.createUserRole(role.name());
 }  catch (AuthorityEntityAlreadyExistsException e){}

但它没有捕获关于重复密钥的报告的异常：

SEVERE: Exception sending context initialized event to listener instance of class org.springframework.web.context.ContextLoaderListener
org.springframework.dao.DataIntegrityViolationException: could not execute statement; SQL [n/a]; constraint [PRIMARY]; nested exception is org.hibernate.exception.ConstraintViolationException: could not execute statement
    at org.springframework.orm.jpa.vendor.HibernateJpaDialect.convertHibernateAccessException(HibernateJpaDialect.java:259)
    at org.springframework.orm.jpa.vendor.HibernateJpaDialect.translateExceptionIfPossible(HibernateJpaDialect.java:225)
    at org.springframework.orm.jpa.JpaTransactionManager.doCommit(JpaTransactionManager.java:521)
    at org.springframework.transaction.support.AbstractPlatformTransactionManager.processCommit(AbstractPlatformTransactionManager.java:761)
    at org.springframework.transaction.support.AbstractPlatformTransactionManager.commit(AbstractPlatformTransactionManager.java:730)

Caused by: org.hibernate.exception.ConstraintViolationException: could not execute statement
    at org.hibernate.exception.internal.SQLExceptionTypeDelegate.convert(SQLExceptionTypeDelegate.java:59)
    at org.hibernate.exception.internal.StandardSQLExceptionConverter.convert(StandardSQLExceptionConverter.java:42)
    at org.hibernate.engine.jdbc.spi.SqlExceptionHelper.convert(SqlExceptionHelper.java:109)
    at org.hibernate.engine.jdbc.spi.SqlExceptionHelper.convert(SqlExceptionHelper.java:95)
    at org.springframework.transaction.interceptor.TransactionAspectSupport.commitTransactionAfterReturning(TransactionAspectSupport.java:485)

Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry 'ROLE_ADMIN' for key 'PRIMARY'
    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
    at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
    at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
    at java.lang.reflect.Constructor.newInstance(Constructor.java:422)

所以，我的角色并没有被扔出去。我的角色已经不存在了。在服务结束方法的事务提交期间引发异常。如何捕捉异常？？？或者如何以另一种方式在Spring中实现这种逻辑？？

Answer 1

对DAO或服务或控制器层使用@transactional注释，以便在提交期间捕获任何SQLexception时回滚该方法。

i.e   @transactional
public void method(@param somevalue)
{
  // Database saving or updating function
  }

如果您希望在异常期间显示特定消息

如果您想为特定的ExpException类使用全局处理程序，请使用以下命令

@ExceptionHandler(SQLException.class)      
public String exceptionMessage(){ //return exception message}

Answer 2

EntityManager.persist没有必要执行sql语句：新实体注册在缓存中，并在需要时发送到数据库。

如果数据库检查了您的约束，那么当这个实体被发送到数据库时，您将看到一个错误，在事务提交的最佳情况下：这是您在跟踪中看到的行为。

可以通过调用EntityManager.flush（）强制JPA实现将其缓存发送到数据库

public void createUserRole(String role) throws RoleAlreadyExistsException {
   try {
       UserRole userRole = new UserRole(role);
       em.persist(userRole);
       em.flush();
   } catch (Exception e) {
       throw new RoleAlreadyExistsException();
   }
}

然而，调用flush太多可能会导致性能损失，您应该只在必要时调用它。分离DAO和服务可能更简单：在UserService中尝试cach DataIntegrityException，在DAO中不要调用flush

Answer 3

1）DAO不应该捕捉异常。让Hibernate或Spring生成的异常被抛出，不要管它。特别是如果您的异常转换非常广泛，并且丢失了信息（丢弃了原始的堆栈跟踪）。

2） 不要依靠违反约束来告诉你有一个预先存在的条目。您可以在告诉Hibernate执行插入之前查询它。只要查询与insert处于同一事务中，并且隔离级别为可重复读取或更好，查询结果就会可靠。