Java关于Mysql数据库的事物处理类

Mysql5很好的支持了事物处理功能。不过支持这个功能的只有两种表类型。

分别是BDB，InnoDB。
先建立一个表，名为Kiss，数据为id （int），name（varchar），pop（varchar）。
下面是源码：
复制代码
import java.sql.*;
public class TestCommit{
public static void main(String args[]){
Connection conn=null;
try{
Class.forName("com.mysql.jdbc.Driver");
String url="jdbc:mysql://localhost:3306/kiss";
conn=DriverManager.getConnection(url,"username","password");
boolean autoCommit=conn.getAutoCommit();
//关闭自动提交功能
conn.setAutoCommit(false);
Statement stmt=conn.createStatement();
stmt.executeUpdate("insert into sun values(15,'Hello','Beijing')");
stmt.executeUpdate("insert into sun values(16,'Hi','shanghai')");
//代码效果参考：http://0791zd.com/zx/art_5278.html

   ResultSet rs=stmt.executeQuery("select * from sun");
   while(rs.next()){
        System.out.print("DeptNo:"+rs.getInt(1));
        System.out.print("\tDeptName:"+rs.getString(2));
        System.out.println("\tLOC:"+rs.getString(3));

}
//提交事务
conn.commit();
//恢复原来的提交模式
conn.setAutoCommit(autoCommit);
stmt.close();
}catch(Exception e){
System.out.println("操作失败！！！任务撤销！！！");
//回滚、取消前述操作
conn.rollback();
}catch(Exception e1){
e1.printStackTrace();
}
}finally{
try{
if(conn!=null){
conn.close();
}
}catch(Exception e1){
e1.printStackTrace();
}
}
执行第一次执行这个类，id如果不冲突，就可以顺利插入数据，第二次插入，id冲突，则实现回滚。
下面是部分回滚：
public class TestSavepoint{
stmt.executeUpdate("insert into sun values(21,'Hello','Beijing')");
stmt.executeUpdate("insert into sun values(22,'Hi','shanghai')");
Savepoint sp1=conn.setSavepoint("p1");
stmt.executeUpdate("insert into sun values(25,'shiyang','xingtai')");
Savepoint sp2=conn.setSavepoint("p2");
//代码效果参考：http://0791zd.com/bx/art_4989.html

   stmt.executeUpdate("insert into sun values(60,'shiyang','baoding')");
   ResultSet rs=stmt.executeQuery("select avg(id) from sun");
   rs.next();
   double avg_id=rs.getDouble(1);
   if(avg_id>100){
     conn.rollback(sp1);
   }else if(avg_id>30){
     conn.rollback(sp2);
   }
   conn.commit();
   rs=stmt.executeQuery("select * from sun");
        System.out.print(rs.getInt(1));
        System.out.print("\t"+rs.getString(2).trim());
        System.out.println("\t"+rs.getString(3));

rs.close();
stmt.close();
}catch(Exception e){
System.out.println("Failure.rollback!!!");
conn.rollback();
e.printStackTrace();
}finally{
try{
if(conn!=null){
conn.close();
}catch(Exception e1){
e1.printStackTrace();
}