2018-02-25 使用jdbc实现事务(一)

在数据库的事务特性中, 最重要的是隔离性,如果 多个事务共同同时操作 同一个表中数据时, 不考虑 隔离性,
那么就会引发灰常严重的问题, 主要会有以下的三类问题:

第一类: 脏读(dirty read ), 一个事务在操作的时候,读到了其他的事务未提交的数据, 这叫做脏读,也是最严重的
问题.

第二类: 不可重复读(unreatable read), 一个事务在操作的时候,读到的其他的事务已经提交的数据 , 主要指
通过update 语句对数据库中现有的数据进行了更新操作

第三类: 虚读,幻读(phantom read), 一个事务在操作的时候,读到的其他的事务已经提交的数据, 主要值 使用
Insert 语句 插入了新的记录

针对以上三类问题,数据库 提供了4 种 隔离级别, 用于解决以上三类问题.

第一种: read uncommitted (读未 提交), 会产生 脏读, 不可重复读, 虚读的发生是有概率的

第二种: read committed(读已提交), 不会产生脏读, 但是会引发不可重复读. 虚读的发生是有概率的

第三种: repeatable read (可以重复读), 不会发生脏读, 不可重复读, 虚读发生是有概率的

第四种: serializable (串行化), 不会发生以上的三类问题.

对于 以上四种隔离级别,串行化解决了所有的问题, 但是效率是最低的, 实际开发中,最常用的是
第二种以及第三种隔离级别.

Mysql: 默认的隔离级别是 repeatable read
Oracle: 默认的隔离级别是 read committed

通过如下的命令 可以去更改 隔离级别 :

set session transaction isolation level 隔离级别值---- 设置当前的隔离级别了

select @@tx_isolation ----查询当前的隔离级别

这些问题, 都是在 事务操作过程中 才会出现的. 所以 肯定会去使用

Start transaction ----开启事务

Rollback----- 回滚事务

Commit ---提交事务

• 导入mysql-connector-java-5.1.45-bin.jar
• JdbcUtils.java工具类代码

public class JdbcUtils {
    
    //使用ResouceBundle
    private static String driverClass = null ;
    private static String url = null ;
    private static String username = null ;
    private static String password = null ;
    
    static {
        //专门用于读取properties文件
        //properties文件要放在src下
        //忽略扩展名
        ResourceBundle bundle = ResourceBundle.getBundle("db");
        
        driverClass = bundle.getString("driverClass");
        url = bundle.getString("url");
        username = bundle.getString("username");
        password = bundle.getString("password");
    }
    
    
    
    
    public static Connection getConnection() {
        
        
        try {
            loadDriver();
            //建立连接
            
            
            
            return DriverManager.getConnection(url,username,password);
            
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            return null;
        }
        
        
    }

    private static void loadDriver() {
        
        try {
            
            //这里是加载字节码.在Driver类中,
            Class.forName(driverClass);
            
            //Class.forName("com.mysql.jdbc.Driver");
            
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
    //释放资源
    public static void release(ResultSet rs ,Statement stmt, Connection conn) {
        if(rs != null) {
            try {
                //释放获得的资源
                rs.close();
            } catch (SQLException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
            }   
            
            //设置为空:斩断引用的对象
            //有利于回收垃圾
            rs = null;
            
        }
        
        if(stmt != null) {
            try {
                stmt.close();
            } catch (SQLException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
            }
            stmt = null;
        }
        if(conn != null) {
            
            try {
                conn.close();
            } catch (SQLException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
            }
            
            conn = null;
            
        }

    }
    
}

• TransactionTest.java

//使用jdbc去管理事务
    @Test
    public void test1() {
        Connection conn = null;
        Statement stmt = null;
        
        try {
            
            //获得连接
            conn = JdbcUtils.getConnection();
            
            conn.setAutoCommit(false);//相当于开启事务
            
            stmt = conn.createStatement();
            stmt.executeUpdate("update account set money=money-100 where name=\"aaa\"");
            //int i=1/0;
            stmt.executeUpdate("update account set money=money+100 where name=\"bbb\"");
            
            conn.commit();//提交事务
            
        } catch (Exception e) {
            // TODO: handle exception
            
            
            //如果出现了异常,就回滚事务
            try {
                conn.rollback();
            } catch (SQLException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
            }
            
            e.printStackTrace();
            
        }finally {
            
            JdbcUtils.release(null, stmt, conn);
            
        }
        
        
    }