Hibernate、spring、JPS 和隔离 - 不支持自定义隔离

Question

我一直在尝试这个：

@Transactional(isolation=Isolation.SERIALIZABLE, 
               rollbackFor={Exception.class}, 
               propagation=Propagation.REQUIRES_NEW)

关于我的服务方法，但是 spring 抱怨说：

Standard JPA does not support custom isolation levels - use a special JpaDialect

我该如何解决这个问题？

Answer 1

@Shahzad Mughal 我给你留下了两点；-) 你的答案应该被接受为正确的答案。接受的答案将源自以下问题，例如随机错过导致开发人员认为 mysql 驱动程序存在错误：

警告 [org.hibernate.util.JDBCExceptionReporter] - SQL 错误：0， SQLState：S1009 错误 [org.hibernate.util.JDBCExceptionReporter] - 连接是只读的。导致数据修改的查询不是 允许

您可以在http://thinkinginsoftware.blogspot.com/2013/10/connection-is-read-only-queries-leading.htmlhttp://thinkinginsoftware.blogspot.com/2013/10/connection-is-read-only-queries-leading.html 上阅读更多关于我们的冒险经历

Answer 2

您也可以使用“IsolationLevelDataSourceAdapter”包装“数据源”bean，只需执行以下操作：

<bean id="dataSource" class="org.springframework.jdbc.datasource.IsolationLevelDataSourceAdapter">
    <property name="isolationLevelName" value="ISOLATION_READ_COMMITTED"/>
    <property name="targetDataSource" ref="_dataSource"/>
</bean>

其中“_dataSource”是对实际数据源的引用。

Answer 3

借鉴 Bozho 的答案并考虑其上的 cmets，以下似乎是一个完整的（与 Hibernate 4 兼容）解决方案，解决了重置连接的需要。尽我所能，spring 层将保证调用 cleanupTransaction 方法，但如果实际上不能保证，这可能需要重新考虑，因为可能存在 permGen 内存泄漏和连接对象上的 post request 副作用.

public class HibernateExtendedJpaDialect extends HibernateJpaDialect {

  ThreadLocal<Connection> connectionThreadLocal = new ThreadLocal<>();
  ThreadLocal<Integer> originalIsolation = new ThreadLocal<>();

  @Override
  public Object beginTransaction(EntityManager entityManager,
                                 TransactionDefinition definition) 
      throws PersistenceException, SQLException, TransactionException {

    boolean readOnly = definition.isReadOnly();
    Connection connection = 
        this.getJdbcConnection(entityManager, readOnly).getConnection();
    connectionThreadLocal.set(connection);
    originalIsolation.set(DataSourceUtils
        .prepareConnectionForTransaction(connection, definition));

    entityManager.getTransaction().begin();

    return prepareTransaction(entityManager, readOnly, definition.getName());
  }

  /*

   We just have to trust that spring won't forget to call us. If they forget,
   we get a thread-local/classloader memory leak and messed up isolation 
   levels. The finally blocks on line 805 and 876 of 
   AbstractPlatformTransactionManager (Spring 3.2.3) seem to ensure this, 
   though there is a bit of logic between there and the actual call to this 
   method.

   */
  @Override
  public void cleanupTransaction(Object transactionData) {
    try {
      super.cleanupTransaction(transactionData);
      DataSourceUtils.resetConnectionAfterTransaction(
          connectionThreadLocal.get(), originalIsolation.get());
    } finally {
      connectionThreadLocal.remove();
      originalIsolation.remove();
    }
  }
}

Answer 4

这个实现不考虑清理的东西，我已经实现了一个类似的解决方案，但也考虑了清理。 该解决方案可以在这里找到： http://shahzad-mughal.blogspot.com/2012/04/spring-jpa-hibernate-support-for-custom.html

Answer 5

JPA 不支持自定义隔离级别。您可以扩展HibernateJpaDialect 类并覆盖与连接相关的方法，以便您可以在Connection 上设置自定义隔离级别

这是我写的，但还没有测试过的东西：

public class HibernateExtendedJpaDialect extends HibernateJpaDialect {

    @Override
    public Object beginTransaction(EntityManager entityManager,
            TransactionDefinition definition) throws PersistenceException,
            SQLException, TransactionException {

        Session session = (Session) entityManager.getDelegate();
        DataSourceUtils.prepareConnectionForTransaction(session.connection(), definition);

        entityManager.getTransaction().begin();

        return prepareTransaction(entityManager, definition.isReadOnly(), definition.getName());
    }

}

您将其定义为 EntityManagerFactory 的属性：

<property name="jpaDialect">
    <bean class="com.company.util.HibernateExtendedJpaDialect" />
</property>

Answer 6

在指定JpaTransactionManager 时，您是否指定了 JPADialect？默认情况下，我认为它使用DefaultJpaDialect，而您需要HibernateJpaDialect。