设计模式之事务处理

public interface BookStoreManager{
          public boolean buyBook(String bookId,int quantity)throws SystemException;
          .其他业务方法
}

   public class BookStoreManagerImpl implements BookStoreManager{
         public boolean buyBook(String bookId)throws SystemException{
              Connection conn=ConnectionManager.getConnection();//获取数据库连接
              boolean b=false;
              
              try{
                  conn.setAutoCommit(false);  //取消自动提交
                  BookDAO bookDAO=DAOFactory.getBookDAO();
                  CustomerDAO customerDAO=DAOFactory.getCustomerDAO();
                    //尝试从库存中取书 
                  if(BookDAO.reduceInventory(conn,bookId,quantity)){
                       BigDecimal price=BookDAO.getPrice(bookId);  //取价格
                       //从客户帐户中扣除price*quantity的费用
                       b=
                       CustomerDAO.reduceAccount(conn,price.multiply(new BigDecimal(quantity));
                       .
                       其他业务方法，如通知管理员，生成定单等.
                        
                       conn.commit();   //提交事务
                       conn.setAutoCommit(true);
                  }
               }catch(SQLException e){
                  conn.rollback();   //出现异常，回滚事务
                  con.setAutoCommit(true);
                  e.printStackTrace();
                  throws new SystemException(e);   
               }
               return b;
         } 
    }

 public final class ManagerFactory {
      public static BookStoreManager getBookStoreManager() {
         return new BookStoreManagerImpl();
      }
   }

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;

import java.sql.Connection;

import com.strutslet.demo.service.SystemException;

public final class TransactionWrapper {

    /**
     * 装饰原始的业务代表对象，返回一个与业务代表对象有相同接口的代理对象 
     */
    public static Object decorate(Object delegate) {
        return Proxy.newProxyInstance(delegate.getClass().getClassLoader(),
                delegate.getClass().getInterfaces(), new XAWrapperHandler(
                        delegate));
    }
    
    //动态代理技术
    static final class XAWrapperHandler implements InvocationHandler {
        private final Object delegate;

        XAWrapperHandler(Object delegate) {
           this.delegate = delegate;
        }
        
        //简单起见，包装业务代表对象所有的业务方法
        public Object invoke(Object proxy, Method method, Object[] args)
                throws Throwable {
            Object result = null;
            Connection con = ConnectionManager.getConnection();
            try { 
                //开始一个事务
                con.setAutoCommit(false);
                //调用原始业务对象的业务方法
                result = method.invoke(delegate, args);
                con.commit();   //提交事务
                con.setAutoCommit(true);
            } catch (Throwable t) {
                //回滚
                con.rollback();
                con.setAutoCommit(true);
                throw new SystemException(t);
            }

            return result;
        }
    }
}

public class BookStoreManagerImpl implements BookStoreManager {
    public boolean buyBook(String bookId)throws SystemException{
          Connection conn=ConnectionManager.getConnection();// 获取数据库连接
          boolean b=false;
          try{
              BookDAO bookDAO=DAOFactory.getBookDAO();
              CustomerDAO customerDAO=DAOFactory.getCustomerDAO();
              // 尝试从库存中取书
              if(BookDAO.reduceInventory(conn,bookId,quantity)){
                  BigDecimal price=BookDAO.getPrice(bookId);  // 取价格
                  // 从客户帐户中扣除price*quantity的费用
                  b=
                  CustomerDAO.reduceAccount(conn,price.multiply(new BigDecimal(quantity));
                  .
                  其他业务方法，如通知管理员，生成定单等.
                  
              }
          }catch(SQLException e){
             throws new SystemException(e);
          }
          return b;
    }
    . 
}

 public final class ManagerFactory {
      //返回一个被包装的对象，有事务控制能力
      public static BookStoreManager getBookStoreManagerTrans() {
          return (BookStoreManager) TransactionWrapper
                  .decorate(new BookStoreManagerImpl());
      }
      //原始版本
      public static BookStoreManager getBookStoreManager() {
         return new BookStoreManagerImpl();
      }
      
   }

   我们的设计还不够优雅，比如我们默认所有的业务代表对象的方法调用都将被包装在一个Transaction Context。可事实是很多方法也许并不需要与数据库打交道，如果我们能配置哪些方法需要事务声明，哪些不需要事务管理就更完美了。解决办法也很简单，一个XML配置文件来配置这些，调用时判断即可。说到这里，了解spring的大概都会意识到这不正是声明式事务控制吗？正是如此，事务控制就是AOP的一种服务，spring的声明式事务管理是通过AOP实现的。AOP的实现方式包括：动态代理技术，字节码生成技术（如CGLIB库），java代码生成（早期EJB采用），修改类装载器以及源代码级别的代码混合织入（aspectj)等。我们这里就是利用了动态代理技术，只能对接口代理；对类的动态代理可以使用cglib库。

文章转自庄周梦蝶  ，原文发布时间2007-02-06