Spring事物处理规则：

运行时异常，默认回滚。

编译异常，默认提交。

 

事物案例：购买股票

数据库脚本

/*SQLyog v10.2 MySQL - 5.6.24 : Database - y2167**********************************************************************//*!40101 SET NAMES utf8 */;/*!40101 SET SQL_MODE=''*/;/*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0 */;/*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0 */;/*!40101 SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE='NO_AUTO_VALUE_ON_ZERO' */;/*!40111 SET @OLD_SQL_NOTES=@@SQL_NOTES, SQL_NOTES=0 */;CREATE DATABASE /*!32312 IF NOT EXISTS*/`y2167` /*!40100 DEFAULT CHARACTER SET utf8 */;USE `y2167`;/*Table structure for table `account` */DROP TABLE IF EXISTS `account`;CREATE TABLE `account` (  `aid` INT(11) NOT NULL AUTO_INCREMENT,  `aname` VARCHAR(20) DEFAULT NULL,  `balance` INT(11) DEFAULT NULL,  PRIMARY KEY (`aid`)) ENGINE=INNODB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;/*Data for the table `account` */insert  into `account`(`aid`,`aname`,`balance`) values (1,'xcq',60000);/*Table structure for table `stock` */DROP TABLE IF EXISTS `stock`;CREATE TABLE `stock` (  `sid` int(11) NOT NULL AUTO_INCREMENT,  `sname` varchar(30) DEFAULT NULL,  `count` int(11) DEFAULT NULL,  PRIMARY KEY (`sid`)) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8;/*Data for the table `stock` */insert  into `stock`(`sid`,`sname`,`count`) values (1,'股票A',5),(2,'股票B',20),(3,'股票C',30);/*!40101 SET SQL_MODE=@OLD_SQL_MODE */;/*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */;/*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */;/*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */;

 

 

创建DAO和Service层

 

//DAO层package cn.happy.day15tx.dao;/** * Created by Administrator on 2018/3/14. *///账户public interface IAccountDAO {    public void updateAccount(int aid,int balance,boolean isBuy);}-------------------------------------------------------------------------public interface IStockDAO {    //改变股票数量    public void updateIStock(int sid,int count,boolean isBuy);}-------------------------------------------------------------------------//DAOImplpackage cn.happy.day15tx.dao.impl;import cn.happy.day15tx.dao.IStockDAO;import org.springframework.jdbc.core.support.JdbcDaoSupport;/** * Created by Administrator on 2018/3/14. *///卖出public class StockDaoImpl extends JdbcDaoSupport implements IStockDAO {    public void updateIStock(int sid, int count, boolean isBuy) {        String sql=null;        if(isBuy){            //增加股票            sql="update Stock set count=count+? where sid=?";        }else{            //卖出股票            sql="update Stock set count=count-? where sid=?";        }        this.getJdbcTemplate().update(sql,count,sid);    }}-------------------------------------------------------------------------package cn.happy.day15tx.dao.impl;import cn.happy.day15tx.dao.IAccountDAO;import org.springframework.jdbc.core.support.JdbcDaoSupport;/** * Created by Administrator on 2018/3/14. *///买入public class AccountDaoImpl extends JdbcDaoSupport implements IAccountDAO {    public void updateAccount(int aid, int balance, boolean isBuy) {        String sql=null;        if(isBuy){            //购买            sql="update Account set balance=balance-? where aid=?";        }else{            //卖出            sql="update Account set balance=balance+? where aid=?";        }        this.getJdbcTemplate().update(sql,balance,aid);    }}------------------------------------------------------------------------Servicepackage cn.happy.day15tx.service;/** * Created by Administrator on 2018/3/14. */public interface IStockService {    //购买股票    public void updateStock(int aid,int balance,int sid,int count) throws Exception, Exception;}------------------------------------------------------------------------ServiceImplpackage cn.happy.day15tx.service.impl;import cn.happy.day15tx.dao.IAccountDAO;import cn.happy.day15tx.dao.IStockDAO;import cn.happy.day15tx.service.IStockService;import com.sun.javafx.beans.annotations.Default;import org.springframework.transaction.annotation.Isolation;import org.springframework.transaction.annotation.Propagation;import org.springframework.transaction.annotation.Transactional;/** * Created by Administrator on 2018/3/14. */public class StockServiceImpl implements IStockService {    //植入DAO层对象    private IAccountDAO accountDAO;    private IStockDAO iStockDAO;    //使用注解    @Transactional(isolation = Isolation.DEFAULT,propagation = Propagation.REQUIRED,rollbackFor = Exception.class)    public void updateStock(int aid, int balance, int sid, int count) throws Exception {        //创建boolean对象判断是买入true还是卖出false        boolean isBuy=true;        accountDAO.updateAccount(aid,balance,isBuy);　　　　//定义一个异常        if(true)        throw new Exception("出错了");        iStockDAO.updateIStock(sid,count,isBuy);    }    public IAccountDAO getAccountDAO() {        return accountDAO;    }    public void setAccountDAO(IAccountDAO accountDAO) {        this.accountDAO = accountDAO;    }    public IStockDAO getiStockDAO() {        return iStockDAO;    }    public void setiStockDAO(IStockDAO iStockDAO) {        this.iStockDAO = iStockDAO;    }} ------------------------------------------------------------- entity

package cn.happy.day15tx.entity; /**  * Created by Administrator on 2018/3/14.  */ //购票类 public class Account {
       private Integer aid;     private String aname;     private Integer balance;     public Integer getAid() {
           return aid;     }     public void setAid(Integer aid) {
           this.aid = aid;     }     public String getAname() {
           return aname;     }     public void setAname(String aname) {
           this.aname = aname;     }     public Integer getBalance() {
           return balance;     }     public void setBalance(Integer balance) {
           this.balance = balance;     } } -------------------------------------------------------

package cn.happy.day15tx.entity; /**  * Created by Administrator on 2018/3/14.  */ //股票类 public class Stock {
       private Integer sid;     private String sname;     private Integer count;     public Integer getSid() {
           return sid;     }     public void setSid(Integer sid) {
           this.sid = sid;     }     public String getSname() {
           return sname;     }     public void setSname(String sname) {
           this.sname = sname;     }     public Integer getCount() {
           return count;     }     public void setCount(Integer count) {
           this.count = count;     } }

 

一、配置xml文件

        
            
             
             
             
         
         
        
         
         
             
          
         
             
          
         
         
             
              
          
         
         
             
          
         
        
         
             
              
              
              
                  
                       
                        
        
         ISOLATION_DEFAULT,PROPAGATION_REQUIRED,-Exception
         　　　　　　　　　　
        
       
      
     

　　　　　　　　　　--> 　　　　　　  　　　　  　　

　　

测试方法

package day15tx;import cn.happy.JDBCTemplate.service.BookService;import cn.happy.day15tx.service.IStockService;import org.junit.Test;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;import java.util.List;/** * Created by Administrator on 2018/3/3. */public class Test20180314 {    //事物    @Test    public void Spring(){        ApplicationContext ctx=new ClassPathXmlApplicationContext("day15tx.xml");        IStockService service=(IStockService)ctx.getBean("stockServiceProxy");        try{            service.updateStock(1,2000,1,5);        }catch (Exception e){            e.printStackTrace();        }    }}

　　

 

二、使用注解管理事物

　　

在需要管理的方法上添加注解

@Transactional(isolation = Isolation.DEFAULT,propagation = Propagation.REQUIRED,rollbackFor = Exception.class)

　　

三、使用AspectJ实现事物管理