Spring 事務(wù)<5>

Spring事務(wù)策略是通過PlatformTransactionManager接口提現(xiàn)的

public interface PlatformTransactionManager {

    //獲取平臺(tái)無關(guān)的事務(wù)
    TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException;

    //平臺(tái)無關(guān)的事務(wù)提交
    void commit(TransactionStatus status) throws TransactionException;

    //平臺(tái)無關(guān)的事務(wù)回滾
    void rollback(TransactionStatus status) throws TransactionException;

}

TransactionDefinition 接口定義了一個(gè)事務(wù)的規(guī)則兔朦,有如下幾個(gè)屬性:

  • 事務(wù)隔離 當(dāng)前事務(wù)和其它事務(wù)的隔離程度
  • 事務(wù)傳播 一個(gè)事務(wù)上下文已經(jīng)存在螟蝙,有幾個(gè)事務(wù)選項(xiàng)可指定該事務(wù)性方法的執(zhí)行行為。
  • 事務(wù)超時(shí) 事務(wù)的最長持續(xù)時(shí)間,超時(shí)回滾
  • 只讀狀態(tài) 不能修改任何數(shù)據(jù)
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代表事務(wù)本身

public interface TransactionStatus extends SavepointManager, Flushable {
    boolean isNewTransaction();
    boolean hasSavepoint();
    void setRollbackOnly();
    @Override
    void flush();
    boolean isCompleted();
}
事務(wù).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">
    <!-- 自動(dòng)掃描 -->
    <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一起啟動(dòng)@Aspectj支持-->
    <!--<aop:aspectj-autoproxy/>-->
    <!--啟動(dòng)@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>
        <!-- 連接池最大數(shù)量 -->
        <property name="maxActive" value="${maxActive}"></property>
        <!-- 連接池最大空閑 -->
        <property name="maxIdle" value="${maxIdle}"></property>
        <!-- 連接池最小空閑 -->
        <property name="minIdle" value="${minIdle}"></property>
        <!-- 獲取連接最大等待時(shí)間 -->
        <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>–>-->
        <!--<!– 自動(dòng)掃描mapping.xml文件 –>-->
        <!--<property name="mapperLocations" value="classpath:mapper/*.xml"></property>-->
    <!--</bean>-->

    <!--<!– DAO接口所在包名照弥,Spring會(huì)自動(dòng)查找其下的類言津,掃描所有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>
    <!--<!– (事務(wù)管理)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>

數(shù)據(jù)庫定義

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);
    }
}

結(jié)果:執(zhí)行前數(shù)據(jù)庫

image.png

執(zhí)行后數(shù)據(jù)庫

image.png

沒有事務(wù)控制,出現(xiàn)異常的情況下取试,由于沒有回滾悬槽,只做了減錢沒有加錢,出現(xiàn)了前后不一致的問題瞬浓。
使用TemplateTranscation,修改執(zhí)行方法

    @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);

    }

可以看到執(zhí)行前后都為:做了事務(wù)回滾操作


image.png

修改執(zhí)行方法初婆,去掉異常,正常執(zhí)行

@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);

    }

執(zhí)行后

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">
    <!-- 自動(dòng)掃描 -->
    <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一起啟動(dòng)@Aspectj支持-->
    <!--<aop:aspectj-autoproxy/>-->
    <!--啟動(dòng)@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>
        <!-- 連接池最大數(shù)量 -->
        <property name="maxActive" value="${maxActive}"></property>
        <!-- 連接池最大空閑 -->
        <property name="maxIdle" value="${maxIdle}"></property>
        <!-- 連接池最小空閑 -->
        <property name="minIdle" value="${minIdle}"></property>
        <!-- 獲取連接最大等待時(shí)間 -->
        <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>–>-->
    <!--<!– 自動(dòng)掃描mapping.xml文件 –>-->
    <!--<property name="mapperLocations" value="classpath:mapper/*.xml"></property>-->
    <!--</bean>-->

    <!--<!– DAO接口所在包名磅叛,Spring會(huì)自動(dòng)查找其下的類,掃描所有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>-->
    <!-- 配置事務(wù)通知 -->


    <tx:advice transaction-manager="transactionManager" id="txAdvice">
        <tx:attributes>
            <!-- 以方法為單位,指定方法應(yīng)用什么事務(wù)屬性 isolation:隔離級(jí)別 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>
        <!-- 配置切點(diǎn)表達(dá)式 -->
        <aop:pointcut id="txPc" expression="execution(* com.lq.play.serviceimpl.*.*(..))"/>
        <!-- 配置切面 : 通知+切點(diǎn) advice-ref:通知的名稱 pointcut-ref:切點(diǎn)的名稱 -->
        <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>
    <!--<!– (事務(wù)管理)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;
    }
}

