5

我是休眠的新手。

我试图编写一个小程序来将数据插入 mysql 数据库服务器。

这是我的程序的源代码：

private int insertRelateNew(int newId, List<DocSimilar> relateNews) {
    Session session = HibernateUtils.currentSession();
    Transaction tx = session.beginTransaction();
    RelatedArticles relatedArticles = null;
    try {
        relatedArticles = new RelatedArticles();
        for (DocSimilar doc : relateNews) {
            ApplicationPK appPK = new ApplicationPK(newId,
                    (int) doc.getDocid());
            relatedArticles.setApplicationPK(appPK);
            relatedArticles.setRelated_score(doc.getPercent());
            session.save(relatedArticles);
            tx.commit();
            session.flush();
        }
    } catch (Exception e) {
        e.printStackTrace();
        tx.rollback();
    }
    return newId;
}

运行时，插入成功，但有时会抛出 TransactionException。

这是异常控制台：

org.hibernate.TransactionException: Transaction not successfully started
    at org.hibernate.transaction.JDBCTransaction.commit(JDBCTransaction.java:131)
    at com.ant.crawler.dao.hibernate.SqlNewsPersistencer.insertRelateNew(SqlNewsPersistencer.java:56)
    at com.ant.crawler.dao.hibernate.SqlNewsPersistencer.insertNews(SqlNewsPersistencer.java:40)
    at com.ant.crawler.dao.hibernate.SqlPersistencer.store(SqlPersistencer.java:44)
    at com.ant.crawler.core.AbstractCrawler.crawl(AbstractCrawler.java:186)
    at com.ant.crawler.core.Worker.run(Worker.java:14)
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
    at java.lang.Thread.run(Thread.java:662)

我搜索了问题，有人建议捕获异常和回滚（）。

但是这种方式可能会丢失我想要插入数据库的记录。

我想找出为什么会发生异常以避免它。

我在 Hibernate Java Doc 中搜索了异常：http ://www.dil.univ-mrs.fr/~massat/docs/hibernate-3.1/api/org/hibernate/TransactionException.html

它说：“表示事务无法开始、提交或回滚。”

它没有解释为什么会发生异常。

请为我解释为什么会发生异常以及如何避免它。

非常感谢。

4

2 回答 2

6

解释很简单：你只启动一次事务，但提交了多次：

Transaction tx = session.beginTransaction();
...
for (DocSimilar doc : relateNews) {
    ...
    tx.commit();
}

要么您希望每个文档有一个单独的事务，并且该事务必须在 for 循环内开始，或者您希望所有文档都有一个事务，并且提交必须在 for 循环之外。

于 2012-06-06T07:34:47.533 回答
2

我收到了和你一样的错误信息，我发现即使是回滚也会给你带来问题。

就我而言，当我调用“ tx.rollback()”时，它会抛出错误“org.hibernate.TransactionException：事务未成功启动”。

因此，当我意识到这一点时，我添加了以下内容...

if (tx!=null && tx.isActive()) {
 tx.rollback();
}

然后它向我揭示了另一个例外，现在更好，现在我可以看到真正的问题在哪里，这是我插入的一些标准我没有满足......

希望这会有所帮助，干杯。

于 2014-02-12T22:52:53.157 回答