mysql - 如何使用jpa处理分布式事务

Question

我有一个要求，我需要将缩减插入两个不同的数据库MYSQL和mongodb中。在发生故障转移的情况下，应该回滚整个事务。请尽早提供帮助。需要实现这个要求。

Answer 1

首先，您必须定义两个数据库连接，因此还要定义两个不同的持久性单元

persistence.xml

文件。

之后，只需在每个 DAO 方法中创建 2 个单独的 EntityManager。

尝试以下操作:

persistFoo(Foo f) {
    // Create these EntityManagers with a proper connection/persistence unit name
    EntityManager emMySQL = //your MySQL db
    EntityManager emMongo = //your Mongo db

    EntityTransaction txMySQL = emMySQL.getTransaction();
    EntityTransaction txMongo = emMongo.getTransaction();    

    try {
       txMySQL.begin();
       emMySQL.persist(f);
       txMySQL.commit();

       txMongo.begin();
       emMongo.persist(f);
       txMongo.commit();
    } catch(Exception e) {
       if(txMySQL.isActive()) {
          txMySQL.rollback();
       }
       if(txMongo.isActive()) {
          txMongo.rollback();
       }
    } finally {
       emMySQL.close();
       emMongo.close();
    }
}