Spring 事务<5>

Spring事务策略是通过PlatformTransactionManager接口提现的

public interface PlatformTransactionManager {

    //获取平台无关的事务
    TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException;

    //平台无关的事务提交
    void commit(TransactionStatus status) throws TransactionException;

    //平台无关的事务回滚
    void rollback(TransactionStatus status) throws TransactionException;

}

TransactionDefinition 接口定义了一个事务的规则，有如下几个属性：

  • 事务隔离 当前事务和其它事务的隔离程度
  • 事务传播 一个事务上下文已经存在，有几个事务选项可指定该事务性方法的执行行为。
  • 事务超时 事务的最长持续时间，超时回滚
  • 只读状态 不能修改任何数据
public interface TransactionDefinition {

    int PROPAGATION_REQUIRED = 0;
    int PROPAGATION_SUPPORTS = 1;
    int PROPAGATION_MANDATORY = 2;
    int PROPAGATION_REQUIRES_NEW = 3;
    int PROPAGATION_NOT_SUPPORTED = 4;
    int PROPAGATION_NEVER = 5;
    int PROPAGATION_NESTED = 6;

    int ISOLATION_DEFAULT = -1;
    int ISOLATION_READ_UNCOMMITTED = Connection.TRANSACTION_READ_UNCOMMITTED;
    int ISOLATION_READ_COMMITTED = Connection.TRANSACTION_READ_COMMITTED;
    int ISOLATION_REPEATABLE_READ = Connection.TRANSACTION_REPEATABLE_READ;
    int ISOLATION_SERIALIZABLE = Connection.TRANSACTION_SERIALIZABLE;

    int TIMEOUT_DEFAULT = -1;

    int getPropagationBehavior();
    int getIsolationLevel();
    int getTimeout();
    boolean isReadOnly();
    String getName();
}

TransactionStatus.java代表事务本身

public interface TransactionStatus extends SavepointManager, Flushable {
    boolean isNewTransaction();
    boolean hasSavepoint();
    void setRollbackOnly();
    @Override
    void flush();
    boolean isCompleted();
}
事务.jpg

方式一：Spring TransactionTemplate
配置spring-mybatis.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:p="http://www.springframework.org/schema/p"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xmlns:mvc="http://www.springframework.org/schema/mvc"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
                        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
                        http://www.springframework.org/schema/context
                        http://www.springframework.org/schema/context/spring-context-4.0.xsd
                        http://www.springframework.org/schema/aop
                        http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
                        http://www.springframework.org/schema/tx
                        http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
                        http://www.springframework.org/schema/mvc
                        http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd">
    <!-- 自动扫描 -->
    <context:component-scan base-package="com.lq.play" >
        <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller" />
        <context:exclude-filter type="annotation" expression="org.aspectj.lang.annotation.Aspect" />
    </context:component-scan>
    <!--和schema一起启动@Aspectj支持-->
    <!--<aop:aspectj-autoproxy/>-->
    <!--启动@Aspectj支持-->
    <!--<bean class="org.springframework.aop.aspectj.annotation.AnnotationAwareAspectJAutoProxyCreator"/>-->
    <!-- 引入配置文件 -->
    <bean id="propertyConfigurer"
          class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="location" value="classpath:jdbc.properties" />
    </bean>

    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
          destroy-method="close">
        <property name="driverClassName" value="${driver}" />
        <property name="url" value="${url}" />
        <property name="username" value="${username}" />
        <property name="password" value="${password}" />
        <!-- 初始化连接大小 -->
        <property name="initialSize" value="${initialSize}"></property>
        <!-- 连接池最大数量 -->
        <property name="maxActive" value="${maxActive}"></property>
        <!-- 连接池最大空闲 -->
        <property name="maxIdle" value="${maxIdle}"></property>
        <!-- 连接池最小空闲 -->
        <property name="minIdle" value="${minIdle}"></property>
        <!-- 获取连接最大等待时间 -->
        <property name="maxWait" value="${maxWait}"></property>
    </bean>

    <!--<!– spring和MyBatis完美整合，不需要mybatis的配置映射文件 –>-->
    <!--<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">-->
        <!--<property name="dataSource" ref="dataSource" />-->
        <!--<!–<property name="configLocation" value="classpath:mybatis-config.xml"></property>–>-->
        <!--<!– 自动扫描mapping.xml文件 –>-->
        <!--<property name="mapperLocations" value="classpath:mapper/*.xml"></property>-->
    <!--</bean>-->

    <!--<!– DAO接口所在包名，Spring会自动查找其下的类，扫描所有dao –>-->
    <!--<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">-->
        <!--<property name="basePackage" value="com.lq.play.mapper" />-->
        <!--<property name="annotationClass" value="org.springframework.stereotype.Repository" />-->

        <!--<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>-->
    <!--</bean>-->

    <!--<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">-->
        <!--<property name="dataSource" ref="dataSource" />-->
    <!--</bean>-->

    <bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate">
        <property name="transactionManager" ref="transactionManager"/>
    </bean>
    <bean id="accountDao" class="com.lq.play.daoimpl.AccountDaoImpl">
        <property name="dataSource" ref="dataSource" />
    </bean>
    <bean id="accountService" class="com.lq.play.serviceimpl.AccountServiceImpl">
        <property name="ad" ref="accountDao" />
        <property name="tt" ref="transactionTemplate" />
    </bean>
    <!--<!– (事务管理)transaction manager, use JtaTransactionManager for global tx –>-->
    <bean id="transactionManager"
          class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource" />
    </bean>
    <!--<tx:annotation-driven transaction-manager="transactionManager"/>-->
