Spring + Mybatis 事务

作者: shpunishment | 来源:发表于2018-08-24 19:06 被阅读0次

spring事务管理
mybatis于spring事务结合
Spring 与 Mybatis 的事务
Spring学习day-65：事务和注解
动态数据源dynamic-datasource,切换失效问题
面试问题总结
Spring + Mybatis 事务
Spring MyBatis 事务分析 -- Spring 事务
SpringBoot事务失效(1)—dataSource配置问题
spring,mybatis事务管理配置与@Transactio

Customer

package com.shpun.entity;
public class Customer {
    private String id;
    private String name;
    private String gender;
    private String birthday;
    private String tel;
    private String email;
    private String introduction;
    /*getter  setter*/
}

CustomerMapper

package com.shpun.mapper;

@Repository
public interface CustomerMapper {
    int insertCustomer(Customer customer);
    int deleteCustomer(String id);
    int updateCustomer(Customer customer);
    Customer selectCustomer(String id);
    List<Customer> selectAllCustomers();
}

CustomerMapper.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.shpun.mapper.CustomerMapper">

    <insert id="insertCustomer" useGeneratedKeys="true" keyProperty="id" parameterType="customer">
        insert into customers (name,gender,birthday,tel,email,introduction) value (#{name},#{gender},#{birthday},#{tel},#{email},#{introduction})
    </insert>

    <delete id="deleteCustomer" parameterType="string">
        delete from customers where id=#{id}
    </delete>

    <update id="updateCustomer" parameterType="customer">
        update customers set name=#{name},gender=#{gender},birthday=#{birthday},tel=#{tel},email=#{email},introduction=#{introduction} where id=#{id}
    </update>

    <select id="selectCustomer" parameterType="string" resultType="customer">
        select * from customers where id=#{id}
    </select>

    <select id="selectAllCustomers" resultType="customer">
        select * from customers
    </select>

</mapper>

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>

    <settings>
        <!-- 全局映射器启用缓存 -->
        <setting name="cacheEnabled" value="true"/>
        <!-- 允许JDBC支持生成的键 -->
        <setting name="useGeneratedKeys" value="true"/>
        <!-- 配置默认执行器 Reuse 重用预处理语句 -->
        <setting name="defaultExecutorType" value="REUSE"/>
        <!-- 全局启用延迟加载 -->
        <setting name="lazyLoadingEnabled" value="true"/>
        <!-- 设置超时时间，决定驱动等待一个数据库相应的时间 -->
        <setting name="defaultStatementTimeout" value="2500"/>
    </settings>

    <!-- 别名 -->
    <typeAliases>
        <typeAlias alias="customer" type="com.shpun.entity.Customer"/>
    </typeAliases>

    <!-- 映射器路径 -->
    <mappers>
        <mapper resource="com/shpun/mapper/CustomerMapper.xml"/>
    </mappers>

</configuration>

spring-config.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:context="http://www.springframework.org/schema/context" 
       xmlns:tx="http://www.springframework.org/schema/tx"
       xsi:schemaLocation="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/tx 
       http://www.springframework.org/schema/tx/spring-tx.xsd">

    <!-- 启用扫描 -->
    <context:annotation-config></context:annotation-config>
    <context:component-scan base-package="com.shpun.*"/>

    <!-- 引入外部properties文件 -->
    <context:property-placeholder location="mysql.properties"/>

    <!-- 设置数据库信息等 -->
    <bean id="dateSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="username" value="${jdbc.username}"/>
        <property name="password" value="${jdbc.password}"/>
        <property name="driverClassName" value="${jdbc.driver}"/>
        <property name="url" value="${jdbc.url}"/>
    </bean>

    <!-- 集成Mybatis  SqlSessionFactoryBean 去支持 SqlSessionFactory 配置 -->
    <bean  id="SqlSessionFactory"  class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dateSource"/>
        <property name="configLocation" value="mybatis-config.xml"/>
    </bean>

    <!-- 事务管理器配置数据源事务 -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dateSource"/>
    </bean>

    <!-- 使用注解定义事务 -->
    <tx:annotation-driven transaction-manager="transactionManager"/>

    <!-- 自动扫描配置Mapper的类 -->
    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <!-- 指定Spring扫描的包 -->
        <property name="basePackage" value="com.shpun.mapper"/>
        <!-- 指定Spring中SqlSessionFactory的Bean的名称 -->
        <property name="SqlSessionFactoryBeanName" value="SqlSessionFactory"/>
        <!-- 指定类被注解标识才扫描 @Repository -->
        <property name="annotationClass" value="org.springframework.stereotype.Repository"/>
    </bean>

</beans>

CustomerService接口及其实现类

package com.shpun.service;
public interface CustomerService {
    int insertCustomer(Customer customer);
    int deleteCustomer(String id);
    int updateCustomer(Customer customer);
    Customer selectCustomer(String id);
    List<Customer> selectAllCustomer();
}

CustomerServiceImpl

package com.shpun.service;

@Service
public class CustomerServiceImpl implements CustomerService {

    @Autowired
    private CustomerMapper customerMapper = null;

    /**
     * @Transactional(propagation = Propagation.REQUIRES_NEW,isolation = Isolation.READ_COMMITTED)
     * propagation = Propagation.REQUIRES_NEW 传播行为，每次都开启一个新事务
     * isolation = Isolation.READ_COMMITTED 隔离级别，读/写提交  大部分情况下的选择
     * @param customer
     * @return
     */
    @Override
    @Transactional(propagation = Propagation.REQUIRES_NEW,isolation = Isolation.READ_COMMITTED)
    public int insertCustomer(Customer customer) {
        return customerMapper.insertCustomer(customer);
    }

    @Override
    @Transactional(propagation = Propagation.REQUIRES_NEW,isolation = Isolation.READ_COMMITTED)
    public int deleteCustomer(String id) {
        return customerMapper.deleteCustomer(id);
    }

    @Override
    @Transactional(propagation = Propagation.REQUIRES_NEW,isolation = Isolation.READ_COMMITTED)
    public int updateCustomer(Customer customer) {
        return customerMapper.updateCustomer(customer);
    }

    @Override
    @Transactional(propagation = Propagation.REQUIRES_NEW,isolation = Isolation.READ_COMMITTED)
    public Customer selectCustomer(String id) {
        return customerMapper.selectCustomer(id);
    }

    @Override
    @Transactional(propagation = Propagation.REQUIRES_NEW,isolation = Isolation.READ_COMMITTED)
    public List<Customer> selectAllCustomer() {
        return customerMapper.selectAllCustomers();
    }
}

CustomerListService接口及其实现类

package com.shpun.service;

public interface CustomerListService {
    int insertCustomerList(List<Customer> customerList);
    int deleteCustomerList(List<Customer> customerList);
    int updateCustomerList(List<Customer> customerList);
    List<Customer> selectCustomerList(List<Customer> customerList);
}

CustomerListServiceImpl

package com.shpun.service;

@Service
public class CustomerListServiceImpl implements CustomerListService {

    @Autowired
    private CustomerService customerService;

    /**
     * @Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.READ_COMMITTED)
     * propagation = Propagation.REQUIRED Spring默认传播方式，存在当前事务则沿用；否则创建新事务
     * isolation = Isolation.READ_COMMITTED 隔离级别，读/写提交  大部分情况下的选择
     *
     * @param customerList
     * @return
     */
    @Override
    @Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.READ_COMMITTED)
    public int insertCustomerList(List<Customer> customerList) {
        int count = 0;
        for(Customer customer : customerList){
            try{
                customerService.insertCustomer(customer);
            }catch(Exception e){
                e.printStackTrace();
            }
        }
        return count;
    }

    @Override
    @Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.READ_COMMITTED)
    public int deleteCustomerList(List<Customer> customerList) {
        int count = 0;
        for(Customer customer : customerList){
            try{
                customerService.deleteCustomer(customer.getId());
            }catch(Exception e){
                e.printStackTrace();
            }
        }
        return count;
    }

    @Override
    @Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.READ_COMMITTED)
    public int updateCustomerList(List<Customer> customerList) {
        int count = 0;
        for(Customer customer : customerList){
            try{
                customerService.updateCustomer(customer);
            }catch(Exception e){
                e.printStackTrace();
            }
        }
        return count;
    }

    @Override
    @Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.READ_COMMITTED)
    public List<Customer> selectCustomerList(List<Customer> customerList) {
        List<Customer> customers = new ArrayList<>();
        for(Customer customer : customerList){
            try{
                customers.add(customerService.selectCustomer(customer.getId()));
            }catch(Exception e){
                e.printStackTrace();
            }
        }
        return customers;
    }
}

