7、SpringBoot2之整合事务及AOP

本文在SpringBoot2之整合Mybatis的基础上进行

7.1、整合事务

7.1.1、mapper接口

1.     int deleteEmployeeById(int id);

复制代码

7.1.2、mapper映射文件

1.     <delete id="deleteEmployeeById" parameterType="int">
2.         delete from t_emp where emp_id = #{id}
3.     </delete>

复制代码

7.1.3、业务层接口及实现类

1. package online.liaojy.service;
3. /**
4. * @author liaojy
5. * @date 2023/12/25 - 6:31
6. */
7. public interface EmployeeService {
9.     int deleteEmployeeById(int id);
11. }

复制代码

注意：只要引入 spring-boot-starter-jdbc 启动器（详见6.1节），spring boot 便会自动配置好 DataSourceTransactionManager ；
因此，只需在方法（或者类）加上 @Transactional 注解，即可进行事务管理。

1. package online.liaojy.service.impl;
3. import online.liaojy.mapper.EmployeeMapper;
4. import online.liaojy.service.EmployeeService;
5. import org.springframework.beans.factory.annotation.Autowired;
6. import org.springframework.stereotype.Service;
7. import org.springframework.transaction.annotation.Transactional;
9. /**
10. * @author liaojy
11. * @date 2023/12/25 - 6:33
12. */
13. @Service
14. public class EmployeeServiceImpl implements EmployeeService {
16.     @Autowired
17.     private EmployeeMapper employeeMapper;
19.     @Transactional
20.     @Override
21.     public int deleteEmployeeById(int id) {
23.         // 删除一条数据
24.         int rowsOfDelete = employeeMapper.deleteEmployeeById(id);
25.         System.out.println("已成功删除"+rowsOfDelete+"行数据");
27.         // 制造一个异常
28.         int i = 1/0;
30.         return rowsOfDelete;
31.     }
33. }

复制代码

7.1.4、控制层方法

1.     @Autowired
2.     private EmployeeService employeeService;
4.     @RequestMapping("/deleteEmployeeById")
5.     public String deleteEmployeeById(){
6.         int i = employeeService.deleteEmployeeById(26);
7.         return "删除成功";
8.     }

复制代码

7.1.5、测试效果

测试前的数据

测试时发生异常

测试后的数据没变化，说明事务回滚功能正常

7.2、整合AOP

7.2.1、导入AOP启动器依赖

1.         
2.         <dependency>
3.             <groupId>org.springframework.boot</groupId>
4.             <artifactId>spring-boot-starter-aop</artifactId>
5.         </dependency>

复制代码

7.2.2、创建切面类

1. package online.liaojy.advice;
3. import org.aspectj.lang.JoinPoint;
4. import org.aspectj.lang.annotation.Aspect;
5. import org.aspectj.lang.annotation.Before;
6. import org.springframework.core.annotation.Order;
7. import org.springframework.stereotype.Component;
9. /**
10. * @author liaojy
11. * @date 2023/12/25 - 6:51
12. */
13. @Component
14. @Aspect
15. @Order(5)
16. public class LogAdvice {
18.     @Before("execution(* online.liaojy.service.*.*.*(..))")
19.     public void beforeLog(JoinPoint joinPoint){
20.         // 获取连接点所对应目标方法所在类的名称
21.         String className = joinPoint.getSignature().getClass().getSimpleName();
22.         // 获取连接点所对应目标方法的名称
23.         String methodName = joinPoint.getSignature().getName();
25.         System.out.println(className+"类的"+methodName+"方法开始执行了！");
26.     }
28. }

复制代码

7.2.3、测试效果



免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！