2. 程式人生 > >springboot整合Mybatis、事務、多資料來源、分散式事務

springboot整合Mybatis、事務、多資料來源、分散式事務

阿新 • • 發佈：2019-01-11

springboot整合Mybatis、事務、多資料來源

文章目錄

一. 整合Mybatis

第一步：匯入包

<dependency>
    <groupId>org.mybatis.spring.boot</groupId>
    <artifactId>mybatis-spring-boot-starter</artifactId>
    <version>1.3.2</version>
</dependency>

第二步：如果需要使用mapper配置檔案的，可以在application.properties中新增配置

mybatis.mapper-locations=classpath:mapper/*.xml

第三步：在配置類中新增配置

@MapperScan("com.qianfeng.demo.dao")  // 掃描mybatis的介面類
@SpringBootApplication
public class Demo31Application {
	public static void main(String[] args) {
		SpringApplication.run(Demo31Application.class, args);
	}
}

第四步：編寫介面並編寫註解配置（或編寫對應的Mapper.xml）

@Repository
public interface StudentDAO {
    @Select({"SELECT id, name, sex from student_info"})
    public List<Student> findAll();
}

二. 事務

2.1 回顧事務的特徵
2.1.1 什麼是事務(Transaction)

是併發控制的單元，是使用者定義的一個操作序列。這些操作要麼都做，要麼都不做，是一個不可分割的工作單位。通過事務，sql 能將邏輯相關的一組操作繫結在一起，以便伺服器 保持資料的完整性。事務通常是以begin transaction開始，以commit或rollback結束。Commint表示提交，即提交事務的所有操作。具體地說就是將事務中所有對資料的更新寫回到磁碟上的物理資料庫中去，事務正常結束。Rollback表示回滾，即在事務執行的過程中發生了某種故障，事務不能繼續進行，系統將事務中對資料庫的所有已完成的操作全部撤消，滾回到事務開始的狀態。

設想網上購物的一次交易，其付款過程至少包括以下幾步資料庫操作：

1）更新客戶所購商品的庫存資訊

2）儲存客戶付款資訊–可能包括與銀行系統的互動

3）生成訂單並且儲存到資料庫中

4）更新使用者相關資訊，例如購物數量等等

正常的情況下，這些操作將順利進行，最終交易成功，與交易相關的所有資料庫資訊也成功地更新。但是，如果在這一系列過程中任何一個環節出了差錯，例如在更新商品庫存資訊時發生異常、該顧客銀行帳戶存款不足等，都將導致交易失敗。一旦交易失敗，資料庫中所有資訊都必須保持交易前的狀態不變，比如最後一步更新使用者資訊時失敗而導致交易失敗，那麼必須保證這筆失敗的交易不影響資料庫的狀態–庫存資訊沒有被更新、使用者也沒有付款，訂單也沒有生成。否則，資料庫的資訊將會一片混亂而不可預測。

資料庫事務正是用來保證這種情況下交易的平穩性和可預測性的技術

2.1.2 為什麼要使用事務?
  • 為了提高效能
  • 為了保持業務流程的完整性
2.1.3 事務的特性

ACID

  • 原子性（atomicity）

事務是資料庫的邏輯工作單位，而且是必須是原子工作單位，對於其資料修改，要麼全部執行，要麼全部不執行。

  • 一致性（consistency）

事務在完成時，必須是所有的資料都保持一致狀態。在相關資料庫中，所有規則都必須應用於事務的修改，以保持所有資料的完整性。

  • 隔離性（isolation）

一個事務的執行不能被其他事務所影響。企業級的資料庫每一秒鐘都可能應付成千上萬的併發訪問，因而帶來了併發控制的問題。由資料庫理論可知，由於併發訪問，在不可預料的時刻可能引發如下幾個可以預料的問題：

  • 永續性（durability）

一個事務一旦提交，事物的操作便永久性的儲存在DB中。即使此時再執行回滾操作也不能撤消所做的更改

2.1.4 事務的併發問題
  • 髒讀（Dirty Read）

一個事務讀取到了另一個事務未提交的資料操作結果。這是相當危險的，因為很可能所有的操作都被回滾。

  • 不可重複讀（虛讀）（NonRepeatable Read）

一個事務對同一行資料重複讀取兩次，但是卻得到了不同的結果。例如事務T1讀取某一資料後，事務T2對其做了修改，當事務T1再次讀該資料時得到與前一次不同的值。

  • 幻讀（Phantom Read）

事務在操作過程中進行兩次查詢，第二次查詢的結果包含了第一次查詢中未出現的資料或者缺少了第一次查詢中出現的資料，這是因為在兩次查詢過程中有另外一個事務插入資料造成的

2.1.5 事務的隔離級別
  • 1- 讀未提交

Read uncommitted：最低級別，以上情況均無法保證。

  • 2- 讀已提交

Read committed：可避免髒讀情況發生。（Oracle預設）

  • 4- 可重複讀

Repeatable read：可避免髒讀、不可重複讀情況的發生。不可以避免虛讀。（MySQl預設）

  • 8- 序列化讀

Serializable：事務只能一個一個執行，避免了髒讀、不可重複讀、幻讀。執行效率慢，使用時慎重.

2.1.6 事務的傳播行為

事務傳播行為用來描述由某一個事務傳播行為修飾的方法被巢狀進另一個方法的時事務如何傳播。

注意：Spring在TransactionDefinition介面中規定了7種類型的事務傳播行為。事務傳播行為是Spring框架獨有的事務增強特性，他不屬於的事務實際提供方資料庫行為。這是Spring為我們提供的強大的工具箱，使用事務傳播行可以為我們的開發工作提供許多便利。

Spring中七種事務傳播行為：

事務傳播行為型別 說明
PROPAGATION_REQUIRED 如果當前沒有事務，就新建一個事務，如果已經存在一個事務中，加入到這個事務中。這是最常見的選擇。
PROPAGATION_SUPPORTS 支援當前事務，如果當前沒有事務，就以非事務方式執行。
PROPAGATION_MANDATORY 使用當前的事務，如果當前沒有事務，就丟擲異常。
PROPAGATION_REQUIRES_NEW 新建事務，如果當前存在事務，把當前事務掛起。
PROPAGATION_NOT_SUPPORTED 以非事務方式執行操作，如果當前存在事務，就把當前事務掛起。
PROPAGATION_NEVER 以非事務方式執行，如果當前存在事務，則丟擲異常。
PROPAGATION_NESTED 如果當前存在事務，則在巢狀事務內執行。如果當前沒有事務，則執行與PROPAGATION_REQUIRED類似的操作。
2.2 spring整合MyBatis的事務配置（宣告式事務）
2.2.1 使用配置檔案方式：applicationContext.xml
 <!-- 配置事務管理器 -->
    <bean id="transactionManager"
		class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource">
			<ref bean="dataSource" />
		</property>
	</bean>

	<!-- 配置通知（配置事務執行的方法定義的名稱規則） -->
	<tx:advice id="myAdvice" transaction-manager="transactionManager">
		<tx:attributes>
			<tx:method name="save*" propagation="REQUIRED" />
			<tx:method name="del*" propagation="REQUIRED" />
			<tx:method name="update*" propagation="REQUIRED" />
			<tx:method name="*" read-only="true" />
		</tx:attributes>
	</tx:advice>

	<!-- 配置AOP的規則 -->
	<aop:config>
		<!-- 配置切入點 -->
		<aop:pointcut id="pc" expression="execution(* com.qianfeng.demo.service.*.*(..))" />
		<aop:advisor pointcut-ref="pc" advice-ref="myAdvice" />
	</aop:config>

注意：使用此配置要求service中的方法名稱必須按照規則編寫。

2.2.2 使用註解的方式

第一步：在配置檔案中新增：

<tx:annotation-driven transaction-manager="transactionManager"></tx:annotation-driven>

第二步：在類中添加註解即可：

@Service
@Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
public class CustomerService {
    @Resource
    private CustomerDAO customerDAO;

    @Transactional(propagation = Propagation.SUPPORTS, readOnly = true)
    public List<Customer> findAll(){
        return customerDAO.findAll();
    }
}
2.3 在springboot中使用事務

springboot由於可以自動配置，所以幾乎不需要任何配置就可以使用註解的方式實現事務。

@Service
public class CustomerService {
    @Resource
    private CustomerDAO customerDAO;

    public List<Customer> findAll(){
        return customerDAO.findAll();
    }

    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
    public void transferMoney(Integer fromId, Integer toId, Double money) throws Exception {
        customerDAO.increaseMoney(toId, money);
        Customer customer = customerDAO.findById(fromId);
        if (customer != null && customer.getMoney() >= money) {
            customerDAO.decreaseMoney(fromId, money);
        }else {
            throw new Exception("餘額不足");
        }
    }
}

三. 在springboot中整合mybatis使用多資料來源

3.1 多資料來源的配置

springboot中可以使用多個數據源，但是需要對多個數據源進行配置，最簡單的辦法就是分別配置：

第一步：在application.properties中配置各個資料來源的引數

#第一個資料來源
spring.datasource.bank1.username=root
spring.datasource.bank1.password=root
spring.datasource.bank1.url=jdbc:mysql://localhost:3306/bank1?useUnicode=true&characterEncoding=utf-8
spring.datasource.bank1.driver-class-name=com.mysql.jdbc.Driver
bank1.mybatis.mapper-locations=classpath:mapper/bank1/*.xml

#第二個資料來源
spring.datasource.bank2.username=root
spring.datasource.bank2.password=root
spring.datasource.bank2.url=jdbc:mysql://localhost:3306/bank2?useUnicode=true&characterEncoding=utf-8
spring.datasource.bank2.driver-class-name=com.mysql.jdbc.Driver

bank2.mybatis.mapper-locations=classpath:mapper/bank2/*.xml

第二步：編寫對應的配置類：（第一個資料來源的配置）

@Configuration
// 掃描的包路徑
@MapperScan(basePackages = "com.qianfeng.demo.dao.bank1",
        sqlSessionTemplateRef = "bank1SqlSessionTemplate") // 引用的template的name
public class Bank1DataSourceConfig {
    // 引用application.properties中的路徑
    @Value("${bank1.mybatis.mapper-locations}")
    private String mapperLocation;

    // 配置dataSource
    @Bean(name = "bank1DataSource")
    @Primary  // 配置為預設值
    @ConfigurationProperties(prefix = "spring.datasource.bank1") // application.properties中資料來源的字首
    public DataSource bank1DataSource(){
        return DataSourceBuilder.create().build();
    }

    @Primary // 配置為預設值
    @Bean(name = "bank1SqlSessionFactory")
    public SqlSessionFactory bank1SqlSessionFactory(@Qualifier("bank1DataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
        sqlSessionFactoryBean.setDataSource(dataSource);
        sqlSessionFactoryBean.setMapperLocations(
                new PathMatchingResourcePatternResolver().getResources(mapperLocation));
        return sqlSessionFactoryBean.getObject();
    }

    @Bean(name = "bank1TransactionManager")
    @Primary // 配置為預設值
    public DataSourceTransactionManager bank1TransactionManager(@Qualifier("bank1DataSource") DataSource dataSource){
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean(name = "bank1SqlSessionTemplate")
    @Primary // 配置為預設值
    public SqlSessionTemplate bank1SqlSessionTemplate(@Qualifier("bank1SqlSessionFactory") SqlSessionFactory sqlSessionFactory){
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

第二個資料來源的配置：

注意：幾乎和第一個資料來源的配置幾乎一樣，但是一定不要配置@Primary註解，因為不可能有兩個預設值

@Configuration
@MapperScan(basePackages = "com.qianfeng.demo.dao.bank2",
        sqlSessionTemplateRef = "bank2SqlSessionTemplate")
public class Bank2DataSourceConfig {
    @Value("${bank2.mybatis.mapper-locations}")
    private String mapperLocation;

    @Bean(name = "bank2DataSource")
    @ConfigurationProperties(prefix = "spring.datasource.bank2")
    public DataSource bank2DataSource(){
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "bank2SqlSessionFactory")
    public SqlSessionFactory bank2SqlSessionFactory(@Qualifier("bank2DataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
        sqlSessionFactoryBean.setDataSource(dataSource);
        sqlSessionFactoryBean.setMapperLocations(
                new PathMatchingResourcePatternResolver().getResources(mapperLocation));
        return sqlSessionFactoryBean.getObject();
    }

    @Bean(name = "bank2TransactionManager")
    public DataSourceTransactionManager bank2TransactionManager(@Qualifier("bank2DataSource") DataSource dataSource){
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean(name = "bank2SqlSessionTemplate")
    public SqlSessionTemplate bank2SqlSessionTemplate(@Qualifier("bank2SqlSessionFactory") SqlSessionFactory sqlSessionFactory){
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

注意：DAO中名稱的唯一性，避免系統自動裝配的時候找不到唯一的名稱。

3.2 多資料來源的事務管理

由於多資料來源中的資料是跨資料庫的，單資料庫那種事務管理是無效的，這裡需要使用JTA去完成（這裡使用atomikos）。

第一步：匯入atomikos的包

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jta-atomikos</artifactId>
    <version>2.0.0.RELEASE</version>
</dependency>

第二步：在application.properties中編寫atomikos的多資料來源的配置（這裡只是簡單配置，更多引數配置請參考對應的文件）

spring.jta.enabled=true

spring.datasource.bank1.xa-properties.url=jdbc:mysql://localhost:3306/bank1?useUnicode=true&characterEncoding=utf-8
spring.datasource.bank1.xa-properties.user=root
spring.datasource.bank1.xa-properties.password=root
spring.datasource.bank1.xa-data-source-class-name=com.mysql.jdbc.jdbc2.optional.MysqlXADataSource
spring.datasource.bank1.unique-resource-name=bank1DataSource
bank1.mybatis.mapper-locations=classpath:mapper/bank1/*.xml

spring.datasource.bank2.xa-properties.url=jdbc:mysql://localhost:3306/bank2?useUnicode=true&characterEncoding=utf-8
spring.datasource.bank2.xa-properties.user=root
spring.datasource.bank2.xa-properties.password=root
spring.datasource.bank2.xa-data-source-class-name=com.mysql.jdbc.jdbc2.optional.MysqlXADataSource
spring.datasource.bank2.unique-resource-name=bank2DataSource
bank2.mybatis.mapper-locations=classpath:mapper/bank2/*.xml

第三步：修改配置類中的程式碼，將原來的事務管理的程式碼註釋掉，並將資料來源換成atomikos的資料來源。

@Configuration
@MapperScan(basePackages = "com.qianfeng.demo.dao.bank1",
        sqlSessionTemplateRef = "bank1SqlSessionTemplate")
public class Bank1DataSourceConfig {
    @Value("${bank1.mybatis.mapper-locations}")
    private String mapperLocation;

    @Bean(name = "bank1DataSource")
    @Primary
    @ConfigurationProperties(prefix = "spring.datasource.bank1")
    public DataSource bank1DataSource(){
//        return DataSourceBuilder.create().build();
        return new AtomikosDataSourceBean();
    }

    @Primary
    @Bean(name = "bank1SqlSessionFactory")
    public SqlSessionFactory bank1SqlSessionFactory(@Qualifier("bank1DataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
        sqlSessionFactoryBean.setDataSource(dataSource);
        sqlSessionFactoryBean.setMapperLocations(
                new PathMatchingResourcePatternResolver().getResources(mapperLocation));
        return sqlSessionFactoryBean.getObject();
    }

//    @Bean(name = "bank1TransactionManager")
//    @Primary
//    public DataSourceTransactionManager bank1TransactionManager(@Qualifier("bank1DataSource") DataSource dataSource){
//        return new DataSourceTransactionManager(dataSource);
//    }

    @Bean(name = "bank1SqlSessionTemplate")
    @Primary
    public SqlSessionTemplate bank1SqlSessionTemplate(@Qualifier("bank1SqlSessionFactory") SqlSessionFactory sqlSessionFactory){
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

程式碼地址

相關推薦

【十九】Spring Boot 之多資料來源和分散式事務(JTA、Atomikos、Druid、Mybatis)

1.事務開始 2.A資料來源insert 3.B資料來源insert 4.報錯 5.事務回滾（A、B資料來源都回滾） 專案目錄 pom.xml <?xml version="1.0" encoding="UTF-8"?> <projec

Spring Boot 整合Mybatis實現主從（多資料來源）分離方案

新建一個Maven專案，最終專案結構如下：多資料來源注入到sqlSessionFactoryPOM增加如下依賴： <!--JSON--> <dependency> <groupId>com.fasterxml.jackson.cor

使用Atomikos Transactions Essentials實現多資料來源JTA分散式事務

宣告:本片文章來源於開源社群論壇轉載~！奮鬥 使用NonXADataSourceBean. Mysql在5.0版本和Connecter/J5.0版本後提供了XADatasource支援，如果使用了支援XADatasouce版本 最近做的project中遇到要

SpringBoot學習筆記（三）：SpringBoot整合Mybatis、SpringBoot事務管理、SpringBoot多資料來源

SpringBoot整合Mybatis 第一步我們需要在pom.xml裡面引入mybatis相關的jar包 <dependency> <groupId>org.mybatis.spring.boot</groupId> <artif

springboot整合Mybatis、事務、多資料來源、分散式事務

springboot整合Mybatis、事務、多資料來源 文章目錄 springboot整合Mybatis、事務、多資料來源 一. 整合Mybatis 二. 事務 2.1 回顧事務

【Spring Boot】（29）、SpringBoot整合Mybatis原始碼分析

在【Spring Boot】（23）、Spring Boot整合Mybatis的章節中講述了SpringBoot整合Mybatis的過程，以及一些配置說明，這節主要講解一下整合的原始碼。 廢話不多說，直接進入今天的主題。 閱讀過我之前寫的文章的童靴，肯定知道SpringBoot整合第三方

springboot整合Mybatis配置多資料來源

springboot配置多資料來源有好幾種方式 1.application.properties配置 ## 埠 server.port=8080 # 資料庫訪問配置 spring.datasource.type=com.alibaba.druid.pool.DruidDataSource spri

Springboot整合mybatis實現多資料來源

1:SpringBoot整合mybatis實現多資料來源有兩種方法 1:靜態方式 將每個資料來源都實現一個mybatis的sqlSessionFactory中,但是這種方法,缺點在於:你有幾個資料來源都會有幾個mybatis的配置類;對於資料來源的事務也不是很

SpringBoot整合Mybatis多資料來源(Atomikos)

一、 Spring介紹 1.1、SpringBoot簡介 在您第1次接觸和學習Spring框架的時候，是否因為其繁雜的配置而退卻了？在你第n次使用Spring框架的時候，是否覺得一堆反覆黏貼的配置有一些厭煩？那麼您就不妨來試試使用Spring Boot來讓你更易上手，更簡

Springboot整合mybatis、以及xml配置例項、熱部署

整合mybatis： 引入jar包，這個包是dao+server整合，內涵mybatis生成的xml，及mapper介面和bean物件 引入包後，其包的依賴也會下來，所依賴的jar yml檔案配置連線引數，資料來源如果有引入jar則還可以配置資料來源，myb

SpringBoot整合MyBatis、PageHelper和通用Mapper

之前一直用SSM框架，今天嘗試了一下將MyBatis、PageHelper和通用Mapper進行整合，所以將整合過程記錄作為後續檢視之用。 Mybatis-PageHelper的說明介紹可以點選這裡，一些配置引數與使用介紹可以點選這裡檢視，我在整合這些外掛的時

springboot整合mybatis的多資料來源解決辦法

　　最近專案有一個非解決不可的問題，我們的專案中的使用者表是用的自己庫的資料，但是這些資料都是從一個已有庫中遷過來的，所以使用者資訊都是在那個專案裡面維護，自然而然我們專案不提供使用者註冊功能，這就有個問題，如何解決資料遷移的問題，總不能我每次都手動導資料吧，所以我決心寫一個介面把那個庫中的使用者資訊同步我們

九、SpringBoot整合MyBatis

1、新增pom依賴 <!-- mysql --> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId>

SpringBoot整合mybatis、shiro、redis實現基於資料庫的細粒度動態許可權管理系統例項

1.前言 本文主要介紹使用SpringBoot與shiro實現基於資料庫的細粒度動態許可權管理系統例項。 使用技術：SpringBoot、mybatis、shiro、thymeleaf、pagehelper、Mapper外掛、druid、dataTables

Springboot整合mybatis及分頁查詢、定時任務）

整了一整天，看了一位前輩的部落格，在此基礎上加上本人的理解及創作，哪位前輩忘記了，望諒解！不多說，直接上程式碼。 以上是專案的整體結構，下面是pom.xml檔案資訊：<project xmlns="http://maven.apache.org/POM/4.0.0"

java鬼混筆記：springboot 6、springboot整合mybatis(支援多數源)

、、、、、、、、、、、、、、、、、、 玩玩springboot 整合mybatis，且支援多個數據源。 首先建立一個springboot web 專案，還是eclipse加外掛好，創建出來的springboot專案比較全面。 注意：注意：注意： 想要程式掃描到@servic

springboot整合mybatis多資料來源

application.properties #mysql [email protected]@ spring.datasource.primary.username= @[email protected] spring.datasource.prim

【SpringBoot】——SpringBoot 整合mybatis-plus 單資料來源 & 多資料來源，附原始碼

相信大家已經看了不少的教程了，所以在此我不在贅述。。。。。。 遇到的坑，在專案中readme.md 中有描述。具體下載下來配置比較詳細，初始化sql ，單元測試。。。檢視流程即可。 demo非常簡單，下載下來參考 readme.md 修改必要內容即可完成配

二、springBoot 整合 mybatis 專案實戰

前言 上一篇文章開始了我們的springboot序篇，我們配置了mysql資料庫，但是我們sql語句直接寫在controller中並且使用的是jdbcTemplate。專案中肯定不會這樣使用，上篇文章也說了，會結合mybatis 或者JPA 使用。我們這篇文章就來結合 mybatis 來使用吧，至於為什麼選m

SpringBoot整合Mybatis動態多資料來源後，MybatisPlus的IPage失效的問題解決方案

背景 之前做資料抽取的時候，搭了一個mybatis動態資料來源切換的架子。方便他們寫抽取的程式碼。今天同事問我，架子裡面的mybatisplus的IPage失效了是什麼問題。想了一下，應該是寫動態資料來源的時候，我自定義的mybatis的配置覆蓋了已有的配置。於是我讓他先把我寫的配置進行刪除，看是否正常。得到