文章目录
- 一、事务的传播机制
- 1.1、nested 事务的几点说明:
- 二、示例
- 2.1、前言:
- 2.2、准备测试方法
- 1)创建beans.xml,开启事务
- 2)创建实体类和表(表创建读者可自定义创建)
- 3)创建service接口
- 4)创建其实现类(BlogServiceImpl,BlogService2)
- 5)创建Configuration类,用于创建DataSource实现
- 6)测试
- 2.3、事务传播机制的测试
- 1)required
- 操作1:BlogServiceImpl 和 BlogServiceImpl2 事务都为 required
- 操作2:BlogServiceImpl 事务为 not_supported,BlogServiceImpl2 为 required
- 2)requires_new
- 操作:blogserviceimpl 为 required,blogserviceimpl2 为 requires_new
- 3)nested
- 操作1:blogserviceimpl 事务 为 required,blogserviceimpl2 为 nested
- 操作2:BlogServiceImpl 事务传播机制 为 not_supported,BlogServiceImpl2 为 nested
- 4)supports
- 操作1:blogserviceimpl 事务为 required,blogserviceimpl2 为 supports
- 操作2:blogserviceimpl 事务为 not_supported,blogserviceimpl2 为 supports
- 5)not_supported
- 操作:BlogServiceImpl和BlogServiceImpl2 的事务都为 not_supported
- 6)mandatory
- 操作:BlogServiceImpl 事务为 not_supported,BlogServiceImpl2 为 mandatory
- mandatory 与 not_supported 的区别:
- 7)never
- 操作:BlogServiceImp l事务为 required,BlogServiceImpl2 为 mandatory
- 2.4、注意事项
- 三、参考文章
一、事务的传播机制
序号 | 事务的传播机制 | 说明 | 备注 |
---|---|---|---|
1 | required | 如果当前存在事务,就加入该事务。 如果当前没有事务,就创建一个新事务。 这是最常用的设置。 | 只创建一个事务。 |
2 | requires_new | 不管是否存在事务,都创建一个新的、自己的事务。 老事务 先挂起,再创建 新事务, 新事务 执行完并提交, 接着,继续执行 老事务,最后提交。 | 1、每次都创建一个新的事务。 2、创建 新事务 前,老事务 先挂起。 3、先执行的方法后提交事务,后执行的方法先提交事务。 4、老事务 的回滚,不会影响 新事务 的提交。 |
3 | nested | 如果当前存在事务,则 嵌套事务与外面事务使用同一事务,不同的是 嵌套内部开启一个新的保存点( savepoint ),执行有两种情况:(1)当嵌套内部 发生回滚,不影响外面事务的正常提交。 (2)当外面事务 发生回滚,则嵌套内的事务要回滚。 如果当前没有事务,则执行与 required 类似的操作。 | 皮之在,毛被烧掉。 皮之不存,毛将焉附。 |
4 | supports | 支持当前事务。 如果当前存在事务,就加入该事务, 如果当前不存在事务,就以非事务执行。 | supports 不会创建事务。 |
5 | not_supported | 不支持事务。 如果当前存在事务,就把当前事务 挂起。 如果当前没有事务,就以非事务执行。 | |
6 | mandatory | 强制、必须使用事务。 如果当前 已经存在事务,就加入该事务, 如果当前不存在事务,就 抛出异常。 | 1、mandatory 不会创建事务。 2、mandatory 执行的前提是已经存在事务。 |
7 | never | 禁止事务 。 如果当前存在事务,则 抛出异常, 如果当前没有事务,以非事务方式执行, | 必须在一个没有事务中执行,否则报错。 |
mandatory [ˈmændətəri]
强制的;命令的;受委托的
https://blog.csdn.net/u013378306/article/details/124738590
https://blog.csdn.net/albertfly/article/details/52681993
https://blog.csdn.net/weixin_43901882/article/details/125789702
1.1、nested 事务的几点说明:
- 嵌套事务开始执行时,它将取得一个 保存点(
savepoint
)。 如果这个嵌套事务失败,我们将回滚到此 保存点(savepoint
)。嵌套事务是外部事务的一部分,只有外部事务结束后它才会被提交。 - nested 事务与外部事务是同一个事务,不同之处是 nested 内部发生回滚时,回滚到 嵌套事务时的保存点 。
- 外面事务发生回滚时,嵌套事务了会回滚。皮之不存,毛将焉附
二、示例
转载: https://blog.csdn.net/qq_26323323/article/details/81908955
2.1、前言:
Spring的事务,也就是数据库的事务操作,符合ACID标准,也具有标准的事务隔离级别。
但是Spring事务有自己的特点,也就是事务传播机制。
所谓事务传播机制,也就是在事务在多个方法的调用中是如何传递的,是重新创建事务还是使用父方法的事务?父方法的回滚对子方法的事务是否有影响?这些都是可以通过事务传播机制来决定的。
2.2、准备测试方法
主要是创建两个service接口(接口主要是对数据库表的操作),并创建其实现类
1)创建beans.xml,开启事务
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:aop="http://www.springframework.org/schema/aop"xmlns:tx="http://www.springframework.org/schema/tx"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx.xsdhttp://www.springframework.org/schema/aophttp://www.springframework.org/schema/aop/spring-aop.xsd"><tx:annotation-driven transaction-manager="transactionManager"/></beans>
2)创建实体类和表(表创建读者可自定义创建)
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Blog {private int id;private String name;private String ur;
}
3)创建service接口
(BlogService和BlogService2,主要是对Blog的不同操作)
// BlogService
package jdbc;
public interface BlogService {void save(Blog blog);void update(Blog blog);
}// BlogService2
package jdbc;
public interface BlogService2 {void delete(int id);
}
4)创建其实现类(BlogServiceImpl,BlogService2)
BlogServiceImpl.java
@Transactional(propagation=Propagation.REQUIRED)
@Component
public class BlogServiceImpl implements BlogService {@Autowiredprivate JdbcTemplate jdbcTemplate;@Autowiredprivate BlogService2 blogService2;@Overridepublic void save(Blog blog) {String sql = "insert into blog values(?,?,?)";jdbcTemplate.update(sql,new Object[]{blog.getId(),blog.getName(),blog.getUr()},new int[]{java.sql.Types.INTEGER,java.sql.Types.VARCHAR,java.sql.Types.VARCHAR});blogService2.delete(16);// update(blog);
// throw new RuntimeException("error"); }@Overridepublic void update(Blog blog){String sql = "update blog set name = ? where id=?";jdbcTemplate.update(sql, new Object[]{blog.getName(),blog.getId()},new int[]{java.sql.Types.VARCHAR,java.sql.Types.INTEGER});}
}
BlogService2.java
@Transactional(propagation=Propagation.REQUIRED)
@Component
public class BlogServiceImpl2 implements BlogService2 {@Autowiredprivate JdbcTemplate jdbcTemplate;@Overridepublic void delete(int id){String sql = "delete from blog where id=?";jdbcTemplate.update(sql, id);}
}
注意:既然要实现多事务的传播,就需要在一个方法里调用另一个类的方法,下面的测试就是基于这种方法,
在 BlogService
的 save()
方法中调用 BlogService2
的 delete()
方法 。
5)创建Configuration类,用于创建DataSource实现
@Configuration
@ComponentScan(basePackages={"jdbc"})// 扫描BlogService实现类所在的包路径
@ImportResource(locations={"classpath:beans.xml"})// 添加事务管理
public class JdbcConfig {@Beanpublic JdbcTemplate jdbcTemplate(DataSource dataSource){return new JdbcTemplate(dataSource);}@Beanpublic DataSourceTransactionManager transactionManager(DataSource dataSource){return new DataSourceTransactionManager(dataSource);}@Beanpublic DataSource dataSource(){try {return new SimpleDriverDataSource(new com.mysql.jdbc.Driver(), "jdbc:mysql://localhost:3306/test", "root", "root");} catch (SQLException e) { e.printStackTrace();}return null;}
}
6)测试
public class Test {public static void main(String[] args) {AnnotationConfigApplicationContext ac = new AnnotationConfigApplicationContext(JdbcConfig.class);BlogService service = ac.getBean(BlogService.class);Blog b = new Blog(18,"lili","url");service.save(b);}
}
总结:大体的测试框架就如上所示,下面的测试修改主要是修改 BlogServiceImpl
、BlogServiceImpl2
的事务传播机制
@Transactional(propagation=Propagation.REQUIRED)
。
2.3、事务传播机制的测试
在 BlogService
的 save()
方法中调用
BlogService2
的 delete()
方法 。
1)required
定义:如果有事务则加入事务,如果没有事务,则创建一个新的(默认值)。
操作1:BlogServiceImpl 和 BlogServiceImpl2 事务都为 required
BlogServiceImpl 和 BlogServiceImpl2 的事务都为 @Transactional(propagation=Propagation.REQUIRED)
。
结果1:
说明:
当 BlogServiceImpl 提供事务的时,BlogServiceImpl2 的方法执行使用当前已有事务,不再新建事务;
操作2:BlogServiceImpl 事务为 not_supported,BlogServiceImpl2 为 required
BlogServiceImpl 事务 为 @Transactional(propagation=Propagation.NOT_SUPPORTED)
,
BlogServiceImpl2 为 @Transactional(propagation=Propagation.REQUIRED)
。
结果2:
说明:
当 BlogServiceImpl 不创建事务的时候,BlogServiceImpl2 的方法执行发现没有事务可用,自己新建事务;
2)requires_new
定义:不管是否存在事务,都创建一个新的事务,原来的事务挂起,新的事务执行完毕后,继续执行老的事务。
操作:blogserviceimpl 为 required,blogserviceimpl2 为 requires_new
BlogServiceImpl 事务为 @Transactional(propagation=Propagation.REQUIRED)
,
BlogServiceImpl2 为 @Transactional(propagation=Propagation.requires_new)
。
结果:
总结:
requires_new 为当前方法创建一个新的事务,并且 新事务 先提交 ,然后再提交 老事务。
3)nested
定义:如果当前存在事务,则在嵌套事务内执行。
操作1:blogserviceimpl 事务 为 required,blogserviceimpl2 为 nested
BlogServiceImpl 事务为 @Transactional(propagation=Propagation.REQUIRED)
,
BlogServiceImpl2 为 @Transactional(propagation=Propagation.NESTED)
。
结果1:
说明:
save方法创建一个事务,则再调用delete方法时,直接在该事务的基础上创建一个嵌套事务,本质上还是同一个事务,做一次提交。
操作2:BlogServiceImpl 事务传播机制 为 not_supported,BlogServiceImpl2 为 nested
nested 定义: 当外面没有事务时,则使用与 required
类似。
BlogServiceImpl 事务为 @Transactional(propagation=Propagation.NOT_SUPPORTED)
,
BlogServiceImpl2 的仍为 @Transactional(propagation=Propagation.NESTED)
。
结果2:
说明:
save方法不创建事务,则调用delete方法时,直接创建一个新的事务,单独提交。
4)supports
定义:如果其他bean调用这个方法时,其他bean声明了事务,则就用这个事务,如果没有声明事务,那就不用事务。
操作1:blogserviceimpl 事务为 required,blogserviceimpl2 为 supports
BlogServiceImpl 事务为 @Transactional(propagation=Propagation.REQUIRED)
,
BlogServiceImpl2 为 @Transactional(propagation=Propagation.SUPPORTS)
。
结果1:
操作2:blogserviceimpl 事务为 not_supported,blogserviceimpl2 为 supports
BlogServiceImpl 事务为 @Transactional(propagation=Propagation.NOT_SUPPORTED)
,
BlogServiceImpl2 为 @Transactional(propagation=Propagation.SUPPORTS)
。
结果2:
说明:
SUPPORTS类型的事务传播机制,是否使用事务取决于调用方法是否有事务,如果有则直接用,如果没有则不使用事务。
5)not_supported
定义:Spring不为当前方法开启事务,相当于没有事务。
操作:BlogServiceImpl和BlogServiceImpl2 的事务都为 not_supported
BlogServiceImpl和BlogServiceImpl2 修改为 @Transactional(propagation=Propagation.NOT_SUPPORTED)
。
结果:
说明:
not_supported 相当于没有 Spring事务,每条执行语句单独执行,单独提交。
6)mandatory
定义:必须在一个已有的事务中执行,否则报错。
操作:BlogServiceImpl 事务为 not_supported,BlogServiceImpl2 为 mandatory
BlogServiceImpl 事务为 @Transactional(propagation=Propagation.NOT_SUPPORTED)
,
BlogServiceImpl2 为 @Transactional(propagation=Propagation.MANDATORY)
。 查看是否报错。
结果:
说明:
mandatory 下没有事务下,所以报错。
mandatory 与 not_supported 的区别:
mandatory 必须在已有事务下被调用,否则报错。
not_supported 执行数据库层面的事务操作,故当前测试中,insert方法成功执行,delete方法的抛错并不影响insert方法的执行
7)never
定义:必须在一个没有的事务中执行,否则报错。
操作:BlogServiceImp l事务为 required,BlogServiceImpl2 为 mandatory
BlogServiceImpl 事务为 @Transactional(propagation=Propagation.REQUIRED)
,
BlogServiceImpl2 为 @Transactional(propagation=Propagation.MANDATORY)
。 查看是否报错。
结果:
说明:
never 存在事务,所以报错;
save方法开启一个事务,还没来及提交发现delete方法报错,只能回滚事务。
2.4、注意事项
1)required
当两个方法的传播机制都是required时,如果一旦发生回滚,两个方法都会回滚。
2)requires_new
当delete方法传播机制为requires_new,会开启一个新的事务,并单独提交方法,所以save方法的回滚并不影响delete方法事务提交。
3)nested
当save方法为required,delete方法为nested时,delete方法开启一个嵌套事务;
当save方法回滚时,delete方法也会回滚;反之,如果delete方法回滚,则并不影响save方法的提交。
三、参考文章
https://blog.csdn.net/qq_26323323/article/details/81908955
https://blog.csdn.net/qq_17085835/article/details/84837253