使用aop解决事务问题（xml版）

忘是亡心i 2022-01-26 11:09 180阅读 0赞

# 一、引入依赖 #

![使用依赖][20190528213054455.png]  
pom.xml代码：

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>com.william</groupId>
        <artifactId>spring_day04_01_tx_aop_xml</artifactId>
        <version>1.0-SNAPSHOT</version>
    
        <properties>
            <maven.compiler.source>1.8</maven.compiler.source>
            <maven.compiler.target>1.8</maven.compiler.target>
        </properties>
        <dependencies>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.47</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-context-support</artifactId>
                <version>5.0.2.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-test</artifactId>
                <version>5.0.2.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>com.mchange</groupId>
                <artifactId>c3p0</artifactId>
                <version>0.9.5.2</version>
            </dependency>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.12</version>
            </dependency>
            <dependency>
                <groupId>commons-dbutils</groupId>
                <artifactId>commons-dbutils</artifactId>
                <version>1.4</version>
            </dependency>
            <dependency>
                <groupId>org.aspectj</groupId>
                <artifactId>aspectjweaver</artifactId>
                <version>1.8.9</version>
            </dependency>
        </dependencies>
    
    </project>

# 二、目录结构 #

![目录结构][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70]

# 三、applicationContext.xml配置文件 #

![重点][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70 1]

<?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"
           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/aop http://www.springframework.org/schema/aop/spring-aop.xsd">
        
        <context:component-scan base-package="com.william"></context:component-scan>
        
        <bean id="QueryRunner" class="org.apache.commons.dbutils.QueryRunner">
        </bean>
        
        <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
            <property name="driverClass" value="${jdbc.driverClass}"></property>
            <property name="jdbcUrl" value="${jdbc.jdbcUrl}"></property>
            <property name="user" value="${jdbc.user}"></property>
            <property name="password" value="${jdbc.password}"></property>
        </bean>
        
      <context:property-placeholder location="classpath:db.properties"></context:property-placeholder>
        
        
        
        <bean id="transactionManager" class="com.william.utils.TransactionManager"></bean>
        
        <aop:config>
            
            <aop:aspect ref="transactionManager">
            
            <aop:pointcut id="pc" expression="execution(* com.william.service.Impl.*.*(..))"></aop:pointcut>
            
                <aop:before method="beganTransaction" pointcut-ref="pc"></aop:before>
                <aop:after-returning method="Commit" pointcut-ref="pc"></aop:after-returning>
                <aop:after-throwing method="rollBack" pointcut-ref="pc"></aop:after-throwing>
                <aop:after method="release" pointcut-ref="pc"></aop:after>
    
            </aop:aspect>
        </aop:config>
    </beans>

# 四、Class文件 #

## 1.AccountDaoImpl ##

代码：

