我有一个 native 查询,可以批量插入到 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(...);
}
此查询导致死锁:当它使用 insert ..select
从 t2
读取时,另一个进程试图将一行插入 t2
.
在执行 insert .. select
时,我不关心从 t2
读取的一致性,并且想将事务隔离级别设置为 READ_UNCOMMITTED .
我该如何在 JPA 中设置它?
更新
所以我最终为这种情况创建了一个常规 SQL 连接,因为在我看来这是最简单的选择。谢谢大家!
最佳答案
您需要在连接级别设置它,从实体管理器获取 session 并执行此操作:
org.hibernate.Session session = (Session)entityManager.getDelegate();
Connection connection = session.connection();
connection.setTransactionIsolation(Connection.READ_UNCOMMITTED);
关于java - JPA 和 MySQL 事务隔离级别,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/2924147/