Spring(十六):声明式事务管理

一、什么是事务

事务就是一系列的业务逻辑的操作,必须要全部执行成功,否则每个操作所执行的内容都要撤销。

二、事务的四大特性

1.原子性(atomicity):事务虽然有一系列的操作,但要把它看作一个整体(单一原子),要么都成功,要么都失败;

2.一致性(consistency):事务必须是使数据库从一个一致性状态变到另一个一致性状态;

3.隔离性(isolation):一个事务的执行不能被其他事务干扰。即一个事务内部的操作及使用的数据对并发的其他事务是隔离的,并发执行的各个事务之间不能互相干扰;

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

三、Spring中声明式的事务管理实现

以上一篇学习中的项目为例

1.我们修改UserMapper接口,添加两个方法:

 package  com.jms.mapper;  import  com.jms.pojo.User;  import  java.util.List;  public   interface  UserMapper {

List
<User> selectUsers(); void insertUser(User user); void deleteUser( int id);

}

2.修改UserMapper.xml文件

 <?  xml version="1.0" encoding="UTF-8"  ?> 
 <!  DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd"
> < mapper namespace ="com.jms.mapper.UserMapper" > < select id ="selectUsers" resultType ="user" > select * from mybaties.user </ select > < insert id ="insertUser" parameterType ="com.jms.pojo.User" > insert into mybaties.user values(#{id}, #{username}, #{password}) </ insert > < delete id ="deleteUser" parameterType ="_int" > deletes from mybaties.user where id=#{id} </ delete > </ mapper >

请注意看,这里我的delete语句是有错误的。

3.修改实现类UserMapperImpl

 package  com.jms.mapper;  import  com.jms.pojo.User;  import  org.mybatis.spring.SqlSessionTemplate;  import  java.util.List;  public   class  UserMapperImpl  implements  UserMapper{  private  SqlSessionTemplate sqlSessionTemplate;  public   void  setSqlSessionTemplate(SqlSessionTemplate sqlSessionTemplate) {  this .sqlSessionTemplate = sqlSessionTemplate;
}

@Override
public List<User> selectUsers() {
User user
= new User(101, "jms101", "123456" );
UserMapper userMapper
= sqlSessionTemplate.getMapper(UserMapper. class );
userMapper.insertUser(user);
userMapper.deleteUser(
10001 ); return userMapper.selectUsers();
}

@Override
public void insertUser(User user) {
UserMapper userMapper
= sqlSessionTemplate.getMapper(UserMapper. class );
userMapper.insertUser(user);
}

@Override
public void deleteUser( int id) {
UserMapper userMapper
= sqlSessionTemplate.getMapper(UserMapper. class );
userMapper.deleteUser(id);
}
}

注意看,select方法中调用了insert和delete方法

4.测试类

 @Test  public   void  test01() {
ApplicationContext applicationContext
= new ClassPathXmlApplicationContext("applicationContext.xml" );
UserMapperImpl userMapper
= applicationContext.getBean("userMapper", UserMapperImpl. class );
userMapper.selectUsers();
}

由于delete语句有错误,所以一定会报错,但是insert语句会执行成功

 

查看数据库,insert插入成功

 

 很明显这不符合事务的原子性,所以我们需要配置事务管理,在出现错误时让已经执行的操作进行回滚。

我们先把插入的这一行删掉,然后配置spring配置文件spring-mybatis.xml,添加以下内容:

 <!--  配置声明式事务管理  --> 
     <  bean  id  ="transactionManager"  class  ="org.springframework.jdbc.datasource.DataSourceTransactionManager"  > 
         <  constructor-arg  ref  ="dataSource"   /> 
     </  bean  > 

     <!--  结合AOP实现事务的织入  --> 
     <!--  配置事务通知  --> 
     <  tx:advice  id  ="interceptor"  transaction-manager  ="transactionManager"  > 
         <!--  给哪些方法(这里是所有方法)配置事务管理  --> 
         <!--  配置事务的传播特性  --> 
         <  tx:attributes  > 
             <  tx:method  name  ="select*"  propagation  ="REQUIRED"  /> 
             <  tx:method  name  ="insert*"  propagation  ="REQUIRED"  /> 
             <  tx:method  name  ="delete*"  propagation  ="REQUIRED"  /> 
         </  tx:attributes  > 
     </  tx:advice  > 

     <!--  配置事务切入  --> 
     <  aop:config  > 
         <!--  切入点  --> 
         <  aop:pointcut  id  ="txPointCut"  expression  ="execution(* com.jms.mapper.*.*(..))"  /> 
         <  aop:advisor  advice-ref  ="interceptor"  pointcut-ref  ="txPointCut"  /> 
     </  aop:config  > 

三个步骤:配置事务管理、配置事务通知、配置事务切入。

注意配置事务通知中,name是事务的方法名,propagation是事务传播特性。

PROPAGATION_REQUIRED:支持当前事务,如果当前没有事务,就新建一个事务。这是默认选择。
PROPAGATION_SUPPORTS:支持当前事务,如果当前没有事务,就以非事务方式执行
PROPAGATION_MANDATORY:支持当前事务,如果当前没有事务,就抛出异常。
PROPAGATION_REQUIRES_NEW:新建事务,如果当前存在事务,把当前事务挂起
PROPAGATION_NOT_SUPPORTED:以非事务方式执行操作,如果当前存在事务,就把当前事务挂起。
PROPAGATION_NEVER:以非事务方式执行,如果当前存在事务,则抛出异常。
PROPAGATION_NESTED:支持当前事务,新增Savepoint点,与当前事务同步提交或回滚。

接下来进行测试:

依旧报错,但是表中没有被插入数据

 

 

 

(本文仅作个人学习记录用,如有纰漏敬请指正)

 

标签: Java

添加新评论