使用 Quarkus 事务管理器管理 JTA 事务

流程

1. 注入 UserTransaction 接口：

   src/main/java/org/acme/SantaClauseService.java

   @ApplicationScoped
   public class SantaClausService {
   
       @Inject ChildDAO childDAO;
       @Inject SantaClausDAO santaDAO;
       @Inject UserTransaction transaction;
   }

   Copy to Clipboard Toggle word wrap

2. 使用事务分离方法控制事务：

   src/main/java/org/acme/SantaClauseService.java

   import javax.transaction.Transactional;
   import javax.inject.Inject;
   import javax.transaction.SystemException;
   import javax.transaction.UserTransaction;
   
   @ApplicationScoped
   public class SantaClausService {
   
       @Inject ChildDAO childDAO;
       @Inject SantaClausDAO santaDAO;
       @Inject UserTransaction transaction;
   
       public void getAGiftFromSanta(Child child, String giftDescription) {
           // some transaction work
           try {
               transaction.begin(); 

   1

   
               Gift gift = childDAO.addToGiftList(child, giftDescription);
               santaDAO.addToSantaTodoList(gift);
               transaction.commit();
           }
           catch(SomeException e) {
               // do something on Tx failure
               transaction.rollback(); 

   2

   
           }
       }
   }

   Copy to Clipboard Toggle word wrap

   1

   将事务代码放在 transaction.begin（） 和 transaction.commit（） 之间。

   2

   立即中止事务。

   注意

   您不能在事务以 @Transactional 调用方式使用 UserTransaction。

流程

1. 注入 TransactionManager，并使用 setRollbackOnly 为回滚设置事务：

   在本例中，事务上下文被传播到嵌套在 @Transactional 方法（childDAO.addToGiftList（） 和 santaDAO.addToSantaTodoList（）的所有调用。事务管理器提交事务，除非运行时异常超过方法边界。

   src/main/java/org/acme/SantaClausService.java 示例

   import javax.transaction.Transactional;
   import javax.inject.Inject;
   import javax.transaction.SystemException;
   import javax.transaction.UserTransaction;
   
   @ApplicationScoped
   public class SantaClausService {
   
       @Inject TransactionManager tm; 

   1

   
       @Inject ChildDAO childDAO;
       @Inject SantaClausDAO santaDAO;
   
       @Transactional
       public void getAGiftFromSanta(Child child, String giftDescription) {
           // some transaction work
           Gift gift = childDAO.addToGiftList(child, giftDescription);
           if (gift == null) {
               tm.setRollbackOnly(); 

   2

   
           }
           else {
               santaDAO.addToSantaTodoList(gift);
           }
       }
   }

   Copy to Clipboard Toggle word wrap

   1

   注入 TransactionManager 以便能够激活 setRollbackOnly 语义。

   2

   以编程方式决定何时回滚事务。