索取营销诊断书
QQ
您的位置：上海毫米网络优化公司 > 小程序 > 百度小程序 >
相关推荐recommended
【Spring教程21】Spring框架实战：Spring事务简介、AOP事务管理、代码示例全面详解
作者：mmseoamin日期：2023-12-11

欢迎大家回到《Java教程之Spring30天快速入门》，本教程所有示例均基于Maven实现，如果您对Maven还很陌生，请移步本人的博文《如何在windows11下安装Maven并配置以及 IDEA配置Maven环境》，本文的上一篇为《AOP（面对切面编程）知识总结》

在这里插入图片描述

1 相关概念介绍

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

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

    举个简单的例子，

    • 转账业务会有两次数据层的调用，一次是加钱一次是减钱
    • 把事务放在数据层，加钱和减钱就有两个事务
    • 没办法保证加钱和减钱同时成功或者同时失败
    • 这个时候就需要将事务放在业务层进行处理。

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

      在这里插入图片描述

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

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

      在这里插入图片描述

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

      2 转账案例-需求分析

      接下来通过一个案例来学习下Spring是如何来管理事务的。

      先来分析下需求:

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

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

      为了实现上述的业务需求，我们可以按照下面步骤来实现下:

      ①：数据层提供基础操作，指定账户减钱（outMoney），指定账户加钱（inMoney）

      ②：业务层提供转账操作（transfer），调用减钱与加钱的操作

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

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

      3 转账案例-环境搭建

      步骤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添加相关依赖

      
	
		org.springframework
		spring-context
		5.2.10.RELEASE
	
	
		com.alibaba
		druid
		1.1.16
	
	
		org.mybatis
		mybatis
		3.5.6
	
	
		mysql
		mysql-connector-java
		5.1.47
	
	
		org.springframework
		spring-jdbc
		5.2.10.RELEASE
	
	
		org.mybatis
		mybatis-spring
		1.3.0
	
	
		junit
		junit
		4.12
		test
	
	
		org.springframework
		spring-test
		5.2.10.RELEASE

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

      public class Account implements Serializable {
	private Integer id;
	private String name;
	private Double money;
	//setter...getter...toString...方法略
}

      步骤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) ;
}
	@Service
public 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.Driver
jdbc.url=jdbc:mysql://localhost:3306/spring_db?useSSL=false
jdbc.username=root
jdbc.password=root

      步骤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 ssfb = new SqlSessionFactoryBean();
	ssfb.setTypeAliasesPackage("com.itheima.domain");
	ssfb.setDataSource(dataSource);
	return ssfb;
	}
	@Bean
	public MapperScannerConfigurer mapperScannerConfigurer(){
		MapperScannerConfigurer msc = new MapperScannerConfigurer();
		msc.setBasePackage("com.itheima.dao");
		return msc;
	}
}

      步骤9:创建SpringConfig配置类

      @Configuration
@ComponentScan("com.itheima")
@PropertySource("classpath:jdbc.properties")
@Import({JdbcConfig.class,MybatisConfig.class})
public 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);
	}
}

      最终创建好的项目结构如下:

      在这里插入图片描述

      4 事务管理

      上述环境，运行单元测试类，会执行转账操作，Tom的账户会减少100，Jerry的账户会加100。这是正常情况下的运行结果，但是如果在转账的过程中出现了异常，如:

      @Service
public 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的事务管理就是用来解决这类问题的。

      Spring事务管理具体的实现步骤为:

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

      public interface AccountService {
/**
* 转账操作
* @param out 传出方
* @param in 转入方
* @param money 金额
*/
//配置当前接口方法具有事务
public void transfer(String out,String in ,Double money) ;
}
@Service
public 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("com.itheima")
@PropertySource("classpath:jdbc.properties")
@Import({JdbcConfig.class,MybatisConfig.class
//开启注解式事务驱动
@EnableTransactionManagement
public class SpringConfig {
}

        步骤4:运行测试类

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

        5 知识点总结

        知识点1：@EnableTransactionManagement

        在这里插入图片描述

        知识点2：@Transactional

        在这里插入图片描述

上一篇：快速彻底卸载SQL Server及实例的方法分享

下一篇：MySQL安装教程（详细）

关注我们
扫描二维码
获取更多信息
精彩一手掌握