3

我正在处理一个为分布式事务配置的现有项目。

该项目正在使用 Hibernate，但由于某些历史原因，我正在处理的部分使用 JDBC 并且需要保持这种方式。

要获得连接，我必须调用一个 API，它会返回休眠会话的 JDBC 连接。

我需要在一个事务中完成一些更新/插入，所以这就是我正在做的事情：

  1. 在我的连接上将 autoCommit 设置为 false。
  2. 做我的插入（准备语句，执行查询）
  3. 调用提交。

在提交时，我得到一个 SQLException，因为显然不允许使用分布式事务显式调用提交/回滚。我应该声明将数据源配置更改为非 XA 不是一种选择。

有什么想法可以解决这个问题吗？

        connexionDiff.setAutoCommit(false); 
        psInsertLiv = connexionDiff.prepareStatement(reqInsertLivraison);
        psInsertLivHisto = connexionDiff.prepareStatement(reqInsertLivraisonHisto);
        psSequence = connexionDiff.prepareStatement(reqCleLivraison);

        ps = connexionDiff.prepareStatement(requeteRelivraison);
        rs = ps.executeQuery();

        while(rs.next()) {

            rsSequence = psSequence.executeQuery();
            while ( rsSequence.next() ) {
                sequenceLivraison = rsSequence.getInt(1);
            }

            psInsertLiv.setInt(1, sequenceLivraison);
            psInsertLiv.setInt(2, rs.getInt(1));
            psInsertLiv.executeUpdate();

            psInsertLivHisto.setInt(1, sequenceLivraison);
            psInsertLivHisto.setInt(2, rs.getInt(1));
            psInsertLivHisto.executeUpdate();

            connexionDiff.commit();
        }

    } catch (SQLException ex) {
       try{
        connexionDiff.rollback();
      }catch {
//......
}
    } finally {
        //.....
    }

谢谢

4

1 回答 1

3

当您使用 XA 连接时，您肯定是在使用 JTA 管理您的事务。

如果它是一个独立的 JTA，获取 UserTransaction 并在那里调用 begin 并提交。如果它位于应用程序服务器中，请使用事务注释或应用程序服务器为您提供的任何东西来管理事务。查看此页面以了解它是如何在 JavaEE 6 中完成的。

如果您使用 Spring，您还可以使用事务注释将代码包装在事务中。这是相关文档。

无论您使用的是 Hibernate 还是纯 JDBC，事务管理都应该是相同的。因此，请检查在您的项目中使用 Hibernate 时它是如何完成的，并遵循相同的步骤。

于 2013-01-04T14:06:03.967 回答