Ofbiz 事务详解_ofbtzo

大家都知道Java中的事务分为：本地事务和全局事务。

何为本地事务，因为Java本身通过JDBC进行数据库操作是没有事务的，也就是自动进行提交。而本地事务就是在connection连接里面设置了setAutoCommit(false)，手工打开JDBC事务，然后在该connection上所做的所有操作都能保证ACID属性；

而对于Java的全局事务，说穿了就是采用JTA （Java Transacion API）的事务，该事务不依赖于具体的连接（因为它甚至可以是JMS资源），如果全局事务中包含了多个资源，那么它采用的就是所谓的“两阶段提交”规则，从而也保证了事务的ACID属性。

  

前面是对Java中的事务进行了一个概括性的总结？

而对于我们最熟悉的ofbiz框架中的几个事务性问题应该如何解答：

1、  ofbiz框架中的服务可以通过配置文件进行启用和关闭事务，那么ofbiz服务中如果不开启事务，只要我们在调用服务前用TransactinUtil.begin()显式的打开事务，那么一样可以保证事务的一致性，关于这一点通过查看调用服务的ofbiz原码即可得到，这样不在赘述。

2、  ofbiz框架中如果调用两次连接更新不同的对象，那么通过在调用前启用TransactionUtil.begin()；是不是能够保证事务的一致性呢？

3、  Ofbiz框架中如果在一个TransactionUtil.begin()事务中，既更新了一个数据连接的表，同时通过取得另外的数据连接执行了存储过程的调用，那么这两者能否保持同步？

4、  如果在一个TransactionUtil.begin()事务中，连接了两个不同的数据源，更新第二个数据源时发生异常，能否保证数据的一致性？  

通过查看TransactionUtil.begin()代码跟踪下去，看了一下Tyrex组件对于全局性事务的解析，我们预计：由于Tyrex组件在commit()如果检测到多个资源，而这多个资源都满足XA协议，那么它会采用“两阶段提交”方式，故我们预期上面几个情况均能保证事务的一致性。

 通过几个简单的实验证明，上述预期是完全正确的。 核心代码如下：

 

public static String CustomerGatherMethodCreate(HttpServletRequest 
request,
                          HttpServletResponse response) {
 
                  boolean isSave = false; 
 
               List toBeStore = new ArrayList();   
 
                  boolean beganTrans = true; 
 
               GenericDelegator delegator = (GenericDelegator) request.getAttribute("delegator"); 
 
               try {    
 
                   if (beganTrans)     
 
                                    beganTrans = TransactionUtil.begin(); 
 
                    List tempList = delegator.findByAnd(      
 
                    "RelationshipAttribute", UtilMisc.toMap(        
 
                            "roleTypeIdFrom", "DISTRIBUTOR",        
 
                            "roleTypeIdTo", "MANUFACTURER", 
 
                            "partyIdFrom", "DKHTV.DRFGL", "partyIdTo",        
 
                                               "01", "attrName",     
 
                                         "GATHER_FEATURE")); 
 
                       GenericValue gv = null; 
 
                       Iterator iter=tempList.iterator();    
 
                          if(iter.hasNext())     
 
                                    gv = (GenericValue)iter.next(); 
 
                       gv.set("attrValue", "NOGATHER");    
 
                          toBeStore.add(gv);  
 
                         delegator.storeAll(toBeStore); 
 
//                      isSave = saveCustomerGatherMethod("abc","3", delegator); 
                       testTulipTransaction(); 
 
                       TransactionUtil.commit(beganTrans); 
 
                          request.setAttribute(SiteDefs.EVENT_MESSAGE, "成功更改客户采集方式!"); 
 
                          return "success"; 
 
               } catch (Exception e) {    
 
                          e.printStackTrace();    
 
                          Debug.logError(e);    
 
                          try {     
 
                                   TransactionUtil.rollback(beganTrans); 
 
                       } catch (GenericTransactionException e1) {     
 
                                   e1.printStackTrace(); 
 
                       } 
 
         request.setAttribute(SiteDefs.ERROR_MESSAGE,e.getMessage()+",更改客户采集方式失败,事务回滚!"); 
 
                       return "error"; 
 
}