對目前的JavaEE企業應用開發來說，基本都會採用分層的架構, 這樣可以分散關注、鬆散耦合、邏輯複用、標準定義。例如，目前使用SSH組合時典型的四層架構：表示層、業務層、持久層和資料層；那麼，在四層架構中，事務的控制應該放在哪一層呢？

如果使用Spring框架，它對事務做了很好的封裝，通過它的AOP配置，可以靈活的配置在任何一層；但是在很多的需求和應用，直接使用JDBC事務控制還是有其優勢的。所以，本文來討論純JDBC事務的控制問題。

其實，事務是以業務邏輯為基礎的；一個完整的業務應該對應業務層裡的一個方法；如果業務操作失敗，則整個事務回滾；所以，事務控制是絕對應該放在業務層的；但是,持久層的設計應該遵循一個很重要的原則：持久層應該保證操作的原子性，就是說持久層裡的每個方法都應該是不可以分割的。

例如針對一個部門和員工的CRUD操作。如果要刪除某個部門，就應該在DeptDao中有一個刪除部門的方法：
public class DeptDao {
    public void deleteDept(int id) ;         //刪除指定ID的部門
}
在EmpDao中有一個刪除指定部門下的所有員工的方法
public interface EmpDao{
    public void deleteEmpByDeptId(int id);    //刪除指定部門下的所有員工
}
這樣，就應該在業務層DeptService中的刪除部門方法中組合這兩個方法，即把它們放置在同一個事務中：
public class DeptService{
    public void deleteDept(int id){
        try{
             //啟動JDBC事務
             //呼叫EmpDao中的deleteEmpByDeptId(id)方法
             //呼叫DeptDao中的deleteDept(id)方法
             //操作正常，提交事務
        }catch(Exception e){
             //異常，回滾事務
        }
    }
}

要讓這兩個Dao操作在同一個事務，最主要的一點就是：啟動JDBC事務中使用的資料庫連線和兩個Dao操作方法裡獲得的資料庫連線要是同一個連線。參照Spring的JDBC事務原理，可以使用ThreadLocal類, 在啟動JDBC事務中把資料庫連線繫結到執行緒，以保證在同一個執行緒下獲得的都是同一個連線。這樣就達到目的了。

如下資料庫工具類：