</beans>

数据库定义

create table t_account
(
    id bigint not null auto_increment primary key,
    money int null
);

dao定义

package com.lq.play.daoimpl;

import com.lq.play.dao.AccountDao;
import org.springframework.jdbc.core.support.JdbcDaoSupport;

public class AccountDaoImpl extends JdbcDaoSupport implements AccountDao {

    @Override
    public void addMoney(Integer id, Double money) {
        
        getJdbcTemplate().update("update t_account set money = money+? where id = ? ", money,id);
        
    }

    @Override
    public void minusMoney(Integer id, Double money) {

        getJdbcTemplate().update("update t_account set money = money-? where id = ? ", money,id);
    }

}

service定义

package com.lq.play.serviceimpl;

import com.lq.play.dao.AccountDao;
import com.lq.play.service.AccountService;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
import org.springframework.transaction.support.TransactionTemplate;


//@Transactional(isolation=Isolation.REPEATABLE_READ,propagation=Propagation.REQUIRED,readOnly=true)
public class AccountServiceImpl implements AccountService {

    private AccountDao ad ;
    private TransactionTemplate tt;

    @Override
    public void transfer(final Integer from,final Integer to,final Double money) {
        System.out.println("transfer");
//      tt.execute(new TransactionCallbackWithoutResult() {
//          @Override
//          protected void doInTransactionWithoutResult(TransactionStatus status) {
//              //减钱
//              ad.minusMoney(from, money);
//              int i = 1/0;
//              //加钱
//              ad.addMoney(to, money);
//          }
//      });
//减钱
        ad.minusMoney(from, money);
        int i = 1/0;
        //加钱
        ad.addMoney(to, money);

    }
    public void setAd(AccountDao ad) {
        this.ad = ad;
    }

    public void setTt(TransactionTemplate tt) {
        this.tt = tt;
    }
}

测试

package test;

import javax.annotation.Resource;

import com.lq.play.service.AccountService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;


@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"classpath:config/mybatis/spring-mybatis.xml"})
public class Demo {
    @Resource(name="accountService")
    private AccountService as;

    @Test
    public void fun1(){
        as.transfer(1, 2, 100d);
    }
}

结果：执行前数据库

image.png

执行后数据库

image.png

