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

最近在研究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 はトランザクションの開始時に遅延操作状態に切り替わります。この状態では、操作は必ずしもすぐに実行されるわけではありません (通常、ステートメントはすぐに実行されます)。コミットすると、遅延したすべての操作が実行され、タイムリーな書き込み状態に戻ります。同様に、ロールバック中は、遅延した書き込み操作が破棄され、この間に適用されたロックが解放され、タイムリーな書き込み状態に戻ります。

ロールバックを実行する鍵は、未書き込みの操作を放棄するのではなく、適用されていたロックを解除して適時の書き込み状態に戻すことです (注目すべき点は未書き込みの操作ですが、未書き込みの操作を書き込む操作はありません)。ロールバックが実行されるかどうかは関係ありません)。

ロールバックを実行しないと、影響がすぐに取り消されない場合があります。結局のところ、次に startTransaction を呼び出したときに状態がリセットされます。ただし、トランザクションまたはその他の関連操作でロックを申請すると、他の関連操作の実行に応答します。これは、プログラムを終了するのと同じです。ロールバックを実行しないと、必ず異常な問題が発生します。

いいねを押す+0
    最新のダウンロード
    詳細>
    ウェブエフェクト
    公式サイト
    サイト素材
    フロントエンドテンプレート
    私たちについて 免責事項 Sitemap
    PHP中国語ウェブサイト:福祉オンライン PHP トレーニング,PHP 学習者の迅速な成長を支援します!