@Transactional的正確打開方式

時間 2019-12-12

標籤 transactional 正確打開方式简体版

原文原文鏈接

常常用到事務管理，可仍是不當心會寫錯，致使事務沒有生效，這裏總結下。java

正確的代碼例子以下所示，框架是使用spring+mybatis的，有些配置的就不貼出來了。mysql

TestController2:web

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接口：spring

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);
}

View Code

UserServiceImpl:　　　　sql

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);
}

View Code

UserMapper.xml(這裏屬於不重要的配置)apache

<?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>

View Code

applicationContext.xml(這裏屬於不重要的配置，可是事務管理的配置重要)json

<?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>

View Code

測試：spring-mvc

在瀏覽器中輸入：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);
}

View Code

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;
        }
    }

}