0%

Spring事务管理

接口介绍

  • PlatformTransactionManager事务管理器
  • TransactionDefinition事务定义信息
    • ISOLATION隔离级别
    • PROPAGATION传播行为
    • TIMEOUT超时信息
  • TransactionStatus事务具体运行状态

编程式事务管理(很少应用)

通过TransactionTemplate手动管理事务,在service使用TransactonTemplate,依赖DataSourceTransactionManager,依赖DataSource构造
spring配置

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
<beans>
<!--配置数据库连接池DataSource-->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="driverClass" value="com.mysql.cj.jdbc.Driver"/>
<property name="jdbcUrl" value="jdbc:mysql://localhost:3306/test?serverTimeZone=GMT&useUnicode=true&characterEncoding=utf8"/>
<property name="user" value="root"/>
<property name="password"value="root"/>
</bean>

<!--在service层注入事务管理模板-->
<bean id="accountService" class="com.ahao.javaeeDemo.service">
<property id="dao" ref="accountDao"/>
<property id="transactionTemplate" ref="transactionTemplate" />
</bean>
<!--配置事务管理模板-->
<bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate">
<property name="transactionManager" ref="transactionManager"/><!--注入事务管理器-->
</bean>
<!--配置事务管理器-->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/><!--注入数据库连接池-->
</bean>
</beans>

service层编写java代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
public class AccountServiceImpl implements AccountService{
private AccountDao dao;
private TransactionTemplate transactionTemplate;
// getter And Setter
public void transfer(String out, String in, Double money){
transactionTemplate.execute(new TransactionCallbackWithoutResult(){
protected void doInTransactionWithoutResult(TransactionStatus status){
dao.outMoney(out, money);
int i = 1/0;//引发异常,事务回滚
dao.inMoney (in, money);
}
});
}
}

声明式事务管理

通过XML配置,代码侵入性小,通过AOP实现
需要导入

基于TransactionProxyFactoryBean的方式(很少应用)

缺点是要为每个增强类添加一个TransactionProxyFactoryBean配置。
spring配置

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
<beans>
<!--配置数据库连接池DataSource-->
<!--service层-->
<bean id="accountService" class="com.ahao.javaeeDemo.service">
<property id="dao" ref="accountDao"/>
</bean>
<!--创建代理对象-->
<bean id="accountServiceProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
<property name="target" ref="accountService"/><!--注入被增强的对象-->
<property name="transactionManager" ref="transactionManager"/><!--注入事务管理器-->
<property name="transactionAttributes">
<props>
<!--<prop key"save*表示以save开头的方法">PROPAGATION(事务传播行为),ISOLATION(事务隔离级别),readOnly(只读),-Exception(发生某些异常回滚),+Exception(发生某些异常不回滚)</prop>-->
<prop key="transfer">PROPAGATION_REQUIRED</prop>
</props>
</property>
</bean>
<!--配置事务管理器-->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/><!--注入数据库连接池-->
</bean>
</beans>

基于AspectJ的XML方式(推荐)

需要导入

spring配置

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
<beans>
<!--配置数据库连接池DataSource-->
<!--service层-->
<bean id="accountService" class="com.ahao.javaeeDemo.service">
<property id="dao" ref="accountDao"/>
</bean>
<!--配置事务的通知-->
<tx:advice id="txAdvice" transaction-manager="transactionManager">
<tx:attributes>
<tx:method name="transfer" propagation="REQUIRED" isolation="DEFAULT" read-only="false" no-rollback-for="MyException1" rollback-for="MyException2" timeout="-1"/>
</tx:attributes>
</tx:advice>
<!--配置切面-->
<aop:config>
<!--配置切入点-->
<aop:pointcut id="pointcut" expression="execution(* com.ahao.javaeeDemo.service.AccountService+.*(..))"/>
<!--配置切面-->
<aop:advisor advice-ref="txAdvice" pointcut-ref="pointcut" />
</aop:config>

<!--配置事务管理器-->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/><!--注入数据库连接池-->
</bean>
</beans>

基于注解的方式(代码侵入性强,配置简单)

spring配置

1
2
3
4
5
6
7
8
9
10
11
12
13
<beans>
<!--配置数据库连接池DataSource-->
<!--service层-->
<bean id="accountService" class="com.ahao.javaeeDemo.service">
<property id="dao" ref="accountDao"/>
</bean>
<!--配置注解驱动-->
<tx:annotation-driven transaction-manager="transactionManager"/>
<!--配置事务管理器-->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/><!--注入数据库连接池-->
</bean>
</beans>

在类上添加注解

1
2
3
4
5
6
7
8
9
10
11
12
13
@Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.DEFAULT,readOnly = false)
public class AccountServiceImpl implements AccountService {
private AccountDaoImpl dao;
public void setDao(AccountDaoImpl dao) {
this.dao = dao;
}
@Override
public void transfer(String out, String in, Double money) {
dao.outMoney(out, money);
int i = 1/0;
dao.inMoney(in, money);
}
}
点击进入云乞讨模式!