Spring事务管理（转账例子）

搭建转账环境

1、创建数据库，添加数据

Spring 事务管理（转账例子）

2、创建 service 和 dao 类，完成注入关系

Spring 事务管理（转账例子）

（1）service 层又叫业务逻辑层

Spring 事务管理（转账例子）

（2）dao 层，单纯对数据库操作层，在 dao 层不添加业务

Spring 事务管理（转账例子）

（3）需求：Jerry 转账 300 给 Tom

– Jerry 少 300

– Tom 多 300

详细代码，见下面

3、解决问题

（1）如果 Jerry 转出了 300 之后，出现异常（比如银行停电之类的），Tom 不会多 300，钱丢失了

4、解决

（1）添加事务解决，出现异常进行回滚操作

声明式事务管理（xml 配置）

1、配置文件方式使用 aop 思想配置

第一步、配置事务管理器

Spring 事务管理（转账例子）

第二步、配置事务增强

Spring 事务管理（转账例子）

第三步、配置切面

Spring 事务管理（转账例子）

2、完整代码如下

AccountDao.java

package com.liuyanzhao.spring.demo1;
import org.springframework.jdbc.core.JdbcTemplate;
/**
* Created by 言曌 on 2017/8/8.
*/
public class AccountDao {
//注入 JdbcTemplate 对象
private JdbcTemplate jdbcTemplate;
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}
/**
* @param name 转账人
* @param money 转账金额
*/
public void outMoney(String name,double money) {
String sql = “update account set money = money – ? where name = ?”;
jdbcTemplate.update(sql,money,name);
}
/**
* @param name 收账人
* @param money 收账金额
*/
public void inMoney(String name,double money) {
String sql = “update account set money = money + ? where name = ?”;
jdbcTemplate.update(sql,money,name);
}
}

AccountService.java

package com.liuyanzhao.spring.demo1;
/**
* Created by 言曌 on 2017/8/8.
*/
public class AccountService {
//注入 ordersDao 对象
private AccountDao accountDao;
public void setAccountDao(AccountDao accountDao) {
this.accountDao = accountDao;
}
/**
* @param Transfer_person 转账人
* @param account_holder 收账人
* @param money 交易金额
*/
public void accountMoney(String Transfer_person,String account_holder,double money) {
//转账
accountDao.outMoney(Transfer_person,money);
/**
* 假如，转账过程中，出现异常
* 如果我们不配置事务管理，会出现转账成功，收账失败
* 如果我们配置了事务管理，两者必然是同时成功，同时失败
*/
//int i = 10/0;
//收账
accountDao.inMoney(account_holder,money);
}
}

applicationContext.xml 配置文件

<?xml version=“1.0” encoding=“UTF-8”?>
<beans xmlns=“http://www.springframework.org/schema/beans”
xmlns:xsi=“http://www.w3.org/2001/XMLSchema-instance”
xmlns:context=“http://www.springframework.org/schema/context”
xmlns:aop=“http://www.springframework.org/schema/aop”
xmlns:tx=“http://www.springframework.org/schema/tx”
xsi:schemaLocation=”http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd”>
<context:component-scan base-package=“com.liuyanzhao.spring.demo1”/>
<!– 引入外部属性文件 –>
<context:property-placeholder location=“classpath:jdbc.properties”/>
<!– 配置 C3P0 连接池 –>
<bean id=“dataSource” class=“com.mchange.v2.c3p0.ComboPooledDataSource”>
<property name=“driverClass” value=“${jdbc.driverClass}”/>
<property name=“jdbcUrl” value=“${jdbc.url}”/>
<property name=“user” value=“${jdbc.username}”/>
<property name=“password” value=“”/>
</bean>
<!–
id 值可以随便写，与 ref 对应；
name 值是类中的要注入的属性
—>
<bean id=“accountService” class=“com.liuyanzhao.spring.demo1.AccountService”>
<property name=“accountDao” ref=“accountDao”></property>
</bean>
<bean id=“accountDao” class=“com.liuyanzhao.spring.demo1.AccountDao”>
<property name=“jdbcTemplate” ref=“jdbcTemplate”></property>
</bean>
<bean id=“jdbcTemplate” class=“org.springframework.jdbc.core.JdbcTemplate”>
<property name=“dataSource” ref=“dataSource”></property>
</bean>
<!–第一步、配置事务管理器–>
<bean id=“transactionManager” class=“org.springframework.jdbc.datasource.DataSourceTransactionManager”>
<!–注入 DataSource–>
<property name=“dataSource” ref=“dataSource”></property>
</bean>
<!–第二步、配置事务增强–>
<tx:advice id=“txadvice” transaction-manager=“transactionManager”>
<!–做事务操作–>
<tx:attributes>
<!–设置事务操作的方法匹配规则–>
<tx:method name=“account*” propagation=“REQUIRED” />
</tx:attributes>
</tx:advice>
<!–第三步、配置切面–>
<aop:config>
<!–切入点–>
<aop:pointcut id=“pointcut1” expression=“execution(* com.liuyanzhao.spring.demo1.AccountService.*(..))”/>
<!–切面–>
<aop:advisor advice-ref=“txadvice” pointcut-ref=“pointcut1”/>
</aop:config>
</beans>

