Spring的事务管理以及转账案例

叁歲伎倆 2022-05-17 12:34 239阅读 0赞

**1.1回顾事务**

1.事务：一组业务操作ABCD，要么全部成功，要么全部不成功。  
2.特性：ACID  
原子性：整体  
一致性：完成  
隔离性：并发  
持久性：结果  
3.隔离问题：  
脏读：一个事务读到另一个事务没有提交的数据  
不可重复读：一个事务读到另一个事务已提交的数据（update）  
虚读(幻读)：一个事务读到另一个事务已提交的数据（insert）  
4.隔离级别：  
read uncommitted：读未提交。存在3个问题  
read committed：读已提交。解决脏读，存在2个问题  
repeatable read：可重复读。解决：脏读、不可重复读，存在1个问题。  
serializable ：串行化。都解决，单事务。  
![这里写图片描述][70]  
**1.5.mysql 事务操作–简单**

ABCD 一个事务
    Connection conn = null;
    try{
      //1 获得连接
      conn = ...;
      //2 开启事务
      conn.setAutoCommit(false);
      A
      B
      C
      D
      //3 提交事务
      conn.commit();
    } catche(){
      //4 回滚事务
      conn.rollback();
    }

**1.6mysql 事务操作–Savepoint**

需求：AB（必须），CD（可选） 
    Connection conn = null;
    Savepoint savepoint = null;  //保存点，记录操作的当前位置，之后可以回滚到指定的位置。（可以回滚一部分）
    try{
      //1 获得连接
      conn = ...;
      //2 开启事务
      conn.setAutoCommit(false);
      A
      B
      savepoint = conn.setSavepoint();
      C
      D
      //3 提交事务
      conn.commit();
    } catche(){
      if(savepoint != null){   //CD异常
         // 回滚到CD之前
         conn.rollback(savepoint);
         // 提交AB
         conn.commit();
      } else{   //AB异常
         // 回滚AB
         conn.rollback();
      }
    }

**1.2事务管理介绍**

**1.2.1导入jar包**  
transaction –> tx  
![这里写图片描述][70 1]  
**1.2.2三个顶级接口**  
![这里写图片描述][70 2]  
1.PlatformTransactionManager 平台事务管理器，spring要管理事务，**必须使用事务管理器**  
进行事务配置时，**必须配置事务管理器。**  
2.TransactionDefinition：事务详情（事务定义、事务属性），spring用于确定事务具体详情，  
例如：隔离级别、是否只读、超时时间 等  
进行事务配置时，\*\*必须配置详情。\*\*spring将配置项封装到该对象实例。  
3.TransactionStatus：事务状态，spring用于记录当前事务运行状态。例如：是否有保存点，事务是否完成。  
spring底层根据状态进行相应操作。

**1.2.3PlatformTransactionManager 事务管理器**

1.导入jar包：需要时平台事务管理器的实现类  
![这里写图片描述][70 3]  
2.常见的事务管理器  
**DataSourceTransactionManager ，jdbc开发时事务管理器，采用JdbcTemplate**  
**HibernateTransactionManager，hibernate开发时事务管理器，整合hibernate**  
![这里写图片描述][70 4]  
1.api详解  
TransactionStatus getTransaction(TransactionDefinition definition) ，事务管理器 通过“事务详情”，获得“事务状态”，从而管理事务。  
void commit(TransactionStatus status) 根据状态提交  
void rollback(TransactionStatus status) 根据状态回滚

**1.2.4TransactionStatus**  
![这里写图片描述][70 5]  
**1.2.5TransactionDefinition**  
![这里写图片描述][70 6]  
传播行为：在两个业务之间如何共享事务。

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

**案例：转账** *案例：转账*

**2.3.1搭建环境**

**创建表**

create database ee19_spring_day03;
    use ee19_spring_day03;
    create table account( id int primary key auto_increment, username varchar(50), money int );
    insert into account(username,money) values('jack','10000');
    insert into account(username,money) values('rose','10000');

**1.3.1.2导入jar包**  
1.核心：4+1  
2.aop ： 4 (aop联盟、spring aop、aspectj规范、spring aspect)  
3.数据库：2 （jdbc/tx）  
4.驱动：mysql  
5.连接池：c3p0  
![这里写图片描述][70 7]  
**2.3.1.3dao层**

public class AccountDaoImpl extends JdbcDaoSupport implements AccountDao { 
    
        @Override
        public void out(String outer, Integer money) {
            this.getJdbcTemplate().update("update account set money = money - ? where username = ?", money,outer);
        }
    
        @Override
        public void in(String inner, Integer money) {
            this.getJdbcTemplate().update("update account set money = money + ? where username = ?", money,inner);
        }
    
    }

