【问题标题】:JPA and MySQL transaction isolation levelJPA 和 MySQL 事务隔离级别
【发布时间】:2011-02-24 19:59:18
【问题描述】:

我有一个本机查询,可以批量插入 MySQL 数据库:

    String sql = "insert into t1 (a, b) select x, y from t2 where x = 'foo'";
    EntityTransaction tx = entityManager.getTransaction();
    try {
        tx.begin();
        int rowCount = entityManager.createNativeQuery(sql).executeUpdate();
        tx.commit();
        return rowCount;
    }
    catch(Exception ex) {
        tx.rollback();
        log.error(...);
    }

此查询导致死锁:当它从t2insert .. select 读取时,另一个进程尝试将一行插入t2

我不关心在执行insert .. select 时从t2 读取的一致性,并希望将事务隔离级别设置为READ_UNCOMMITTED

如何在 JPA 中进行设置?


更新

所以我最终为这种情况创建了一个常规 SQL 连接,因为在我看来这是最简单的选择。谢谢大家!

【问题讨论】:

  • 我不明白它是如何导致死锁的?如果 tx1 执行: insert into t1 (a, b) select x, y from t2 where x = 'foo' 而当这种情况发生时,第二个 tx make insert 到“t2”表中,比 tx1 等待 tx2 结束,在 tx2 结束后 tx1 继续它的工作。 Dedalock 意味着 tx2 在插入 t2 时也会从 t1 读取数据?这是你的情况吗?我的意思是这样的事情会导致死锁: tx1: insert into t1 (a, b) select x, y from t2 where x = 'foo' tx2: insert into t2 (a, b) select x, y from t1 where x ='富'

标签: java mysql jpa transactions isolation-level


【解决方案1】:

您需要在连接级别进行设置,从实体管理器获取会话并执行以下操作:

org.hibernate.Session session = (Session)entityManager.getDelegate();
Connection connection = session.connection();
connection.setTransactionIsolation(Connection.READ_UNCOMMITTED);

【讨论】:

  • 这就是为什么我说“从 em 中获取会话”;)我编辑了代码
  • 如果不是休眠怎么办?
  • 嗯,他说他正在使用 Hibernate。我想对于其他 JPA 实现也有类似的方法。
  • 嗨 Guillaume,我最后确实尝试了你的方法,但不幸的是它没有奏效;看到 session.connection() 方法已被弃用,我决定不花时间调查。
【解决方案2】:

在 JPA 中你没有。 JDO 是唯一支持设置 txn 隔离的标准。显然,使用特定的实现方法可以允许它,但是你变得不可移植

【讨论】:

    【解决方案3】:

    由于您使用的是 BMT,因此您可以使用数据源执行以下操作来获取连接。 并设置iso。级别。

    DataSource source = (javax.sql.DataSource) jndiCntxt.lookup("java:comp/env/jdbc/myds");
    Connection con = source.getConnection( );
    con.setTransactionIsolation(Connection.TRANSACTION_READ_UNCOMMITTED);
    

    【讨论】:

    • 如果他没有使用数据源,而是指定了 connectionURL ?