博客

上一篇博文

《SSM三大框架整合详细教程》

详细说了如何整合Spring、SpringMVC和MyBatis这三大框架。但是没有说到如何配置mybatis的事务管理，在编写业务的过程中，会需要进行事务处理，当需要执行多条插入语句时，如果前几条成功，而最后一条失败，那么我们需要回滚数据库操作，保持数据的一致性和完整性，此时，就需要利用DB的事务处理。事务是恢复和并发控制的基本单位。

简单来说，所谓的事务，是一个操作序列，这些操作要么都执行，要么都不执行，它是一个不可分割的工作单位。

事务应该具有4个属性：原子性、一致性、隔离性、持久性。这四个属性通常称为ACID特性。

原子性（atomicity）。一个事务是一个不可分割的工作单位，事务中包括的诸操作要么都做，要么都不做。

一致性（consistency）。事务必须是使数据库从一个一致性状态变到另一个一致性状态。一致性与原子性是密切相关的。

隔离性（isolation）。一个事务的执行不能被其他事务干扰。即一个事务内部的操作及使用的数据对并发的其他事务是隔离的，并发执行的各个事务之间不能互相干扰。

持久性（durability）。持续性也称永久性（permanence），指一个事务一旦提交，它对数据库中数据的改变就应该是永久性的。接下来的其他操作或故障不应该对其有任何影响。

MyBatis集成Spring事务管理

在SSM框架中，使用的是Spring的事务管理机制。Spring可以使用编程式实现事务，声明式实现事务以及注解式实现事务。本文主要说一下如何使用注解式@Transanctional实现实现事务管理。

本文代码例子基于上一篇博文，具体代码

《SSM三大框架整合详细教程》

中已经给出。简单看下目录结构以及实体类：

1、配置spring-mybatis.xml文件

如要实现注解形式的事务管理，只需要在配置文件中加入以下代码即可：

       
        <!– 开启事务注解驱动 –>
       
        <
        
         tx:annotation-driven
         
          />
       
        <!– (事务管理)transaction manager, use JtaTransactionManager for global tx –>
       
        <
        
         bean
         
          id=
          
           “transactionManager”
       
        class=
        
         “org.springframework.jdbc.datasource.DataSourceTransactionManager”
         
          >
       
        <
        
         property
         
          name=
          
           “dataSource”
           
            ref=
            
             “dataSource”
             
              />
       
        </
        
         bean
         
          >

当然，如果此时xml文件报错，那是由于没有引入xmlns和schema导致的，无法识别文档结构。引入头文件即可，以下是我的，根据自己需要引入：

       
        <
        
         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:mvc=
          
           “http://www.springframework.org/schema/mvc”
       
        xmlns:tx=
        
         “http://www.springframework.org/schema/tx”
         
          xmlns:jdbc=
          
           “http://www.springframework.org/schema/jdbc”
       
        xsi:schemaLocation=”http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
       http://www.springframework.org/schema/context
       http://www.springframework.org/schema/context/spring-context-3.1.xsd
       http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
       http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
       http://www.springframework.org/schema/mvc
       http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd”
       
        >

在此用一个小例子来测试事务管理是否成功配置。代码基础是SSM框架搭建里面的测试代码。我们现在注意@Transactional只能被应用到public方法上，对于其它非public的方法，如果标记了@Transactional也不会报错,但方法没有事务功能。

实体类、DAO接口，业务接口，以及业务实现都有，这个测试

      
       /**
      
       * 事务处理必须抛出异常，Spring才会帮助事务回滚
      
       * @param users
      
       */

      
       @Transactional
      
       @Override
      
       public
       
        void insertUser(List<User> users) {
      
       // TODO Auto-generated method stub
      
       for (
       
        int i =
        
         0; i < users.size(); i++) {
      
       if(i<
       
        2){
      
       this.userDao.insert(users.get(i));
      }
      
       else {
      
       throw
       
        new RuntimeException();
      }
      }
      }

接下来在测试类中添加如下方法进行测试：

         
          @Test
         
        

         
          public
          
           void testTransaction(){
          
         
        

         List<User> users =
         
          new ArrayList<User>();
         
        

         
          for(
          
           int i=
           
            1;i<
            
             5;i++){
            
           
          
         
        

         User user =
         
          new User();
         
        

         user.setAge(i);
        

         user.setPassword(i+
         
          “111111”);
         
        

         user.setUserName(
         
          “测试”+i);
         
        

         users.add(user);
        

         }
        

         
          this.userService.insertUser(users);
         
        

         }
         
          @Test
         
          public
          
           void testTransaction(){
         List<User> users =
         
          new ArrayList<User>();
         
          for(
          
           int i=
           
            1;i<
            
             5;i++){
         User user =
         
          new User();
         user.setAge(i);
         user.setPassword(i+
         
          “111111”);
         user.setUserName(
         
          “测试”+i);
         users.add(user);
         }
         
          this.userService.insertUser(users);
         }