1、spring事务管理器PlatformTransactionManager
1.1、没有spring事务管理器时的操作
(1) jdbc事务
public void save(User user) throws SQLException{
Connection conn=jdbcDao.getConnection();
conn.setAutoCommit(false);
try {
PreparedStatement ps=conn.prepareStatement("insert into user(name,age) value(?,?)");
ps.setString(1,user.getName());
ps.setInt(2,user.getAge());
ps.execute();
conn.commit();
} catch (Exception e) {
e.printStackTrace();
conn.rollback();
}finally{
conn.close();
}
}
说明：1、如何使用事务：上图中获取连接、将连接的自动提交设置为setAutoCommit(false)、手动执行conn.commit() 或 conn.rollback() 这些属于事务代码，而其他的属于业务代码；
2、只有业务代码和事务代码使用的是同一个Connection时，事务的回滚或提交才能起作用，所以要实现【事务代码】和【业务代码】的分离就必须保证他们使用的是同一个Connection；
3、谁在执行事务：Connection连接并不具有执行事务的功能，他只是把一些命令commit()、rollback()传递给数据库，真正使用的是数据库的事务；
4、try-catch块中的是业务代码，如果这里面有多个业务代码（save.()、update()）时没法保证事务的一致性，因为这两个方法使用的是不同的数据库连接Connection；
（2）Hibernate的事务
public void save(User user){
Session session=hibernateDao.openSession();
Transaction tx=null;
try {
tx=session.beginTransaction();
session.save(user);
tx.commit();
} catch (Exception e) {
if(tx!=null){
tx.rollback();
}
}finally{
session.close();
}
}
说明：1、jdbc的Connection肩负了事务的开启、提交和执行sql的功能，为了避免这种问题，Hibernate将事务管理（开始事务、事务提交、回滚）和sql执行独立开来，示例代码中的Transaction是Hibernate自定义的事务，用于管理事务的提交、回滚；
2、Hibernate事务的原理：Session、Transaction内部有一个相同的Connection，这样保证了业务代码和事务代码使用相同的Connection，该Transaction事务的回滚都是依托内部的Connection来完成的；
1.2、spring事务解决的问题
（1） 基于1.1的分析，实现事务功能的方式各不相同，spring针对这种情况进行了统一的抽象，抽象为PlatformTransactionManager事务管理器来进行 事务的提交、回滚等操作，spring事务功能的总接口为：
PlatformTransactionManager：事务管理器；
TransactionDefinition：事务的一些基础信息，如超时时间、隔离级别、传播属性等；
TransactionStatus：事务的一些状态信息，如是否是一个新的事务、是否已被标记为回滚；
1.3、事务管理器PlatformTransactionManager
（1）PlatformTransactionManager接口介绍
public interface PlatformTransactionManager {
//根据事务定义TransactionDefinition，获取事务
TransactionStatus getTransaction(TransactionDefinition var1) throws TransactionException;
//提交事务
void commit(TransactionStatus var1) throws TransactionException;
//回滚事务
void rollback(TransactionStatus var1) throws TransactionException;
}
事务定义包含：事务的隔离级别、事务的传播属性、超时时间设置、是否只读等---事务的隔离级别是数据库本身的事务功能，事务的传播属性是spring自己定义的，数据库没有传播属性这种说法；
（2）TransactionDefinition事务定义
public class DefaultTransactionDefinition implements TransactionDefinition, Serializable {
//事务的传播属性为PROPAGATION_REQUIRED，即当前没有事务的时候，创建一个，如果有则使用当前事务
private int propagationBehavior = PROPAGATION_REQUIRED;
//事务的隔离级别采用底层数据库默认的隔离级别
private int isolationLevel = ISOLATION_DEFAULT;
//超时时间采用底层数据库默认的超时时间
private int timeout = TIMEOUT_DEFAULT;
// 是否只读为false
private boolean readOnly = false;
//略
}
（3）事务接口定义TransactionStatus
//创建一个保存点
Object createSavepoint() throws TransactionException;
// 回滚到保存点
void rollbackToSavepoint(Object var1) throws TransactionException;
//释放保存点
void releaseSavepoint(Object var1) throws TransactionException;
Spring利用保存点功能实现了事务的嵌套，TransactionStatus存储的是事务的一些状态信息。
(4)、TransactionStatus的接口实现为DefaultTransactionStatus
private final Object transaction;
private final boolean newTransaction;
private final boolean newSynchronization;
private final boolean readOnly;
private final boolean debug;
private final Object suspendedResources;
目前jdbc事务是通过Connection来实现事务的，Hibernate是通过他自己定义的Transaction来实现的，各自的事务都不同，所以spring使用Object transaction 的形式来表示各自的事务，事务的回滚、提交都会最终委托给上述的Object transaction 来完成，该Object transaction的选择可以是：DataSourceTransactionObject、HibernateTransactionObject、JpaTransactionObject；
DataSourceTransactionObject：使用DataSource来获取连接，要想实现事务功能必然要使用Connection，DataSourceTransactionObject中有一个ConnectionHolder，他封装了一个Connection；
HibernateTransactionObject：使用Hibernate自定义的Transaction来完成事务操作，含有一个SessionHolder，它里面封装了一个Session，有了Session就可以创建自定义的Transaction了；
（5）事务详细分析
1、通过如下的TransactionStatus getTransaction(@Nullable TransactionDefinition definition) 判断当前事务是否存在
public interface PlatformTransactionManager{
TransactionStatus getTransaction(@Nullable TransactionDefinition definition) ;
void commit(TransactionStatus status);
void rollback(TransactionStatus status)
}
PlatformTransactionManager的实现类AbstractPlatformTransactionManager. getTransaction(TransactionDefinition definition) 判断当前事务是否存在，如果存在则进行事务的传播性处理，如果不存在则新创建一个事务。
1.4、DataSourceTransactionObject
网友评论