ServiceTest.java 测试类

package com.liuyanzhao.spring.demo1;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* Created by 言曌 on 2017/8/8.
*/
public class ServiceTest {
@Test
public void test() {
ApplicationContext context =
new ClassPathXmlApplicationContext(“applicationContext.xml”);
AccountService accountService = (AccountService) context.getBean(“accountService”);
//Jerry 给 Tom 转账 300
accountService.accountMoney(“Jerry”,“Tom”,300);
}
}

声明式事务管理（注解）

1、注解的形式更简单

第一步配置事务管理器

Spring 事务管理（转账例子）

第二步配置事务注解

Spring 事务管理（转账例子）

第三步在要使用事务的方法所在类上面添加注解

Spring 事务管理（转账例子）

以上三步替代 xml 方式的三步，相对更简单。

2、完整代码如下

AccountDao.java

同上

ServiceTest.java

同上

AccountService.java

package com.liuyanzhao.spring.demo1;
import org.springframework.transaction.annotation.Transactional;
/**
* Created by 言曌 on 2017/8/8.
*/
@Transactional
public class AccountService {
//注入 ordersDao 对象
private AccountDao accountDao;
public void setAccountDao(AccountDao accountDao) {
this.accountDao = accountDao;
}
/**
* @param Transfer_person 转账人
* @param account_holder 收账人
* @param money 交易金额
*/
public void accountMoney(String Transfer_person,String account_holder,double money) {
//转账
accountDao.outMoney(Transfer_person,money);
/**
* 假如，转账过程中，出现异常
* 如果我们不配置事务管理，会出现转账成功，收账失败
* 如果我们配置了事务管理，两者必然是同时成功，同时失败
*/
//int i = 10/0;
//收账
accountDao.inMoney(account_holder,money);
}
}

applicationContext.xml

<?xml version=“1.0” encoding=“UTF-8”?>
<beans xmlns=“http://www.springframework.org/schema/beans”
xmlns:xsi=“http://www.w3.org/2001/XMLSchema-instance”
xmlns:context=“http://www.springframework.org/schema/context”
xmlns:aop=“http://www.springframework.org/schema/aop”
xmlns:tx=“http://www.springframework.org/schema/tx”
xsi:schemaLocation=”http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd”>
<context:component-scan base-package=“com.liuyanzhao.spring.demo1”/>
<!– 引入外部属性文件 –>
<context:property-placeholder location=“classpath:jdbc.properties”/>
<!– 配置 C3P0 连接池 –>
<bean id=“dataSource” class=“com.mchange.v2.c3p0.ComboPooledDataSource”>
<property name=“driverClass” value=“${jdbc.driverClass}”/>
<property name=“jdbcUrl” value=“${jdbc.url}”/>
<property name=“user” value=“${jdbc.username}”/>
<property name=“password” value=“”/>
</bean>
<!–
id 值可以随便写，与 ref 对应；
name 值是类中的要注入的属性
—>
<bean id=“accountService” class=“com.liuyanzhao.spring.demo1.AccountService”>
<property name=“accountDao” ref=“accountDao”></property>
</bean>
<bean id=“accountDao” class=“com.liuyanzhao.spring.demo1.AccountDao”>
<property name=“jdbcTemplate” ref=“jdbcTemplate”></property>
</bean>
<bean id=“jdbcTemplate” class=“org.springframework.jdbc.core.JdbcTemplate”>
<property name=“dataSource” ref=“dataSource”></property>
</bean>
<!–第一步配置事务管理器–>
<bean id=“transactionManager” class=“org.springframework.jdbc.datasource.DataSourceTransactionManager”>
<property name=“dataSource” ref=“dataSource”></property>
</bean>
<!–第二步开启事务注解–>
<tx:annotation-driven transaction-manager=“transactionManager”/>
</beans>

参考：传智播客视频

搭建转账环境

声明式事务管理（xml 配置）

声明式事务管理（注解）

您必须 登录 才能发表评论！

您必须登录才能发表评论！