如何在 Java 中创建多数据库事务？

Question

场景：

• DB1 和 DB2 各有一个表“T1”
• 当我在我的服务上调用 insert(..) 方法时，我需要更新两个数据库表。
• 如果其中一个数据库的更新失败，它们都需要 ROLLBACK。

调查：

• JTA 分布式事务 - 还没有运气好。

服务电话：

Service.update(id, value);

服务实现伪代码：

@Transactional(value="twoDBTransactionManager")
public class Service {
    TwoDBTransMgr tm = new TwoDBTransMgr(DB1, DB2);

    /** Option #1 **/
    public void updateBoth(id, value) {
        tm.updateBothAndCommit(id, value);
    }

    /** Option #2 **/
    public void update(id, value) {
        tm.updateDB1(id, value);
        tm.updateDB2(id, value);
        tm.commitBoth();
    }

应用程序上下文

<jee:jndi-lookup id="db1" jndi-name="jdbc/db1" resource-ref="true" proxy-interface="javax.sql.DataSource"/>
<jee:jndi-lookup id="db2" jndi-name="jdbc/db2" resource-ref="true" proxy-interface="javax.sql.DataSource"/>

技术：

Oracle 12c、Java 6、Spring、Maven、Hibernate、JNDI

PL/SQL 等效解决方案：

DECLARE
BEGIN
  INSERT INTO t1@TESTLINK (val) VALUES ('DB LINK');
  INSERT INTO t1 (val) VALUES ('NO DB LINK');
  COMMIT;
EXCEPTION WHEN OTHERS THEN
  ROLLBACK;
  RAISE;
END;
/

Answer 1

我之前对这个话题做过同样的研究。似乎没有直接的方法可以实现。

如果 DB1 和 DB2 使用相同的数据库系统（比如说 oracle）。我认为最好使用 DB Link 来执行此操作。

这意味着，您使用单个数据源来访问两个数据库中的表。

Answer 2

我认为消息可能是解决此问题的一种方法。假设 A，B 是两个 DB 连接。他们不能互相认识。我们需要另一个组件来沟通。

假设：在交易之前，A，B 向 C 发送一个 msg，并进行一些操作，然后向 c 发送一个 msg 来判断是否正常。然后 C 向 A、B 发送一个 msg，它定义了事务提交或回滚。

就像：

开始：

A---->C

B---->C

给C发消息，告诉C帮忙观察操作员

操作：

A：做一些操作，比

A ---> C 告诉 C 操作成功或失败

B：做一些操作，比

B ---> C 告诉 C 操作成功或失败

A,B 等待，给 C 发送一条消息后，等待 C 的信号形式

结束：

C---> A

C---> B

告诉 A、B 提交或回滚