经常用到事务管理，可还是不小心会写错，导致事务没有生效，这里总结下。

正确的代码例子如下所示，框架是使用spring+mybatis的，有些配置的就不贴出来了。

TestController2:

package com.test.controller;

import com.alibaba.fastjson.JSON;

import com.cy.service.UserService;

import com.test.dto.Child;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

@Controller

public class TestController2 {

    @Autowired

    private UserService userService;

    /**

     * 测试transcation

     */

    @RequestMapping("/testTranscation.do")

    public void testTranscation(){

        String username = "小王";

        String password = "123455";

        userService.callAddUserMethod(username, password);

    }

}

UserService接口：

package com.cy.service;

import com.cy.entity.User;

/**

 * 用户Service接口

 * @author Administrator

 *

 */

public interface UserService {

    User login(User user);

    void addUserMethod(User user);

    void callAddUserMethod(String username, String password);

}

UserServiceImpl:　　　　

package com.cy.service.impl;

import com.cy.dao.UserDao;

import com.cy.entity.User;

import com.cy.service.UserService;

import org.springframework.stereotype.Service;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;

/**

 * 用户Service实现类

 * @author Administrator

 *

 */

@Service("userService")

public class UserServiceImpl implements UserService {

    @Resource(name = "userService")

    private UserService userService;

    @Autowired

    private UserDao userDao;

    @Override

    public User login(User user) {

        return userDao.login(user);

    }

    @Override

    public void callAddUserMethod(String username, String password){

        User user = new User();

        user.setUsername(username);

        user.setPassword(password);

        try{

            userService.addUserMethod(user);

        }catch (Exception e){

            System.err.println("addUserMethod异常:" + e.getMessage());

            e.printStackTrace();

        }

    }

    @Transactional(rollbackFor = Exception.class)

    @Override

    public void addUserMethod(User user){

        int a = userDao.addUser(user);

        badMethod();

    }

    private void badMethod(){

        int i = 1/0;

    }

}

UserDao接口：

package com.cy.dao;

import com.cy.entity.User;

public interface UserDao {

    //登录

    User login(User user);

    Integer addUser(User user);

}

UserMapper.xml(这里属于不重要的配置)

<?xml version="1.0" encoding="UTF-8" ?>

<!DOCTYPE mapper

        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"

        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

<mapper namespace="com.cy.dao.UserDao">

    <select id="login" parameterType="User" resultType="User">

        select * from t_user where username=#{username} and password=#{password}

    </select>

    <insert id="addUser" parameterType="User">

        INSERT INTO

            t_user(

                username,

                password

            )

        VALUES(

            #{username},

            #{password}

        )

    </insert>

</mapper>

applicationContext.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:p="http://www.springframework.org/schema/p"

       xmlns:aop="http://www.springframework.org/schema/aop"

       xmlns:context="http://www.springframework.org/schema/context"

       xmlns:mvc="http://www.springframework.org/schema/mvc"

       xmlns:jee="http://www.springframework.org/schema/jee"

       xmlns:tx="http://www.springframework.org/schema/tx"

       xsi:schemaLocation="

        http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd

        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd

        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd

        http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd

        http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee.xsd

        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">

    <!-- 自动扫描 -->

    <context:component-scan base-package="com.cy.service,com.test.service" />

    <!-- 配置数据源 -->

    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">

        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>

        <property name="url" value="jdbc:mysql://localhost:3306/demodb"/>

        <property name="username" value="root"/>

        <property name="password" value="root"/>

    </bean>

    <!-- 配置mybatis的sqlSessionFactory -->

    <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">

        <property name="dataSource" ref="dataSource" />

        <!-- 自动扫描mappers.xml文件 -->

        <property name="mapperLocations" value="classpath:com/cy/mappers/*.xml"></property>

        <!-- mybatis配置文件 -->

        <property name="configLocation" value="classpath:mybatis-config.xml"></property>

    </bean>

    <!-- DAO接口所在包名，Spring会自动查找其下的类 -->

    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">

        <property name="basePackage" value="com.cy.dao" />

        <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"></property>

    </bean>

    <!-- (事务管理)transaction manager, use JtaTransactionManager for global tx -->

    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">

        <property name="dataSource" ref="dataSource" />

    </bean>

    <tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>

