最近在研究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();
}
}
進行事務處理的時候,MySQL 在開始事務時會切換到一個延緩操作的狀態,這個狀態下操作並不都是立即執行的(通常情況下語句是立即執行的)。而在 commit 時,會將延緩執行的操作都執行進去,並將狀態回歸到及時寫入狀態。同樣的, rollback 時會把延緩寫入的操作拋棄掉,此間申請的鎖釋放掉,並將狀態回歸到及時寫入狀態。
執行rollback 的關鍵在於釋放申請的鎖和回歸及時寫入狀態,而並不是放棄未寫入的操作(你關心的點在未寫入的操作,然而執行與不執行rollback 都沒有操作寫入去,所有你感覺執行或不執行都沒什麼區別)。
有時候你不執行 rollback ,影響不會馬上提現,畢竟你下次呼叫 startTransaction 的時候還是會重置一下狀態。但是如果你在事務之中申請了鎖,或者是其他一些關聯操作,那就會回應你其他與之關聯操作的執行。這就好比是關閉程序,rollback 是正常的關閉流程,你不執行 rollback 就好像是強行關閉程序,難免發生奇怪的問題。