package jdbc_affair; import java.sql.Connection; public class BaseBiz { /** *開始一個(gè)事務(wù) * @param con 數(shù)據(jù)庫(kù)的連接。 * @throw* **ception 執(zhí)行操作時(shí)發(fā)生的任何異常。 */ public static void beginTransaction(Connection con) throw* **ception { if (con == null) { throw new Exception("Can not start transaction with a null onnection!"); } con.setAutoCommit(false); // 更改JDBC事務(wù)的默認(rèn)提交方式 } /** *開始一個(gè)事務(wù) * @param con 數(shù)據(jù)的連接。 * @param success 是否進(jìn)行提交的標(biāo)志,true - 提交,否則回退。 * @throw* **ception 執(zhí)行操作時(shí)發(fā)生的任何異常。 */ public static void endTransaction(Connection con, boolean success) throw* **ception { if (con == null) { throw new Exception("Can not end transaction with a null connection!"); } if (success) { con.commit(); con.setAutoCommit(true);// 恢復(fù)JDBC事務(wù)的默認(rèn)提交方式 } else { con.rollback(); } } } |