博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Java中开启事务操作数据库
阅读量:5887 次
发布时间:2019-06-19

本文共 3811 字,大约阅读时间需要 12 分钟。

hot3.png

一、事务的四大特性(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);         }              }

转载于:https://my.oschina.net/liuyuanyuangogo/blog/1630899

你可能感兴趣的文章
作为菜鸟怎样快速的的学习微信小程序
查看>>
一次诡异的mysql乱码
查看>>
springmvc mybatis shiro构建cms系统
查看>>
MySQL8.0 新特性 top10
查看>>
大数据架构师必读:常见的七种Hadoop和Spark项目案例
查看>>
程序员笔记|如何编写优雅的Dockerfile
查看>>
牛客网上的前端面经
查看>>
从Chronometer中学习控件中的定时器生命周期
查看>>
丽江a货翡翠,揭阳a货翡翠
查看>>
gitbook 入门教程之使用 gitbook.com 在线开发电子书
查看>>
每周一个 Python 模块 | json
查看>>
讲个大部分数据结构和算法教科书中都不会讲的问题
查看>>
mysql优化 | 存储引擎,建表,索引,sql的优化建议
查看>>
阿里P7级架构师总结Spring核心模块及功能汇总
查看>>
Java初学者最佳的学习方法以及会遇到的坑(内含学习资料)!
查看>>
前端开发笔记
查看>>
332 Reconstruct Itinerary[PriorityQueue]
查看>>
java B2B2C 源码 多级分销springmvc mybatis多租户电子商城系统---服务网关zuul
查看>>
2022年杭州亚运会会徽的设计方案
查看>>
masonry 使用 UIView 的动画
查看>>