标签:
在实际开发中,其实很少会用到事务,一般情况下事务用的比较多的是在金钱计算方面。
mybatis与spring集成后,其事务该怎么做?其实很简单,直接在上一节代码的基础上在相应的方法(通常是service层)上加上@Transactional注解即可。
1、com.xxx.firstboot.exception.UserException
1 package com.xxx.firstboot.exception; 2 3 import org.springframework.dao.DataAccessException; 4 5 /** 6 * 自定义异常,用于测试事务 7 */ 8 public class UserException extends DataAccessException{ 9 10 private static final long serialVersionUID = 8901479830692029025L; 11 12 public UserException(String msg) { 13 super(msg); 14 } 15 16 }
说明:这是一个自定义注解,继承了DataAccessException类。
2、com.xxx.firstboot.dao.UserDao
1 public int insertUser(String username, String password){ 2 return userMapper.insertUser(username, password); 3 } 4 5 public void testTransactional(String username){ 6 throw new UserException("测试事务"); 7 }
说明:该类中对于事务的测试只使用到了两个方法,第二个方法testTransactional抛出自定义的异常。
3、com.xxx.firstboot.service.UserService
1 @Transactional 2 public void testTransaction(String username, String password){ 3 System.out.println(userDao.insertUser(username, password)); 4 userDao.testTransactional(username); 5 }
说明:在该方法中调用了上述的userDao的两个方法。
第一个方法向数据库插入一条数据,第二个方法抛出我们的自定义异常,如果事务配置成功,那么第一个方法插入数据库会回滚,否则,插入数据成功。
4、com.xxx.firstboot.controller.UserController
1 @ApiOperation("测试事务") 2 @ApiImplicitParams({ 3 @ApiImplicitParam(paramType="query",name="username",dataType="String",required=true,value="用户的姓名",defaultValue="zhaojigang"), 4 @ApiImplicitParam(paramType="query",name="password",dataType="String",required=true,value="用户的密码",defaultValue="wangna") 5 }) 6 @ApiResponses({ 7 @ApiResponse(code=400,message="请求参数没填好"), 8 @ApiResponse(code=404,message="请求路径没有或页面跳转路径不对") 9 }) 10 @RequestMapping(value="/testTransaction",method=RequestMethod.GET) 11 public void testTransaction(@RequestParam("username") String username, 12 @RequestParam("password") String password) { 13 userService.testTransaction(username, password); 14 }
测试:
使用maven命令启动服务-->swagger运行URL-->查看数据库是否插入成功
疑问:查了很多资料,mybatis与springboot集成后(数据源采用了druid),为了添加事务,很多人会在上一节的MyBatisConfig这个类中做两件事请
1 /** 2 * 配置事务管理器 3 */ 4 @Bean 5 @Primary 6 public DataSourceTransactionManager transactionManager() throws Exception{ 7 return new DataSourceTransactionManager(getDataSource()); 8 }
添加这句的作用:在使用@Transactional注解的地方使用方法中的事务管理器进行事务管理。
标签:
原文地址:http://www.cnblogs.com/java-zhao/p/5350106.html