测试

package com.shpun.main;

public class Test {

    public static void main(String[] args){

        ApplicationContext context = new ClassPathXmlApplicationContext("spring-config.xml");
        CustomerService cutomerService = context.getBean(CustomerService.class);
        CustomerListService customerListService = context.getBean(CustomerListService.class);

        List<Customer> customerList = new ArrayList<>();

          // insert
        for(int i=0;i<3;i++){
            Customer customer = new Customer();
            customer.setName("tx"+i);
            customer.setIntroduction("spring mybatis transaction "+i);
            customerList.add(customer);
        }
        System.out.println("insert");
        customerListService.insertCustomerList(customerList);

        // delete
        customerList.clear();
        for(int i=1;i<=3;i++){
            Customer customer = new Customer();
            customer.setId("101"+i);
            customerList.add(customer);
        }
        System.out.println("delete");
        customerListService.deleteCustomerList(customerList);

        // update
        customerList.clear();
        for(int i=1;i<=3;i++){
            Customer customer = new Customer();
            customer.setId("102"+i);
            customer.setName("修改");
            customer.setIntroduction("我被修改了TX"+i);
            customerList.add(customer);
        }
        System.out.println("update");
        customerListService.updateCustomerList(customerList);

        // select singal
        System.out.println(cutomerService.selectCustomer("1001"));

        // select list
        customerList.clear();
        for(int i=5;i<=7;i++){
            Customer customer = new Customer();
            customer.setId("104"+i);
            customerList.add(customer);
        }
        System.out.println(customerListService.selectCustomerList(customerList));

        // select all
        customerList.clear();
        System.out.println("select all");
        customerList = cutomerService.selectAllCustomer();
        for(Customer customer : customerList){
            System.out.println(customer);
        }

    }
}