没有事务控制，出现异常的情况下，由于没有回滚，只做了减钱没有加钱，出现了前后不一致的问题。
使用TemplateTranscation,修改执行方法

    @Override
    public void transfer(final Integer from,final Integer to,final Double money) {
        System.out.println("transfer");
        tt.execute(new TransactionCallbackWithoutResult() {
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus status) {
                //减钱
                ad.minusMoney(from, money);
                int i = 1/0;
                //加钱
                ad.addMoney(to, money);
            }
        });
//减钱
//      ad.minusMoney(from, money);
//      int i = 1/0;
//      //加钱
//      ad.addMoney(to, money);

    }

可以看到执行前后都为：做了事务回滚操作


image.png

修改执行方法，去掉异常，正常执行

@Override
    public void transfer(final Integer from,final Integer to,final Double money) {
        System.out.println("transfer");
        tt.execute(new TransactionCallbackWithoutResult() {
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus status) {
                //减钱
                ad.minusMoney(from, money);
//              int i = 1/0;
                //加钱
                ad.addMoney(to, money);
            }
        });
//减钱
//      ad.minusMoney(from, money);
//      int i = 1/0;
//      //加钱
//      ad.addMoney(to, money);

    }

执行后

image.png

方式二：声明式配置
配置spring-mybatis.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:p="http://www.springframework.org/schema/p"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xmlns:mvc="http://www.springframework.org/schema/mvc"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
                        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
                        http://www.springframework.org/schema/context
                        http://www.springframework.org/schema/context/spring-context-4.0.xsd
                        http://www.springframework.org/schema/aop
                        http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
                        http://www.springframework.org/schema/tx
                        http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
                        http://www.springframework.org/schema/mvc
                        http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd">
    <!-- 自动扫描 -->
    <context:component-scan base-package="com.lq.play">
        <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller"/>
        <context:exclude-filter type="annotation" expression="org.aspectj.lang.annotation.Aspect"/>
    </context:component-scan>
    <!--和schema一起启动@Aspectj支持-->
    <!--<aop:aspectj-autoproxy/>-->
    <!--启动@Aspectj支持-->
    <!--<bean class="org.springframework.aop.aspectj.annotation.AnnotationAwareAspectJAutoProxyCreator"/>-->
    <!-- 引入配置文件 -->
    <bean id="propertyConfigurer"
          class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="location" value="classpath:jdbc.properties"/>
    </bean>

    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
          destroy-method="close">
        <property name="driverClassName" value="${driver}"/>
        <property name="url" value="${url}"/>
        <property name="username" value="${username}"/>
        <property name="password" value="${password}"/>
        <!-- 初始化连接大小 -->
        <property name="initialSize" value="${initialSize}"></property>
        <!-- 连接池最大数量 -->
        <property name="maxActive" value="${maxActive}"></property>
        <!-- 连接池最大空闲 -->
        <property name="maxIdle" value="${maxIdle}"></property>
        <!-- 连接池最小空闲 -->
        <property name="minIdle" value="${minIdle}"></property>
        <!-- 获取连接最大等待时间 -->
        <property name="maxWait" value="${maxWait}"></property>
    </bean>

    <!--<!– spring和MyBatis完美整合，不需要mybatis的配置映射文件 –>-->
    <!--<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">-->
    <!--<property name="dataSource" ref="dataSource" />-->
    <!--<!–<property name="configLocation" value="classpath:mybatis-config.xml"></property>–>-->
    <!--<!– 自动扫描mapping.xml文件 –>-->
    <!--<property name="mapperLocations" value="classpath:mapper/*.xml"></property>-->
    <!--</bean>-->

    <!--<!– DAO接口所在包名，Spring会自动查找其下的类，扫描所有dao –>-->
    <!--<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">-->
    <!--<property name="basePackage" value="com.lq.play.mapper" />-->
    <!--<property name="annotationClass" value="org.springframework.stereotype.Repository" />-->

    <!--<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>-->
    <!--</bean>-->

    <!--<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">-->
    <!--<property name="dataSource" ref="dataSource" />-->
    <!--</bean>-->
    <!-- 配置事务通知 -->


    <tx:advice transaction-manager="transactionManager" id="txAdvice">
        <tx:attributes>
            <!-- 以方法为单位,指定方法应用什么事务属性 isolation:隔离级别 propagation:传播行为 read-only:是否只读 -->
            <tx:method name="save*" read-only="false" propagation="REQUIRED" isolation="REPEATABLE_READ"/>
            <tx:method name="persist*" read-only="false" propagation="REQUIRED" isolation="REPEATABLE_READ"/>
            <tx:method name="update*" read-only="false" propagation="REQUIRED" isolation="REPEATABLE_READ"/>
            <tx:method name="modify*" read-only="false" propagation="REQUIRED" isolation="REPEATABLE_READ"/>
            <tx:method name="delete*" read-only="false" propagation="REQUIRED" isolation="REPEATABLE_READ"/>
            <tx:method name="remove*" read-only="false" propagation="REQUIRED" isolation="REPEATABLE_READ"/>
            <tx:method name="get*" read-only="true" propagation="REQUIRED" isolation="REPEATABLE_READ"/>
            <tx:method name="find*" read-only="true" propagation="REQUIRED" isolation="REPEATABLE_READ"/>
            <tx:method name="transfer" read-only="false" propagation="REQUIRED" isolation="REPEATABLE_READ"/>
        </tx:attributes>
    </tx:advice>
    <!-- 配置织入 -->
    <aop:config>
        <!-- 配置切点表达式 -->
        <aop:pointcut id="txPc" expression="execution(* com.lq.play.serviceimpl.*.*(..))"/>
        <!-- 配置切面 : 通知+切点 advice-ref:通知的名称 pointcut-ref:切点的名称 -->
        <aop:advisor pointcut-ref="txPc" advice-ref="txAdvice"/>
    </aop:config>

    <!--<bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate">-->
        <!--<property name="transactionManager" ref="transactionManager"/>-->
    <!--</bean>-->
    <bean id="accountDao" class="com.lq.play.daoimpl.AccountDaoImpl">
        <property name="dataSource" ref="dataSource"/>
    </bean>
    <bean id="accountService" class="com.lq.play.serviceimpl.AccountServiceImpl">
        <property name="ad" ref="accountDao"/>
        <!--<property name="tt" ref="transactionTemplate"/>-->
    </bean>
    <!--<!– (事务管理)transaction manager, use JtaTransactionManager for global tx –>-->
    <bean id="transactionManager"
          class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"/>
    </bean>
    <!--<tx:annotation-driven transaction-manager="transactionManager"/>-->