執(zhí)行

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);
    }
}

執(zhí)行前后結(jié)果都為


image.png

方式三:注解式
@Transactional可指定如下幾個(gè)屬性:

  • isolation 事務(wù)隔離級(jí)別
  • noRollbackFor 遇到指定異常強(qiáng)制不會(huì)滾
  • noRollbackForClassName 指定遇到特定的多個(gè)異常時(shí)強(qiáng)制不回滾事務(wù)萨赁”浊伲可以指定多個(gè)異常類名。
  • propagation 指定事務(wù)傳播行為
  • readOnly 指定事務(wù)是否只讀
  • rollbackFor 指定遇到特定異常時(shí)強(qiáng)制回滾事務(wù)
  • rollbackForClassName 指定遇到特定的多個(gè)異常時(shí)強(qiáng)制回滾事務(wù)位迂。該屬性值可以指定多個(gè)異常類名访雪。
  • timeout 指定事務(wù)的超時(shí)時(shí)長。
    配置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">
    <!-- 自動(dòng)掃描 -->
    <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一起啟動(dòng)@Aspectj支持-->
    <!--<aop:aspectj-autoproxy/>-->
    <!--啟動(dòng)@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>
        <!-- 連接池最大數(shù)量 -->
        <property name="maxActive" value="${maxActive}"></property>
        <!-- 連接池最大空閑 -->
        <property name="maxIdle" value="${maxIdle}"></property>
        <!-- 連接池最小空閑 -->
        <property name="minIdle" value="${minIdle}"></property>
        <!-- 獲取連接最大等待時(shí)間 -->
        <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>–>-->
    <!--<!– 自動(dòng)掃描mapping.xml文件 –>-->
    <!--<property name="mapperLocations" value="classpath:mapper/*.xml"></property>-->
    <!--</bean>-->

    <!--<!– DAO接口所在包名臣缀,Spring會(huì)自動(dòng)查找其下的類,掃描所有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>-->
    <!-- 配置事務(wù)通知 -->


    <!--<tx:advice transaction-manager="transactionManager" id="txAdvice">-->
        <!--<tx:attributes>-->
            <!--<!– 以方法為單位,指定方法應(yīng)用什么事務(wù)屬性 isolation:隔離級(jí)別 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>-->
        <!--<!– 配置切點(diǎn)表達(dá)式 –>-->
        <!--<aop:pointcut id="txPc" expression="execution(* com.lq.play.serviceimpl.*.*(..))"/>-->
        <!--<!– 配置切面 : 通知+切點(diǎn) advice-ref:通知的名稱 pointcut-ref:切點(diǎn)的名稱 –>-->
        <!--<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>-->
    <!--<!– (事務(wù)管理)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);
    }

執(zhí)行前后結(jié)果都為


