码迷，mamicode.com
首页 > 编程语言 > 详细

spring再学习之AOP事务

时间：2018-06-14 01:01:17      阅读：182      评论：0      收藏：0      [点我收藏+]

标签：ring   run   vat   接口   ssi   accounts   encoding   ext1   end   

spring中的事务

技术分享图片技术分享图片技术分享图片

spring怎么操作事务的：

技术分享图片

 

 技术分享图片

 

 事务的转播行为：

 技术分享图片

技术分享图片

事务代码转账操作如下：

接口：

public interface AccountDao {
    
    //加钱
    void addMoney(Integer id,Double money);
    //减钱
    void decreaseMoney(Integer id,Double Money);
    

}

实现类：

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

public class AccountDaoImpl extends JdbcDaoSupport implements AccountDao {

    @Override
    public void addMoney(Integer id, Double money) {
        String sql="update t_account set money=money+? where id = ?"; 
        getJdbcTemplate().update(sql,money,id);
        // TODO Auto-generated method stub

    }

    @Override
    public void decreaseMoney(Integer id, Double money) {
        String sql="update t_account set money=money-? where id = ?"; 
        getJdbcTemplate().update(sql,money,id);

    }

}

servoce层接口

package cn.itcast.service;

public interface AccountService {
    
    //转账方法
    void transfer(Integer from,Integer to,Double money);

}

service实现类：

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.TransactionCallback;
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
import org.springframework.transaction.support.TransactionTemplate;

import cn.itcast.dao.AccountDao;
@Transactional(isolation=Isolation.REPEATABLE_READ,propagation=Propagation.REQUIRED,readOnly=false)
public class AccountServiceImpl implements AccountService {

    
    private AccountDao ad;
    private TransactionTemplate tt;

    @Override
    
    public void transfer(final Integer from, final Integer to,final  Double money) {
               //事务
                //减钱
                ad.decreaseMoney(from, money);
                //加钱
                ad.addMoney(to, money);
        
    }
    
    public AccountDao getAd() {
        return ad;
    }
    public void setAd(AccountDao ad) {
        this.ad = ad;
    }

    public TransactionTemplate getTt() {
        return tt;
    }

    public void setTt(TransactionTemplate tt) {
        this.tt = tt;
    }
    
/*    @Override
    public void transfer(final Integer from, final Integer to,final  Double money) {
        //事务
        tt.execute(new TransactionCallbackWithoutResult() {
            
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus arg0) {
                // TODO Auto-generated method stub
                //减钱
                ad.decreaseMoney(from, money);
                int i=1/0;
                //加钱
                ad.addMoney(to, money);
            }
        });
    }
*/
}

分析：

技术分享图片

XML配置式实现事务：

原理;

技术分享图片

 

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
       xmlns="http://www.springframework.org/schema/beans" 
       xmlns:p="http://www.springframework.org/schema/p" 
       xmlns:context="http://www.springframework.org/schema/context" 
       xmlns:tx="http://www.springframework.org/schema/tx" 
       xmlns:aop="http://www.springframework.org/schema/aop" 
       xsi:schemaLocation="http://www.springframework.org/schema/beans 
       http://www.springframework.org/schema/beans/spring-beans-4.2.xsd 
       http://www.springframework.org/schema/context 
       http://www.springframework.org/schema/context/spring-context-4.2.xsd 
       http://www.springframework.org/schema/tx 
       http://www.springframework.org/schema/tx/spring-tx-4.2.xsd 
       http://www.springframework.org/schema/aop 
       http://www.springframework.org/schema/aop/spring-aop-4.2.xsd ">      
   
   <!--指定Spring读取db.properties  -->
   <context:property-placeholder location="classpath:db.properties"  />
   
      <!-- 事物核心管理器，
           封装了所有事物操作，
           依赖于连接池 
       -->
      <bean name="dataSourceTransactionManager" 
           class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
           <property name="dataSource" ref="dataSource"></property>
      </bean>
      
      <!-- 事务模板对象 -->
      <bean name="transactionTemplate" 
            class="org.springframework.transaction.support.TransactionTemplate">
           <property name="transactionManager" ref="dataSourceTransactionManager"></property>
      </bean>
      
      <!-- 配置事务通知 
           isolation:隔离级别
           propagation:传播行为
           read-only：是否只读  
       -->
      <tx:advice id="txAdvice" transaction-manager="dataSourceTransactionManager">
            <tx:attributes>
                   <tx:method name="save*" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false"/>
                   <tx:method name="persist*" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false"/>
                   <tx:method name="update*" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false"/>
                   <tx:method name="modify*" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false"/>
                   <tx:method name="delete*" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false"/>
                   <tx:method name="remove*" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false"/>
                   <tx:method name="get*" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="true"/>
                   <tx:method name="find*" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="true"/>
                   <tx:method name="transfer" isolation="REPEATABLE_READ" propagation="REQUIRED" read-only="false"/>
            </tx:attributes>
      </tx:advice>
      
      <!-- 配置织入 -->
     <aop:config>
         <aop:pointcut expression="execution(* cn.itcast.service..*ServiceImpl.*(..))" id="txPc"/>
         <!-- 配置切面 -->
         <aop:advisor advice-ref="txAdvice" pointcut-ref="txPc"/>
     </aop:config>

      
      
   <!-- 1.将连接池交给Spring管理 -->   
      <bean name="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
          <property name="jdbcUrl" value="${jdbc.jdbcUrl}"></property>
          <property name="driverClass" value="${jdbc.driverClass}"></property>
          <property name="user" value="${jdbc.user}"></property>
          <property name="password" value="${jdbc.password}"></property>
      </bean>
    <!-- 2.将JDBCTemplate放入Spring容器 
      <bean name="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
           <property name="dataSource" ref="dataSource"></property>
      </bean> -->
   <!-- 3.将accountDao放入spring容器 -->
   <bean name="accountDao" class="cn.itcast.dao.AccountDaoImpl">
        <property name="dataSource" ref="dataSource"></property>
   
   </bean>
    <!-- 3.将accountService放入spring容器 -->
   <bean name="accountService" class="cn.itcast.service.AccountServiceImpl">
        <property name="ad" ref="accountDao"></property>
        <property name="tt" ref="transactionTemplate"></property>
   
   </bean>
   


