在数据库的事务特性中, 最重要的是隔离性,如果 多个事务共同同时操作 同一个表中数据时, 不考虑 隔离性,
那么就会引发灰常严重的问题, 主要会有以下的三类问题:
第一类: 脏读(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);
}
}
