Spring 事务注解原理
spring事务实现方式
1. 手动式事务
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class JdbcTransactionExample {
public static void main(String[] args) {
Connection conn = null;
try {
// 1. 创建数据库连接
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydatabase", "username", "password");
// 2. 开启事务
conn.setAutoCommit(false);
// 3. 执行数据库操作
updateData(conn);
insertData(conn);
// 4. 提交事务
conn.commit();
} catch (SQLException e) {
e.printStackTrace();
// 5. 回滚事务
try {
if (conn != null) {
conn.rollback();
}
} catch (SQLException ex) {
ex.printStackTrace();
}
} finally {
// 6. 关闭数据库连接
try {
if (conn != null) {
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
private static void updateData(Connection conn) throws SQLException {
String sql = "UPDATE table_name SET column_name = ? WHERE id = ?";
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
stmt.setString(1, "new value");
stmt.setInt(2, 1);
stmt.executeUpdate();
}
}
private static void insertData(Connection conn) throws SQLException {
String sql = "INSERT INTO table_name (column1, column2) VALUES (?, ?)";
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
stmt.setString(1, "value1");
stmt.setString(2, "value2");
stmt.executeUpdate();
}
}
}
通过 JDBC 原生命令操作事务
2. 声明式事务
public class UserService {
private final DataSource dataSource;
@Autowired
public UserService(DataSource dataSource) {
this.dataSource = dataSource;
}
@Transactional
public void performTransaction() {
Connection conn = null;
try {
conn = dataSource.getConnection();
// 3. 执行数据库操作
updateData(conn);
insertData(conn);
} catch (SQLException e) {
e.printStackTrace();
throw new RuntimeException("Transaction failed.", e);
} finally {
// 6. 关闭数据库连接
try {
if (conn != null) {
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
private void updateData(Connection conn) throws SQLException {
String sql = "UPDATE table_name SET column_name = ? WHERE id = ?";
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
stmt.setString(1, "new value");
stmt.setInt(2, 1);
stmt.executeUpdate();
}
}
private void insertData(Connection conn) throws SQLException {
String sql = "INSERT INTO table_name (column1, column2) VALUES (?, ?)";
try (PreparedStatement stmt = conn.prepareStatement(sql)) {
stmt.setString(1, "value1");
stmt.setString(2, "value2");
stmt.executeUpdate();
}
}
如果有事务注解我们是如何使用的？
- 在方法上添加
@Transactional注解即可。
Q：为什么事务注解这么方便，原理是什么（动态代理）？
- 声明式事务的书写方式就是在方法上加上一个
@Transactional注解，这里涉及到了Spring的AOP思想，即：把当前方法作为一个切面，对其执行前后进行功能增强。 - AOP的原理就是动态代理，通过扫描对应的注解，创建相应的代理对象，并实现功能增强。简单看一下源码：
在try块中代理对象调用了增强方法，catch块中对异常情况进行回滚处理，finally块中清理本次事务的信息。
Q：事务注解有哪些参数可以控制？
-
传播行为（Propagation）：
- REQUIRED(0) ： 默认的事务传播级别，它表示如果当前存在事务，则加入该事务；如果当前没有事务，则创建一个新的事务。
- SUPPORTS(1)：如果当前存在事务，则加入该事务；如果当前没有事务，则以非事务的方式继续运行。
- MANDATORY(2)：如果当前存在事务，则加入该事务；如果当前没有事务，则抛出异常。
- REQUIRES_NEW(3)：表示创建一个新的事务，如果当前存在事务，则把当前事务挂起。也就是说不管外部方法是否开启事务，Propagation.REQUIRES_NEW 修饰的内部方法会新开启自己的事务，且开启的事务相互独立，互不干扰。
- NOT_SUPPORTED(4)：以非事务方式运行，如果当前存在事务，则把当前事务挂起。
- NEVER(5)：以非事务方式运行，如果当前存在事务，则抛出异常。
- NESTED(6)：如果当前存在事务，则创建一个事务作为当前事务的嵌套事务来运行；如果当前没有事务，则该取值等价于 PROPAGATION_REQUIRED。
-
回滚处理（RollbackFor）：控制事务什么时候回滚，如果不配置，默认在遇到RuntimeException和Error时才回滚。
@Transactional(rollbackFor = Exception.class)配置之后，遇见非运行时异常时回滚。
-
隔离级别（Isolation）：与数据库隔离级别一致，默认为Default，直接使用数据库的隔离级别。注意：如果Spring的隔离级别与MySQL不一致，则以Spring为准。
Q：事务失效的场景有哪些？
- 事务方法执行期间出现了异常，但是并未指定rollbackFor：Spring默认只会在遇到error和RunTimeException时才会回滚。
public boolean rollbackOn(Throwable ex) {
return (ex instanceof RuntimeException || ex instanceof Error);
}
- 事务方法执行期间出现了异常，但被方法本身捕获： 使用catch进行捕获之后，Spring无法感知到异常，无法回滚。
- 同一个类种方法互相调用： 因为Spring事务的本质是动态代理，通过生成代理对象去调用方法，并且在方法前后增加事务效果；同一类中的方法调用时，无法使用代理对象调用，使用的是this调用，因此无法实现动态代理效果。
- 方法不是public： Spring源码做了判断，如果不是Public会直接返回。
if (allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) {
return null;
}
- 方法是final或static： 考虑动态代理的实现原理，无论是基于JDK还是CGLib，都不允许final和static的修饰。