爱玩科技网
您的当前位置:首页@Transactional注解详细用法

@Transactional注解详细用法

来源:爱玩科技网
@Transactional注解详细⽤法

概述

事务管理对于企业应⽤来说是⾄关重要的,即使出现异常情况,它也可以保证数据的⼀致性。Spring Framework对事务管理提供了⼀致的抽象,其特点如下:

为不同的事务API提供⼀致的编程模型,⽐如JTA(Java Transaction API), JDBC, Hibernate, JPA(Java Persistence API和JDO(JavaData Objects)

⽀持声明式事务管理,特别是基于注解的声明式事务管理,简单易⽤提供⽐其他事务API如JTA更简单的编程式事务管理API与spring数据访问抽象的完美集成事务管理⽅式

spring⽀持编程式事务管理和声明式事务管理两种⽅式。

编程式事务管理使⽤TransactionTemplate或者直接使⽤底层的PlatformTransactionManager。对于编程式事务管理,spring推荐使⽤TransactionTemplate。

声明式事务管理建⽴在AOP之上的。其本质是对⽅法前后进⾏拦截,然后在⽬标⽅法开始之前创建或者加⼊⼀个事务,在执⾏完⽬标⽅法之后根据执⾏情况提交或者回滚事务。声明式事务最⼤的优点就是不需要通过编程的⽅式管理事务,这样就不需要在业务逻辑代码中掺杂事务管理的代码,只需在配置⽂件中做相关的事务规则声明(或通过基于@Transactional注解的⽅式),便可以将事务规则应⽤到业务逻辑中。显然声明式事务管理要优于编程式事务管理,这正是spring倡导的⾮侵⼊式的开发⽅式。声明式事务管理使业务代码不受污染,⼀个普通的POJO对象,只要加上注解就可以获得完全的事务⽀持。和编程式事务相⽐,声明式事务唯⼀不⾜地⽅是,后者的最细粒度只能作⽤到⽅法级别,⽆法做到像编程式事务那样可以作⽤到代码块级别。但是即便有这样的需求,也存在很多变通的⽅法,⽐如,可以将需要进⾏事务管理的代码块独⽴为⽅法等等。

声明式事务管理也有两种常⽤的⽅式,⼀种是基于tx和aop名字空间的xml配置⽂件,另⼀种就是基于@Transactional注解。显然基于注解的⽅式更简单易⽤,更清爽。

⾃动提交(AutoCommit)与连接关闭时的是否⾃动提交

⾃动提交默认情况下,数据库处于⾃动提交模式。每⼀条语句处于⼀个单独的事务中,在这条语句执⾏完毕时,如果执⾏成功则隐式的提交事务,如果

执⾏失败则隐式的回滚事务。

对于正常的事务管理,是⼀组相关的操作处于⼀个事务之中,因此必须关闭数据库的⾃动提交模式。不过,这个我们不⽤担⼼,spring会将底层连接的⾃动提交特性设置为false。

org/springframework/jdbc/datasource/DataSourceTransactionManager.java

1 // switch to manual commit if necessary. this is very expensive in some jdbc drivers, 2 // so we don't want to do it unnecessarily (for example if we've explicitly 3 // configured the connection pool to set it already). 4 if (con.getautocommit()) {

5 txobject.setmustrestoreautocommit(true); 6 if (logger.isdebugenabled()) {

7 logger.debug(\"switching jdbc connection [\" + con + \"] to manual commit\"); 8 }

9 con.setautocommit(false);10 }

有些数据连接池提供了关闭事务⾃动提交的设置,最好在设置连接池时就将其关闭。但C3P0没有提供这⼀特性,只能依靠spring来设置。因为JDBC规范规定,当连接对象建⽴时应该处于⾃动提交模式,这是跨DBMS的缺省值,如果需要,必须显式的关闭⾃动提交。C3P0遵守这⼀规范,让客户代码来显式的设置需要的提交模式。

连接关闭时的是否⾃动提交当⼀个连接关闭时,如果有未提交的事务应该如何处理?JDBC规范没有提及,C3P0默认的策略是回滚任何未提交的事务。这是⼀个正确的策略,但JDBC驱动提供商之间对此问题并没有达成⼀致。

C3P0的autoCommitOnClose属性默认是false,没有⼗分必要不要动它。或者可以显式的设置此属性为false,这样会更明确。基于注解的声明式事务管理配置spring-servlet.xml

1

2

3 4 5

6

7

还要在spring-servlet.xml中添加tx名字空间

1 ...

2 xmlns:tx=\"http://www.springframework.org/schema/tx\" 3 xmlns:aop=\"http://www.springframework.org/schema/aop\" 4 xsi:schemaLocation=\" 5 ... 6

7 http://www.springframework.org/schema/tx 8 9

10 http://www.springframework.org/schema/tx/spring-tx.xsd11 12 ...

MyBatis⾃动参与到spring事务管理中,⽆需额外配置,只要org.mybatis.spring.SqlSessionFactoryBean引⽤的数据源与DataSourceTransactionManager引⽤的数据源⼀致即可,否则事务管理会不起作⽤。另外需要下载依赖包.jar放置到WEB-INF/lib⽬录下。否则spring初始化时会报异常java.lang.NoClassDefFoundError: org/aopalliance/intercept/MethodInterceptorspring事务特性

spring所有的事务管理策略类都继承⾃org.springframework.transaction.PlatformTransactionManager接⼝

1 public interface PlatformTransactionManager {2

3 TransactionStatus getTransaction(TransactionDefinition definition)4 throws TransactionException;5

6 void commit(TransactionStatus status) throws TransactionException;7

8 void rollback(TransactionStatus status) throws TransactionException;9 }

其中TransactionDefinition接⼝定义以下特性:

事务隔离级别隔离级别是指若⼲个并发的事务之间的隔离程度。TransactionDefinition 接⼝中定义了五个表⽰隔离级别的常量:

TransactionDefinition.ISOLATION_DEFAULT:这是默认值,表⽰使⽤底层数据库的默认隔离级别。对⼤部分数据库⽽⾔,通常这值就是TransactionDefinition.ISOLATION_READ_COMMITTED。

TransactionDefinition.ISOLATION_READ_UNCOMMITTED:该隔离级别表⽰⼀个事务可以读取另⼀个事务修改但还没有提交的数据。该级别不能防⽌脏读,不可重复读和幻读,因此很少使⽤该隔离级别。⽐如PostgreSQL实际上并没有此级别。

TransactionDefinition.ISOLATION_READ_COMMITTED:该隔离级别表⽰⼀个事务只能读取另⼀个事务已经提交的数据。该级别可以防⽌脏读,这也是⼤多数情况下的推荐值。

TransactionDefinition.ISOLATION_REPEATABLE_READ:该隔离级别表⽰⼀个事务在整个过程中可以多次重复执⾏某个查询,并且每次返回的记录都相同。该级别可以防⽌脏读和不可重复读。

TransactionDefinition.ISOLATION_SERIALIZABLE:所有的事务依次逐个执⾏,这样事务之间就完全不可能产⽣⼲扰,也就是说,该级别可以防⽌脏读、不可重复读以及幻读。但是这将严重影响程序的性能。通常情况下也不会⽤到该级别。

事务传播⾏为所谓事务的传播⾏为是指,如果在开始当前事务之前,⼀个事务上下⽂已经存在,此时有若⼲选项可以指定⼀个事务性⽅法的执⾏⾏为。在TransactionDefinition定义中包括了如下⼏个表⽰传播⾏为的常量:

TransactionDefinition.PROPAGATION_REQUIRED:如果当前存在事务,则加⼊该事务;如果当前没有事务,则创建⼀个新的事务。这是默认值。

TransactionDefinition.PROPAGATION_REQUIRES_NEW:创建⼀个新的事务,如果当前存在事务,则把当前事务挂起。

TransactionDefinition.PROPAGATION_SUPPORTS:如果当前存在事务,则加⼊该事务;如果当前没有事务,则以⾮事务的⽅式继续运⾏。

TransactionDefinition.PROPAGATION_NOT_SUPPORTED:以⾮事务⽅式运⾏,如果当前存在事务,则把当前事务挂起。TransactionDefinition.PROPAGATION_NEVER:以⾮事务⽅式运⾏,如果当前存在事务,则抛出异常。

TransactionDefinition.PROPAGATION_MANDATORY:如果当前存在事务,则加⼊该事务;如果当前没有事务,则抛出异常。TransactionDefinition.PROPAGATION_NESTED:如果当前存在事务,则创建⼀个事务作为当前事务的嵌套事务来运⾏;如果当前没有事务,则该取值等价于TransactionDefinition.PROPAGATION_REQUIRED。

事务超时所谓事务超时,就是指⼀个事务所允许执⾏的最长时间,如果超过该时间但事务还没有完成,则⾃动回滚事务。在TransactionDefinition 中以 int 的值来表⽰超时时间,其单位是秒。

默认设置为底层事务系统的超时值,如果底层数据库事务系统没有设置超时值,那么就是none,没有超时。

事务只读属性只读事务⽤于客户代码只读但不修改数据的情形,只读事务⽤于特定情景下的优化,⽐如使⽤Hibernate的时候。默认为读写事务。spring事务回滚规则

指⽰spring事务管理器回滚⼀个事务的推荐⽅法是在当前事务的上下⽂内抛出异常。spring事务管理器会捕捉任何未处理的异常,然后依据规则决定是否回滚抛出异常的事务。

默认配置下,spring只有在抛出的异常为运⾏时unchecked异常时才回滚该事务,也就是抛出的异常为RuntimeException的⼦类(Errors也会导致事务回滚),⽽抛出checked异常则不会导致事务回滚。

可以明确的配置在抛出那些异常时回滚事务,包括checked异常。也可以明确定义那些异常抛出时不回滚事务。

还可以编程性的通过setRollbackOnly()⽅法来指⽰⼀个事务必须回滚,在调⽤完setRollbackOnly()后你所能执⾏的唯⼀操作就是回滚。@Transactional注解@Transactional属性

属性valuepropagationisolationreadOnlytimeoutrollbackForrollbackForClassNamenoRollbackForString

enum: Propagationenum: Isolationboolean

int (in seconds granularity)类名数组,必须继承⾃Throwable

类型

描述

可选的限定描述符,指定使⽤的事务管理器可选的事务传播⾏为设置可选的事务隔离级别设置读写或只读事务,默认读写事务超时时间设置

导致事务回滚的异常类名字数组不会导致事务回滚的异常类名字数组

Class对象数组,必须继承⾃Throwable导致事务回滚的异常类数组Class对象数组,必须继承⾃Throwable不会导致事务回滚的异常类数组

noRollbackForClassName类名数组,必须继承⾃Throwable

⽤法@Transactional 可以作⽤于接⼝、接⼝⽅法、类以及类⽅法上。当作⽤于类上时,该类的所有 public ⽅法将都具有该类型的事务属性,同时,我们也可以在⽅法级别使⽤该标注来覆盖类级别的定义。

虽然 @Transactional 注解可以作⽤于接⼝、接⼝⽅法、类以及类⽅法上,但是 Spring 建议不要在接⼝或者接⼝⽅法上使⽤该注解,因为这只有在使⽤基于接⼝的代理时它才会⽣效。另外, @Transactional 注解应该只被应⽤到 public ⽅法上,这是由 Spring AOP 的本质决定的。如果你在 protected、private 或者默认可见性的⽅法上使⽤ @Transactional 注解,这将被忽略,也不会抛出任何异常。

默认情况下,只有来⾃外部的⽅法调⽤才会被AOP代理捕获,也就是,类内部⽅法调⽤本类内部的其他⽅法并不会引起事务⾏为,即使被调⽤⽅法使⽤@Transactional注解进⾏修饰。

1 @Transactional(readOnly = true)

2 public class DefaultFooService implements FooService { 3

4 public Foo getFoo(String fooName) { 5 // do something 6 } 7

8 // these settings have precedence for this method 9 //⽅法上注解属性会覆盖类注解上的相同属性

10 @Transactional(readOnly = false, propagation = Propagation.REQUIRES_NEW)11 public void updateFoo(Foo foo) {12 // do something13 }14 }

因篇幅问题不能全部显示,请点此查看更多更全内容