</beans>

 

xml配置式，中java写法：

1、打开事务

2、调用doInTransactionWithoutResult

3、提交事务

package cn.itcast.service;

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.TransactionCallback;
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
import org.springframework.transaction.support.TransactionTemplate;

import cn.itcast.dao.AccountDao;public class AccountServiceImpl implements AccountService {

    
    private AccountDao ad;
    private TransactionTemplate tt;

    @Override
    
    public void transfer(final Integer from, final Integer to,final  Double money) {
               //事务
                //减钱
                ad.decreaseMoney(from, money);
                //加钱
                ad.addMoney(to, money);
        
    }
    
    public AccountDao getAd() {
        return ad;
    }
    public void setAd(AccountDao ad) {
        this.ad = ad;
    }

    public TransactionTemplate getTt() {
        return tt;
    }

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

测试：

package cn.itcast.tx;

import javax.annotation.Resource;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import cn.itcast.service.AccountService;


@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext1.xml")

public class Demo {
    
    @Resource(name="accountService")
    private AccountService ad;
    @Test
    public void fun1() {
        ad.transfer(1, 2, 1000.00);
    }
 
}

注解式配置事务：

 

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
       xmlns="http://www.springframework.org/schema/beans" 
       xmlns:p="http://www.springframework.org/schema/p" 
       xmlns:context="http://www.springframework.org/schema/context" 
       xmlns:tx="http://www.springframework.org/schema/tx" 
       xmlns:aop="http://www.springframework.org/schema/aop" 
       xsi:schemaLocation="http://www.springframework.org/schema/beans 
       http://www.springframework.org/schema/beans/spring-beans-4.2.xsd 
       http://www.springframework.org/schema/context 
       http://www.springframework.org/schema/context/spring-context-4.2.xsd 
       http://www.springframework.org/schema/tx 
       http://www.springframework.org/schema/tx/spring-tx-4.2.xsd 
       http://www.springframework.org/schema/aop 
       http://www.springframework.org/schema/aop/spring-aop-4.2.xsd ">      
   
   <!--指定Spring读取db.properties  -->
   <context:property-placeholder location="classpath:db.properties"  />
   
      <!-- 事物核心管理器，封装了所有事物操作，依赖于连接池 -->
      <bean name="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
           <property name="dataSource" ref="dataSource"></property>
      </bean>
      
      <!-- 事务模板对象 -->
      <bean name="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate">
           <property name="transactionManager" ref="transactionManager"></property>
      </bean>
      <!--开启使用注解配置事务  -->
      <tx:annotation-driven />
     

      
      
   <!-- 1.将连接池交给Spring管理 -->   
      <bean name="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
          <property name="jdbcUrl" value="${jdbc.jdbcUrl}"></property>
          <property name="driverClass" value="${jdbc.driverClass}"></property>
          <property name="user" value="${jdbc.user}"></property>
          <property name="password" value="${jdbc.password}"></property>
      </bean>
    <!-- 2.将JDBCTemplate放入Spring容器 
      <bean name="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
           <property name="dataSource" ref="dataSource"></property>
      </bean> -->
   <!-- 3.将accountDao放入spring容器 -->
   <bean name="accountDao" class="cn.itcast.dao.AccountDaoImpl">
        <property name="dataSource" ref="dataSource"></property>
   
   </bean>
    <!-- 3.将accountService放入spring容器 -->
   <bean name="accountService" class="cn.itcast.service.AccountServiceImpl">
        <property name="ad" ref="accountDao"></property>
        <property name="tt" ref="transactionTemplate"></property>
   
   </bean>
   


</beans>

 使用注解：

package cn.itcast.service;

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.TransactionCallback;
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
import org.springframework.transaction.support.TransactionTemplate;

import cn.itcast.dao.AccountDao;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.decreaseMoney(from, money);
                //加钱
                ad.addMoney(to, money);
        
    }
    
    public AccountDao getAd() {
        return ad;
    }
    public void setAd(AccountDao ad) {
        this.ad = ad;
    }

    public TransactionTemplate getTt() {
        return tt;
    }

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

测试：

package cn.itcast.tx;

import javax.annotation.Resource;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import cn.itcast.service.AccountService;


@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext2.xml")

public class Demo {
    
    @Resource(name="accountService")
    private AccountService ad;
    @Test
    public void fun1() {
        ad.transfer(1, 2, 1000.00);
    }
 
}

 

结果：

 

spring再学习之AOP事务

标签：ring   run   vat   接口   ssi   accounts   encoding   ext1   end   

原文地址：https://www.cnblogs.com/xiaonantianmen/p/9180326.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！