Spring 温习笔记(六)spring 声明式事务编程

矫情吗；* 2023-01-12 01:46 139阅读 0赞

## 引言 ##

在学习事务之前首先需要学习mysql的事务相关知识，对于事务编程不是很了解的各位大猿请参考小猿的文章[mysql学习笔记（四）mysql事务复习。  
][mysql_mysql_]该文章中详细讲述了有关事务的知识，对于事务而言，有以下几种隔离级别。

- ISOLATION_DEFAULT
    - ISOLATION_READ_UNCOMMITTED
    - ISOLATION_READ_COMMITTED
    - ISOLATION_REPEATABLE_READ
    - ISOLATION_SERIALIZABLE

上文中几种事务的隔离级别的区别一定要清楚，下面小猿将继续深入复习事务知识。

## 编程式事务声明 ##

### 什么是声明式事务控制 ###

spring 声明式事务一般是指采用声明的方式来处理事务，用spring配置文件来声明式的处理事务来代替代码处理事务，也可采用spring注解的方式来来声明的处理事务来代替代码处理事务。

### 三个重要的编程式事务声明类 ###

1.  PlatformTransactionManager  
    PlatformTransactionManager 接口是 spring 的事务管理器，它里面提供了我们常用的操作事务的行为，用于确定不同事务管理器，不同的 Dao 层技术则有不同的实现类，例如：Dao 层技术是jdbc 或 mybatis 时:org.springframework.jdbc.datasource.DataSourceTransactionManager ，当Dao技术是hibernate时:org.springframework.orm.hibernate5.HibernateTransactionManager。
2.  TransactionDefinition  
    封装事务的传播行为，超时时间，和其他属性并告诉事务平台管理器，一下为几个事务传播行为的获取方法。  
    ![在这里插入图片描述][20210129091604769.png]3. TransactionStatus  
    被动封装事务状态信息。  
    ![在这里插入图片描述][20210129092340915.png]

### 事务的传播行为 ###

TransactionDefinition可以设置事务传播行为

*  **REQUIRED：如果当前没有事务，就新建一个事务，如果已经存在一个事务中，加入到这个事务中。一般的选择（默认值）**  
    notes： 如a调b，b看a有没有事务，有事务则加入a的事务，a没有事务的话则b自己创建事务。
 *  **SUPPORTS：支持当前事务，如果当前没有事务，就以非事务方式执行（没有事务）**  
    notes: a调b，b看a有没有事务，有事务则加入a的事务，a没有事务的话则b以非事务运行。
 *  MANDATORY：使用当前的事务，如果当前没有事务，就抛出异常  
    notes: a调b，b看a有没有事务，有事务则加入a的事务，a没有事务的b就抛异常。
 *  REQUERS\_NEW：新建事务，如果当前在事务中，把当前事务挂起。
 *  NOT\_SUPPORTED：以非事务方式执行操作，如果当前存在事务，就把当前事务挂起。
 *  NEVER：以非事务方式运行，如果当前存在事务，抛出异常。
 *  NESTED：如果当前存在事务，则在嵌套事务内执行。如果当前没有事务，则执行 REQUIRED 类似的操作，
 *  也可对TransactionDefinition设置其他属性
 *  超时时间：默认值是-1，没有超时限制。如果有，以秒为单位进行设置
 *  是否只读：建议查询时设置为只读

### 案例详解 ###

#### 数据库连接池 ####

c3p0.driverDriver=com.mysql.jdbc.Driver
    c3p0.url=jdbc:mysql://localhost:3306/test
    c3p0.user=root
    c3p0.password=root
    c3p0.initialSize=5
    c3p0.maxActive=10
    c3p0.maxWait=3000

#### 基础依赖 ####

