java Spring5 xml配置文件方式实现声明式事务

news2024/11/15 11:08:53

在java Spring5通过声明式事务(注解方式)完成一个简单的事务操作中我们通过注解方式完成了一个事务操作
那么下面我还是讲一下基于xml实现声明式事务的操作其实在开发过程中大家肯定都喜欢用注解因为他方便
这篇文章中的xml方式大家做个了解就好

还是我们的这张表记号他们的余额然后我们的项目环境还是延续之前的那个
在这里插入图片描述
如果没有看我之前文章的朋友可以先去看一下 java Spring5 搭建操作数据库事务环境跟着把项目环境搭建一下

然后我们来到 senvice 下的 transfAccoSenvice类修改代码如下

package senvice;

import dao.transfAccoDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class transfAccoSenvice {
    @Autowired
    private transfAccoDao TransfAccoDao;

    //转账方法
    public void transferAccounts(int sponsorId, int recipientId, double money){
        Boolean paym = pay(money,sponsorId);
        if(paym){
            int i = 10/0;
            income(money,recipientId);
            System.out.println("交易完成");
        }
    }
    //支出方法
    public Boolean pay(double money,int userId) {
        String vacancies = CheckTheBalance(userId);
        double vacancie = Double.parseDouble(vacancies);
        if(money > vacancie) {
            System.out.println("余额不足");
            return false;
        }
        double settleAccounts = (vacancie - money);
        TransfAccoDao.updateMoney(String.valueOf(settleAccounts),userId);
        return true;
    }
    //收入方法
    public Boolean income(double money,int userId) {
        String vacancies = CheckTheBalance(userId);
        double vacancie = Double.parseDouble(vacancies);
        double settleAccounts = (vacancie + money);
        TransfAccoDao.updateMoney(String.valueOf(settleAccounts),userId);
        return true;
    }
    //查询指定用户余额
    public String CheckTheBalance(int userId){
        return TransfAccoDao.CheckTheBalance(userId);
    }
}

还是在transferAccounts中用0做除数来模仿出一个异常

然后我们修改bean.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:aop="http://www.springframework.org/schema/aop"
       xmlns:tx="http://www.springframework.org/schema/tx"
       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 http://www.springframework.org/schema/aop/spring-aop.xsd">

       <!-- 数据库连接池 -->
       <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
             destroy-method="close">
              <property name="url" value="jdbc:mysql:///test" /><!--对应SQLyog里的数据库-->
              <property name="username" value="root" />            <!-- 用户名 -->
              <property name="password" value="root" />        <!-- 密码 -->
              <property name="driverClassName" value="com.mysql.jdbc.Driver" />
       </bean>

       <!-- JdbcTemplate对象 -->
       <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
              <!--注入dataSource属性-->
              <property name="dataSource" ref="dataSource"></property>
       </bean>

       <context:component-scan base-package="senvice"></context:component-scan>
       <context:component-scan base-package="dao"></context:component-scan>

       <!-->配置事务管理器-->
       <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
              <property name="dataSource" ref= "dataSource"></property>
       </bean>

       <!-- 配置通知 -->
       <tx:advice id="txadvice">
              <tx:attributes>
                     <tx:method name="transfer*"/>
              </tx:attributes>
       </tx:advice>

       <!-- 配置切入点和切面-->
       <aop:config>
              <aop:pointcut id="pt" expression="execution(* senvice.transfAccoSenvice.*(..))"/>
              <aop:advisor  advice-ref="txadvice" pointcut-ref="pt"/>
       </aop:config>
</beans>

关键的几行在于 tx:advic 配置通知然后 tx:method中 name 我想让他指向的是 transferAccounts 就是我们模仿异常的那个方法当然你直接写 name=“transferAccounts” 自然是可以的但我这个transfer* 表示锁定所有以transfer开头的星号代表模糊搜索

然后用aop:pointcut配合切入点表达式锁定了 senvice下的 transfAccoSenvice 中所有的函数 *代表所有 (…)点方法参数

其他类包括测试类都不需要改
然后我们打开测试类运行代码如下
在这里插入图片描述
可以看到我们这里李四被减去200 打印出 11000 说明第一段sql已经执行了但因为事务异常后应该回滚结果所以李四的钱不会少还是11200