</beans>

dao层不变service如下

package com.lq.play.serviceimpl;

import com.lq.play.dao.AccountDao;
import com.lq.play.service.AccountService;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
import org.springframework.transaction.support.TransactionTemplate;


//@Transactional(isolation=Isolation.REPEATABLE_READ,propagation=Propagation.REQUIRED,readOnly=true)
public class AccountServiceImpl implements AccountService {

    private AccountDao ad ;

    public void transfer(final Integer from,final Integer to,final Double money) {
                //减钱
                ad.minusMoney(from, money);
                int i = 1/0;
                //加钱
                ad.addMoney(to, money);
    }

    public void setAd(AccountDao ad) {
        this.ad = ad;
    }
}

执行

package test;

import javax.annotation.Resource;

import com.lq.play.service.AccountService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;


@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"classpath:config/mybatis/spring-mybatis.xml"})
public class Demo {
    @Resource(name="accountService")
    private AccountService as;

    @Test
    public void fun1(){
        as.transfer(1, 2, 100d);
    }
}

执行前后结果都为


image.png

方式三：注解式
@Transactional可指定如下几个属性：

  • isolation 事务隔离级别
  • noRollbackFor 遇到指定异常强制不会滚
  • noRollbackForClassName 指定遇到特定的多个异常时强制不回滚事务。可以指定多个异常类名。
  • propagation 指定事务传播行为
  • readOnly 指定事务是否只读
  • rollbackFor 指定遇到特定异常时强制回滚事务
  • rollbackForClassName 指定遇到特定的多个异常时强制回滚事务。该属性值可以指定多个异常类名。
  • timeout 指定事务的超时时长。
    配置spring-mybatis.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:p="http://www.springframework.org/schema/p"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xmlns:mvc="http://www.springframework.org/schema/mvc"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
                        http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
                        http://www.springframework.org/schema/context
                        http://www.springframework.org/schema/context/spring-context-4.0.xsd
                        http://www.springframework.org/schema/aop
                        http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
                        http://www.springframework.org/schema/tx
                        http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
                        http://www.springframework.org/schema/mvc
                        http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd">
    <!-- 自动扫描 -->
    <context:component-scan base-package="com.lq.play">
        <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller"/>
        <context:exclude-filter type="annotation" expression="org.aspectj.lang.annotation.Aspect"/>
    </context:component-scan>
    <!--和schema一起启动@Aspectj支持-->
    <!--<aop:aspectj-autoproxy/>-->
    <!--启动@Aspectj支持-->
    <!--<bean class="org.springframework.aop.aspectj.annotation.AnnotationAwareAspectJAutoProxyCreator"/>-->
    <!-- 引入配置文件 -->
    <bean id="propertyConfigurer"
          class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="location" value="classpath:jdbc.properties"/>
    </bean>

    <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
          destroy-method="close">
        <property name="driverClassName" value="${driver}"/>
        <property name="url" value="${url}"/>
        <property name="username" value="${username}"/>
        <property name="password" value="${password}"/>
        <!-- 初始化连接大小 -->
        <property name="initialSize" value="${initialSize}"></property>
        <!-- 连接池最大数量 -->
        <property name="maxActive" value="${maxActive}"></property>
        <!-- 连接池最大空闲 -->
        <property name="maxIdle" value="${maxIdle}"></property>
        <!-- 连接池最小空闲 -->
        <property name="minIdle" value="${minIdle}"></property>
        <!-- 获取连接最大等待时间 -->
        <property name="maxWait" value="${maxWait}"></property>
    </bean>

    <!--<!– spring和MyBatis完美整合，不需要mybatis的配置映射文件 –>-->
    <!--<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">-->
    <!--<property name="dataSource" ref="dataSource" />-->
    <!--<!–<property name="configLocation" value="classpath:mybatis-config.xml"></property>–>-->
    <!--<!– 自动扫描mapping.xml文件 –>-->
    <!--<property name="mapperLocations" value="classpath:mapper/*.xml"></property>-->
    <!--</bean>-->

    <!--<!– DAO接口所在包名，Spring会自动查找其下的类，扫描所有dao –>-->
    <!--<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">-->
    <!--<property name="basePackage" value="com.lq.play.mapper" />-->
    <!--<property name="annotationClass" value="org.springframework.stereotype.Repository" />-->

    <!--<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>-->
    <!--</bean>-->

    <!--<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">-->
    <!--<property name="dataSource" ref="dataSource" />-->
    <!--</bean>-->
    <!-- 配置事务通知 -->


    <!--<tx:advice transaction-manager="transactionManager" id="txAdvice">-->
        <!--<tx:attributes>-->
            <!--<!– 以方法为单位,指定方法应用什么事务属性 isolation:隔离级别 propagation:传播行为 read-only:是否只读 –>-->
            <!--<tx:method name="save*" read-only="false" propagation="REQUIRED" isolation="REPEATABLE_READ"/>-->
            <!--<tx:method name="persist*" read-only="false" propagation="REQUIRED" isolation="REPEATABLE_READ"/>-->
            <!--<tx:method name="update*" read-only="false" propagation="REQUIRED" isolation="REPEATABLE_READ"/>-->
            <!--<tx:method name="modify*" read-only="false" propagation="REQUIRED" isolation="REPEATABLE_READ"/>-->
            <!--<tx:method name="delete*" read-only="false" propagation="REQUIRED" isolation="REPEATABLE_READ"/>-->
            <!--<tx:method name="remove*" read-only="false" propagation="REQUIRED" isolation="REPEATABLE_READ"/>-->
            <!--<tx:method name="get*" read-only="true" propagation="REQUIRED" isolation="REPEATABLE_READ"/>-->
            <!--<tx:method name="find*" read-only="true" propagation="REQUIRED" isolation="REPEATABLE_READ"/>-->
            <!--<tx:method name="transfer" read-only="false" propagation="REQUIRED" isolation="REPEATABLE_READ"/>-->
        <!--</tx:attributes>-->
    <!--</tx:advice>-->
    <!--<!– 配置织入 –>-->
    <!--<aop:config>-->
        <!--<!– 配置切点表达式 –>-->
        <!--<aop:pointcut id="txPc" expression="execution(* com.lq.play.serviceimpl.*.*(..))"/>-->
        <!--<!– 配置切面 : 通知+切点 advice-ref:通知的名称 pointcut-ref:切点的名称 –>-->
        <!--<aop:advisor pointcut-ref="txPc" advice-ref="txAdvice"/>-->
    <!--</aop:config>-->

    <!--<bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate">-->
        <!--<property name="transactionManager" ref="transactionManager"/>-->
    <!--</bean>-->
    <!--<bean id="accountDao" class="com.lq.play.daoimpl.AccountDaoImpl">-->
        <!--<property name="dataSource" ref="dataSource"/>-->
    <!--</bean>-->
    <!--<bean id="accountService" class="com.lq.play.serviceimpl.AccountServiceImpl">-->
        <!--<property name="ad" ref="accountDao"/>-->
        <!--<!–<property name="tt" ref="transactionTemplate"/>–>-->
    <!--</bean>-->
    <!--<!– (事务管理)transaction manager, use JtaTransactionManager for global tx –>-->
    <bean id="transactionManager"
          class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"/>
    </bean>
    <tx:annotation-driven transaction-manager="transactionManager"/>