<dependency>
           <groupId>mysql</groupId>
           <artifactId>mysql-connector-java</artifactId>
           <version>5.1.32</version>
       </dependency>
       <dependency>
           <groupId>com.mchange</groupId>
           <artifactId>c3p0</artifactId>
           <version>0.9.5.2</version>
       </dependency>
       <dependency>
           <groupId>com.alibaba</groupId>
           <artifactId>druid</artifactId>
           <version>1.1.10</version>
       </dependency>
    
       <dependency>
           <groupId>com.twelvemonkeys.common</groupId>
           <artifactId>common-io</artifactId>
           <version>3.4.1</version>
       </dependency>
       <dependency>
           <groupId>commons-fileupload</groupId>
           <artifactId>commons-fileupload</artifactId>
           <version>1.3.3</version>
       </dependency>
    
       <dependency>
           <groupId>org.springframework</groupId>
           <artifactId>spring-jdbc</artifactId>
           <version>5.1.9.RELEASE</version>
       </dependency>
       <dependency>
           <groupId>org.springframework</groupId>
           <artifactId>spring-tx</artifactId>
           <version>5.1.9.RELEASE</version>
       </dependency>
    
       <dependency>
           <groupId>org.springframework</groupId>
           <artifactId>spring-context</artifactId>
           <version>5.1.10.RELEASE</version>
       </dependency>
    
       <dependency>
           <groupId>junit</groupId>
           <artifactId>junit</artifactId>
           <version>4.12</version>
       </dependency>
    
       <dependency>
           <groupId>org.aspectj</groupId>
           <artifactId>aspectjweaver</artifactId>
           <version>1.9.0</version>
       </dependency>
    
       <dependency>
           <groupId>org.springframework</groupId>
           <artifactId>spring-test</artifactId>
           <version>5.1.10.RELEASE</version>
       </dependency>

#### xml配置方式 ####

### dao层 ###

dao接口

public interface AccountDao { 
        boolean out(String outPerson, double money);
        boolean in(String inPerson, double money);
    }

实现类

public class AccountDaoImpl implements AccountDao { 
       /* @Autowired @Qualifier("jdbcTemplate")*/
        private JdbcTemplate jdbcTemplate;
        public void setJdbcTemplate(JdbcTemplate jdbcTemplate) { 
            this.jdbcTemplate = jdbcTemplate;
        }
        public boolean out(String outPerson, double money) { 
            String sql = " update account set balance = balance -? where name = ? " ;
            int update = jdbcTemplate.update(sql, money, outPerson);
            if(update >0){ 
                return true;
            }
            return false;
        }
        
        public boolean in(String inPerson, double money) { 
            String sql = " update account set balance = balance + ? where name = ? " ;
            int update = jdbcTemplate.update(sql, money, inPerson);
            if(update >0){ 
                return true;
            }
            return false;
        }
    }

### service层 ###

接口

public interface AccountService { 
        boolean transfer(String lucy, String tom, double i);
    }

实现类

public class AccountServiceImpl implements AccountService { 
    /* @Autowired @Qualifier("accountDao")*/
        private AccountDao accountDao;
        public void setAccountDao(AccountDao accountDao){ 
            this.accountDao = accountDao;
        }
        public boolean transfer(String outPerson, String inPerson, double money) { 
            boolean flag1=  accountDao.out(outPerson,money);
            /*int i = 2/0;*/
            boolean flag2 = accountDao.in(inPerson,money);
            return flag1&&flag2;
        }
    }

### 应用层 ###

public class AccountController { 
        public static void main(String[] args) { 
            ClassPathXmlApplicationContext app = new 
                    ClassPathXmlApplicationContext("applicationContext.xml");
            AccountService accountService = app.getBean(AccountService.class);
            boolean flag =  accountService.transfer("lucy","tom",1000);
            System.out.println(flag);
        }
    }

