Spring事务的⼏种实现⽅式
前⾔
1.、事务⼏种实现⽅式
（1）编程式事务管理对基于 POJO 的应⽤来说是唯⼀选择。我们需要在代码中调⽤beginTransaction()、commit()、rollback()等事务管理相关的⽅法，这就是编程式事务管理。
（2）基于 TransactionProxyFactoryBean的声明式事务管理
（3）基于 @Transactional 的声明式事务管理
（4）基于Aspectj AOP配置事务
简单总结⼀下编程式事务管理
第⼀种：使⽤ TransactionTemplate 事务模板对象
1. ⾸先：因为我们使⽤的是特定的平台，所以，我们需要创建⼀个合适我们的平台事务管理PlateformTransactionManager。如果使
⽤的是JDBC的话，就⽤DataSourceTransactionManager。注意需要传⼊⼀个DataSource，这样，平台才知道如何和数据库打交道。
2. 第⼆： 为了使得平台事务管理器对我们来说是透明的，就需要使⽤TransactionTemplate。使⽤TransactionTemplat需要传⼊⼀个
PlateformTransactionManager 进⼊，这样，我们就得到了⼀个TransactionTemplate，⽽不⽤关⼼到底使⽤的是什么平台了。
3. 第三： TransactionTemplate 的重要⽅法就是 execute ⽅法，此⽅法就是调⽤TransactionCallback 进⾏处理。实际上我们需要处
理的事情全部都是在 TransactionCallback 中编码的。
4. 第四： 也就是 TransactionCallback 接⼝，我们可以定义⼀个类并实现此接⼝，然后作为ute 的参数。
把需要完成的事情放到 doInTransaction中，并且传⼊⼀个TransactionStatus 参数。此参数是来调⽤回滚的。 也就是说
，
PlateformTransactionManager 和 TransactionTemplate 只需在程序中定义⼀次，⽽TransactionCallback 和
TransactionStatus 就要针对不同的任务多次定义了。
这就是Spring的编程式事务管理。下⾯贴出例⼦代码：
步骤：
1.配置事务管理器
<!-- 配置事务管理器 ，封装了所有的事务操作，依赖于连接池 -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"></property>
</bean>
2.配置事务模板对象
<!-- 配置事务模板对象 -->
<bean id="transactionTemplate" class="ansaction.support.TransactionTemplate">
<property name="transactionManager" ref="transactionManager"></property>
</bean>
3.Test
public class TransactionController {
@Resource
public TransactionTemplate transactionTemplate;
@Resource
public PlatformTransactionManager transactionManager;
@Resource
public DataSource dataSource;
private static JdbcTemplate jdbcTemplate;
private static final String INSERT_SQL = "insert into cc(id) values(?)";
private static final String COUNT_SQL = "select count(*) from cc";
@Test
public void TransactionTemplateTest(){
//获取jdbc核⼼类对象，进⽽操作数据库
jdbcTemplate = new JdbcTemplate(dataSource);
//通过注解获取xml中配置的事务模板对象
transactionTemplate.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);
//重写execute⽅法实现事务管理
@Override
protected void doInTransactionWithoutResult(TransactionStatus status) {
jdbcTemplate.update(INSERT_SQL, "33"); //字段sd为int型，所以插⼊肯定失败报异常，⾃动回滚，代表TransactionTemplate⾃动管理事务 }
});
int i = jdbcTemplate.queryForInt(COUNT_SQL);
System.out.println("表中记录总数："+i);
}
}
第⼆种：使⽤事务管理器 PlatformTransactionManager 对象
此⽅式，可⼿动开启、提交、回滚事务。
**1.只需要：配置事务管理 **
<!-- 配置事务管理 ，封装了所有的事务操作，依赖于连接池 -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"></property>
</bean>
2.Test
public class TransactionController {
@Resource
public PlatformTransactionManager transactionManager;
@Resource
public DataSource dataSource;
private static JdbcTemplate jdbcTemplate;
private static final String INSERT_SQL = "insert into cc(id) values(?)";
private static final String COUNT_SQL = "select count(*) from cc";
@Test
public void showTransaction(){
//定义使⽤隔离级别，传播⾏为
DefaultTransactionDefinition def = new DefaultTransactionDefinition();
def.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);
def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
//事务状态类，通过PlatformTransactionManager的getTransaction⽅法根据事务定义获取；获取事务状态后，Spring根据传播⾏为来决定如何开启事务 TransactionStatus transaction = Transaction(def);
jdbcTemplate = new JdbcTemplate(dataSource);
int i = jdbcTemplate.queryForInt(COUNT_SQL);
System.out.println("表中记录总数："+i);
try {
jdbcTemplate.update(INSERT_SQL,"2");
jdbcTemplate.update(INSERT_SQL,"是否");//出现异常，因为字段为int类型，会报异常，⾃动回滚
transactionManagermit(transaction);
}catch (Exception e){
e.printStackTrace();
}
int i1 = jdbcTemplate.queryForInt(COUNT_SQL);
System.out.println("表中记录总数："+i1);
}
}
以下为声明式事务管理
第三种：基于Aspectj AOP开启事务
1.配置事务通知
<!-- 配置事务增强 -->
<tx:advice id="txAdvice" transaction-manager="transactionManager">
<tx:attributes>
<tx:method name="*" propagation="REQUIRED" rollback-for="Exception" />
</tx:attributes>
</tx:advice>
2.配置织⼊
<!-- aop代理事务。扫描 cn.sys.service 路径下所有的⽅法 -->
<aop:config>
<!-- 扫描 cn.sys.service 路径下所有的⽅法，并加⼊事务处理 -->
<aop:pointcut id="tx" expression="execution(* cn.sys.service.*.*(..))" />
<aop:advisor advice-ref="txAdvice" pointcut-ref="tx" />
</aop:config>
3.这样就算是给 cn.sys.service下所有的⽅法加⼊了事务
第四种：基于注解的 @Transactional 的声明式事务管理
@Transactional
public int saveRwHist(List<RwHist> list) {
return rwDao.saveRwHist(list);
}
以上所需的总配置⽂件
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="/schema/beans"
xmlns:xsi="/2001/XMLSchema-instance"
xmlns:aop="/schema/aop"
xmlns:context="/schema/context"
xmlns:tx="/schema/tx"
xsi:schemaLocation="/schema/beans
/schema/beans/spring-beans-3.2.xsd
/schema/aop
/schema/aop/spring-aop-3.2.xsd
/schema/context
/schema/context/spring-context-3.2.xsd
/schema/tx
/schema/tx/spring-tx-3.2.xsd">
<!-- 创建加载外部Properties⽂件对象 -->
<bean class="org.springframework.fig.PropertyPlaceholderConfigurer">
<property name="location" value="classpath:dataBase.properties"></property>
</bean>
<!-- 引⼊redis属性配置⽂件 -->
<import resource="l"/>
<!-- 配置数据库连接资源 -->
<bean id="dataSource" class="org.apachemons.dbcp.BasicDataSource" scope="singleton"> <property name="driverClassName" value="${driver}"></property>
<property name="url" value="${url}"></property>
<property name="username" value="${username}"></property>
<property name="password" value="${password}"></property>
<property name="maxActive" value="${maxActive}"></property>
<property name="maxIdle" value="${maxIdle}"></property>
<property name="minIdle" value="${minIdle}"></property>
<property name="initialSize" value="${initialSize}"></property>
<property name="maxWait" value="${maxWait}"></property>
spring aop应用场景<property name="removeAbandonedTimeout" value="${removeAbandonedTimeout}"></property> <property name="removeAbandoned" value="${removeAbandoned}"></property>
<!-- 配置sql⼼跳包 -->
<property name= "testWhileIdle" value="true"/>
<property name= "testOnBorrow" value="false"/>
<property name= "testOnReturn" value="false"/>
<property name= "validationQuery" value="select 1"/>
<property name= "timeBetweenEvictionRunsMillis" value="60000"/>
<property name= "numTestsPerEvictionRun" value="${maxActive}"/>
</bean>
<!--创建SQLSessionFactory对象 -->
<bean id="sqlSessionFactory" class="batis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="dataSource"></property>
<property name="configLocation" value="classpath:l"></property>
</bean>
<!-- 创建MapperScannerConfigurer对象 -->
<bean class="batis.spring.mapper.MapperScannerConfigurer">
<property name="basePackage" value="cn.sys.dao"></property>
</bean>
<!-- 配置扫描器 IOC 注解 -->
<context:component-scan base-package="cn.sys" />
<!-- 配置事务管理 ，封装了所有的事务操作，依赖于连接池 -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"></property>
</bean>
<!-- 配置事务模板对象 -->
<bean id="transactionTemplate" class="ansaction.support.TransactionTemplate">
<property name="transactionManager" ref="transactionManager"></property>
</bean>
<!-- 配置事务增强 -->
<tx:advice id="txAdvice" transaction-manager="transactionManager">
<tx:attributes>
<tx:method name="*" propagation="REQUIRED" rollback-for="Exception" />
</tx:attributes>
</tx:advice>
<!-- aop代理事务 -->
<aop:config>
<aop:pointcut id="tx" expression="execution(* cn.sys.service.*.*(..))" />
<aop:advisor advice-ref="txAdvice" pointcut-ref="tx" />
</aop:config>
</beans>
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论