基于XML的声明式事务控制

1、maven依赖

<?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.ly.spring</groupId>

    <artifactId>spring07</artifactId>

    <version>1.0-SNAPSHOT</version>

    <packaging>jar</packaging>

    <dependencies>

        <dependency>

            <groupId>org.springframework</groupId>

            <artifactId>spring-context</artifactId>

            <version>5.0.2.RELEASE</version>

        </dependency>

        <!--JdbcTemplate-->

        <dependency>

            <groupId>org.springframework</groupId>

            <artifactId>spring-jdbc</artifactId>

            <version>5.0.2.RELEASE</version>

        </dependency>

        <!--整合junit-->

        <dependency>

            <groupId>org.springframework</groupId>

            <artifactId>spring-test</artifactId>

            <version>5.0.2.RELEASE</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>mysql</groupId>

            <artifactId>mysql-connector-java</artifactId>

            <version>5.1.6</version>

        </dependency>

        <!--解析切入点表达式-->

        <dependency>

            <groupId>org.aspectj</groupId>

            <artifactId>aspectjweaver</artifactId>

            <version>1.8.7</version>

        </dependency>

        <dependency>

            <groupId>junit</groupId>

            <artifactId>junit</artifactId>

            <version>4.12</version>

            <scope>test</scope>

        </dependency>

    </dependencies>

    <!--解决IDEA maven变更后自动重置LanguageLevel和JavaCompiler版本的问题-->

    <build>

        <plugins>

            <plugin>

                <groupId>org.apache.maven.plugins</groupId>

                <artifactId>maven-compiler-plugin</artifactId>

                <version>2.3.2</version>

                <configuration>

                    <source>13</source>

                    <target>13</target>

                </configuration>

            </plugin>

        </plugins>

    </build>

</project>

2、abc服务和实现类

package com.ly.spring.service;

public interface IAbcService {

    public void updateAbcMoney(String abcBankNo,double addMoney);

}

package com.ly.spring.service.impl;

import com.ly.spring.dao.IAbcDao;

import com.ly.spring.service.IAbcService;

public class AbcServiceImpl implements IAbcService {

    private IAbcDao abcDao;

    public void setAbcDao(IAbcDao abcDao) {

        this.abcDao = abcDao;

    }

    @Override

    public void updateAbcMoney(String abcBankNo, double addMoney) {

        abcDao.updateAbcMoney(abcBankNo,addMoney);

    }

}

3、abc dao和实现类

package com.ly.spring.dao;

public interface IAbcDao {

    public void updateAbcMoney(String abcBankNo,double addMoney);

}

package com.ly.spring.dao.impl;

import com.ly.spring.dao.IAbcDao;

import org.springframework.jdbc.core.support.JdbcDaoSupport;

public class AbcDaoImpl extends JdbcDaoSupport implements IAbcDao {

    @Override

    public void updateAbcMoney(String abcBankNo, double addMoney) {

        super.getJdbcTemplate().update("update abc set money = money+? where bankno = ?",addMoney,abcBankNo);

    }

}

4、icbc服务和实现类

package com.ly.spring.service;

public interface IIcbcService {

    public void updateIcbcMoney(String icbcBankNo, double addMoney);

}

package com.ly.spring.service.impl;

import com.ly.spring.dao.IIcbcDao;

import com.ly.spring.service.IIcbcService;

public class IcbcServiceImpl implements IIcbcService {

    private IIcbcDao icbcDao;

    public void setIcbcDao(IIcbcDao icbcDao) {

        this.icbcDao = icbcDao;

    }

    @Override

    public void updateIcbcMoney(String icbcBankNo, double addMoney) {

        icbcDao.updateIcbcMoney(icbcBankNo,addMoney);

    }

}

5、icbc dao和实现类

package com.ly.spring.dao;

public interface IIcbcDao {

    public void updateIcbcMoney(String icbcBankNo, double addMoney);

}

package com.ly.spring.dao.impl;

import com.ly.spring.dao.IIcbcDao;

import org.springframework.jdbc.core.support.JdbcDaoSupport;

public class IcbcDaoImpl extends JdbcDaoSupport implements IIcbcDao {

    @Override

    public void updateIcbcMoney(String icbcBankNo, double addMoney) {

        super.getJdbcTemplate().update("update icbc set money = money+? where bankno = ?",addMoney,icbcBankNo);

    }

}

6、转账服务和实现类

package com.ly.spring.service;

/**

 * 转账服务

 */

public interface ITransferAccountService {

