mysql
mysql-connector-java
5.1.6
org.aspectj
aspectjweaver
1.8.7
junit
junit
4.12
org.springframework
spring-test
5.0.2.RELEASE
业务层及其实现类：
public interface IAccountService {
void transfer(String sourceName, String targetName, Float money);
}
public class AccountServiceImpl implements IAccountService {
private IAccountDao accountDao;
public void setAccountDao(IAccountDao accountDao) {
this.accountDao = accountDao;
}
public void transfer(String sourceName, String targetName, Float money) {
//1. 根据名称查询转出账户
Account source = accountDao.findAccountByName(sourceName);// 1. 第一次事务，提交
//2. 根据名称查询转入账户
Account target = accountDao.findAccountByName(targetName);// 2. 第二次事务提交
//3. 转出账户减钱
source.setMoney(source.getMoney()-money);
//4. 转入账户加钱
target.setMoney(target.getMoney()+money);
//5. 更新转出账户
accountDao.updateAccount(source); // 3. 第三次事务提交
int i = 1/0; // 4. 报异常
//6. 更新转入账户
accountDao.updateAccount(target); // 5. 事务不执行
}
}
账户持久层及其接口：
public interface IAccountDao {
Account findAccountById(Integer accountId);
Account findAccountByName(String accountName);
void updateAccount(Account account);
}
public class AccountDaoImpl extends JdbcDaoSupport implements IAccountDao {
public Account findAccountById(Integer accountId) {
List accounts = super.getJdbcTemplate().query(“select * from account where id = ?”,new BeanPropertyRowMapper(Account.class),accountId);
return accounts.isEmpty()?null:accounts.get(0);
}
public Account findAccountByName(String accountName) {
List accounts = super.getJdbcTemplate().query(“select * from account where name = ?”,new BeanPropertyRowMapper(Account.class),accountName);
if(accounts.isEmpty()){
return null;
}
if 《一线大厂Java面试题解析+后端开发学习笔记+最新架构讲解视频+实战项目源码讲义》无偿开源 威信搜索公众号【编程进阶路】 (accounts.size()>1){
throw new RuntimeException(“结果集不唯一”);
}
return accounts.get(0);
}
public void updateAccount(Account account) {
super.getJdbcTemplate().update(“update account set name=?,money=? where id=?”,account.getName(),account.getMoney(),account.getId());
}
}
这里配置的是 Spring 内置数据源，当然也可以应用 JdbcTemplate。
bean.xml：
xmlns:xsi=“http://www.w3.org/2001/XMLSchema-instance” 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/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"> [](()二、基于 XML 的事务控制 使用 tx:advice 标签配置事务通知 属性： id：给事务通知起一个唯一标识 transaction-manager：给事务通知提供一个事务管理器引用 aop:config .(…))”> aop:config .(…))”> 在事务的通知 tx:advice 标签的内部 配置事务的属性： isolation： 用于指定事务的隔离级别。默认值是DEFAULT，表示使用数据库的默认隔离级别。 propagation： 用于指定事务的传播行为。默认值是REQUIRED，表示一定会有事务，增删改的选择。查询方法可以选择SUPPORT。 read-only： 用于指定事务是否只读。只有查询方法才能设置为true。默认值时false，表示读写。 timeout： 用于指定事务的超时时间。默认值是-1，表示永不超时。如果指定了数值，则以秒为单位。 rollback-for： 用于指定一个异常，当产生该异常时，事务不回滚，产生其他异常，事务不回滚。没有默认值。表示任何异常都回滚。 no-rollback-for： 用于指定一个异常，当产生该异常时，事务不回滚，产生其他异常时，事务回滚。没有默认值。表示任何异常都回滚。 tx:attributes 最终 bean.xml： xmlns:xsi=“http://www.w3.org/2001/XMLSchema-instance” 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/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">
[](()Spring 中基于 xml 的声明式事务控制配置步骤 ★
