写点什么

Spring 事务管理

  • 2022 年 9 月 22 日
    黑龙江
  • 本文字数:4910 字

    阅读完需:约 16 分钟

Spring 事务简介

  • 事务作用:在数据层保障一系列的数据库操作同成功同失败

  • Spring 事务作用:在数据层或业务层保障一系列的数据库操作同成功同失败


数据层有事务我们可以理解,为什么业务层也需要处理事务呢?


举个简单的例子,


  • 转账业务会有两次数据层的调用,一次是加钱一次是减钱

  • 把事务放在数据层,加钱和减钱就有两个事务

  • 没办法保证加钱和减钱同时成功或者同时失败

  • 这个时候就需要将事务放在业务层进行处理。


Spring 为了管理事务,提供了一个平台事务管理器PlatformTransactionManager



commit 是用来提交事务,rollback 是用来回滚事务。


PlatformTransactionManager 只是一个接口,Spring 还为其提供了一个具体的实现:



从名称上可以看出,我们只需要给它一个 DataSource 对象,它就可以帮你去在业务层管理事务。其内部采用的是 JDBC 的事务。所以说如果你持久层采用的是 JDBC 相关的技术,就可以采用这个事务管理器来管理你的事务。而 Mybatis 内部采用的就是 JDBC 的事务,所以后期我们 Spring 整合 Mybatis 就采用的这个 DataSourceTransactionManager 事务管理器。


接下来我们通过案例来更深入的了解事务管理

银行转账案例

需求: 实现任意两个账户间转账操作


需求微缩: A 账户减钱,B 账户加钱


为了实现上述的业务需求,我们可以按照下面步骤来实现下:①:数据层提供基础操作,指定账户减钱(outMoney),指定账户加钱(inMoney)


②:业务层提供转账操作(transfer),调用减钱与加钱的操作


③:提供 2 个账号和操作金额执行转账操作


④:基于 Spring 整合 MyBatis 环境搭建上述操作

环境搭建

步骤 1:准备数据库表


之前我们在整合 Mybatis 的时候已经创建了这个表,可以直接使用



create database spring_db character set utf8;use spring_db;create table tbl_account(    id int primary key auto_increment,    name varchar(35),    money double);insert into tbl_account values(1,'Tom',1000);insert into tbl_account values(2,'Jerry',1000);
复制代码


步骤 2:创建项目导入 jar 包


项目的 pom.xml 添加相关依赖


<dependencies>    <dependency>      <groupId>org.springframework</groupId>      <artifactId>spring-context</artifactId>      <version>5.2.10.RELEASE</version>    </dependency>    <dependency>      <groupId>com.alibaba</groupId>      <artifactId>druid</artifactId>      <version>1.1.16</version>    </dependency>
<dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis</artifactId> <version>3.5.6</version> </dependency>
<dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.47</version> </dependency>
<dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>5.2.10.RELEASE</version> </dependency>
<dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis-spring</artifactId> <version>1.3.0</version> </dependency>
<dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.12</version> <scope>test</scope> </dependency>
<dependency> <groupId>org.springframework</groupId> <artifactId>spring-test</artifactId> <version>5.2.10.RELEASE</version> </dependency>
</dependencies>
复制代码


步骤 3:根据表创建模型类


public class Account implements Serializable {    private Integer id;    private String name;    private Double money;
public Integer getId() { return id; }
public void setId(Integer id) { this.id = id; }
public String getName() { return name; }
public void setName(String name) { this.name = name; }
public Double getMoney() { return money; }
public void setMoney(Double money) { this.money = money; }
@Override public String toString() { return "Account{" + "id=" + id + ", name='" + name + '\'' + ", money=" + money + '}'; }}
复制代码


步骤 4:创建 Dao 接口


创建数据层接口


public interface AccountDao {
@Update("update tbl_account set money = money + #{money} where name = #{name}") void inMoney(@Param("name") String name, @Param("money") Double money);
@Update("update tbl_account set money = money - #{money} where name = #{name}") void outMoney(@Param("name") String name, @Param("money") Double money);}
复制代码


步骤 5:创建 Service 接口和实现类


这里创建的是业务层的接口及其实现类


public interface AccountService {    /**     * 转账操作     * @param out 传出方     * @param in 转入方     * @param money 金额     */    public void transfer(String out,String in ,Double money) ;}
@Servicepublic class AccountServiceImpl implements AccountService {
@Autowired private AccountDao accountDao;
public void transfer(String out,String in ,Double money) { accountDao.outMoney(out,money); accountDao.inMoney(in,money); }
}
复制代码


步骤 6:添加 jdbc.properties 文件


jdbc.driver=com.mysql.jdbc.Driverjdbc.url=jdbc:mysql://localhost:3306/spring_db?useSSL=falsejdbc.username=rootjdbc.password=************
复制代码


步骤 7:创建 JdbcConfig 配置类


public class JdbcConfig {    @Value("${jdbc.driver}")    private String driver;    @Value("${jdbc.url}")    private String url;    @Value("${jdbc.username}")    private String userName;    @Value("${jdbc.password}")    private String password;
@Bean public DataSource dataSource(){ DruidDataSource ds = new DruidDataSource(); ds.setDriverClassName(driver); ds.setUrl(url); ds.setUsername(userName); ds.setPassword(password); return ds; }}
复制代码


