JDBC学习笔记(7)——事务的隔离级别批量处理
数据库事务的隔离级别
对于同时运行的多个事务, 当这些事务访问数据库中相同的数据时, 如果没有采取必要的隔离机制, 就会导致各种并发问题:
脏读: 对于两个事务 T1, T2, T1 读取了已经被 T2 更新但还没有被提交的字段. 之后, 若 T2 回滚, T1读取的内容就是临时且无效的.
不可重复读: 对于两个事务 T1, T2, T1 读取了一个字段, 然后 T2 更新了该字段. 之后, T1再次读取同一个字段, 值就不同了.
幻读: 对于两个事务 T1, T2, T1 从一个表中读取了一个字段, 然后 T2 在该表中插入了一些新的行. 之后, 如果 T1 再次读取同一个表, 就会多出几行.
数据库事务的隔离性: 数据库系统必须具有隔离并发运行各个事务的能力, 使它们不会相互影响, 避免各种并发问题.
一个事务与其他事务隔离的程度称为隔离级别. 数据库规定了多种事务隔离级别, 不同隔离级别对应不同的干扰程度, 隔离级别越高, 数据一致性就越好, 但并发性越弱
数据库提供的 4 种事务隔离级别:
Oracle 支持的 2 种事务隔离级别:READ COMMITED, SERIALIZABLE. Oracle 默认的事务隔离级别为: READ COMMITED
Mysql 支持 4 中事务隔离级别. Mysql 默认的事务隔离级别为: REPEATABLE READ
具体代码实现:
1 /** 2 * ID1 给 ID2 500钱 3 * 关于事务: 4 * 1.如果多个操作,每个使用自己单独的连接,则无法保证事务 例 test1演示 5 * 2.具体步骤: 6 * 1) 事务开始前,取消Connection 的默认的自动提交 setAutoCommit(false); 7 * 2) 如果事务的操作都成功,那么就提交事务 8 * 3)否则在 try-catch块中回滚 9 * try { 10 * 11 * conn.setAutoCommit(false); 12 * ... 13 * conn.commit(); 14 * }catch{ 15 * ... 16 * conn.rollback(); 17 * } 18 */ 19 @Test 20 public void test2(){ 21 22 Connection conn = null; 23 try { 24 conn = JDBC_Tools.getConnection(); 25 //System.out.println(conn.getAutoCommit()); 26 27 // 1) 取消自动提交 28 conn.setAutoCommit(false); 29 30 String sql = "UPDATE rent set money = " 31 + "money - 500 where id = ?"; 32 33 // 2) 如果事务的操作都成功,那么就提交事务 34 update(conn,sql, 1); 35 36 //int i = 1 / 0; 37 38 sql = "UPDATE rent set money = " 39 + "money + 500 where id = ?"; 40 update(conn,sql, 2); 41 conn.commit(); 42 } catch (Exception e) { 43 e.printStackTrace(); 44 45 // 3)否则在 try-catch块中回滚 46 try { 47 conn.rollback(); 48 } catch (SQLException e1) { 49 e1.printStackTrace(); 50 } 51 52 }finally{ 53 JDBC_Tools.relaseSource(conn, null); 54 } 55 } 56 public static void update(Connection conn,String sql,Object...objs){ 57 58 PreparedStatement ps =null; 59 try { 60 ps = conn.prepareStatement(sql); 61 62 for(int i = 0;i<objs.length;i++){ 63 ps.setObject(i+1, objs[i]); 64 } 65 ps.executeUpdate(); 66 } catch (Exception e) { 67 e.printStackTrace(); 68 }finally{ 69 JDBC_Tools.relaseSource(null, ps); 70 } 71 } 72 73 @Test 74 public void test1() { 75 76 String sql = "UPDATE rent set money = " 77 + "money - 500 where id = ?"; 78 DAO.update(sql, 1); 79 80 int i = 1 / 0; //一旦出现异常, ID1 减了500,但是 ID2 的钱并没有增加 81 82 sql = "UPDATE rent set money = " 83 + "money + 500 where id = ?"; 84 DAO.update(sql, 2); 85 }设置隔离级别 86 87 public static <E> E getForValue(String sql){ 88 89 //1. 得到结果集,该结果只有一行一列 90 Connection conn = null; 91 PreparedStatement ps = null; 92 ResultSet rs = null; 93 try { 94 //1. 获取数据库连接 95 conn = JDBC_Tools.getConnection();//System.out.println(conn.getTransactionIsolation()); 96 conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED); 97 //2. 获取 PreparedStatement 对象 98 ps = conn.prepareStatement(sql); 99 //2. 取得结果 100 rs = ps.executeQuery(); 101 if(rs.next()){ 102 return (E)rs.getObject(1); 103 } 104 }catch(Exception e){ 105 e.printStackTrace(); 106 }finally{ 107 JDBC_Tools.relaseSource(rs,conn, ps); 108 } 109 return null; 110 }
在 MySql 中设置隔离级别
具体代码实现:
1 public static <E> E getForValue(String sql){ 2 3 //1. 得到结果集,该结果只有一行一列 4 Connection conn = null; 5 PreparedStatement ps = null; 6 ResultSet rs = null; 7 try { 8 //1. 获取数据库连接 9 conn = JDBC_Tools.getConnection();//System.out.println(conn.getTransactionIsolation()); 10 conn.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED); 11 //2. 获取 PreparedStatement 对象 12 ps = conn.prepareStatement(sql); 13 //2. 取得结果 14 rs = ps.executeQuery(); 15 if(rs.next()){ 16 return (E)rs.getObject(1); 17 } 18 }catch(Exception e){ 19 e.printStackTrace(); 20 }finally{ 21 JDBC_Tools.relaseSource(rs,conn, ps); 22 } 23 return null; 24 }
启动一个 mysql 程序, 就会获得一个单独的数据库连接. 每个数据库连接都有一个全局变量 @@tx_isolation, 表示当前的事务隔离级别. MySQL 默认的隔离级别为 Repeatable Read
查看当前的隔离级别: SELECT @@tx_isolation;
设置当前 mySQL 连接的隔离级别:
set transaction isolation level read committed;
设置数据库系统的全局的隔离级别:
set global transaction isolation level read committed;
JDBC批量执行
当需要成批插入或者更新记录时。可以采用Java的批量更新机制,这一机制允许多条语句一次性提交给数据库批量处理。通常情况下比单独提交处理更有效率
/*** 向mysql的testJ数据表中插入100000条记录* 测试如何插入用时最短* 版本一:使用Statement*/
版本一:我们使用Statement进行事务的操作
1 @Test 2 public void testBatchWithStatement(){ 3 Connection connection=null; 4 Statement statement=null; 5 String sql; 6 try { 7 connection=JDBCTools.getConnection(); 8 //放到一个事务里面 9 JDBCTools.beginTx(connection); 10 statement=connection.createStatement(); 11 long begin=System.currentTimeMillis(); 12 for(int i=0;i<100000;i++){ 13 sql="insert into testj values("+ 14 (i+1)+", 'name_"+ i+"', '2016-05-08')"; 15 statement.execute(sql); 16 } 17 long end=System.currentTimeMillis(); 18 System.out.println("Time:"+(end-begin)); 19 JDBCTools.commit(connection); 20 } catch (Exception e) { 21 e.printStackTrace(); 22 JDBCTools.rollback(connection); 23 }finally{ 24 JDBCTools.release(null, statement, connection); 25 } 26 }
运行结果:
Time:8991
结论一:我们使用Statement插入100000条记录用时8991;
版本二:我们使用PreparedStatement进行事务的操作
1 @Test 2 public void testBatchWithPreparedStatement() { 3 Connection connection = null; 4 PreparedStatement preparedStatement = null; 5 String sql; 6 try { 7 connection = JDBCTools.getConnection(); 8 // 放到一个事务里面 9 JDBCTools.beginTx(connection); 10 sql = "isnert into testJ values(?,?,?)"; 11 preparedStatement = connection.prepareStatement(sql); 12 long begin = System.currentTimeMillis(); 13 for (int i = 0; i < 100000; i++) { 14 preparedStatement.setInt(1, i + 1); 15 preparedStatement.setString(2, "name_" + i); 16 preparedStatement.setDate(3, 17 new Date(new java.util.Date().getTime())); 18 preparedStatement.execute(); 19 } 20 long end = System.currentTimeMillis(); 21 System.out.println("Time:" + (end - begin)); 22 JDBCTools.commit(connection); 23 } catch (Exception e) { 24 e.printStackTrace(); 25 JDBCTools.rollback(connection); 26 } finally { 27 JDBCTools.release(null, preparedStatement, connection); 28 } 29 }
运行结果:
Time:8563
结论2:因为我这里使用的是mysql数据库进行的操作,插入大量数据的时间性能方面的影响不是很大,如果我们换成oracle数据库或其他大型的关系型数据库,事务执行用时相比版本一的1/4;
版本三:批处理插入数据
1 @Test 2 public void testBatchWithBatch() { 3 Connection connection = null; 4 PreparedStatement preparedStatement = null; 5 String sql=null; 6 try { 7 connection = JDBCTools.getConnection(); 8 // 放到一个事务里面 9 JDBCTools.beginTx(connection); 10 sql = "insert into testJ values(?,?,?)"; 11 preparedStatement = connection.prepareStatement(sql); 12 long begin = System.currentTimeMillis(); 13 for (int i = 0; i < 100000; i++) { 14 preparedStatement.setInt(1, i + 1); 15 preparedStatement.setString(2, "name_" + i); 16 preparedStatement.setDate(3, 17 new Date(new java.util.Date().getTime())); 18 //积攒SQL 19 preparedStatement.addBatch(); 20 //当积攒到一定程度,就统一执行,并且清空先前积攒的SQL 21 if((i+1)%300==0){ 22 //执行 23 preparedStatement.executeBatch(); 24 //清空 25 preparedStatement.clearBatch(); 26 } 27 } 28 //如果插入的记录数不是300的整倍数,再执行一次 29 if(100000%300!=0){ 30 //执行 31 preparedStatement.executeBatch(); 32 //清空 33 preparedStatement.clearBatch(); 34 } 35 long end = System.currentTimeMillis(); 36 System.out.println("Time:" + (end - begin)); 37 JDBCTools.commit(connection); 38 } catch (Exception e) { 39 e.printStackTrace(); 40 JDBCTools.rollback(connection); 41 } finally { 42 JDBCTools.release(null, preparedStatement, connection); 43 } 44 }
运行结果:4587(又提高了,但是还是不明显)
结论三:批处理事务建议采用版本三的方式,再次建议使用oracle数据库做这个插入数据事务的实验,mysql小数据还成,大量的数据也真呵呵了;
本文为博主原创文章,转载请注明出处:http://www.cnblogs.com/ysw-go/
1、本博客的原创原创文章,都是本人平时学习所做的笔记,如有错误,欢迎指正。
2、如有侵犯您的知识产权和版权问题,请通知本人,本人会即时做出处理文章。
3、本博客的目的是知识交流所用,转载自其它博客或网站,作为自己的参考资料的,感谢这些文章的原创人员
JDBC学习笔记(7)——事务的隔离级别批量处理相关推荐
- 数据库事务的四大特性以及事务的隔离级别详解
作者 : fjdingsd 来源 : 博客园 本篇讲诉数据库中事务的四大特性(ACID),并且将会详细地说明事务的隔离级别. 如果一个数据库声称支持事务的操作,那么该数据库必须要具备以下四个特性: ⑴ ...
- 数据库事务的四大特性以及事务的隔离级别
本篇讲诉数据库中事务的四大特性(ACID),并且将会详细地说明事务的隔离级别. 如果一个数据库声称支持事务的操作,那么该数据库必须要具备以下四个特性: ⑴ 原子性(Atomicity) 原子性是指事务 ...
- 事务的特性及事务的隔离级别(转)
原文:http://www.cnblogs.com/fjdingsd/p/5273008.html 本篇讲诉数据库中事务的四大特性(ACID),并且将会详细地说明事务的隔离级别. 如果一个数据库声称支 ...
- JDBC学习笔记03【JDBC事务管理、数据库连接池、JDBCTemplate】
黑马程序员-JDBC文档(腾讯微云)JDBC笔记.pdf:https://share.weiyun.com/Kxy7LmRm JDBC学习笔记01[JDBC快速入门.JDBC各个类详解.JDBC之CR ...
- jdbc事务和事务的隔离级别
转载自 jdbc事务和事务的隔离级别 在jdbc的使用中以最简单的jdbc的使用为例,说明了jdbc的具体用法.然而在通常项目中,需要考虑更多内容,例如事务. 事务,在单个数据处理单元中,存在若干 ...
- java禁止数据库写入事务_Java -- JDBC 事务处理, 事务的隔离级别 脏读 不可重复读 等......
1. 事务指逻辑上的一组操作,组成这组操作的各个单元,要不全部成功,要不全部不成功. 数据库开启事务命令 •start transaction开启事务 •Rollback 回滚事务 •Commit 提 ...
- 事务与隔离级别------《Designing Data-Intensive Applications》读书笔记10
和数据库打交道的程序员绕不开的话题就是:事务,作为一个简化访问数据库的应用程序的编程模型.通过使用事务,应用程序可以忽略某些潜在的错误场景和并发问题,由数据库负责处理它们.而并非每个应用程序都需要事务 ...
- MySQL数据库引擎、数据事务与隔离级别
MySQL数据库引擎 MySQL数据库引擎取决于MySQL在安装的时候是如何被编译的.要添加一个新的引擎,就必须重新编译MYSQL.在缺省情况下,MYSQL支持三个引擎:ISAM.MYISAM和HEA ...
- JSP、Servlet、JDBC学习笔记
WEB的学习 * 服务器 * 网络的架构(面试题) * C/S client/server 客户端/服务器端 例子:QQ 快播 暴风影音 * 优点:交互性好,服务器压力小. * 缺点:客户端更新了,下 ...
最新文章
- P300脑机接口及数据集处理
- 华硕p8b75v主板说明书_我们测了22块主板 发现128GB内存不是想上就上
- 【Linux】一步一步学Linux——perl命令(264)
- XCode的使用心得
- redirect java 配置_Java从后台重定向(redirect)到另一个项目的方法
- android intent bundle传递参数,Android 使用Intent和Bundle传递数据及如何传递enum
- shell和php区别,PHP中exec函数和shell_exec函数的区别
- 社保在广东十三年,在长沙五年,现要退休到哪里办工资多一点?
- inner/left/right/full join on
- python开发安卓盒子_Python盒子:模块、包和程序
- Excel如何快速提取红色字体文本
- 安卓对讲机安装滔滔对讲黑屏起麦黑屏对讲设置
- LDC1314 学习资料
- 推荐一个免费的JSP空间
- Euraka服务注册篇
- 阿里新推出“阿里云网盘”App,有机会干掉“百度网盘”吗?
- 习题2.4 编写程序,从键盘输入两个整数分别给变量x,y,如果x大于y,则输出x及x-y的值;否则,输出y及y-x的值
- 可ping通主机而不能连上主机端口的一般原因
- [share]深入探讨PHP中的内存管理问题
- 演讲如何克服紧张情绪