之前因為教師斷了一次網，然後又開始學前端，和js做了一個多月的鬥爭，回過神要講Spring了才發現部落格已經冷了很久了。。。慢慢補上吧

今天先把資料庫事務的一個案例記一下，也是前幾個星期剛剛才會寫的。。

package mjy.kuguan.ruku.dao.impl;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.text.SimpleDateFormat;
import java.util.Date;

import mjy.common.util.jdbc.JdbcUtil;
import mjy.common.util.jdbc.TransactionManager;
import mjy.kuguan.ruku.dao.RukuUserDao;
import mjy.kuguan.ruku.po.DiaoborukuPO;

/**
 * 調撥單用事務：調撥入庫單刪除 與 已完成入庫表插入
 * @author student
 *
 */
public class DiaoboTransaction {
	//設定本類入庫型別顯示內容
	private final String RUKU_TYPE = "調撥入庫";
	
	private Connection conn;
	private PreparedStatement prep;
	private TransactionManager transactionManager;
	private RukuUserDao rukuUserDao = new RukuUserDaoImpl();
	
	/**
	 * 【事務操作】
	 * 將該條調撥入庫單1.插入入庫完成表 2.從採購入庫表中刪除
	 * @param diaoborukuPO
	 * @param wanchengChecker
	 */
	public void diaoboruku(int diaoboBossId, DiaoborukuPO diaoborukuPO, int wanchengChecker){
		//獲取連線
		conn = JdbcUtil.getConnection();

		//將連線部署於事務管理
		transactionManager = JdbcUtil.getTransactionManager();
		
		//開啟事務，關閉自動提交
		transactionManager.startTransaction();
		
		/*	事務執行主體	*/
		
		//插入語句
		String sqlInsert = "insert into kuguan_rukuwancheng values(?,?,?,?,?,?,?,?,?,?,?)";
		//刪除語句
		String sqlDelete = "delete from kuguan_diaoboruku where diaoboBossId = ? and diaoboCode = ?";
		
		try {
			//執行插入操作
			prep = conn.prepareStatement(sqlInsert);
			prep.setString(1, Thread.currentThread().hashCode() + "-" + System.currentTimeMillis());
			prep.setInt(2, diaoboBossId);
			prep.setString(3, diaoborukuPO.getDiaoboCode());			//設定入庫單編號
			prep.setString(4, diaoborukuPO.getDiaoboDiaobodanCode());	//設定相關單據號
			prep.setString(5, RUKU_TYPE); 								//設定入庫型別
			prep.setInt(6, diaoborukuPO.getDiaoboInCount()); 			//設定入庫數量
			prep.setString(7, diaoborukuPO.getDiaoboSetTime()); 		//設定制單時間
			prep.setInt(8, rukuUserDao.getSelectIdByName(diaoborukuPO.getDiaoboAuthor()).get(0)); 			//設定制單人
			prep.setInt(9, wanchengChecker); 						//設定確認人（唯一輸入項）
			prep.setString(10, new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));//設定確認時間
			prep.setString(11, diaoborukuPO.getDiaoboNote()); 			//設定本單備註
			prep.executeUpdate();
			
			//int i=1/0;	//測試
			
			//執行刪除操作
			prep = conn.prepareStatement(sqlDelete);
			prep.setInt(1, diaoboBossId);
			prep.setString(2, diaoborukuPO.getDiaoboCode());
			prep.executeUpdate();
			
		} catch (Exception e) {//此處Exception應包含上述所有可能異常
			// 期間出現異常時,回滾&釋放連結
			transactionManager.rollbackAndClose();
			e.printStackTrace();
			return;//防止執行finally
		} finally {
			//無異常則提交
			transactionManager.commitAndClose();
		}
	}
}
 

用到的TransactionManager類也貼一下：

package mjy.common.util.jdbc;

import java.sql.Connection;
import java.sql.SQLException;

/**
 * �������Ӷ�����ύ ���ع� ����������Ȳ���
 * @author igeek
 *
 */
public class TransactionManager {
	private Connection connection = null;
	
	public TransactionManager(Connection connection){
		this.connection=connection;
	}
	
	
	/**
	 * ��������
	 */
	public void startTransaction(){
		try {
			connection.setAutoCommit(false);
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	/**
	 * �ύ����
	 */
	public void commitAndClose(){
		
		try {
			connection.commit();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			JdbcUtil.free(connection);
		}
		
	}
	
	/**
	 * �ع�����
	 */
	public void rollbackAndClose(){
		try {
			connection.rollback();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			JdbcUtil.free(connection);
		}
		
	}
	
}