博客
关于我
验证mysql的自动提交事务和手动提交事务(java版)
阅读量:220 次
发布时间:2019-02-28

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

个人理解的一个事务:是一个Connection一系列的操作过程,如果是两个Connection连接在操作,那就是两个事务。

事务的前提:数据库的存储引擎是innodb。

事务的目的:保证数据的安全性。

事务安全

1.自动提交事务:每执行一条sql语句,就同步到数据库中。
2.手动提交事务:执行一系列的sql语句后一起同步到数据库中。

事务的四大特性

A(atomic):原子性,事务中的全部操作是一个整体,要么全部成功,要么全部失败;
C(consistency):一致性:事务开启后,数据表中的数据状态没有变化,因为还没有提交;
I(Isolation):隔离型,多个事务操作是相互隔离,互不影响的;
D(Durability):持久性,事务一旦提交,数据表就发生永久改变.

自动提交事务和手动提交事务的区别:

自动提交事务:

在数据库工具下的测试:

数据库的数据:

数据库的数据

自动提交事务执行select查询的结果:

这里写图片描述

用java代码测试自动提交事务时的测试结果:

@Test    //自动提交事务(隐形事务时)    public void testNotAddAffair(){        Connection con = JDBCTemple.getConnection();        String sql = "select count(1) from sal_table";        int count = 0;        try {            //查询操作            count = JDBCTemple.selectData(con,sql);            System.out.println("(try中)插入前的count=" + count);            //插入操作            String insert = "insert into sal_table(sname,sal) values(?,?)";            Object[] objs = {  "王五", 2000};            JDBCTemple.updateDate(con,insert, objs);            //再次查询操作            count = JDBCTemple.selectData(con,sql);            System.out.println("(try中)插入一条数据以后的count=" + count);            //插入操作            //Object[] objs1 = {"王五他大哥", 2000};            JDBCTemple.updateDate(con,insert, null);            count = JDBCTemple.selectData(con,sql);            System.out.println("(try中)第二次插入后的count=" + count);        } catch (Exception e1) {            count = JDBCTemple.selectData(con,sql);            System.out.println("(catch中)出现异常后count=" + count);            e1.printStackTrace();        }finally{            System.out.println("(finally中)最终count=" + count);        }    }

执行结果如下:

这里写图片描述

结果分析:

1.插入之前,第一次执行select查询语句时,查询到的结果是20,与工具中查的结果是一样的。
2.插入后,第二次执行select查询语句时,查询到的结果为21,说明数据可能插入到数据库中。
3.第二次插入时,因为参数是null,所以出现了空指针异常,没有成功插入到数据库中,sql执行出现异常,转到catch{}代码块中。
4.在catch{}代码块中再次查询,查询到的结果为21,说明第一次数据已经插入到数据库中。
5.在finally{}代码块中再次查询,查询的数据还是21,说明最终第一次数据插入到数据库,但是第二次没有成功插入到数据库中。

显示提交事务

在数据库工具下的测试:
手动提交事务执行select查询的结果
这里写图片描述

用java代码测试手动提交事务时的测试结果:

@Test        public void testAddAffair(){            Connection con = JDBCTemple.getConnection();            String sql = "select count(1) from sal_table";            int count = 0;            try {                //事务的提交方式为手动提交                con.setAutoCommit(false);                //查询操作                count = JDBCTemple.selectData(con,sql);                System.out.println("(try中)插入前的count=" + count);                //插入操作                System.out.println("开始第一次插入数据...");                String insert = "insert into sal_table(sname,sal) values(?,?)";                Object[] objs = {  "王五", 2000};                JDBCTemple.updateDate(con,insert, objs);                System.out.println("第一次插入数据成功!");                //再次查询操作                count = JDBCTemple.selectData(con,sql);                System.out.println("(try中)插入一条数据以后的count=" + count);                //插入操作                System.out.println("开始第二次插入数据....");                //Object[] objs1 = {  "王五他大哥", 2000};                JDBCTemple.updateDate(con,insert, null);                System.out.println("第二次插入数据成功!");                count = JDBCTemple.selectData(con,sql);                System.out.println("(try中)插入两条数据以后的count=" + count);                //提交事务                con.commit();            } catch (Exception e1) {                try {                    con.rollback();                    count = JDBCTemple.selectData(con,sql);                    System.out.println("(catch(try)中)回滚后的count=" + count);                } catch (SQLException e) {                    System.out.println("回滚失败!");                    e.printStackTrace();                }                count = JDBCTemple.selectData(con,sql);                System.out.println("(catch中)的count=" + count);                e1.printStackTrace();            }finally{                count = JDBCTemple.selectData(con,sql);                System.out.println("(finally中)最终count=" + count);            }        }

执行结果如下:

这里写图片描述

结果分析:

很明显的一点是:显示提交事务时,如果出现异常,那么执行结果和未执行sql语句之前的结果是一样的。
1.插入之前,第一次执行select查询语句时,查询到的结果是21,与工具中查的结果是一样的。
2.插入后,第二次执行select查询语句时,查询到的结果为22,说明这条数据可能插入到数据库中。
3.第二次插入时,因为参数是null,所以出现了空指针异常,没有成功插入到数据库中,sql执行出现异常,转到catch{}代码块中。
4.在catch{}代码块中再次查询,查询到的结果为21,又回到了第一条数据没有插入之前的结果。
5.在finally{}代码块中再次查询,查询的数据还是21,说明第一次的插入最终没有同步到数据库中

那么问题出现了,第一次插入的数据最终没有同步到数据库中,那么第一次插入后查询到的数据条数是22,这是为什么?属于幻读吗?

对于以上结果做以下分析:
1.原子性:以上所有的操作共用一个客户端的Connection对象,因为显示提交事务,所以为了保证数据的原子性,try{}代码块中的所有更新 操作属于不可分割的一部分,要么全部成功,要么全部失败。
2.是否属于幻读的问题:如果单单理解幻读史两次读取数据的行数结果不一样,那么这确实是幻读。但是真正幻读的概念是两次读取数据中间的时间间隔内,有其他的事务(其他的Connection连接)对表中数据进行了更新的操作,导致两次数据不一致的问题。在这个小demo中,始终用的是同一个Connection链接,属于同一个事务,所以不属于幻读。
3.理解第一次插入后查询到的数据条数是22,就要理解事务操作时数据库执行过程,请看下图:
这里写图片描述
从上图我们知道这个22的出现是因为:第一次插入的数据写入到了日志文件中,当我们在第一次插入后查询数据时,先从数据库表格中查到数据21,再经过日志文件处理,变成22,此时数据库表格中并没有更新。当第二次插入数据失败时,回滚数据,将日志中的记录删除,最终没有将第一次的数据同步到数据库中,所以最终数据库中的记录数还是21.

你可能感兴趣的文章
memcached高速缓存学习笔记003---利用JAVA程序操作memcached crud操作
查看>>
Memcached:Node.js 高性能缓存解决方案
查看>>
memcache、redis原理对比
查看>>
memset初始化高维数组为-1/0
查看>>
Metasploit CGI网关接口渗透测试实战
查看>>
Metasploit Web服务器渗透测试实战
查看>>
MFC模态对话框和非模态对话框
查看>>
Moment.js常见用法总结
查看>>
MongoDB出现Error parsing command line: unrecognised option ‘--fork‘ 的解决方法
查看>>
mxGraph改变图形大小重置overlay位置
查看>>
MongoDB可视化客户端管理工具之NoSQLbooster4mongo
查看>>
Mongodb学习总结(1)——常用NoSql数据库比较
查看>>
MongoDB学习笔记(8)--索引及优化索引
查看>>
mongodb定时备份数据库
查看>>
mppt算法详解-ChatGPT4o作答
查看>>
mpvue的使用(一)必要的开发环境
查看>>
MQ 重复消费如何解决?
查看>>
mqtt broker服务端
查看>>
MQTT 保留消息
查看>>
MQTT 持久会话与 Clean Session 详解
查看>>