image.png
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末泻帮,一起剝皮案震驚了整個(gè)濱河市精置,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌锣杂,老刑警劉巖脂倦,帶你破解...
    沈念sama閱讀 212,332評(píng)論 6 493
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場離奇詭異元莫,居然都是意外死亡赖阻,警方通過查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,508評(píng)論 3 385
  • 文/潘曉璐 我一進(jìn)店門踱蠢,熙熙樓的掌柜王于貴愁眉苦臉地迎上來火欧,“玉大人,你說我怎么就攤上這事茎截∥郑” “怎么了?”我有些...
    開封第一講書人閱讀 157,812評(píng)論 0 348
  • 文/不壞的土叔 我叫張陵企锌,是天一觀的道長榆浓。 經(jīng)常有香客問我,道長撕攒,這世上最難降的妖魔是什么陡鹃? 我笑而不...
    開封第一講書人閱讀 56,607評(píng)論 1 284
  • 正文 為了忘掉前任烘浦,我火速辦了婚禮,結(jié)果婚禮上杉适,老公的妹妹穿的比我還像新娘谎倔。我一直安慰自己柳击,他們只是感情好猿推,可當(dāng)我...
    茶點(diǎn)故事閱讀 65,728評(píng)論 6 386
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著捌肴,像睡著了一般蹬叭。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上状知,一...
    開封第一講書人閱讀 49,919評(píng)論 1 290
  • 那天秽五,我揣著相機(jī)與錄音,去河邊找鬼饥悴。 笑死坦喘,一個(gè)胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的西设。 我是一名探鬼主播瓣铣,決...
    沈念sama閱讀 39,071評(píng)論 3 410
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼贷揽!你這毒婦竟也來了棠笑?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 37,802評(píng)論 0 268
  • 序言:老撾萬榮一對(duì)情侶失蹤禽绪,失蹤者是張志新(化名)和其女友劉穎蓖救,沒想到半個(gè)月后,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體印屁,經(jīng)...
    沈念sama閱讀 44,256評(píng)論 1 303
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡循捺,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 36,576評(píng)論 2 327
  • 正文 我和宋清朗相戀三年,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了雄人。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片从橘。...
    茶點(diǎn)故事閱讀 38,712評(píng)論 1 341
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖柠衍,靈堂內(nèi)的尸體忽然破棺而出洋满,到底是詐尸還是另有隱情,我是刑警寧澤珍坊,帶...
    沈念sama閱讀 34,389評(píng)論 4 332
  • 正文 年R本政府宣布牺勾,位于F島的核電站,受9級(jí)特大地震影響阵漏,放射性物質(zhì)發(fā)生泄漏驻民。R本人自食惡果不足惜翻具,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 40,032評(píng)論 3 316
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望回还。 院中可真熱鬧裆泳,春花似錦、人聲如沸柠硕。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,798評(píng)論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽蝗柔。三九已至闻葵,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間癣丧,已是汗流浹背槽畔。 一陣腳步聲響...
    開封第一講書人閱讀 32,026評(píng)論 1 266
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留胁编,地道東北人厢钧。 一個(gè)月前我還...
    沈念sama閱讀 46,473評(píng)論 2 360
  • 正文 我出身青樓,卻偏偏與公主長得像嬉橙,于是被迫代替她去往敵國和親早直。 傳聞我的和親對(duì)象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 43,606評(píng)論 2 350

推薦閱讀更多精彩內(nèi)容

  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理憎夷,服務(wù)發(fā)現(xiàn)莽鸿,斷路器,智...
    卡卡羅2017閱讀 134,637評(píng)論 18 139
  • Spring Boot 參考指南 介紹 轉(zhuǎn)載自:https://www.gitbook.com/book/qbgb...
    毛宇鵬閱讀 46,778評(píng)論 6 342
  • 1. 簡介 1.1 什么是 MyBatis 拾给? MyBatis 是支持定制化 SQL祥得、存儲(chǔ)過程以及高級(jí)映射的優(yōu)秀的...
    笨鳥慢飛閱讀 5,461評(píng)論 0 4
  • 一直盼著它的到來级及,天天打開樓下的郵箱見不到一封屬于我的信,前段時(shí)間急得拖朋友聯(lián)系上村委主任找到了郵遞員家里還是沒我...
    劉盈兒閱讀 610評(píng)論 7 5
  • 簡直就是在自毀前程 1:24pm 認(rèn)真起來其實(shí)好像也挺簡單额衙? 11:32pm
    Planck閱讀 104評(píng)論 0 0