ps:

Spring + Mybatis 启用事务，并使用注解的方式@Transactional记得在spring配置文件中添加

    <!-- 事务管理器配置数据源事务 -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dateSource"/>
    </bean>

    <!-- 使用注解定义事务 -->
    <tx:annotation-driven transaction-manager="transactionManager"/>

spring事务管理
仅供参考 mybatis-spring – MyBatis-Spring | 第四章事务《Spring技术内幕...
mybatis于spring事务结合
mybatis如何和spring的事务结合的 PlatformTransactionManager （平台）事务管...
Spring 与 Mybatis 的事务
1、前言 mybatis 是有事务模块的，mybatis 与 spring 结合的时候，spring 实现了 my...
Spring学习day-65：事务和注解
一、Spring中的TX事务 1.为什么使用事务？当时学习mybatis的时，mybatis中的事务和JDBC事...
动态数据源dynamic-datasource,切换失效问题
环境: 数据库操作mybatis-plus原因:使用了spring自带的事务管理.原理:spring自带事务会创建...
面试问题总结
1.spring对mybatis的事务管理是怎么支持的一、事务的基本原理 Spring事务的本质其实就是数据库对...
Spring + Mybatis 事务
Customer CustomerMapper CustomerMapper.xml Mybatis-config...
Spring MyBatis 事务分析 -- Spring 事务
Spring + MyBatis 基本是现在 Java Web 开发的标配了，MyBatis 提供简单易用的 OR...
SpringBoot事务失效(1)—dataSource配置问题
场景：Spring事务没有生效。环境：SpringBoot+mybatis 或者SpringBoot+JdbcTe...
spring,mybatis事务管理配置与@Transactio
spring,mybatis事务管理配置与@Transactional注解使用概述事务管理对于企业应用来说是至...