eclipse 使用maven 构建maven + 数据库事务

àì夳堔傛蜴生んèń 2023-10-17 11:35 56阅读 0赞

本文转载至：[http://www.cnblogs.com/java-zhao/p/5350106.html][http_www.cnblogs.com_java-zhao_p_5350106.html]

在实际开发中，其实很少会用到事务，一般情况下事务用的比较多的是在金钱计算方面。

mybatis与spring集成后，其事务该怎么做？其实很简单，直接在上一节代码的基础上在相应的方法（通常是service层）上加上@Transactional注解即可。

1、com.wlsq.app.exception.UserException

package com.wlsq.app.exception;
    
    import org.springframework.dao.DataAccessException;
    
    public class UserException extends DataAccessException {
    
    	/**
    	 * 
    	 */
    	private static final long serialVersionUID = 1L;
    
    	public UserException(String msg) {
    		super(msg);
    		// TODO Auto-generated constructor stub
    	}
    
    }

说明：这是一个自定义注解，继承了DataAccessException类。

2、com.wlsq.app.dao.UserDao

package com.wlsq.app.dao;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Repository;
    
    import com.wlsq.app.domain.User;
    import com.wlsq.app.exception.UserException;
    import com.wlsq.app.mapper.UserMapper;
    
    @Repository
    public class UserDao {
    	 	@Autowired
    	    private UserMapper userMapper;
    	    
    	    public int insertUser(String loginname, String password){
    	        return userMapper.insertUser(loginname, password);
    	    }
    	    
    	    public int insertUserWithBackId(User user){    
    	        return userMapper.insertUserWithBackId(user);
    	    }
    	    
    	    public void testTransactional(String username){
    	        throw new UserException("测试事务");
    	    }
    
    }

说明：该类中对于事务的测试只使用到了两个方法，第二个方法testTransactional抛出自定义的异常。

3、com.wlsq.app.service.UserService

package com.wlsq.app.service;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import org.springframework.transaction.annotation.Transactional;
    
    import com.wlsq.app.dao.UserDao;
    import com.wlsq.app.domain.User;
    
    
    @Service
    public class UserService {
    	@Autowired
    	private UserDao userDao;
    
    	 public boolean addUser(String loginname, String password){
    	        return userDao.insertUser(loginname, password)==1?true:false;
    	    }
    	 
    	   public User addUserWithBackId(String loginname, String password){
    	        User user = new User();
    	        user.setLoginname(loginname);
    	        user.setPassword(password);
    	        userDao.insertUserWithBackId(user);//该方法后，主键已经设置到user中了
    	        return user;
    	    }
    	   
    	   @Transactional
    	    public void testTransaction(String username, String password){
    	         System.out.println(userDao.insertUser(username, password));
    	          userDao.testTransactional(username);
    	    }
    
    }

说明：在该方法中调用了上述的userDao的两个方法。

第一个方法向数据库插入一条数据，第二个方法抛出我们的自定义异常，如果事务配置成功，那么第一个方法插入数据库会回滚，否则，插入数据成功。

4、com.wlsq.app.web.UserController

package com.wlsq.app.web;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestHeader;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.RequestParam;
    import org.springframework.web.bind.annotation.RestController;
    
    import com.wlsq.app.domain.User;
    import com.wlsq.app.service.UserService;
    
    import io.swagger.annotations.Api;
    import io.swagger.annotations.ApiImplicitParam;
    import io.swagger.annotations.ApiImplicitParams;
    import io.swagger.annotations.ApiOperation;
    import io.swagger.annotations.ApiResponse;
    import io.swagger.annotations.ApiResponses;
    
    @RestController
    @RequestMapping("/user")
    @Api("userController相关api")
    public class UserController {
    	@Autowired
        private UserService userService;
    
    //    @RequestMapping("/getUser")
    //    public User getUser() {
    //        return userService.getUser();
    //    }
        
        @ApiOperation("注册用户信息")
        @ApiImplicitParams({
            @ApiImplicitParam(paramType="query",name="loginname",dataType="String",required=true,value="用户的姓名",defaultValue="zhaojigang"),
            @ApiImplicitParam(paramType="query",name="password",dataType="String",required=true,value="用户的密码",defaultValue="wangna")
        })
        @ApiResponses({
            @ApiResponse(code=400,message="请求参数没填好"),
            @ApiResponse(code=404,message="请求路径没有或页面跳转路径不对")
        })
        @RequestMapping(value="/getUser",method=RequestMethod.GET)
        public boolean getUser( @RequestParam("loginname") String username, @RequestParam("password") String password) {
            return userService.addUser(username,password);
        }
        
        @ApiOperation("添加用户且返回已经设置了主键的user实例")
        @ApiImplicitParams({
            @ApiImplicitParam(paramType="query",name="loginname",dataType="String",required=true,value="用户的姓名",defaultValue="zhaojigang"),
            @ApiImplicitParam(paramType="query",name="password",dataType="String",required=true,value="用户的密码",defaultValue="wangna")
        })
        @ApiResponses({
            @ApiResponse(code=400,message="请求参数没填好"),
            @ApiResponse(code=404,message="请求路径没有或页面跳转路径不对")
        })
        @RequestMapping(value="/addUserWithBackId",method=RequestMethod.POST)
        public User addUserWithBackId(@RequestParam("loginname") String loginname, 
                                         @RequestParam("password") String password) {
            return userService.addUserWithBackId(loginname, password);
        }
        
        @ApiOperation("测试事务")
        @ApiImplicitParams({
            @ApiImplicitParam(paramType="query",name="loginname",dataType="String",required=true,value="用户的姓名",defaultValue="zhaojigang"),
            @ApiImplicitParam(paramType="query",name="password",dataType="String",required=true,value="用户的密码",defaultValue="wangna")
        })
        @ApiResponses({
            @ApiResponse(code=400,message="请求参数没填好"),
            @ApiResponse(code=404,message="请求路径没有或页面跳转路径不对")
        })
        @RequestMapping(value="/testTransaction",method=RequestMethod.GET)
        public void testTransaction(@RequestParam("loginname") String loginname, 
                                       @RequestParam("password") String password) {
           userService.testTransaction(loginname, password);
        }
    
    }

测试：使用maven命令启动服务-->swagger运行URL-->查看数据库是否插入成功

疑问：查了很多资料，mybatis与springboot集成后（数据源采用了druid），为了添加事务，很多人会在上一节的MyBatisConfig这个类中做两件事请

*  在MyBatisConfig类上添加@EnableTransactionManagement注解，该注解启用了注解式事务管理 <tx:annotation-driven />，这样在方法上的@Transactional注解就起作用了，但是实际测试中不加这句，@Transactional注解依然有用
 *  在MyBatisConfig类中添加了获取事务管理器的方法

/**
         * 配置事务管理器
         */
        @Bean
        @Primary
        public DataSourceTransactionManager transactionManager() throws Exception{
            return new DataSourceTransactionManager(getDataSource());
        }

[http_www.cnblogs.com_java-zhao_p_5350106.html]: http://www.cnblogs.com/java-zhao/p/5350106.html