14

我正在尝试将 Hibernate 用于多线程应用程序，其中每个线程检索一个对象并尝试将其插入表中。我的代码如下所示。我每个线程都有本地休眠会话对象，并且在每个 InsertData 中我执行 beginTransaction 和提交。

我面临的问题是很多时候我得到“org.hibernate.TransactionException：不支持嵌套事务”

由于我是休眠新手，我不知道我在做什么是否正确？请让我知道在多线程应用程序中使用休眠的正确方法是什么，以及如何避免上述异常。

谢谢

public class Worker extends Thread {
private Session session = null;

Worker() {
    SessionFactory sf = HibernateUtil.getSessionFactory(); // Singleton
    session = sf.openSession();
    session.setFlushMode(FlushMode.ALWAYS);
}

public void run() {
    // Some loop which will run thousand of times 
    for (....)
    {
        InsertData(b);
    }
    session.close();
}

// BlogPost Table has (pk = id AutoGenerated), dateTime, blogdescription etc. 
private void InsertData(BlogPost b) {
    session.beginTransaction();
    Long id = (Long) session.save(b);
    b.setId(id);
    session.getTransaction().commit();
}
}

我的休眠配置文件c3p0.min_size=10有c3p0.max_size=20

4

1 回答 1

11

使用每线程会话对象，只要您不在多个线程之间共享会话对象，就可以了。

您收到的错误与您的多线程使用或会话管理无关。您session.save()对 ID 的使用以及显式设置并不完全正确。

没有看到您的映射BlogPost很难分辨，但是如果您告诉 Hibernate 使用该id字段作为主键，并且您正在使用本机生成器作为主键，那么您需要做的就是：

session.beginTransaction();
session.persist(b);
session.flush(); // only needed if flush mode is "manual"
session.getTransaction().commit();

Hibernate会为你填写ID，persist()会导致插入发生在事务的范围内（save()不关心事务）。如果您的冲洗模式未设置为手动，那么您无需调用flush()，因为它Transaction.commit()会为您处理。

请注意，使用 时persist()，不能保证在刷新会话之前设置 BlogPost 的 ID，这对您在此处的使用很好。

优雅地处理错误：

try {
    session.beginTransaction();
    try {
        session.persist(b);
        session.flush(); // only needed if flush mode is "manual"
        session.getTransaction().commit();
    } catch (Exception x) {
        session.getTransaction().rollback();
        // log the error
    }
} catch (Exception x) {
    // log the error
}

顺便说一句，我建议使BlogPost.setId()私有或包可见。如果另一个类显式设置 ID（再次假设本机生成器，并且 id 作为主键），则很可能是实现错误。

于 2013-08-13T17:37:10.977 回答