步骤 8:创建 MybatisConfig 配置类


public class MybatisConfig {
@Bean public SqlSessionFactoryBean sqlSessionFactory(DataSource dataSource){ SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean(); sqlSessionFactoryBean.setTypeAliasesPackage("ModelClasses"); sqlSessionFactoryBean.setDataSource(dataSource); return sqlSessionFactoryBean; }
@Bean public MapperScannerConfigurer mapperScannerConfigurer(){ MapperScannerConfigurer mapperScannerConfigurer = new MapperScannerConfigurer(); mapperScannerConfigurer.setBasePackage("Dao"); return mapperScannerConfigurer; }}
复制代码


步骤 9:创建 SpringConfig 配置类


@Configuration@ComponentScan({"impl","Service","Advice"})@Import({JdbcConfig.class,MybatisConfig.class})@PropertySource("classpath:JDBC.properties")@EnableAspectJAutoProxypublic class SpringConfig {
}
复制代码


步骤 10:编写测试类


@RunWith(SpringJUnit4ClassRunner.class)@ContextConfiguration(classes = SpringConfig.class)public class AccountServiceTest {
@Autowired private AccountService accountService;
@Test public void testTransfer() throws IOException { accountService.transfer("Tom","Jerry",100D); }
}
复制代码


运行后,控制台:



数据库:


事务管理分析

上述环境,运行单元测试类,会执行转账操作,Tom的账户会减少 100,Jerry的账户会加 100。


这是正常情况下的运行结果,但是如果在转账的过程中出现了异常,如:


@Servicepublic class AccountServiceImpl implements AccountService {
@Autowired private AccountDao accountDao;
public void transfer(String out,String in ,Double money) { accountDao.outMoney(out,money); int i = 1/0; accountDao.inMoney(in,money); }
}
复制代码


这个时候就模拟了转账过程中出现异常的情况,正确的操作应该是转账出问题了,Tom应该还是 900,Jerry应该还是 1100,但是真正运行后会发现,并没有像我们想象的那样,Tom账户为 800 而Jerry还是 1100,100 块钱凭空消息了,银行乐疯了。如果把转账换个顺序,银行就该哭了。


不管哪种情况,都是不允许出现的,对刚才的结果我们做一个分析:


①:程序正常执行时,账户金额 A 减 B 加,没有问题


②:程序出现异常后,转账失败,但是异常之前操作成功,异常之后操作失败,整体业务失败


当程序出问题后,我们需要让事务进行回滚,而且这个事务应该是加在业务层上,而 Spring 的事务管理就是用来解决这类问题的。

实现步骤

步骤 1:在需要被事务管理的方法上添加注解


public interface AccountService {    /**     * 转账操作     * @param out 传出方     * @param in 转入方     * @param money 金额     */    //配置当前接口方法具有事务    public void transfer(String out,String in ,Double money) ;}
@Servicepublic class AccountServiceImpl implements AccountService {
@Autowired private AccountDao accountDao; @Transactional public void transfer(String out,String in ,Double money) { accountDao.outMoney(out,money); int i = 1/0; accountDao.inMoney(in,money); }
}
复制代码


注意:


@Transactional 可以写在接口类上、接口方法上、实现类上和实现类方法上


  • 写在接口类上,该接口的所有实现类的所有方法都会有事务

  • 写在接口方法上,该接口的所有实现类的该方法都会有事务

  • 写在实现类上,该类中的所有方法都会有事务

  • 写在实现类方法上,该方法上有事务

  • ==建议写在实现类或实现类的方法上==


步骤 2:在 JdbcConfig 类中配置事务管理器


public class JdbcConfig {    @Value("${jdbc.driver}")    private String driver;    @Value("${jdbc.url}")    private String url;    @Value("${jdbc.username}")    private String userName;    @Value("${jdbc.password}")    private String password;
@Bean public DataSource dataSource(){ DruidDataSource ds = new DruidDataSource(); ds.setDriverClassName(driver); ds.setUrl(url); ds.setUsername(userName); ds.setPassword(password); return ds; }
//配置事务管理器,mybatis使用的是jdbc事务 @Bean public PlatformTransactionManager transactionManager(DataSource dataSource){ DataSourceTransactionManager transactionManager = new DataSourceTransactionManager(); transactionManager.setDataSource(dataSource); return transactionManager; }}
复制代码


注意:事务管理器要根据使用技术进行选择,Mybatis 框架使用的是 JDBC 事务,可以直接使用DataSourceTransactionManager


步骤 3:开启事务注解


在 SpringConfig 的配置类中开启


@Configuration@ComponentScan({"impl","Service","Advice"})@Import({JdbcConfig.class,MybatisConfig.class})@PropertySource("classpath:JDBC.properties")@EnableAspectJAutoProxy@EnableTransactionManagementpublic class SpringConfig {
}
复制代码


然后我们运行测试类:


会发现在转换的业务出现错误后,事务就可以控制回顾,保证数据的正确性。

案例总结

知识点 1:@EnableTransactionManagement


知识点 2:@Transactional



发布于: 刚刚阅读数: 3
用户头像

还未添加个人签名 2022.07.31 加入

还未添加个人简介

评论

发布
暂无评论
Spring事务管理_Java_十八岁讨厌编程_InfoQ写作社区