package com.tjitcast.common; import java.io.IOException; import java.sql.Connection; import java.sql.SQLException; import java.util.Properties; import javax.sql.DataSource; import com.mchange.v2.c3p0.DataSources; import com.tjitcast.dao.DaoException; /** * 資料庫工具類 * 可以根據classpath下配置檔案jdbc.properties中配置的引數來獲取資料庫連線並繫結到當前執行緒上 * 可以獲取JDBC的事務管理器 * @author qiujy * @version 0.9Beta */ public class DbUtils { private static Properties prop = new Properties(); /** 資料來源 */ private static DataSource ds = null; //用來把Connection繫結到當前執行緒上的變數 private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>(); static{ try { prop.load(Thread.currentThread().getContextClassLoader().getResourceAsStream("jdbc.properties")); } catch (IOException e) { e.printStackTrace(); System.out.println("在classpath下沒有找到jdbc.properties檔案"); } //使用C3P0連線池技術 try { Class.forName("com.mysql.jdbc.Driver"); DataSource unpooled = DataSources.unpooledDataSource( prop.getProperty("url"), prop.getProperty("user"), prop.getProperty("password")); ds = DataSources.pooledDataSource(unpooled); } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } } private DbUtils(){} /** * 根據資料庫的預設連線引數獲取資料庫的Connection物件，並繫結到當前執行緒上 * @return 成功，返回Connection物件，否則返回null */ public static synchronized Connection getConnection(){ Connection conn = tl.get(); //先從當前執行緒上取出連線例項 if(null == conn){ //如果當前執行緒上沒有Connection的例項 try { conn = ds.getConnection(); // 從連線池中取出一個連線例項 tl.set(conn); //把它繫結到當前執行緒上 } catch (SQLException e) { e.printStackTrace(); } } return conn; } /** * 獲取事務管理器 * @return 事務管理例項 */ public static synchronized TransactionManager getTranManager(){ return new TransactionManager(getConnection()); } /** * 關閉資料庫連線，並卸裝執行緒繫結 * @param conn 要關閉資料庫連線例項 * @throws DaoException */ protected static void close(Connection conn) throws DaoException{ if(conn != null){ try { conn.close(); } catch (SQLException e) { throw new DaoException("關閉連線時出現異常",e); } finally { tl.remove(); //卸裝執行緒繫結 } } } }

如下事務管理器類：

package com.tjitcast.common; import java.sql.Connection; import java.sql.SQLException; import com.tjitcast.dao.DaoException; /** * 事務管理器 * @author qiujy * @version 0.9Beta */ public class TransactionManager { private Connection conn; protected TransactionManager(Connection conn) { this.conn = conn; } /** 開啟事務 */ public void beginTransaction() throws DaoException{ try { conn.setAutoCommit(false); //把事務提交方式改為手工提交 } catch (SQLException e) { throw new DaoException("開戶事務時出現異常",e); } } /** 提交事務並關閉連線 */ public void commitAndClose() throws DaoException{ try { conn.commit(); //提交事務 } catch (SQLException e) { throw new DaoException("提交事務時出現異常",e); }finally{ DbUtils.close(conn); } } /** 回滾並關閉連線 */ public void rollbackAndClose()throws DaoException{ try { conn.rollback(); } catch (SQLException e) { throw new DaoException("回滾事務時出現異常",e); }finally{ DbUtils.close(conn); } } }

如下業務層類：

package com.tjitcast.service; import java.util.List; import com.tjitcast.common.DbUtils; import com.tjitcast.common.TransactionManager; import com.tjitcast.dao.DaoException; import com.tjitcast.dao.DaoFactory; import com.tjitcast.dao.DeptDao; import com.tjitcast.dao.EmployeeDao; import com.tjitcast.entity.Dept; import com.tjitcast.entity.Employee; import com.tjitcast.entity.PageModel; /** * 業務層門面 --> 新增事務控制 * @author qiujy */ public class ServiceFacade { private DeptDao deptDao = DaoFactory.getInstance("deptDao", DeptDao.class); private EmployeeDao empDao = DaoFactory.getInstance("empDao", EmployeeDao.class); /** * 新增部門 * @param dept */ public void insertDept(Dept dept){ TransactionManager tx = DbUtils.getTranManager(); try{ tx.beginTransaction(); deptDao.insert(dept); tx.commitAndClose(); }catch (DaoException e) { tx.rollbackAndClose(); } } /** * 新增員工 * @param emp 員工 */ public void insertEmp(Employee emp){ TransactionManager tx = DbUtils.getTranManager(); try{ tx.beginTransaction(); empDao.insert(emp); tx.commitAndClose(); }catch (DaoException e) { tx.rollbackAndClose(); } } /** * 獲取所有部門的列表 * @return 部門列表 */ public List<Dept> getDeptList(){ List<Dept> list = null; TransactionManager tx = DbUtils.getTranManager(); try{ tx.beginTransaction(); list = deptDao.getDeptList(); tx.commitAndClose(); }catch (DaoException e) { e.printStackTrace(); tx.rollbackAndClose(); } return list; } /** * 獲取指定部門下的員工分頁列表 * @param deptId * @param pageNo * @param pageSize * @return 符合條件的PageModel */ public PageModel<Employee> getEmpListByDeptId(int deptId, int pageNo, int pageSize){ PageModel<Employee> pm = null; TransactionManager tx = DbUtils.getTranManager(); try{ tx.beginTransaction(); pm = empDao.getEmpListByDeptId(deptId, pageNo, pageSize); tx.commitAndClose(); }catch (DaoException e) { tx.rollbackAndClose(); } return pm; } /** * 刪除指定ID的部門 * @param id 部門ID */ public void deleteDept(int id){ TransactionManager tx = DbUtils.getTranManager(); try{ tx.beginTransaction(); empDao.deleteByDeptId(id); //先刪除指定ID部門下的所有員工 deptDao.delete(id); //再刪除該部門 tx.commitAndClose(); }catch (DaoException e) { tx.rollbackAndClose(); } } }

具體的示例程式碼結構如下（Eclipse工程）：

如有需要，留下郵箱。