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')"); 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("操作失败！！！任务撤销！！！"); try{ //回滚、取消前述操作 conn.rollback(); }catch(Exception e1){ e1.printStackTrace(); }}finally{ try{ if(conn!=null){ conn.close(); } }catch(Exception e1){ e1.printStackTrace(); } } }
}
执行第一次执行这个类，id如果不冲突，就可以顺利插入数据，第二次插入，id冲突，则实现回滚。
下面是部分回滚：
import
java.sql.
*
;
public
class
TestSavepoint
{ 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(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"); 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"); while(rs.next()){ 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!!!"); try{ conn.rollback(); }catch(Exception e1){ e1.printStackTrace(); } e.printStackTrace(); }finally{ try{ if(conn!=null){ conn.close(); } }catch(Exception e1){ e1.printStackTrace(); } } }}
代码测试通过，完美运行。
本文转自施杨博客园博客，原文链接：http://www.cnblogs.com/shiyangxt/archive/2008/08/16/1269065.html，如需转载请自行联系原作者
