运行类上开启事物注解@EnableTransactionManagement
@RestController
@SpringBootApplication
public class App {
public static void main( String[] args ){
ConfigurableApplicationContext context = SpringApplication.run(App.class, args);
}
准备工作:创建Book.java和Author.java且增删改查方法
单表多数据事物处理
有一个很常见的需求,在同一张表里面,批量插入100条数据,但是由于这100条数据之间存在一定的相关性,只要其中任何一条事物的插入失败,之前插入成功的数据就全部回滚,这应当如何实现?这里有两种解决方案:
1、使用MyBatis的批量插入功能
2、使用Spring管理事物,任何一条数据插入失败则失败
由于我们限定的前提是单表,因此比较推荐的是第一种做法。
第二种做法尽管也可以实现我们的目标,但是每插入一条数据就要发起一次数据库连接,即使使用了数据库连接池,但在性能上依然有一定程度的损失。而使用MyBatis的批量插入功能,只需要发起一次数据库的连接,这100次的插入操作在MyBatis看来是一个整体,其中任何一个插入的失败都将导致整体插入操作的失败,即:要么全部成功,要么全部失败。
dao层已定义一个批量插入的方法
多库、多表多数据处理
上面的场景是对于单表的事物管理做法的推荐:实际上这并没有用到事物管理,而是使用MyBatis批量操作数据的做法,目的是为了减少和数据库的交互次数。
现在有另外一种场景,我要对单库/多库的两张表(Book表、Author表)同时插入一条数据,要么全部成功,要么全部失败,该如何处理?此时明显就不可以使用MyBatis批量操作的方法了,要实现这个功能,可以使用Spring的事物管理。
前面文章有讲,Dao层中的方法更多的是一种对数据库的增删改查的原子性操作,而Service层中的方法相当于对这些原子性的操作做一个组合。
严格地说Service作为服务层,更多的是应该对同一个Dao中的多个方法进行组合,如果要用到多个Dao中的方法,建议应该是放到Controller层中,引入两个Service
@Transactional注解
这个注解用于开启事物管理,注意@Transactional注解的使用前提是该方法所在的类是一个Spring Bean
@RestController
@RequestMapping("/author")
public class AuthorController {
@Resource
private BookService bookService;
@Resource
private AuthorService authorService;
@Transactional
@RequestMapping("/saveAuthor")
public String saveAuthor(){
Book book = new Book();
book.setName("Test1");
book.setPrice(101.3f);
book.setProduceTime(new Date());
bookService.save(book);
//
Author author = new Author();
//author.setName("lucy");
authorService.save(author);
return "success author";
}
}
测试
controller里面新增book和author,book新增成功之后,author故意不设置name属性,此时数据库报错(设置author的name的数据库属性不能为null),则book也会回滚掉
关于注解@Transactional
@Transactional可以精细到具体的类甚至具体的方法上(区别是同一个类,对方法的事物管理配置会覆盖对类的事务管理配置),另外,声明式事物中的一些属性,在@Transaction注解中都可以进行配置,下面总结一下常用的一些属性。
(1) @Transactional(propagation = Propagation.REQUIRED)
最重要的先说,propagation属性表示的是事物的传播特性,一共有以下几种:
因此我们可以来简单分析一下上面的insertTeacherAndStudent方法:
由于没有指定propagation属性,因此事物传播特性为默认的REQUIRED
StudentDao的insertStudent方法先运行,此时没有事物,因此新建一个事物
TeacherDao的insertTeacher方法接着运行,此时由于StudentDao的insertStudent方法已经开启了一个事物,insertTeacher方法加入到这个事物中
StudentDao的insertStudent方法和TeacherDao的insertTeacher方法组成了一个事物,两个方法要么同时执行成功,要么同时执行失败
(2)@Transactional(isolation = Isolation.DEFAULT)
事物隔离级别,这个不细说了,可以参看事物及事物隔离级别一文。
(3)@Transactional(readOnly = true)
该事物是否为一个只读事物,配置这个属性可以提高方法执行效率。
(4)@Transactional(rollbackFor = {ArrayIndexOutOfBoundsException.class, NullPointerException.class})
遇到方法抛出ArrayIndexOutOfBoundsException、NullPointerException两种异常会回滚数据,仅支持RuntimeException的子类。
(5)@Transactional(noRollbackFor = {ArrayIndexOutOfBoundsException.class, NullPointerException.class})
这个和上面的相反,遇到ArrayIndexOutOfBoundsException、NullPointerException两种异常不会回滚数据,同样也是仅支持RuntimeException的子类。对(4)、(5)不是很理解的朋友,我给一个例子:
@Transactional(rollbackForClassName = {"NullPointerException"})public void insertTeacherAndStudent(Teacher teacher, Student student){ studentDao.insertStudent(student); teacherDao.insertTeacher(teacher); String s = null; s.length();}
构造Student、Teacher的数据运行一下,然后查看下库里面有没有对应的记录就好了,然后再把rollbackForClassName改为noRollbackForClassName,对比观察一下。
(6)@Transactional(rollbackForClassName = {"NullPointerException"})、@Transactional(noRollbackForClassName = {"NullPointerException"})
这两个放在一起说了,和上面的(4)、(5)差不多,无非是(4)、(5)是通过.class来指定要回滚和不要回滚的异常,这里是通过字符串形式的名字来制定要回滚和不要回滚的异常。
(7)@Transactional(timeout = 30)
事物超时时间,单位为秒。
(8)@Transactional(value = "tran_1")
value这个属性主要就是给某个事物一个名字而已,这样在别的地方就可以使用这个事物的配置。