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（六）—— 数据库事务

JDBC（六）——　数据库事务