• Spring事务简介（案例：银行账户转账）

    目录

    事务简介 ：

    银行账户转账代码实现：

    需求：

    分析：

    分析结果：

    一.解决办法(开启Spring事务管理步骤)：

    1.在业务层接口上添加Spring事务管理

     2.设置事务管理器（在Spring jdbc配置文件中）

    3.开启注解式事务驱动

    二.代码实现：

    1.文件大致格式

    2.ServiceAdvise(上一章节的AOP，这一章节没有使用，在Spring配置类里面注释了)

    3.JdbcConfig（jdbc配置类）

    4.SpringConfig（Spring配置类）

    5.MyBatisConfig（MyBatis配置类）

    6.AccountDao（数据层接口）

    7.Account（实体类）

    8.AccountServiceImpl（业务层实现类）

    9.AccountService（业务层接口）

    10.jdbc.properties（jdbc配置信息）

    11.AccountServiceTest（测试类）

    12.pom.xml（Maven配置文件）

    事务简介 ：

    事务作用：在数据层保障一系列的数据库操作同成功同失败（一致性）

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

    进行保障的呢？（通过PlatformTransactionManager接口进行保障）

    PlatformTransactionManager接口

    1. public interface PlatformTransactionManager {
    2.  
    3.     @Override
    4.     public TransactionStatus getTransaction(TransactionDefinition transactionDefinition) throws TransactionException {
    5.         return null;
    6.     }
    7.     @Override
    8.     public void commit(TransactionStatus transactionStatus) throws TransactionException {
    9.  
    10.     }
    11.     @Override
    12.     public void rollback(TransactionStatus transactionStatus) throws TransactionException {
    13.  
    14.     }
    15. }

    PlatformTransactionManager接口的实现类（DataSourceTransactionManager）

    银行账户转账代码实现：

    需求：

    需求：实现任意两个账户之间的转账操作

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

    ps:真正的银行转账有三个用户，a转b，b转c

    分析：

    1.数据层提供基础操作，指定账户减钱（outMoney），指定账户加钱（inmoney）

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

    3.提供两个账号和操作金额执行转账操作

    4.基于Spring整合MyBatis环境搭建上述操作

    分析结果：

    1.程序正常执行时，账户金额A加B减，程序正常

    2.程序出现异常之后，转账失败，但是异常之前的得操作成功，异常之后得操作失败，整体业务失败

    一.解决办法(开启Spring事务管理步骤)：

    1.在业务层接口上添加Spring事务管理

    注意事项：

    1.Spring注解式事务通常添加在业务层接口中，而不会添加在业务层得实现类中，降低耦合

    2.注解式事务可以添加到业务层方法上，表示为此方法开启事务。也可以添加到业务层接口上，表示当前接口的所有方法都开启事务

    1.   @Transactional
    2.     void transfer(String out,String in ,Double money) ;

     2.设置事务管理器（在Spring jdbc配置文件中）

    注意事项：

    1.事务管理器要根据实现技术进行选择

    2.MyBtis框架使用的式Jdbc事务

    1.  //事务管理器
    2.     @Bean
    3.     public PlatformTransactionManager transactionManager(DataSource dataSource){
    4.         //一个bean需要外部资源怎么办，引用注入帮你解决问题
    5.         DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
    6.         transactionManager.setDataSource(dataSource);
    7.         return transactionManager;
    8.     }

    3.开启注解式事务驱动

    1. package com.itheima.config;
    2.  
    3. import org.springframework.context.annotation.*;
    4. import org.springframework.transaction.annotation.EnableTransactionManagement;
    5.  
    6. @Configuration                       //代表了这是个配置类，以此与applicationContext.xml基础配置文件相当
    7. @ComponentScan("com.itheima")        //包扫描
    8. @PropertySource("jdbc.properties")   //加载properties配置文件
    9. @Import({JdbcConfig.class,MybatisConfig.class})            //加载JdbcConfig,MybatisConfig配置类
    10. //@EnableAspectJAutoProxy                                  //启动AOP的注解，切面
    11. @EnableTransactionManagement                               //启动事务管理，加载相对应的事务
    12. public class SpringConfig {
    13. }

    二.代码实现：

    1.文件大致格式

    2.ServiceAdvise(上一章节的AOP，这一章节没有使用，在Spring配置类里面注释了)

    1. package com.itheima.aop;
    2.  
    3. import org.aspectj.lang.ProceedingJoinPoint;
    4. import org.aspectj.lang.Signature;
    5. import org.aspectj.lang.annotation.Around;
    6. import org.aspectj.lang.annotation.Aspect;
    7. import org.aspectj.lang.annotation.Pointcut;
    8. import org.springframework.stereotype.Component;
    9.  
    10.  
    11. public class ServiceAdvise {
    12.  
    13.     //定义切入点,切入点时Service里面的所有方法，
    14.     @Pointcut("execution(* com.itheima.service.*Service.*(..))")
    15.     private void servicePt(){}
    16.  
    17.     //把切入点servicePt()与通知runSpeed()进行绑定
    18.     @Around("ServiceAdvise.servicePt()")
    19.     public void runSpeed(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {
    20.         long star = System.currentTimeMillis();
    21.         Signature signature = proceedingJoinPoint.getSignature();//代表了一次执行的签名信息
    22.         String name = signature.getName();                       //方法名
    23.         Class declaringType = signature.getDeclaringType();      //表示方法的接口名
    24.         for (int i = 0; i < 10000; i++) {
    25.             proceedingJoinPoint.proceed();
    26.         }
    27.         Object proceed = proceedingJoinPoint.proceed();//调取原始操作，即时AccountServiceImpl的返回值
    28.         long end = System.currentTimeMillis();
    29.         System.out.println("业务层接口"+declaringType+"的"+name+"方法，执行万次的测试为"+(end - star)+"ms");
    30.     }
    31.  
    32.  
    33. }

    3.JdbcConfig（jdbc配置类）

    1. package com.itheima.config;
    2.  
    3. import com.alibaba.druid.pool.DruidDataSource;
    4. import org.springframework.beans.factory.annotation.Value;
    5. import org.springframework.context.annotation.Bean;
    6. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    7. import org.springframework.transaction.PlatformTransactionManager;
    8.  
    9. import javax.sql.DataSource;
    10.  
    11. public class JdbcConfig {
    12.  
    13.     @Value("${jdbc.driver}")
    14.     private String driver;
    15.     @Value("${jdbc.url}")
    16.     private String url;
    17.     @Value("${jdbc.username}")
    18.     private String username;
    19.     @Value("${jdbc.password}")
    20.     private String password;
    21.  
    22.     //1.定义一个方法获取响应的bean
    23.     //2.添加@Bean，表示当前方法的返回值是一个bean
    24.     @Bean
    25.     public DataSource dataSource(){
    26.         DruidDataSource ds = new DruidDataSource();
    27.         ds.setDriverClassName(driver);
    28.         ds.setUrl(url);
    29.         ds.setUsername(username);
    30.         ds.setPassword(password);
    31.         return ds;
    32.     }
    33.  
    34.     //事务管理器
    35.     @Bean
    36.     public PlatformTransactionManager transactionManager(DataSource dataSource){
    37.         //一个bean需要外部资源怎么办，引用注入帮你解决问题
    38.         DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
    39.         transactionManager.setDataSource(dataSource);
    40.         return transactionManager;
    41.     }
    42. }

    4.SpringConfig（Spring配置类）

    1. package com.itheima.config;
    2.  
    3. import org.springframework.context.annotation.*;
    4. import org.springframework.transaction.annotation.EnableTransactionManagement;
    5.  
    6. @Configuration                       //代表了这是个配置类，以此与applicationContext.xml基础配置文件相当
    7. @ComponentScan("com.itheima")        //包扫描
    8. @PropertySource("jdbc.properties")   //加载properties配置文件
    9. @Import({JdbcConfig.class,MybatisConfig.class})            //加载JdbcConfig,MybatisConfig配置类
    10. //@EnableAspectJAutoProxy                                  //启动AOP的注解，切面
    11. @EnableTransactionManagement                               //启动事务管理，加载相对应的事务
    12. public class SpringConfig {
    13. }

    5.MyBatisConfig（MyBatis配置类）

    1. package com.itheima.config;
    2.  
    3. import org.mybatis.spring.SqlSessionFactoryBean;
    4. import org.mybatis.spring.mapper.MapperScannerConfigurer;
    5. import org.springframework.context.annotation.Bean;
    6.  
    7. import javax.sql.DataSource;
    8.  
    9. public class MybatisConfig {
    10.     //定义bean，SqlSessionFactoryBean，用于产生SqlSessionFactory对象
    11.     @Bean
    12.     public SqlSessionFactoryBean sqlSessionFactory(DataSource dataSource){//这里得DataSource是代表着引用注入，jdbcConfig
    13.         SqlSessionFactoryBean ssfb = new SqlSessionFactoryBean();
    14.         ssfb.setTypeAliasesPackage("com.itheima.domain");//问实体类的位置，，扫描类型别名的包
    15.         ssfb.setDataSource(dataSource);//替代的是jdbcConfig中的DataSource，也就是详细配置信息
    16.         return ssfb;
    17.     }
    18.     //定义bean，返回MapperScannerConfigurer对象
    19.     @Bean
    20.     public MapperScannerConfigurer mapperScannerConfigurer(){
    21.         MapperScannerConfigurer msc = new MapperScannerConfigurer();
    22.         msc.setBasePackage("com.itheima.dao");//问映射在什么位置，由于注解完成了执行语句，所以不需要有映射文件
    23.         return msc;
    24.     }
    25. }
    26.  
    27.  
    28.

    6.AccountDao（数据层接口）

    1. package com.itheima.dao;
    2.  
    3. import com.itheima.domain.Account;
    4. import org.apache.ibatis.annotations.*;
    5.  
    6. import java.util.List;
    7.  
    8. public interface AccountDao {
    9.  
    10.     @Insert("insert into account(username,password)values(#{username},#{password})")
    11.     void save(Account account);
    12.  
    13.     @Delete("delete from account where id = #{id} ")
    14.     void delete(Integer id);
    15.  
    16.     @Update("update account set username = #{username} , password = #{password} where id = #{id} ")
    17.     void update(Account account);
    18.  
    19.     @Select("select * from account")
    20.     List findAll();
    21.  
    22.     @Select("select * from account where id = #{id} ")
    23.     Account findById(Integer id);
    24.  
    25.     @Update("update account set money = money + #{money} where name = #{name}")
    26.     void inMoney(@Param("name") String name, @Param("money") Double money);
    27.  
    28.     @Update("update account set money = money - #{money} where name = #{name}")
    29.     void outMoney(@Param("name") String name, @Param("money") Double money);
    30.  
    31. }

    7.Account（实体类）

    1. package com.itheima.domain;
    2.  
    3. import java.io.Serializable;
    4.  
    5. public class Account implements Serializable {
    6.  
    7.     private Integer id;
    8.     private String name;
    9.     private Double money;
    10.  
    11.     public Integer getId() {
    12.         return id;
    13.     }
    14.  
    15.     public void setId(Integer id) {
    16.         this.id = id;
    17.     }
    18.  
    19.     public String getName() {
    20.         return name;
    21.     }
    22.  
    23.     public void setName(String name) {
    24.         this.name = name;
    25.     }
    26.  
    27.     public Double getMoney() {
    28.         return money;
    29.     }
    30.  
    31.     public void setMoney(Double money) {
    32.         this.money = money;
    33.     }
    34.  
    35.     @Override
    36.     public String toString() {
    37.         return "Account{" +
    38.                 "id=" + id +
    39.                 ", name='" + name + '\'' +
    40.                 ", money=" + money +
    41.                 '}';
    42.     }
    43. }

    8.AccountServiceImpl（业务层实现类）

    1. package com.itheima.service.impl;
    2.  
    3. import com.itheima.dao.AccountDao;
    4. import com.itheima.domain.Account;
    5. import com.itheima.service.AccountService;
    6. import org.springframework.beans.factory.annotation.Autowired;
    7. import org.springframework.stereotype.Service;
    8.  
    9. import java.util.List;
    10. @Service
    11. public class AccountServiceImpl implements AccountService {
    12.  
    13.     @Autowired
    14.     private AccountDao accountDao;
    15.     @Override
    16.     public void save(Account account) {
    17.         accountDao.save(account);
    18.     }
    19.     @Override
    20.     public void update(Account account){
    21.         accountDao.update(account);
    22.     }
    23.     @Override
    24.     public void delete(Integer id) {
    25.         accountDao.delete(id);
    26.     }
    27.     @Override
    28.     public Account findById(Integer id) {
    29.         return accountDao.findById(id);
    30.     }
    31.     @Override
    32.     public List findAll() {
    33.         return accountDao.findAll();
    34.     }
    35.     @Override
    36.     public void transfer(String out, String in, Double money) {
    37.         accountDao.outMoney(out,money);
    38.         int i = 1/0;
    39.         accountDao.inMoney(in,money);
    40.     }
    41. }

    9.AccountService（业务层接口）

    1. package com.itheima.service;
    2.  
    3. import com.itheima.domain.Account;
    4. import org.springframework.transaction.annotation.Transactional;
    5.  
    6. import java.util.List;
    7.  
    8. public interface AccountService {
    9.  
    10.     void save(Account account);
    11.  
    12.     void delete(Integer id);
    13.  
    14.     void update(Account account);
    15.  
    16.     List findAll();
    17.  
    18.     Account findById(Integer id);
    19.  
    20.     @Transactional
    21.     void transfer(String out,String in ,Double money) ;
    22.  
    23. }

    10.jdbc.properties（jdbc配置信息）

    1. jdbc.driver=com.mysql.jdbc.Driver
    2. jdbc.url= jdbc:mysql://localhost:3306/db1?useSSL=false
    3. jdbc.username=root
    4. jdbc.password=root

    11.AccountServiceTest（测试类）

    1. package com.itheima.service;
    2.  
    3. import com.itheima.config.SpringConfig;
    4. import org.junit.Test;
    5. import org.junit.runner.RunWith;
    6. import org.springframework.beans.factory.annotation.Autowired;
    7. import org.springframework.test.context.ContextConfiguration;
    8. import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
    9.  
    10. @RunWith(SpringJUnit4ClassRunner.class)              //设置专用的类运行器
    11. @ContextConfiguration(classes = SpringConfig.class)  //指定Spring文件的配置类
    12. public class AccountServiceTest {
    13.  
    14.     @Autowired
    15.     private AccountService accountService;
    16.  
    17.     @Test
    18.     public void  testFindById(){
    19.         System.out.println(accountService.findById(2));
    20.     }
    21.  
    22.     @Test
    23.     public  void  testFindAll(){
    24.         System.out.println(accountService.findAll());
    25.     }
    26.  
    27.     @Test
    28.     public void testTransfer() {
    29.         accountService.transfer("刘德华","周杰伦",100D);
    30.     }
    31. }

    12.pom.xml（Maven配置文件）

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <modelVersion>4.0.0modelVersion>
    6.  
    7.     <groupId>org.examplegroupId>
    8.     <artifactId>Spring-demo1-lifeCycleartifactId>
    9.     <version>1.0-SNAPSHOTversion>
    10.  
    11.     <properties>
    12.         <maven.compiler.source>18maven.compiler.source>
    13.         <maven.compiler.target>18maven.compiler.target>
    14.     properties>
    15.  
    16.     <dependencies>
    17.         
    18.         <dependency>
    19.             <groupId>org.springframeworkgroupId>
    20.             <artifactId>spring-contextartifactId>
    21.             <version>5.3.23version>
    22.         dependency>
    23.         <dependency>
    24.             <groupId>javax.annotationgroupId>
    25.             <artifactId>javax.annotation-apiartifactId>
    26.             <version>1.3.2version>
    27.         dependency>
    28.         <dependency>
    29.             <groupId>com.alibabagroupId>
    30.             <artifactId>druidartifactId>
    31.             <version>1.2.11version>
    32.         dependency>
    33.         <dependency>
    34.             <groupId>org.mybatisgroupId>
    35.             <artifactId>mybatisartifactId>
    36.             <version>3.5.6version>
    37.         dependency>
    38.         <dependency>
    39.             <groupId>mysqlgroupId>
    40.             <artifactId>mysql-connector-javaartifactId>
    41.             <version>5.1.46version>
    42.         dependency>
    43.         
    44.         <dependency>
    45.             <groupId>org.springframeworkgroupId>
    46.             <artifactId>spring-jdbcartifactId>
    47.             <version>5.0.0.RELEASEversion>
    48.         dependency>
    49.         
    50.         <dependency>
    51.             <groupId>org.mybatisgroupId>
    52.             <artifactId>mybatis-springartifactId>
    53.             <version>1.3.0version>
    54.         dependency>
    55.         
    56.         <dependency>
    57.             <groupId>junitgroupId>
    58.             <artifactId>junitartifactId>
    59.             <version>4.12version>
    60.             <scope>testscope>
    61.         dependency>
    62.         
    63.         <dependency>
    64.             <groupId>org.springframeworkgroupId>
    65.             <artifactId>spring-testartifactId>
    66.             <version>5.2.10.RELEASEversion>
    67.         dependency>
    68.         
    69.         <dependency>
    70.             <groupId>org.aspectjgroupId>
    71.             <artifactId>aspectjweaverartifactId>
    72.             <version>1.8.8version>
    73.         dependency>
    74.     dependencies>
    75. project>
  • 相关阅读:
    springmvc、springBoot---第三篇
    c语言基础：L1-057 PTA使我精神焕发
    MATLAB中fillmissing函数用法
    SpringBoot+Vue搭建Admin管理系统
    mysql查询速度 limit 1000,10 和limit 10 一样快吗？
    PostgreSQL部署与配置
    ARM：使用汇编完成三个灯流水亮灭
    核货宝：服装店收银系统如何选择？收银系统选购指南！
    【数字通信原理】第五章 基带传输理论
    GEE：根据影像最小值和最大值自适应可视化参数设置
  • 原文地址：https://blog.csdn.net/qq_51272114/article/details/127834039