</beans>

mybatis-config.xml:（这个是完全不重要的配置）

<?xml version="1.0" encoding="UTF-8" ?>

<!DOCTYPE configuration

        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"

        "http://mybatis.org/dtd/mybatis-3-config.dtd">

<configuration>

    <!-- 别名 -->

    <typeAliases>

        <package name="com.cy.entity"/>

    </typeAliases>

</configuration>

测试：

在浏览器中输入：http://localhost:8088/testTranscation.do，发现"小王"并没有被插入数据库，因为报异常回滚掉了。

console中可以看到事务的回滚rollback：

  2019-03-29 14:41:52,411 [http-nio-8088-exec-3] DEBUG [org.springframework.jdbc.datasource.DataSourceTransactionManager] - Acquired Connection [com.mysql.jdbc.JDBC4Connection@3f44f876] for JDBC transaction

  2019-03-29 14:41:52,435 [http-nio-8088-exec-3] DEBUG [org.springframework.jdbc.datasource.DataSourceTransactionManager] - Switching JDBC Connection [com.mysql.jdbc.JDBC4Connection@3f44f876] to manual commit

  14:41:53.328 [http-nio-8088-exec-3] DEBUG org.mybatis.spring.SqlSessionUtils - Creating a new SqlSession

14:41:53.353 [http-nio-8088-exec-3] DEBUG org.mybatis.spring.SqlSessionUtils - Registering transaction synchronization for SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@5453248e]

14:41:53.384 [http-nio-8088-exec-3] DEBUG org.mybatis.spring.transaction.SpringManagedTransaction - JDBC Connection [com.mysql.jdbc.JDBC4Connection@3f44f876] will be managed by Spring

14:41:53.437 [http-nio-8088-exec-3] DEBUG com.cy.dao.UserDao.addUser - ==>  Preparing: INSERT INTO t_user( username, password ) VALUES( ?, ? )

14:41:53.668 [http-nio-8088-exec-3] DEBUG com.cy.dao.UserDao.addUser - ==> Parameters: 小王(String), 123455(String)

14:41:53.669 [http-nio-8088-exec-3] DEBUG com.cy.dao.UserDao.addUser - <==    Updates: 1

14:41:53.669 [http-nio-8088-exec-3] DEBUG org.mybatis.spring.SqlSessionUtils - Releasing transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@5453248e]

14:41:59.161 [http-nio-8088-exec-3] DEBUG org.mybatis.spring.SqlSessionUtils - Transaction synchronization deregistering SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@5453248e]

14:41:59.161 [http-nio-8088-exec-3] DEBUG org.mybatis.spring.SqlSessionUtils - Transaction synchronization closing SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@5453248e]

2019-03-29 14:41:59,161 [http-nio-8088-exec-3] DEBUG [org.springframework.jdbc.datasource.DataSourceTransactionManager] - Initiating transaction rollback

  2019-03-29 14:41:59,161 [http-nio-8088-exec-3] DEBUG [org.springframework.jdbc.datasource.DataSourceTransactionManager] - Rolling back JDBC transaction on Connection [com.mysql.jdbc.JDBC4Connection@3f44f876]

  2019-03-29 14:41:59,259 [http-nio-8088-exec-3] DEBUG [org.springframework.jdbc.datasource.DataSourceTransactionManager] - Releasing JDBC Connection [com.mysql.jdbc.JDBC4Connection@3f44f876] after transaction

  2019-03-29 14:41:59,259 [http-nio-8088-exec-3] DEBUG [org.springframework.jdbc.datasource.DataSourceUtils] - Returning JDBC Connection to DataSource

  addUserMethod异常:/ by zero

