欢迎访问优讯网!
您当前的位置:首页 > 爱编程

SpringBoot2.0基础案例(12):基于转账案例,演示事务管理操作

时间:2019-07-25 08:42:09  来源:优讯网  作者:小卡司  浏览次数:

一,事务管理简介 

1,基本概念

一组业务操作ABCD,要么全部成功,要么全部不成功。

2,特性:ACID

原子性:本世纪的牛顿
一致性:完成
隔离性:并发
持久性:结果

3,隔离问题

脏读:事务一个读到另一个事务没有提交的数据
不可重复读:一个事务读到另一个事务已提交的数据(更新)
虚读(幻读):一个事务读到另一个事务已提交的数据(插入)

4,隔离级别

读取未提交:读未提交。
读提交:读已提交。解决脏读。
可重读:可重复读。解决:脏读,不可重复读
.serializable:串行化。都解决,单事务。

二,春季管理事务 

1,顶级接口

1)PlatformTransactionManager 
平台事务管理器,spring要管理事务,必须使用事务管理器进行事务配置时,必须配置事务管理器
.2)TransactionDefinition 
事务详情(事务定义,事务属性),spring用于确定事务具体详情,
例如:隔离级别,是否只读,超时时间等
进行事务配置时,必须配置详情.spring将配置项封装到该对象实例
.3)TransactionStatus 
事务状态,spring用于记录当前事务运行状态。例如:是否有保存点,事务是否完成
.spring底层根据状态进行相应操作。

2,事务状态

3,事务定义

PROPAGATION_REQUIRED , required , 必须  【默认值】
    支持当前事务,A如果有事务,B将使用该事务。
    如果A没有事务,B将创建一个新的事务。
PROPAGATION_SUPPORTS ,supports ,支持
    支持当前事务,A如果有事务,B将使用该事务。
    如果A没有事务,B将以非事务执行。
PROPAGATION_MANDATORY,mandatory ,强制
    支持当前事务,A如果有事务,B将使用该事务。
    如果A没有事务,B将抛异常。
PROPAGATION_REQUIRES_NEW , requires_new ,必须新的
    如果A有事务,将A的事务挂起,B创建一个新的事务
    如果A没有事务,B创建一个新的事务
PROPAGATION_NOT_SUPPORTED ,not_supported ,不支持
    如果A有事务,将A的事务挂起,B将以非事务执行
    如果A没有事务,B将以非事务执行
PROPAGATION_NEVER ,never,从不
    如果A有事务,B将抛异常
    如果A没有事务,B将以非事务执行
PROPAGATION_NESTED ,nested ,嵌套
    A和B底层采用保存点机制,形成嵌套事务。
掌握:PROPAGATION_REQUIRED、PROPAGATION_REQUIRES_NEW、PROPAGATION_NESTED

三,SpringBoot2.0管理事务 

基于转账的案例演示,基于德鲁伊连接池配置.druid连接池在文章如下。

SpringBoot2.0基础案例(07):集成Druid连接池,配置监控界面

1,新建转账表

CREATE TABLE account(
  id INT PRIMARY KEY AUTO_INCREMENT,
  username VARCHAR(50),
  money INT
)ENGINE=InnoDB DEFAULT CHARSET=utf8;
INSERT INTO account(username,money) VALUES('jack','10000');
INSERT INTO account(username,money) VALUES('rose','10000');
SELECT * FROM account;

2,基于事务手动管理器

该配置用于测试事务的手动管理。

/**
 * 事物管理器
 */
@Bean(name = "transactionManager")
public PlatformTransactionManager transactionManager (DruidDataSource dataSource){
    LOGGER.info("【transactionManager 初始化...】");
    DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
    transactionManager.setDataSource(dataSource);
    return transactionManager;
}
/**
 * 创建事物手动管理模板
 */
