保存点的作用是允许事务回滚到指定的保存点位置。在事务中设置好保存点,然后回滚时可以选择回滚到指定的保存点,而不是回滚整个事务!注意,回滚到指定保存点并没有结束事务!!!只有回滚了整个事务才算是结束事务了!
Connection类的设置保存点,以及回滚到指定保存点方法:
l 设置保存点:Savepoint setSavepoint();
l 回滚到指定保存点:void rollback(Savepoint)。
/*
* 李四对张三说,如果你给我转1W,我就给你转100W。
* ==========================================
*
* 张三给李四转1W(张三减去1W,李四加上1W)
* 设置保存点!
* 李四给张三转100W(李四减去100W,张三加上100W)
* 查看李四余额为负数,那么回滚到保存点。
* 提交事务
*/
@Test
public void fun() {
Connection con = null;
PreparedStatement pstmt = null;
try {
con = JdbcUtils.getConnection();
//手动提交
con.setAutoCommit(false);
String sql = "update account set balance=balance+? where name=?";
pstmt = con.prepareStatement(sql);
//操作1(张三减去1W)
pstmt.setDouble(1, -10000);
pstmt.setString(2, "zs");
pstmt.executeUpdate();
//操作2(李四加上1W)
pstmt.setDouble(1, 10000);
pstmt.setString(2, "ls");
pstmt.executeUpdate();
// 设置保存点
Savepoint sp = con.setSavepoint();
//操作3(李四减去100W)
pstmt.setDouble(1, -1000000);
pstmt.setString(2, "ls");
pstmt.executeUpdate();
//操作4(张三加上100W)
pstmt.setDouble(1, 1000000);
pstmt.setString(2, "zs");
pstmt.executeUpdate();
//操作5(查看李四余额)
sql = "select balance from account where name=?";
pstmt = con.prepareStatement(sql);
pstmt.setString(1, "ls");
ResultSet rs = pstmt.executeQuery();
rs.next();
double balance = rs.getDouble(1);
//如果李四余额为负数,那么回滚到指定保存点
if(balance < 0) {
con.rollback(sp);
System.out.println("张三,你上当了!");
}
//提交事务
con.commit();
} catch(Exception e) {
//回滚事务
if(con != null) {
try {
con.rollback();
} catch(SQLException ex) {}
}
throw new RuntimeException(e);
} finally {
//关闭
JdbcUtils.close(con, pstmt);
}
}
事务隔离级别 事务的并发读问题
l 脏读:读取到另一个事务未提交数据;
l 不可重复读:两次读取不一致;
l 幻读(虚读):读到另一事务已提交数据。
2 并发事务问题因为并发事务导致的问题大致有5类,其中两类是更新问题,三类是读问题。
l 脏读(dirty read):读到未提交更新数据,即读取到了脏数据;
l 不可重复读(unrepeatable read):对同一记录的两次读取不一致,因为另一事务对该记录做了修改;
l 幻读(phantom read):对同一张表的两次查询不一致,因为另一事务插入了一条记录;
脏读
事务1:张三给李四转账100元
事务2:李四查看自己的账户
l t1:事务1:开始事务
l t2:事务1:张三给李四转账100元
l t3:事务2:开始事务
l t4:事务2:李四查看自己的账户,看到账户多出100元(脏读)
l t5:事务2:提交事务
l t6:事务1:回滚事务,回到转账之前的状态
不可重复读
事务1:酒店查看两次1048号房间状态
事务2:预订1048号房间
l t1:事务1:开始事务
l t2:事务1:查看1048号房间状态为空闲
l t3:事务2:开始事务
l t4:事务2:预定1048号房间
l t5:事务2:提交事务
l t6:事务1:再次查看1048号房间状态为使用
l t7:事务1:提交事务
对同一记录的两次查询结果不一致!
幻读
事务1:对酒店房间预订记录两次统计
事务2:添加一条预订房间记录
l t1:事务1:开始事务
l t2:事务1:统计预订记录100条
l t3:事务2:开始事务
l t4:事务2:添加一条预订房间记录
l t5:事务2:提交事务
l t6:事务1:再次统计预订记录为101记录
l t7:事务1:提交
对同一表的两次查询不一致!
不可重复读和幻读的区别:
l 不可重复读是读取到了另一事务的更新;
l 幻读是读取到了另一事务的插入(MySQL中无法测试到幻读);
3 四大隔离级别