使用spring的声明式事务管理来搭建一个转账项目。
事务的介绍：事务是一系列动作的组合操作，这个组合里面的所有动作要么都完成要么都不完成。
事务的特性（ASID）：
1.原子性：事务中的所有操作要么都完成要么都不完成（如果有一个动作失败会进行回滚操作）。
2.一致性：事务开始和结束之间的中间状态不会被其他事务看到。
3.隔离性：多个事务同时运行时不会相互影响。
4.持久性：一旦事务结束（无论成功与否），不管系统遇到什么错误都不会改变结果。
1、导入相关jar包
image.png
2、编写spring的配置文件
<?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:aop="http://www.springframework.org/schema/aop"
xmlns:context="http://www.springframework.org/schema/context"
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/tx http://www.springframework.org/schema/tx/spring-tx.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">
<!-- 配置开启注解 -->
<context:component-scan base-package="com.lj"/>
<!-- 配置开启aop -->
<aop:aspectj-autoproxy ></aop:aspectj-autoproxy>
<!-- 配置数据库连接池 -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="driverClass" value="com.mysql.jdbc.Driver"/>
<property name="jdbcUrl" value="jdbc:mysql://localhost:3306/spring?characterEncoding=utf-8"/>
<property name="user" value="root"/>
<property name="password" value="1234"/>
</bean>
<!-- 配置jdbcTemplate -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource"/>
</bean>
<!-- 配置事物管理器 -->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/>
</bean>
<!-- 开启事务注解 -->
<tx:annotation-driven transaction-manager="transactionManager"/>
</beans>
3、编写实现类
dao层：
package com.lj.tx;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
@Component
public class AccountDao {
@Autowired
private JdbcTemplate jdbcTemplate;
public void moreMoney(int money,String name){
String sql = "update account set money=money+? where name=?";
jdbcTemplate.update(sql,money,name);
}
public void lessMoney(int money,String name){
String sql = "update account set money=money-? where name=?";
jdbcTemplate.update(sql,money,name);
}
}
service层
package com.lj.tx;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@Transactional
@Component
public class AccountService {
@Autowired
private AccountDao accountDao;
public void transfer(String man1,String man2,int money){
accountDao.lessMoney(money, man1);
accountDao.moreMoney(money, man2);
}
}
可以使用spring的aop编写一个转账日志记录类
package com.lj.tx;
import java.util.Date;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.After;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.stereotype.Component;
@Aspect
@Component
public class LogAccountService {
@After(value="execution(* com.lj.tx.AccountService.*(..))")
public void log(JoinPoint jp){
System.out.println("转账记录"+new Date());
Object args[] = jp.getArgs();
System.out.println("转账人："+args[0]+" 收账人："+args[1]+" 金额："+args[2]);
}
}
测试类：
package com.lj.tx;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Test {
@org.junit.Test
public void txTest(){
ApplicationContext context = new ClassPathXmlApplicationContext("springTX.xml");
AccountService service = (AccountService) context.getBean("accountService");
service.transfer("张三", "李四", 100);
}
}