java.lang.ArithmeticException: / by zero

    at com.cy.service.impl.UserServiceImpl.badMethod(UserServiceImpl.java:51)

    at com.cy.service.impl.UserServiceImpl.addUserMethod(UserServiceImpl.java:47)

总结：　　　　　　　　

1.@Transactional方法为接口方法，有异常往外抛。 （addUserMethod必须为接口方法）

2.@Transactional方法中可以有私有方法，有异常往外抛。(badMethod)

3.调用@Transactional的方法，可以对它try catch，且必须是接口.方法来调用。（callAddUserMethod中调用addUserMethod，必须是userService.addUserMethod，userServiceImpl把自己注进来）

4.配置文件中必须要有事务管理的配置，缺一不可：

<!-- (事务管理)transaction manager, use JtaTransactionManager for global tx -->

    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">

        <property name="dataSource" ref="dataSource" />

    </bean>

    <tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>

5.@Transactional方法里面不要try catch异常，但是可以声明throws Exception；

@Transactional方法里面的方法也同样往外抛异常

UserService:

public interface UserService {

    User login(User user);

    void addUserMethod(User user) throws ArithmeticException;

    void callAddUserMethod(String username, String password);

}

UserServiceImpl:

package com.cy.service.impl;

import com.cy.dao.UserDao;

import com.cy.entity.User;

import com.cy.service.UserService;

import org.springframework.stereotype.Service;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;

/**

 * 用户Service实现类

 * @author Administrator

 *

 */

@Service("userService")

public class UserServiceImpl implements UserService {

    @Resource(name = "userService")

    private UserService userService;

    @Autowired

    private UserDao userDao;

    @Override

    public User login(User user) {

        return userDao.login(user);

    }

    @Override

    public void callAddUserMethod(String username, String password){

        User user = new User();

        user.setUsername(username);

        user.setPassword(password);

        try{

            userService.addUserMethod(user);

        }catch (Exception e){

            System.err.println("addUserMethod异常:" + e.getMessage());

            e.printStackTrace();

        }

    }

    @Transactional(rollbackFor = Exception.class)

    @Override

    public void addUserMethod(User user) throws ArithmeticException{

        int a = userDao.addUser(user);

        badMethod();

    }

    private void badMethod() throws ArithmeticException{

        try{

            int i = 1/0;

        }catch (ArithmeticException e){

            throw e;

        }

    }

}

transcation事务也是生效的。

最新文章

  1. ASP.NET OAuth：access token的加密解密，client secret与refresh token的生成
  2. Selenium3.0 自动化测试
  3. the king of fighter
  4. jquery weibo 留言
  5. zTree插件之单选下拉菜单代码
  6. 超链接点击后不显示hover
  7. 删除浏览器浏览器删除cookie方法
  8. JavaScript---网络编程(9-1)--DHTML技术演示(2-1)-表格创建的几种方式
  9. Java设计模式---装饰模式
  10. quartz搭建与应用
  11. select选择框在谷歌火狐和IE样式的不同
  12. IO代码记忆
  13. ADO.NET复习总结（6）-断开式数据操作
  14. 转 Caffe学习系列(4)：激活层（Activiation Layers)及参数
  15. Mysql索引使用解析
  16. Spring Data Redis 详解及实战一文搞定
  17. HDU 1115(求质量均匀分布的多边形重心 物理)
  18. MySQL之聚合数据（AVG,COUNT,MAX,MIN,SUM)
  19. 《嵌入式系统原理与接口技术》&mdash;&mdash;嵌入式系统接口应用基础
  20. 微信小程序图片宽100%显示并且不变形

热门文章

  1. 模块四-shutil模块
  2. Windows10 VS2017 C++编译Linux程序
  3. 深入浅出JMS 消息队列
  4. PHP错误日志和内存查看（转）
  5. Vector的用法
  6. 用递归方法求n阶勒让德多项式的值
  7. C++实验四
  8. 653. Two Sum IV - Input is a BST-easy
  9. PowerShell在激活virtualenv虚拟环境时禁止运行的脚本的解决办法
  10. ROS * 通过launch文件添加多个模型