xml配置

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop https://www.springframework.org/schema/aop/spring-aop.xsd">
    
        
        <context:property-placeholder location="c3p0.properties"/>
    
        
        <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
            <property name="driverClass" value="${c3p0.driverDriver}"/>
            <property name="jdbcUrl" value="${c3p0.url}"/>
            <property name="user" value="${c3p0.user}"/>
            <property name="password" value="${c3p0.password}"/>
        </bean>
    
        
        <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
            <property name="dataSource" ref="dataSource"/>
        </bean>
    
        <bean id="accountDao" class="com.feitian.xml.dao.Impl.AccountDaoImpl">
            <property name="jdbcTemplate" ref="jdbcTemplate" />
        </bean>
    
        <bean id="accountService " class="com.feitian.xml.service.Impl.AccountServiceImpl">
            <property name="accountDao" ref="accountDao"/>
        </bean>
    
        
        <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
            <property name="dataSource" ref="dataSource"/>
        </bean>
    
        
        <tx:advice id="txAdvice" transaction-manager="transactionManager">
            
            <tx:attributes>
                <tx:method name="transfer" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false" />
                <tx:method name="save" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false" />
                <tx:method name="findAll" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="true" />
                <tx:method name="update" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="true"/>
                <tx:method name="*" isolation="DEFAULT" propagation="REQUIRED" />
            </tx:attributes>
        </tx:advice>
    
        
        <aop:config>
            <aop:pointcut id="txPointcut" expression="execution(* com.feitian.xml.service.*(..))"/>
            <aop:advisor advice-ref="txAdvice" pointcut-ref="txPointcut"/>
        </aop:config>
    </beans>

#### 注解方式 ####

### service层 ###

接口

public interface AccountService { 
        boolean transfer(String lucy, String tom, double i);
    }

实现类

@Service("accountService")
    @Transactional(isolation = Isolation.READ_COMMITTED ,propagation = Propagation.REQUIRED)
    public class AccountServiceImpl implements AccountService { 
        @Autowired
        @Qualifier("accountDao")
        private AccountDao accountDao;
        @Transactional(isolation = Isolation.READ_COMMITTED ,propagation = Propagation.REQUIRED)
        public boolean transfer(String outPerson, String inPerson, double money) { 
            boolean flag1=  accountDao.out(outPerson,money);
            int i = 2/0;
            boolean flag2 = accountDao.in(inPerson,money);
            return flag1&&flag2;
        }
    }

### dao层 ###

接口层

public interface AccountDao { 
        boolean out(String outPerson, double money);
        boolean in(String inPerson, double money);
    }

实现类

@Repository("accountDao")
    public class AccountDaoImpl implements AccountDao { 
    
        @Autowired
        @Qualifier("jdbcTemplate")
        private JdbcTemplate jdbcTemplate;
    
        public boolean out(String outPerson, double money) { 
            String sql = " update account set balance = balance -? where name = ? " ;
            int update = jdbcTemplate.update(sql, money, outPerson);
            if(update >0){ 
                return true;
            }
            return false;
        }
    
        public boolean in(String inPerson, double money) { 
            String sql = " update account set balance = balance + ? where name = ? " ;
            int update = jdbcTemplate.update(sql, money, inPerson);
            if(update >0){ 
                return true;
            }
            return false;
        }
    }

### 应用 ###

public class AccountControllerAnn { 
        public static void main(String[] args) { 
            ClassPathXmlApplicationContext app = new ClassPathXmlApplicationContext("applicationContext_anno.xml");
            AccountService accountService = app.getBean(AccountService.class);
            boolean flag =  accountService.transfer("lucy","tom",1000);
            System.out.println(flag);
        }
    }

### xml配置 ###

notes:注解方式声明声明事务中值得一提transaction注解，该注解的有效性满足就近原则。  
通过以上案例小猿系统的掌握了了有关spring声明式编程的相关内容，开阔了眼界，加深了对声明式事务的见解。

[mysql_mysql_]: https://blog.csdn.net/xueshanfeitian/article/details/109057460?spm=1001.2014.3001.5501
[20210129091604769.png]: /images/20221119/3a7d994b21174f159bf607ef549c6bc9.png
[20210129092340915.png]: /images/20221119/b76802d3dc1c4ce391a12f9bbc12646a.png