java - mysql rollback 原理以及若干疑问
高洛峰
高洛峰 2017-04-17 16:22:39
0
1
408

最近在研究mysql的事务,参考了网上的一些例子写了一些,但是感觉有一点疑问,google后发现还是没找到答案,翻了下源码,还没找到核心关键点,想请大神们,帮忙指个路

1.如果在commit之前发生异常,进入catch里显式rollback,会造成什么隐形后果,如果在catch里去掉rollback,因为也没有commit所以数据还是不会提交,什么情况下会rollback才会真正发挥作用,并且这个作用如何和innodb挂钩的,看了下ConnectionImpl里的rollback源码,还没找到核心重点部分。

2.我写的这段简单的jdbc事务,有没有问题,我也是按照网上的模仿了下,如果有问题,一般的写法是怎么样的

3.commit和rollback实际的作用,原理是什么让事务提交和回滚,我所知道的spring-mybatis是用的aop,但是jdbc都是依赖的数据库的手动提交方式,那回滚呢?

4.Spring里所谓的小事务控制是什么样的,Manager层

5.insertTest1方法是自己try catch 还是抛出去 让外层得到异常 然后rollback

6.感觉insertTest1(con);insertTest2(con);这里有问题,如果insertTest1有异常 直接insertTest2不会执行,也就相当于事务的感觉(要么同时执行,要么都不执行)但是这里是通过异常造成的流程控制,不是真正的事务控制。

7.执行下面代码 insertTest1(),insertTest2()都正常执行(插入符合规范的值,不抛异常),finally里的rollback不起作用,test1,test2里还是有数据,怎么样去最终为什么没起作用,查看了数据库是innodb的

public static void main(String[] args) {
        Connection con = null;
        try {
            con = getConnection();
            con.setAutoCommit(false);
            insertTest1(con);
            insertTest2(con);
            con.commit();
            System.out.println("=======JDBC Transaction commit===========");
        } catch (SQLException e) {
            try {
                con.rollback();
                System.out.println("=======JDBC Transaction rolled back successfully=======");
            } catch (SQLException e1) {
                System.out.println("=======SQL Exception in rollback" + e1.getMessage()); //回滚必要条件:1.同一个transaction 2.connection未关,所以这里要加异常处理
            }
            e.printStackTrace();
        }finally{
            try {
                con.rollback();
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
            if (con != null) {
                try {
                    con.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    
        
    }

Sql


    CREATE TABLE `test1` (
    `id`  bigint(1) NOT NULL DEFAULT 0 ,
    `name`  varchar(1) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL ,
    PRIMARY KEY (`id`)
    )
    
    CREATE TABLE `test2` (
    `id`  bigint(1) NOT NULL DEFAULT 0 ,
    `name`  varchar(1) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL ,
    PRIMARY KEY (`id`)
    )

Java


    package com.mousycoder.server.jdbc;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.PreparedStatement;
    import java.sql.SQLException;
    
    public class JdbcTransaction {
        
        public final static String DB_DRIVER_CLASS = "com.mysql.jdbc.Driver";
        public final static String DB_URL = "jdbc:mysql://xxx.mysql.rds.aliyuncs.com/weitoo";
        public final static String DB_USERNAME = "xxx";
        public final static String DB_PASSWORD = "xxx";
        public static final String INSERT_TEST1 = "INSERT INTO test1(id,name) VALUES(?,?)";
        public static final String INSERT_TEST2 = "INSERT INTO test2(id,name) VALUES(?,?)";
    
        
    
        public static void main(String[] args) {
            Connection con = null;
            try {
                con = getConnection();
                con.setAutoCommit(false);
                insertTest1(con);
                insertTest2(con);
                con.commit();
                System.out.println("=======JDBC Transaction commit===========");
            } catch (SQLException e) {
                try {
                    con.rollback();
                    System.out.println("=======JDBC Transaction rolled back successfully=======");
                } catch (SQLException e1) {
                    System.out.println("=======SQL Exception in rollback" + e1.getMessage()); //回滚必要条件:1.同一个transaction 2.connection未关,所以这里要加异常处理
                }
                e.printStackTrace();
            }finally{
                if (con != null) {
                    try {
                        con.close();
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }
                }
            }
        
            
        }
        
        public static Connection getConnection() {
            Connection conn = null;
                try {
                    Class.forName(DB_DRIVER_CLASS);
                    conn = DriverManager.getConnection(
                            DB_URL,
                            DB_USERNAME, DB_PASSWORD);
                    System.out.println("======DB connection successfully========");
                } catch (ClassNotFoundException | SQLException e) {
                    System.out.println("======DB connection failed=========");
                    e.printStackTrace();
                } 
            return conn;
        }
        
        public static void insertTest1(Connection conn) throws SQLException {
            PreparedStatement stmt;
                stmt = conn.prepareStatement("INSERT INTO test1(id,name) VALUES(?,?)");
                stmt.setInt(1, 1);
                stmt.setString(2, "1"); 
                stmt.executeUpdate();
                System.out.println("======insert into test1 successfully======");
                stmt.close();
        
        }
        
        public static void insertTest2(Connection conn) throws SQLException {
            PreparedStatement stmt;
                stmt = conn.prepareStatement("INSERT INTO test2(id,name) VALUES(?,?)");
                stmt.setInt(1, 1);
                stmt.setString(2, "11"); //故意长度超出
                stmt.executeUpdate();
                System.out.println("======insert into test2 successfully========");
                stmt.close();
            
        }
    }
高洛峰
高洛峰

拥有18年软件开发和IT教学经验。曾任多家上市公司技术总监、架构师、项目经理、高级软件工程师等职务。 网络人气名人讲师,...

全部回覆(1)
洪涛

進行事務處理的時候,MySQL 在開始事務時會切換到一個延緩操作的狀態,這個狀態下操作並不都是立即執行的(通常情況下語句是立即執行的)。而在 commit 時,會將延緩執行的操作都執行進去,並將狀態回歸到及時寫入狀態。同樣的, rollback 時會把延緩寫入的操作拋棄掉,此間申請的鎖釋放掉,並將狀態回歸到及時寫入狀態。

執行rollback 的關鍵在於釋放申請的鎖和回歸及時寫入狀態,而並不是放棄未寫入的操作(你關心的點在未寫入的操作,然而執行與不執行rollback 都沒有操作寫入去,所有你感覺執行或不執行都沒什麼區別)。

有時候你不執行 rollback ,影響不會馬上提現,畢竟你下次呼叫 startTransaction 的時候還是會重置一下狀態。但是如果你在事務之中申請了鎖,或者是其他一些關聯操作,那就會回應你其他與之關聯操作的執行。這就好比是關閉程序,rollback 是正常的關閉流程,你不執行 rollback 就好像是強行關閉程序,難免發生奇怪的問題。

熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板
關於我們 免責聲明 Sitemap
PHP中文網:公益線上PHP培訓,幫助PHP學習者快速成長!