Spring + Mybatis 事務(wù)

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"/>
        <!-- 配置默認(rèn)執(zhí)行器 Reuse 重用預(yù)處理語句 -->
        <setting name="defaultExecutorType" value="REUSE"/>
        <!-- 全局啟用延遲加載 -->
        <setting name="lazyLoadingEnabled" value="true"/>
        <!-- 設(shè)置超時(shí)時(shí)間，決定驅(qū)動(dòng)等待一個(gè)數(shù)據(jù)庫相應(yīng)的時(shí)間 -->
        <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"/>

    <!-- 設(shè)置數(shù)據(jù)庫信息等 -->
    <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>

    <!-- 事務(wù)管理器配置數(shù)據(jù)源事務(wù) -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dateSource"/>
    </bean>

    <!-- 使用注解定義事務(wù) -->
    <tx:annotation-driven transaction-manager="transactionManager"/>

    <!-- 自動(dòng)掃描配置Mapper的類 -->
    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <!-- 指定Spring掃描的包 -->
        <property name="basePackage" value="com.shpun.mapper"/>
        <!-- 指定Spring中SqlSessionFactory的Bean的名稱 -->
        <property name="SqlSessionFactoryBeanName" value="SqlSessionFactory"/>
        <!-- 指定類被注解標(biāo)識(shí)才掃描 @Repository -->
        <property name="annotationClass" value="org.springframework.stereotype.Repository"/>
    </bean>

</beans>

CustomerService接口及其實(shí)現(xiàn)類

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 傳播行為，每次都開啟一個(gè)新事務(wù)
     * isolation = Isolation.READ_COMMITTED 隔離級(jí)別，讀/寫提交  大部分情況下的選擇
     * @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接口及其實(shí)現(xiàn)類

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默認(rèn)傳播方式，存在當(dāng)前事務(wù)則沿用；否則創(chuàng)建新事務(wù)
     * isolation = Isolation.READ_COMMITTED 隔離級(jí)別，讀/寫提交  大部分情況下的選擇
     *
     * @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;
    }
}

測(cè)試

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 啟用事務(wù)，并使用注解的方式@Transactional記得在spring配置文件中添加

    <!-- 事務(wù)管理器配置數(shù)據(jù)源事務(wù) -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dateSource"/>
    </bean>

    <!-- 使用注解定義事務(wù) -->
    <tx:annotation-driven transaction-manager="transactionManager"/>
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡書系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具（例如配置管理，服務(wù)發(fā)現(xiàn)，斷路器，智...
    卡卡羅2017閱讀 136,680評(píng)論 19贊 139
  • Spring Web MVC Spring Web MVC 是包含在 Spring 框架中的 Web 框架，建立于...
    Hsinwong閱讀 22,966評(píng)論 1贊 92
  • spring,mybatis事務(wù)管理配置與@Transactional注解使用 概述 事務(wù)管理對(duì)于企業(yè)應(yīng)用來說是至...
    tenlee閱讀 4,303評(píng)論 0贊 11
  • Spring Boot 參考指南 介紹 轉(zhuǎn)載自:https://www.gitbook.com/book/qbgb...
    毛宇鵬閱讀 47,283評(píng)論 6贊 342
  • 今天下午，我對(duì)導(dǎo)言至第四章的內(nèi)容進(jìn)行了總體復(fù)習(xí)。雖在自己第一遍看的時(shí)候有所標(biāo)注，但如今回顧又發(fā)現(xiàn)了新的值得重視的細(xì)...
    czj369閱讀 449評(píng)論 6贊 7

友情鏈接更多精彩內(nèi)容