JDBC处理Transaction

package com.ayang.jdbc;

import java.sql.*;
/**
 * transaction的构成，随便写一句insenrt，一执行executeUpdate()，它自动提交。
 * 下边例子有三条update语句，假设第一条是updateA账户上的钱完了，自动提交，这时候出错了，B账户上的钱没update，这时候会出现数据不一致的问题。
 * 解决办法很简单，把它放在一个transtraction里去，要么两条同时完成，要么都不完成。
 * 任何一条DML语句会自动提交，因为在整个数据库连接里，有一个属性：AutoCommit();默认为值true，会自动提交。要想把某些语句放在一个transaction里，
 * 把AutoCommit(false);设为false，手动提交：最后执行conn.commit();然后恢复AutoCommit()为true.
 * 如果catch到任何SQLException，首先进行conn.rollback();然后conn.setAutoCommit(true);确保万无一失。
 */


public class TestTransaction {

    public static void main(String[] args) {
            Connection  conn  = null;
            Statement  stmt =  null;
            try {
                Class.forName("oracle.jdbc.driver.OracleDriver");
                conn  =  DriverManager.getConnection("jdbc:oracle:thin:@127.0.0.1:1521:ORCL","scott","root");
                
                conn.setAutoCommit(false);
                stmt = conn.createStatement();
                stmt.addBatch("insert into dept2 values(60,'CPU','XUCHANG')");
                stmt.addBatch("insert into dept2 values(61,'CPU','XUCHANG')");
                stmt.addBatch("insert into dept2 values(62,'CPU','XUCHANG')");
                stmt.executeBatch();
                conn.commit();
                conn.setAutoCommit(true);
            
                
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            } catch (SQLException e) {
                e.printStackTrace();
                
                try {
                    if(conn != null){
                        conn.rollback();     //有异常时回滚。
                        conn.setAutoCommit(true);
                    
                    }    
                }catch (SQLException e1) {
                    e1.printStackTrace();
                }finally{
                    try{
                        if(conn!=null){
                            conn.close();
                        }if(stmt!=null){
                            stmt.close();
                        }
                    }catch (SQLException e1) {
                        e1.printStackTrace();
                    }
                }
            }
            
        

    }

}

自动提交效果对比，能插入前两条记录（第三条sql语句缺失into）第三条sql不会执行。

 

//conn.setAutoCommit(false);

stmt = conn.createStatement();

stmt.addBatch("insert into dept2 values(60,'CPU','XUCHANG')");

stmt.addBatch("insert into dept2 values(61,'CPU','XUCHANG')");

stmt.addBatch("insert  dept2 values(62,'CPU','XUCHANG')");

stmt.executeBatch();

        conn.commit();

    //conn.setAutoCommit(true);