JDBC（六）——　数据库事务

数据库事务

事务

一组逻辑操作单元，使数据从一种状态变换到另一种状态

事务处理

保证所有事务都作为一个工作单元来执行，即使出现了故障，都不能改变这种执行方式。

当在一个事务中执行多个操作时，要么所有事务都提交，要么数据库管理系统放弃所有修改，整个事务回宫到最初状态。

数据一旦提交就不可回滚

DDL操作执行自动提交
DML默认情况下一旦执行，自动提交。可通过set autocommit = false的方式取消DML操作的自动提交
关闭连接时会自动提交

支持事物的增删改操作

/**
 * 支持事务的增删改操作
 * @param conn
 * @param sql
 * @param args
 */
public void update(Connection conn,String sql,Object ...args){
    PreparedStatement ps = null;
    try {
        //2.预编译sql语句，返回preparedStatement实例
        ps = conn.prepareStatement(sql);
        //3.填充占位符
        //sql占位符的个数与可变形参的长度相同,可变形参相当于一个数组
        for (int i = 0; i < args.length ; i++) {
            ps.setObject(i+1,args[i]);
        }
        //4.执行
        ps.execute();
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        //5.资源关闭
        JdbcUtils.closeResource(null,ps);
    }
}

使用

public void testTransaction() {
    Connection conn = null;
    try {
        String sql1 = "update `transaction` set money = money - 100 where name = ?";
        String sql2 = "update `transaction` set money = money + 100 where name = ?";
        CommonUtils commonUtils = new CommonUtils();
        conn = JdbcUtils.getConnection();

        //取消数据的自动提交功能
        conn.setAutoCommit(false);

        commonUtils.update(conn,sql1,"why");

        commonUtils.update(conn,sql2,"wyy");
        System.out.println("转账成功");
        
        //提交数据
        conn.commit();
        
    } catch (Exception e) {
        e.printStackTrace();
        try {
            //回滚数据
            conn.rollback();
        } catch (SQLException throwables) {
            throwables.printStackTrace();
        }
    } finally {
        JdbcUtils.closeResource(conn,null);
    }
}

事务的ACID属性及四种隔离级别

ACID属性

原子性（Ａｔｏｍｉｃｉｔｙ）：指事务是不可分割的单位
一致性（Ｃｏｎｓｉｓｔｅｎｃｙ）：事务必须使数据库从一个一致性转移到另一个一致性状态
隔离性（Ｉｓｏｌａｔｉｏｎ）：指一个事务的执行不能被其他事务干扰，一个事务内部的操作及使用的数据对并发的其他事务是隔离的
持久性（Ｄｕｒａｂｉｌｉｔｙ）：指事务一旦被提交，对数据库的改变即为永久性的

数据库并发问题

脏读

事务T1,T2

T1读取了已经被T2更新但是没有提交的字段

T2回滚,T1读取的内容无效
不可重复读

事务T1,T2

T1读取了一个字段,然后T2更新了该字段.

之后T1再次读取同一字段,值不同
幻读

事务T1,T2

T1读取了这个表中的某些字段,T2插入了数据

T1再次相同表的同一字段增加了几行

四种隔离级别

READ UNCOMMITED（读未提交数据)

允许事务读取未被其他事务提交的变更.

问题:脏读,不可重复读,幻读
READ COMMITED(读已提交数据)

只允许事务读取已经被其他事务提交的变更,避免脏读.

问题:不可重复的,幻读
REPEATABLE READ(可重复读)

雀稗史无可多次从一个字段中读取相同的值,在此期间,禁止其他事务对这个字段进行更新.

问题:幻读
SERIALIZABLE(串行化)

确保十五从一个表读取相同的行,在此期间,禁止其他事务对该表进行更新操作,所有并发问题都可避免,但是性能低下.

注:

Oracle数据库支持2种事务隔离:READ UNCOMMITED（读未提交数据)和SERIALIZABLE(串行化),默认为READ UNCOMMITED（读未提交数据)
Mysql 支持4种事务隔离,默认:REPEATABLE READ(可重复读)

在MySQL用命令行设置隔离级别

Mysql常用命令

进入mysql

命令行输入:mysql -u用户名 -p密码

修改密码

mysqladmin -u用户名 -p旧密码 password 新密码

添加新用户并赋予相应权限

grant select on 数据库.* to 用户名@登录主机 identified by “密码”

显示所有数据库

show databases

删除数据库

drop database <数据库名>

设置隔离级别

设置当前连接的隔离级别

set transaction isolation level read committed;

设置全局隔离级别

set global transaction isolation level read committed;

Java代码设置隔离级别

conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);

public void testSelect() throws Exception {
    Connection conn = JdbcUtils.getConnection();
    //获取当前隔离级别
    System.out.println(conn.getTransactionIsolation());
    //取消自动提交数据
    conn.setAutoCommit(false);
    //设置数据库隔离级别
    conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
    String sql = "select username,password,reg_date regDate from user where username = ?";
    User user = commonUtils.queryForDifference(conn, User.class, sql, "why");
    System.out.println(user);
}

@Test
public void testUpdae() throws Exception {
    Connection conn = JdbcUtils.getConnection();
    //取消自动提交
    conn.setAutoCommit(false);
    String sql = "update user set username = ? where username = ?";
    commonUtils.update(conn,sql,"love","why");
    Thread.sleep(15000);
    System.out.println("修改结束");
}

JDBC（六）—— 数据库事务