一、事务的四大特性(ACID)
1、原子性(atomicity):组成事务的语句形成了一个逻辑单元,不能只执行一部分;
2、一致性(consistency):在事务处理执行前后,数据库与理论值是一致的(数据库完整性约束);
3、隔离性(isolcation):一个事务处理和另一个事务处理相互间互不影响;
4、持续性(durability):事务处理的效果能够被永久保存下来。
二、隔离级别
1、多线程并发执行可能会产生以下三个问题:
脏读(dirty reads):一个事务读取了另一个事务未提交的并行事务写的数据;
不可重复读(non-repeatablereads):一个事务重新读取前面读取过的数据,发现该数据已经被另一个已提交的事务修改过;
幻读(phantom read):一个事务重新执行一个查询,返回一套符合条件的行,发现这些行因为最近提交的事务而发生了改变
2、隔离级别
读未提交(Read uncommitted):未解决
读已提交 (Read committed):已解决:脏读
可重复读 (Repeatable read):已解决:脏读,不可重复读
序列化 (Serializble):已解决:脏读,不可重复读,幻读
3、设置隔离级别
connection.setTransactionlsolation(Connection.事务级别)
MySql默认为度已提交;
三、Java操作
参考:
1.开启事务(非自动提交):用于批量提交或者事务完整性操作。
默认情况下,数据库连接处于自动提交模式(autocommit mode)。每个SQL语句一旦被执行便被提交给数据库。一旦命令被提交,就无法对它进行回滚操作。
在使用事务时,需要关闭这个默认值:
conn.setAutoCommit(false);
现在可以使用通常的方法创建一个语句对象:
Statement stat = conn.createStatement();
然后任意多次调用executeUpdate方法:
stat.executeUpdate(command1);stat.executeUpdate(command2);...
如果执行了所有命令之后没有出错,则调用commit方法:
conn.commit();
如果出现错误,则调用:
conn.rollback();
此时,程序将自动撤销自上次提交以来的所有语句。当事务被SQLException异常中断时,典型的方法就是发起回滚操作。
2.保存点:撤销事务中的部分操作
在使用某些驱动程序时,使用保存点(save point)可以更细粒度地控制回滚操作。创建一个保存点意味着稍候只需返回到这个点,而非事务的开头。例如,
Statement stat = conn.createStatement(); //开启一个事务;rollback()返回这里stat.executeUpdate(command1);Savepoint svpt = conn.setSavepoint(); //设置保存点;rollback(svpt)返回到这里stat.executeUpdate(command2);if(...) conn.rollback(svpt); //撤销command2产生的影响...conn.commit(); //最后不要忘了提交事务,否则前面需要提交保存的操作也将不会保存到数据库中
当不再需要保存点时,必须释放它:
conn.releaseSavepoint(svpt);
3.批量更新:
假设有一个程序需要执行许多INSERT语句,以便将数据填入数据库表中,此时可以使用批量更新的方法来提高程序性能。在使用批量更新(batch update)时,一个语句序列作为一批操作将同时被收集和提交。
注意:使用DatabaseMetaData接口中的supportsBatchUpdates方法可以获知数据库是否支持这种特性。
处于同一批中的语句可以是INSERT、UPDATE和DELETE等操作,也可以是数据库定义语句,如CREATE TABLE和DROP TABLE。但是,在批量处理中添加SELECT语句会抛出异常(从概念上讲,批量处理中的SELECT语句没有意义,因为它会返回结果集,而不更新数据库)。
为了执行批量处理,首先必须使用通常的办法创建一个Statement对象:
Statement stat = conn.createStatement();
现在应该调用addBatch方法,而非executeUpdate方法:
String command = "CREATE TABLE..."stat.addBatch(command);while(...){ command = "INSERT INTO ... VALUES("+...+")"; stat.addBatch(command);}
最后,提交整个批量更新语句:
int[] counts = stat.executeBatch();
调用executeBatch方法将为所有已提交的语句返回一个记录数的数组。
为了在批量模式下正确地处理错误,必须将批量执行的操作视为单个事务。如果批量更新在执行过程中失败,那么必须将它回滚到批量操作开始之前的状态。
首先,关闭自动提交模式,然后收集批量操作,执行并提交该操作,最后恢复最初的自动提交模式:
boolean autoCommit = conn.getAutoCommit();conn.setAutoCommit(false);Statement stat = conn.getStatement();...//keep calling stat.addBatch(...);...stat.executeBatch();conn.commit();conn.setAutoCommit(true);
4.小例子(开启,提交,回滚事务)
//更新学生信息 public void update(Student s) { Connection connection = JDBCUtil_C3P0.getConnection(); try { //关闭事务自动提交(开启事务) connection.setAutoCommit(false); //在数据库中查找学生原本所在班级 int oldclazzid = studentDao.findById(s.getId()).getClazz().getId(); //如果学生班级发生改变,对班级表进行修改 if(oldclazzid !=s.getClazz().getId()){ //为转到的新班级增加一个学生 clazzDao.addClazzCount(connection, s.getClazz().getId()); //为原本所在的旧班级减少一个学生 clazzDao.subClazzCount(connection, oldclazzid); //测试事务,手动抛出一个SQL异常 //throw new SQLException("操作异常"); } //修改学生信息 studentDao.updateStudent(connection, s); //以上所有操作无异常则提交事务 connection.commit(); } catch (SQLException e) { e.printStackTrace(); //一旦事务中有哪一步操作发生异常则进行事务回滚 try { connection.rollback(); } catch (SQLException e1) { e1.printStackTrace(); } }finally{ //关闭连接资源 clazzDao.close(connection); studentDao.close(connection); } }