@Bean(name = "transactionTemplate")
public TransactionTemplate transactionTemplate(PlatformTransactionManager transactionManager)
    LOGGER.info("【transactionTemplate 初始化...】");
    TransactionTemplate transactionTemplate = new TransactionTemplate() ;
    transactionTemplate.setTransactionManager(transactionManager);
    return transactionTemplate;
}

3,封装转账接口

接口方法

public interface AccountService {
    /**
     * 汇款
     */
    void out (String outer , Integer money);
    /**
     * 收款
     */
    void in (String inner , Integer money);
}

接口实现

@Service
public class AccountServiceImpl implements AccountService {
    @Resource
    private JdbcTemplate jdbcTemplate ;
    public void out(String outer, Integer money) {
        String sql = "update account set money = money - ? where username = ?";
        jdbcTemplate.update(sql, money,outer);
    }
    public void in(String inner, Integer money) {
        String sql = "update account set money = money + ? where username = ?";
        jdbcTemplate.update(sql, money,inner);
    }
}

如图4所示,封装三个测试接口

测试接口

public interface TradeService {
    /**
     * 转账交易:没有事务管理
     */
    void trade1(String outer ,String inner ,Integer money);
    /**
     * 转账交易:手动管理事务
     */
    void trade2(String outer ,String inner ,Integer money);
    /**
     * 转账交易:注解管理事务
     */
    void trade3(String outer ,String inner ,Integer money);
}

接口实现

@Service
public class TradeServiceImpl implements TradeService {

    @Resource
    private AccountService accountService ;
    @Resource
    private TransactionTemplate transactionTemplate ;

    @Override
    public void trade1(String outer, String inner, Integer money) {
        accountService.out(outer, money);
        // 抛出异常
        int i = 1/0;
        accountService.in(inner, money);
    }

    @Override
    public void trade2(String outer, String inner, Integer money) {
        transactionTemplate.execute(new TransactionCallbackWithoutResult() {
            public void doInTransactionWithoutResult(TransactionStatus arg0) {
                accountService.out(outer, money);
                // 抛出异常
                int i = 1/0;
                accountService.in(inner, money);
            }
        });
    }

    @Transactional(value="transactionManager",propagation= Propagation.REQUIRED)
    @Override
    public void trade3(String outer, String inner, Integer money) {
        accountService.out(outer, money);
        // 抛出异常
        int i = 1/0;
        accountService.in(inner, money);
    }
}

5,编写测试类

@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = TransactionApplication.class)
public class TradeTest {
    @Resource
    private TradeService tradeService ;
    /**
     * 没有事务管理
     * jack 减少了1000块钱,但是rose没得到1000块钱
     * 1    jack    9000
     * 2    rose    10000
     */
    @Test
    public void testTrade1 (){
        tradeService.trade1("jack", "rose", 1000);
    }
    /**
     * 手动管理事务
     * 1    jack    10000
     * 2    rose    10000
     */
    @Test
    public void testTrade2 (){
        tradeService.trade2("jack", "rose", 1000);
    }
    /**
     * 注解管理事务
     * 1    jack    10000
     * 2    rose    10000
     */
    @Test
    public void testTrade3 (){
        tradeService.trade3("jack", "rose", 1000);
    }
}

四,源代码地址 

GitHub地址:知了一笑
https://github.com/cicadasmile/spring-boot-base
码云地址:知了一笑
https://gitee.com/cicadasmile/spring-boot-base
来顶一下
返回首页
返回首页

本文未标明来源,如有侵权请联系发布者删除!


推荐资讯
如何下载旧版centos iso镜像 如何下载迷你mini版的centos镜像
如何下载旧版centos i
计算机的正确使用姿势 电脑痴如何正确的使用电脑
计算机的正确使用姿势
好用的后台管理的前端框架模版H-ui H-ui框架模版分享
好用的后台管理的前端
微信电脑多开方法 无需辅助电脑版微信双开方法分享
微信电脑多开方法 无
相关文章
栏目更新
栏目热门