**2.3.1.4service层**

public class AccountServiceImpl implements AccountService { 
    
        private AccountDao accountDao;
        public void setAccountDao(AccountDao accountDao) {
            this.accountDao = accountDao;
        }
        @Override
        public void transfer(String outer, String inner, Integer money) {
            accountDao.out(outer, money);
            //断电
    // int i = 1/0;
            accountDao.in(inner, money);
        }
    
    }

**2.3.1.5spring配置**

<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
            <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
            <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/ee19_spring_day03"></property>
            <property name="user" value="root"></property>
            <property name="password" value="1234"></property>
        </bean>
    
        
        <bean id="accountDao" class="com.itheima.dao.impl.AccountDaoImpl">
            <property name="dataSource" ref="dataSource"></property>
        </bean>
        
        <bean id="accountService" class="com.itheima.service.impl.AccountServiceImpl">
            <property name="accountDao" ref="accountDao"></property>
        </bean>

**2.3.1.6测试**

@Test
        public void demo01(){
            String xmlPath = "applicationContext.xml";
            ApplicationContext applicationContext = new ClassPathXmlApplicationContext(xmlPath);
            AccountService accountService =  (AccountService) applicationContext.getBean("accountService");
            accountService.transfer("jack", "rose", 1000);
        }

**2.3.3工厂bean 生成代理：半自动**  
spring提供 管理事务的代理工厂bean TransactionProxyFactoryBean  
1.getBean() 获得代理对象  
2.spring 配置一个代理

**2.3.3.1spring配置**

<bean id="proxyAccountService" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
            <property name="proxyInterfaces" value="com.itheima.service.AccountService"></property>
            <property name="target" ref="accountService"></property>
            <property name="transactionManager" ref="txManager"></property>
            <property name="transactionAttributes">
                <props>
                    <prop key="transfer">PROPAGATION_REQUIRED,ISOLATION_DEFAULT</prop>
                </props>
            </property>
        </bean>
    
    
        
        <bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
            <property name="dataSource" ref="dataSource"></property>
        </bean>

**2.3.3.2测试**  
![这里写图片描述][70 8]

**2.3.4AOP 配置基于xml【掌握】**  
**2.3.4AOP 配置基于xml【掌握】**  
在spring xml 配置aop 自动生成代理，进行事务的管理  
1.配置管理器  
2.配置事务详情  
3.配置aop

<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
            <property name="dataSource" ref="dataSource"></property>
        </bean>
        
        <tx:advice id="txAdvice" transaction-manager="txManager">
            <tx:attributes>
                <tx:method name="transfer" propagation="REQUIRED" isolation="DEFAULT"/>
            </tx:attributes>
        </tx:advice>
        
        <aop:config>
            <aop:advisor advice-ref="txAdvice" pointcut="execution(* com.itheima.service..*.*(..))"/>
        </aop:config>

**2.3.5AOP配置基于注解【掌握】**  
**2.3.5AOP配置基于注解【掌握】**  
**2.3.5AOP配置基于注解【掌握】**  
1.配置事务管理器，将并事务管理器交予spring  
2.在目标类或目标方法添加注解即可 @Transactional

**2.3.5.1spring配置**

<bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
            <property name="dataSource" ref="dataSource"></property>
        </bean>
        
        <tx:annotation-driven transaction-manager="txManager"/>

**2.3.5.2service 层**

@Transactional
    public class AccountServiceImpl implements AccountService {

**2.3.5.3事务详情配置**  
![这里写图片描述][70 9]

@Transactional(propagation=Propagation.REQUIRED , isolation = Isolation.DEFAULT)
    public class AccountServiceImpl implements AccountService {

**over~~~**

[70]: /images/20220517/cf0bc4820172465a9be54609851d9f3b.png
[70 1]: /images/20220517/dc0d70796ef04183a32f5bef00c89a41.png
[70 2]: /images/20220517/428ce5540bf343c39f5fa662b7ecec36.png
[70 3]: /images/20220517/fd061a9d226049d397163d9a28182449.png
[70 4]: /images/20220517/c956c5a03b054635b203ce1bd62d4e16.png
[70 5]: /images/20220517/3658a80262d448db9a3d5f5bdfa4a21d.png
[70 6]: /images/20220517/9748aa335d174a058625c7417e3d7d31.png
[70 7]: /images/20220517/cb2712021797409aa33268544a461e7e.png
[70 8]: /images/20220517/346e30763f8f4ca6a4b5ace099f58598.png
[70 9]: /images/20220517/894fd519487e4d1fbfec03406ca6011a.png