package com.william.Dao.Impl;
    
    import com.william.Dao.AccountDao;
    import com.william.domain.Account;
    import com.william.utils.ConnectionUtils;
    import org.apache.commons.dbutils.QueryRunner;
    import org.apache.commons.dbutils.handlers.BeanHandler;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Repository;
    
    import java.sql.SQLException;
    import java.util.List;
    
    /**
     * @author ：lijunxuan
     * @date ：Created in 2019/5/27  16:00
     * @description ：
     * @version: 1.0
     */
    @Repository
    public class AccountDaoImpl implements AccountDao {
        @Autowired
        ConnectionUtils connectionUtils;
        @Autowired
        QueryRunner queryRunner;
        @Override
        public Account findByUserName(String username ) {
            String sql="select * from account where name = ?";
            try {
             return     queryRunner.query(connectionUtils.getThreadConnection(),sql,new BeanHandler<>(Account.class),username);
            } catch (SQLException e) {
                e.printStackTrace();
            }
            return null;
        }
    
        @Override
        public void Update(Account account) {
         String sql =" update account set money = ? where id =?";
         Object [] params= {account.getMoney(),account.getId()};
            try {
                queryRunner.update(connectionUtils.getThreadConnection(),sql,params);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

## 2.AccountServiceImpl ##

package com.william.service.Impl;
    
    import com.william.Dao.AccountDao;
    import com.william.domain.Account;
    import com.william.service.AccountService;
    import com.william.utils.TransactionManager;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    /**
     * @author ：lijunxuan
     * @date ：Created in 2019/5/27  16:14
     * @description ：
     * @version: 1.0
     */
    @Service
    public class AccountServiceImpl implements AccountService {
    
        @Autowired
        AccountDao accountDao;
        @Override
        public void transfer(String FromMoney, String ToMoney, Float money) {
    
                //开启事务：transactionManager
    
    
                //查询账户名称 两个账户名称
                Account FromuserName = accountDao.findByUserName(FromMoney);
                Account ToUserName = accountDao.findByUserName(ToMoney);
                //修改金额
                FromuserName.setMoney(FromuserName.getMoney()-money);
                ToUserName.setMoney(ToUserName.getMoney()+money);
               //int i=1/0;
                //修改账户表
                accountDao.Update(FromuserName);
                accountDao.Update(ToUserName);
    
        }
    }

## 3.Utils工具类 ##

### （1）ConnectionUtils ###

package com.william.utils;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    import javax.sql.DataSource;
    import java.sql.Connection;
    import java.sql.SQLException;
    
    /**
     * @author ：lijunxuan
     * @date ：Created in 2019/5/27  16:50
     * @description ：
     * @version: 1.0
     */
    @Component
    public class ConnectionUtils {
        private ThreadLocal<Connection> t1=new ThreadLocal();
        @Autowired
        DataSource dataSource;
        /**
         * 用来获取线程中连接对象
         * 1， 在第一次访问该方法时， 线程中没有对象，先获取一个，放入线程
         */
        public Connection getThreadConnection(){
            //获取线程池中的对象
            Connection conn = t1.get();
            if (conn==null){
                try {
                     conn = dataSource.getConnection();
                     t1.set(conn);
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            return conn;
        }
    
        /**
         * 移除线程
         */
        public void remove()
        {
            t1.remove();
        }
    }

### （2）TransactionManager ###

package com.william.utils;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    import java.sql.SQLException;
    
    /**
     * @author ：lijunxuan
     * @date ：Created in 2019/5/27  16:50
     * @description ：
     * @version: 1.0
     */
    @Component
    public class TransactionManager {
        @Autowired
        ConnectionUtils connectionUtils;
        //开启事务
        public void beganTransaction(){
            try {
                connectionUtils.getThreadConnection().setAutoCommit(false);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        //提交事务
        public void Commit(){
            try {
                connectionUtils.getThreadConnection().commit();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        //回滚
        public void rollBack(){
            try {
                connectionUtils.getThreadConnection().rollback();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        //释放资源
        public void release(){
            try {
                connectionUtils.getThreadConnection().setAutoCommit(true);
                connectionUtils.getThreadConnection().close();
                connectionUtils.remove();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

## 4.TestTrasfer测试类 ##

package com.william;
    
    import com.william.service.AccountService;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    import org.springframework.stereotype.Repository;
    import org.springframework.test.context.ContextConfiguration;
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
    
    /**
     * @author ：lijunxuan
     * @date ：Created in 2019/5/27  16:22
     * @description ：
     * @version: 1.0
     */
    @Component
    @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration("classpath:applicationContext.xml")
    public class TestTrasfer {
        @Autowired
        AccountService accountService;
        @Test
        public void testTrasferMoney(){
    
            accountService.transfer("william","william-Li",500f);
        }
    }

[20190528213054455.png]: /images/20220126/e88ff11f99b24af8a74c65b510a9a8ab.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70]: /images/20220126/e84e47377fee4782925cf3f8960edaa4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3NpbmF0XzM5MTc5OTkz_size_16_color_FFFFFF_t_70 1]: /images/20220126/c103dccd413e47e6be484163b0cbefac.png