事务嵌套，只保存内层正常的记录，其它记录不保存

- 日理万妓 2022-12-16 06:41 100阅读 0赞

内层不出错的方法，开启新事务注解

@Transactional(propagation = Propagation.REQUIRES_NEW)
    	public int saveCategory(Category category)
    	{
    		int i = categoryMapper.insertCategory(category);
    		return i;
    	}

内层出错的方法，开启新事务注解

@Override
    	@Transactional(propagation = Propagation.REQUIRES_NEW)
    	public int insertCategory(Category category)
    	{
    		int i = categoryMapper.insertCategory(category);
    		int a = 1/0;
    		return i;
    	}

外层方法 使用老注解@Transactional(rollbackFor = \{Exception.class\})  
对内层的报错进行捕获，同时抛出异常，所有的外层数据都回滚，内层不出错的数据则不会回滚

@Transactional(rollbackFor = {Exception.class})
    	public int saveBrand2(Brand brand) throws Exception
    	{
    		int i = 0;
    		i = brandMapper.insertBrand(brand);
    		Category category = new Category();
    		category.setCategoryPath("YYYYYY");
    		category.setName("呵呵呵呵呵呵");
    		Category category2 = new Category();
    		category2.setCategoryPath("XXXXXXXX");
    		category2.setName("哈哈哈哈哈哈");
    		try {	categoryService.saveCategory(category);//内层不出错
    				categoryService.insertCategory(category2);//内层出错
    		}catch (Exception e) {
    			e.printStackTrace();
    			System.out.println("发生异常了，回滚所有支付操作");
    			throw new Exception("内层的异常"+e.getMessage());//外层出错
    		}
    		//int a = 1/0;//外层出错
    		return i;
    
    	}

测试方法

@Test
        public void saveBrand2() {
            try {
                Brand brand = new Brand();
                brand.setErpBrandCode("1000000");
                brand.setName("哈哈哈");
                brandService.saveBrand2(brand);
            } catch (Exception e) {
                System.out.println(e.getMessage());
                e.printStackTrace();
            }
        }