学步园

J2EE 开发人员使用数据访问对象(Data Access Object DAO)设计模式，以便将低级别的数据访问逻辑与高级别的业务逻辑分离。实现 DAO 模式涉及比编写数据访问代码更多的内容。在本文中，Java 开发人员 Sean C. Sullivan 讨论了 DAO 编程中三个常常被忽略的方面：事务界定、异常处理和日志记录。

图 1. 应用程序和数据源 
 

• 一个 DAO 工厂类
• 一个 DAO 接口
• 一个实现了 DAO 接口的具体类
• 数据传输对象(有时称为值对象)

事务界定

• 事务要如何开始？
• 事务应如何结束？
• 哪一个对象将负责开始一个事务？
• 哪一个对象将负责结束一个事务？
• DAO 是否要负责事务的开始和结束？
• 应用程序是否需要通过多个 DAO 访问数据？
• 事务涉及到一个 DAO 还是多个 DAO？
• 一个 DAO 是否调用另一个 DAO 的方法？

清单 1. DAO 方法

tx.begin();    // start the transaction
dao.createWarehouseProfile(profile);
dao.updateWarehouseStatus(id1, status1);
dao.updateWarehouseStatus(id2, status2);
tx.commit();   // end the transaction

• public void setAutoCommit(boolean)
• public boolean getAutoCommit()
• public void commit()
• public void rollback()

清单 3. 用 JDBC API 进行事务界定

      import java.sql.*;
      import javax.sql.*;
      // ...
      DataSource ds = obtainDataSource();
      Connection conn = ds.getConnection();
      conn.setAutoCommit(false);
      // ...
      pstmt = conn.prepareStatement("UPDATE MOVIES ...");
      pstmt.setString(1, "The Great Escape");
      pstmt.executeUpdate();
      // ...
      conn.commit();
      // ...

图 2. 一个事务管理器和资源管理器 
 

• JDBC 连接
• JDO PersistenceManager 对象
• JMS 队列
• JMS 主题
• 企业 JavaBeans
• 符合 J2EE 连接体系结构(J2EE Connector Architecture)规范的资源适配器

清单 4. 一个对 UserTransaction 对象的 JDNI 查询

      import javax.transaction.*;
       import javax.naming.*;
      // ...
      InitialContext ctx = new InitialContext();
      Object txObj = ctx.lookup("java:comp/UserTransaction");
      UserTransaction utx = (UserTransaction) txObj;

清单 5. 用 JTA 开始一个事务

     utx.begin();
      // ...
      DataSource ds = obtainXADataSource();
      Connection conn = ds.getConnection();
      pstmt = conn.prepareStatement("UPDATE MOVIES ...");
      pstmt.setString(1, "Spinal Tap");
      pstmt.executeUpdate();
      // ...
      utx.commit();
      // ...

• public void begin()
• public void commit()
• public void rollback()
• public int getStatus()
• public void setRollbackOnly()
• public void setTransactionTimeout(int)

• 事务界定代码嵌入在 DAO 类中。
• DAO 类使用 JDBC API 进行事务界定。
• 调用者不能界定事务。
• 事务范围局限于单个 JDBC 连接。

• 事务用 JTA 界定。
• 事务界定代码从 DAO 中分离出来。
• 调用者负责界定事务。
• DAO 加入一个全局事务。

清单 7. DAO 类中的 Jakarta Commons Logging

import org.apache.commons.logging.*;
class DocumentDAOImpl implements DocumentDAO
{
      static private final Log log = LogFactory.getLog(DocumentDAOImpl.class);
      public void deleteDocument(String id)
      {
          // ...
          log.debug("deleting document: " + id);
          // ...
          try
          {
              // ... data operations ...
          }
          catch (SomeException ex)
          {
              log.error("Unable to delete document", ex);
              // ... handle the exception ...
	}
      }
}

• DAO 的公共接口中的方法是否抛出检查过的异常？
• 如果是的话，抛出何种检查过的异常？
• 在 DAO 实现类中如何处理异常？

• DAO 方法应该抛出有意义的异常。
• DAO 方法不应该抛出 java.lang.Exception 。 java.lang.Exception 太一般化了。它不传递关于底层问题的任何信息。 
  
• DAO 方法不应该抛出 java.sql.SQLException 。SQLException 是一个低级别的 JDBC 异常。一个 DAO 应该力争封装 JDBC 而不是将 JDBC 公开给应用程序的其余部分。 
  
• 只有在可以合理地预期调用者可以处理异常时，DAO 接口中的方法才应该抛出检查过的异常。如果调用者不能以有意义的方式处理这个异常，那么考虑抛出一个未检查的(运行时)异常。
• 如果数据访问代码捕获了一个异常，不要忽略它。忽略捕获的异常的 DAO 是很难进行故障诊断的。
• 使用链接的异常将低级别的异常转化为高级别的异常。
• 考虑定义标准 DAO 异常类。Spring Framework 提供了很好的一套预定义的 DAO 异常类。

• daoexamples.exception
• daoexamples.movie
• daoexamples.moviedemo

• daoexamples.movie.MovieDAOFactory
• daoexamples.movie.MovieDAO
• daoexamples.movie.MovieDAOImpl
• daoexamples.movie.MovieDAOImplJTA
• daoexamples.movie.Movie
• daoexamples.movie.MovieImpl
• daoexamples.movie.MovieNotFoundException
• daoexamples.movie.MovieUtil

• public Movie findMovieById(String id)
• public java.util.Collection findMoviesByYear(String year)
• public void deleteMovie(String id)
• public Movie createMovie(String rating, String year, String, title)
• public void updateMovie(String id, String rating, String year, String title)

清单 8. 将 MovieDAO 和 JMS 代码结合到一个事务中

	UserTransaction utx = MovieUtil.getUserTransaction();
	utx.begin();
	batman = dao.createMovie("R",
			"2008",
			"Batman Reloaded");
	publisher = new MessagePublisher();
	publisher.publishTextMessage("I'll be back");
	dao.updateMovie(topgun.getId(),
			"PG-13",
			topgun.getReleaseYear(),
			topgun.getTitle());
	dao.deleteMovie(legallyblonde.getId());
	utx.commit();