</beans>

service


public class AccountServiceImpl implements AccountService {

    private AccountDao ad ;
//  private TransactionTemplate tt;
    
    @Override
    @Transactional(isolation=Isolation.REPEATABLE_READ,propagation=Propagation.REQUIRED,readOnly=false)
    public void transfer(final Integer from,final Integer to,final Double money) {
                //减钱
                ad.minusMoney(from, money);
                int i = 1/0;
                //加钱
                ad.addMoney(to, money);
    }

执行前后结果都为


image.png
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 212,185评论 6赞 493
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 90,445评论 3赞 385
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 157,684评论 0赞 348
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 56,564评论 1赞 284
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 65,681评论 6赞 386
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 49,874评论 1赞 290
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 39,025评论 3赞 408
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 37,761评论 0赞 268
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 44,217评论 1赞 303
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,545评论 2赞 327
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,694评论 1赞 341
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 34,351评论 4赞 332
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 39,988评论 3赞 315
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,778评论 0赞 21
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,007评论 1赞 266
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 46,427评论 2赞 360
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 43,580评论 2赞 349

推荐阅读更多精彩内容

  • Spring Cloud
    Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具（例如配置管理，服务发现，断路器，智...
    卡卡罗2017阅读 134,633评论 18赞 139
  • Spring boot参考指南
    Spring Boot 参考指南 介绍 转载自:https://www.gitbook.com/book/qbgb...
    毛宇鹏阅读 46,778评论 6赞 342
  • MarkDown
    1. 简介 1.1 什么是 MyBatis ？ MyBatis 是支持定制化 SQL、存储过程以及高级映射的优秀的...
    笨鸟慢飞阅读 5,460评论 0赞 4
  • 为你，千万遍
    一直盼着它的到来，天天打开楼下的邮箱见不到一封属于我的信，前段时间急得拖朋友联系上村委主任找到了邮递员家里还是没我...
    刘盈儿阅读 610评论 7赞 5
  • 拾遗-2016.12.21
    简直就是在自毁前程 1:24pm 认真起来其实好像也挺简单？ 11:32pm
    Planck阅读 104评论 0赞 0