JPA和MySQL事务隔离级别

发布于 2024-09-03 05:36:45 字数 861 浏览 7 评论 0原文

我有一个本机查询，可以批量插入 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 连接，因为在我看来这是最简单的选择。谢谢大家！

原文

I have a native query that does a batch insert into a MySQL database:

    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(...);
    }

This query causes a deadlock: while it reads from t2 with insert .. select, another process tries to insert a row into t2.

I don't care about the consistency of reads from t2 when doing an insert .. select and want to set the transaction isolation level to READ_UNCOMMITTED.

How do I go about setting it in JPA?

Update

So I ended up creating a regular SQL connection for this case as it seemed to me the simplest option. Thanks everyone!

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

一刻暧昧 2024-09-10 05:36:45

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

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

You need to set it at the connection level, get the session from the entitymanager and do this:

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

回复收藏 0 原文

饭团 2024-09-10 05:36:45

在 JPA 中则不然。 JDO 是唯一支持设置 txn 隔离的标准。显然，采用特定的实现方法可以允许它，但随后你就变得不可移植

回复收藏 0 原文

放低过去 2024-09-10 05:36:45

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

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

Since you are using BMT, you can do the following using a datasource to get the connection.
and set the iso. level.

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

回复收藏 0 原文

~没有更多了~