    public void transferAccountFromIcbcToAbc(String icbcBankNo,String abcBankNo,double money);

}

package com.ly.spring.service.impl;

import com.ly.spring.service.IAbcService;

import com.ly.spring.service.IIcbcService;

import com.ly.spring.service.ITransferAccountService;

public class TransferAccountServiceImpl implements ITransferAccountService {

    private IIcbcService icbcService;

    private IAbcService abcService;

    public void setIcbcService(IIcbcService icbcService) {

        this.icbcService = icbcService;

    }

    public void setAbcService(IAbcService abcService) {

        this.abcService = abcService;

    }

    @Override

    public void transferAccountFromIcbcToAbc(String icbcBankNo, String abcBankNo, double money) {

        //先扣减icbc

        icbcService.updateIcbcMoney(icbcBankNo,0-money);

        //再增加abc

        abcService.updateAbcMoney(abcBankNo,money);

        //int i = 1/0;

    }

}

7、jdbc资源文件

jdbc.driver = com.mysql.jdbc.Driver

jdbc.url = jdbc:mysql://localhost:3306/db01

jdbc.user = root

jdbc.password = root

8、spring配置文件

<?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:aop="http://www.springframework.org/schema/aop"

       xmlns:tx="http://www.springframework.org/schema/tx"

       xmlns:context="http://www.springframework.org/schema/context"

       xsi:schemaLocation="

        http://www.springframework.org/schema/beans

        http://www.springframework.org/schema/beans/spring-beans.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

        http://www.springframework.org/schema/context

        http://www.springframework.org/schema/context/spring-context.xsd">

    <!--配置jdbc资源文件-->

    <context:property-placeholder location="classpath:jdbc.properties"></context:property-placeholder>

    <!--转账服务-->

    <bean id="transferAccountService" class="com.ly.spring.service.impl.TransferAccountServiceImpl">

        <property name="abcService" ref="abcService"></property>

        <property name="icbcService" ref="icbcService"></property>

    </bean>

    <!--icbc服务-->

    <bean id="icbcService" class="com.ly.spring.service.impl.IcbcServiceImpl">

        <property name="icbcDao" ref="icbcDao"></property>

    </bean>

    <!--abc服务-->

    <bean id="abcService" class="com.ly.spring.service.impl.AbcServiceImpl">

        <property name="abcDao" ref="abcDao"></property>

    </bean>

    <!--icbc dao-->

    <bean id="icbcDao" class="com.ly.spring.dao.impl.IcbcDaoImpl">

        <property name="dataSource" ref="dataSource"></property>

    </bean>

    <!--abc dao-->

    <bean id="abcDao" class="com.ly.spring.dao.impl.AbcDaoImpl">

        <property name="dataSource" ref="dataSource"></property>

    </bean>

    <!--配置数据源-->

    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">

        <property name="driverClassName" value="${jdbc.driver}"></property>

        <property name="url" value="${jdbc.url}"></property>

        <property name="username" value="${jdbc.user}"></property>

        <property name="password" value="${jdbc.password}"></property>

    </bean>

    <!--配置事务管理器-->

    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">

        <property name="dataSource" ref="dataSource"></property>

    </bean>

    <!--配置事务通知和事务通知的属性-->

    <tx:advice id="transactionAdvice" transaction-manager="transactionManager">

        <tx:attributes>

            <tx:method name="*" propagation="REQUIRED" read-only="false"/>

            <tx:method name="find*" propagation="SUPPORTS" read-only="true"></tx:method>

        </tx:attributes>

    </tx:advice>

    <!--aopp欸之-->

    <aop:config>

        <!--配置切入点-->

        <aop:pointcut id="pt1" expression="execution(* com.ly.spring.service.impl.*.*(..))"/>

        <!--将事务通知和切入点关联起来-->

        <aop:advisor advice-ref="transactionAdvice" pointcut-ref="pt1"></aop:advisor>

    </aop:config>

</beans>

9、测试类

package com.ly.spring.test;

import com.ly.spring.service.ITransferAccountService;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.test.context.ContextConfiguration;

import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

//替换junit的main方法

@RunWith(SpringJUnit4ClassRunner.class)

//指定spring配置文件位置

@ContextConfiguration(locations = "classpath:bean.xml")

public class MainTest {

    @Autowired

    private ITransferAccountService transferAccountService;

    @Test

    public void test() {

        transferAccountService.transferAccountFromIcbcToAbc("1234567890","1001",500);

    }

}

巴特西

基于XML的声明式事务控制

最新文章

热门文章