15《Spring Boot 入門教程》多數(shù)據(jù)源與分布式事務(wù)

一個項目中使用多個數(shù)據(jù)源的需求，我們在日常工作中時常會遇到。

創(chuàng)新互聯(lián)是一家集網(wǎng)站建設(shè),平南企業(yè)網(wǎng)站建設(shè),平南品牌網(wǎng)站建設(shè),網(wǎng)站定制,平南網(wǎng)站建設(shè)報價,網(wǎng)絡(luò)營銷,網(wǎng)絡(luò)優(yōu)化,平南網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強企業(yè)競爭力。可充分滿足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時我們時刻保持專業(yè)、時尚、前沿，時刻以成就客戶成長自我，堅持不斷學(xué)習(xí)、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實用型網(wǎng)站。

以商城系統(tǒng)為例，有一個 MySQL 的數(shù)據(jù)庫負(fù)責(zé)存儲交易數(shù)據(jù)。公司還有一套 ERP 企業(yè)信息化管理系統(tǒng)，要求訂單信息同步錄入 ERP 數(shù)據(jù)庫，便于公司統(tǒng)一管理，而該 ERP 系統(tǒng)采用的數(shù)據(jù)庫為 SQL Server 。

此時，就可以在 Spring Boot 項目中配置多個數(shù)據(jù)源。另外，使用多數(shù)據(jù)源后，需要采用分布式事務(wù)來保持?jǐn)?shù)據(jù)的完整性。

本小節(jié)我們使用 Spring Boot 開發(fā)一個商城系統(tǒng)的訂單生成功能，訂單信息同時進入 MySQL 與 SQL Server 數(shù)據(jù)庫。

首先創(chuàng)建 MySQL 數(shù)據(jù)庫 shop ，并新建訂單表 order ，表結(jié)構(gòu)如下：

order 表結(jié)構(gòu)

然后創(chuàng)建 SQL Server 數(shù)據(jù)庫 erpshop ，并新建訂單表 erp_order ，表結(jié)構(gòu)如下。注意 id 是自增長的唯一標(biāo)識，out_id 是對應(yīng)訂單在 MySQL 數(shù)據(jù)庫中的唯一標(biāo)識，以便在兩個庫中比對訂單。

erp_order 結(jié)構(gòu)

接下來，我們開始實現(xiàn) Spring Boot 后端項目，數(shù)據(jù)持久層采用 MyBatis 框架，同時訪問兩個數(shù)據(jù)源。

Spring Boot 版本選擇 2.2.5 ，Group 為 com.imooc ， Artifact 為 spring-boot-multidb，生成項目后導(dǎo)入 Eclipse 開發(fā)環(huán)境。

我們引入熱部署依賴、 Web 依賴、數(shù)據(jù)庫訪問相關(guān)依賴及測試相關(guān)依賴，具體如下：

實例：

由于我們要同時訪問兩個數(shù)據(jù)庫，所以需要在配置文件中添加兩個數(shù)據(jù)源的配置信息。注意配置多數(shù)據(jù)源時， url 配置需要使用 spring.datasource.db1.jdbc-url=xxx 的形式。

實例：

多個數(shù)據(jù)源的情況下， 我們需要通過配置類，將數(shù)據(jù)源注冊為組件放入 Spring 容器中。

實例：

通過這個配置類， Spring 容器中就有兩個數(shù)據(jù)源組件，這兩個組件分別采用 spring.datasource.db1 和 spring.datasource.db2 開頭的配置信息。所以通過這兩個組件，就能分別操作 MySQL 數(shù)據(jù)源 1 和 SQL Sever 數(shù)據(jù)源 2 。

多數(shù)據(jù)源情況下， MyBatis 中的關(guān)鍵組件 SqlSessionFactory 和 SqlSessionTemplate 也需要單獨配置，我們需要為兩個數(shù)據(jù)源分別配置一套組件。

實例：

通過上面的配置類， com.imooc.springbootmultidb.mapper1 包中的 DAO 數(shù)據(jù)訪問接口會自動調(diào)用 sqlSessionTemplate1 組件實現(xiàn)具體數(shù)據(jù)庫操作，而 sqlSessionTemplate1 操作的數(shù)據(jù)源已經(jīng)通過配置類設(shè)置為 db1 。同時， DAO 數(shù)據(jù)訪問接口對應(yīng)的映射文件已經(jīng)指定到 classpath:mapper1/ 目錄去尋找。這樣數(shù)據(jù)源 – DAO 數(shù)據(jù)訪問接口 – 映射文件三者的對應(yīng)關(guān)系就建立起來了。

數(shù)據(jù)源 2 的配置方法是一樣的， com.imooc.springbootmultidb.mapper2 包中的 DAO 數(shù)據(jù)訪問接口會自動調(diào)用 sqlSessionTemplate2 組件，其操作的數(shù)據(jù)源即為 db2 ，其對應(yīng)的映射文件指定到 classpath:mapper2/ 目錄去尋找。

實例：

數(shù)據(jù)訪問接口的位置已經(jīng)在配置類指定，首先在 com.imooc.springbootmultidb.mapper1 創(chuàng)建 OrderDao ，操作的是數(shù)據(jù)源 1 中的 order 表。

實例：

然后在 com.imooc.springbootmultidb.mapper2 創(chuàng)建 ErpOrderDao ，操作的是數(shù)據(jù)源 2 中的 erporder 表。

實例：

這兩個接口中使用的數(shù)據(jù)對象比較簡單，代碼如下：

實例：

分別針對 OrderDao 、 ErpOrderDao 編寫對應(yīng)的映射文件，然后按照配置類指定的位置，兩個文件分別放到 resources/mapper1 和 resources/mapper2 目錄下。

實例：

實例：

數(shù)據(jù)操作接口與對應(yīng)的映射文件均已編寫完畢，現(xiàn)在可以通過測試類進行多數(shù)據(jù)源測試了，我們在測試類中同時向兩個庫插入記錄。

實例：

運行測試方法后，兩個數(shù)據(jù)庫表中均新增數(shù)據(jù)成功，這樣我們就成功的使用 Spring Boot 同時操作了兩個數(shù)據(jù)源。

采用多數(shù)據(jù)源之后，事務(wù)的實現(xiàn)方式也隨之發(fā)生變化。當(dāng)某個數(shù)據(jù)源操作出現(xiàn)異常時，該數(shù)據(jù)源和其他數(shù)據(jù)源的事務(wù)都需要回滾。這種涉及多個數(shù)據(jù)源的事務(wù)，稱為分布式事務(wù)，接來下我們就來具體實現(xiàn)一下。

在 pom.xml 引入 Atomikos 事務(wù)管理器相關(guān)的依賴項， Atomikos 是一個開源的事務(wù)管理器，支持分布式事務(wù)。

實例：

需要將默認(rèn)的數(shù)據(jù)源更換為支持分布式事務(wù)的數(shù)據(jù)源， MySQL 對應(yīng)的數(shù)據(jù)源為 MysqlXADataSource ， SQL Server 對應(yīng)的數(shù)據(jù)源為 SQLServerXADataSource 。

實例：

繼續(xù)修改 DataSourceConfig 類，在其中配置分布式事務(wù)管理器組件。當(dāng)項目中使用事務(wù)時，會通過配置的分布式事務(wù)管理器管理分布式事務(wù)操作。

實例：

在測試方法上添加 @Transactional 開啟事務(wù)，然后在兩個數(shù)據(jù)源操作中間模擬拋出異常。

實例：

此時運行測試類，可以發(fā)現(xiàn)數(shù)據(jù)源 1 的事務(wù)已回滾，驗證成功！

在開發(fā) Spring Boot 項目時，如果默認(rèn)配置滿足不了我們的需求，可以通過手工配置組件實現(xiàn)我們需要的功能。這些組件可能是各個公司提供的，我們根據(jù)相應(yīng)文檔，為其配置各個屬性即可。

發(fā)貨訂單實效性，用mysql如何實現(xiàn)？

可以使用mysql的事件任務(wù)來實現(xiàn)

這需要你先編寫一個存儲過程，查詢3天內(nèi)沒有狀態(tài)沒有變更為發(fā)貨狀態(tài)的數(shù)據(jù)，然后釋放庫存的邏輯

比如這個邏輯存儲過程叫 prod()

然后可以創(chuàng)建一個存儲過程，每天執(zhí)行一次prod()

CREATE?EVENT?xxx

ON?SCHEDULE?EVERY?1?day

BEGIN?

CALL?prod()

END

這樣就創(chuàng)建了一個每天執(zhí)行一次prod()存儲過程的事件任務(wù)了，xxx是事件任務(wù)的名字

求教mysql觸發(fā)器生成流水號

用存儲過程生成流水號是很常用的，這里以生成訂單編號的流水號作為示例。（新的一天的流水號從1開始，如：今天的訂單編號是CD2013010900014，下一個訂單編號將是CD2013010900015；明天的訂單編號將從CD2013011000001開始）

生成規(guī)則：2位前綴+年月日+5位流水號 或者 2位前綴+年月日時分+5位流水號 或者 2位前綴+年月日時分秒+5位流水號。

測試訂單表(test_orders):

[sql] view plain copy

CREATE TABLE `test_orders` (

`id` int(11) NOT NULL AUTO_INCREMENT,

`orderNo` varchar(25) NOT NULL DEFAULT '',

`orderName` char(10) NOT NULL DEFAULT '',

PRIMARY KEY (`id`)

) ENGINE=InnoDB AUTO_INCREMENT=76 DEFAULT CHARSET=utf8

生成訂單編號的存儲過程(generate_orderNo):

[sql] view plain copy

CREATE DEFINER=PROCEDURE `generate_orderNo`(in orderNamePre char(2), in num int, out newOrderNo varchar(25))

BEGIN

DECLARE currentDate varCHAR (15) ;-- 當(dāng)前日期,有可能包含時分秒

DECLARE maxNo INT DEFAULT 0 ; -- 離現(xiàn)在最近的滿足條件的訂單編號的流水號最后5位，如：SH2013011000002的maxNo=2

-- DECLARE l_orderNo varCHAR (25) ;-- 新生成的訂單編號

-- DECLARE oldDate DATE ;-- 離現(xiàn)在最近的滿足條件的訂單編號的日期

DECLARE oldOrderNo VARCHAR (25) DEFAULT '' ;-- 離現(xiàn)在最近的滿足條件的訂單編號

if num = 8 then -- 根據(jù)年月日生成訂單編號

SELECT DATE_FORMAT(NOW(), '%Y%m%d') INTO currentDate ;-- 訂單編號形式:前綴+年月日+流水號，如：SH2013011000002

elseif num = 14 then -- 根據(jù)年月日時分秒生成訂單編號

SELECT DATE_FORMAT(NOW(), '%Y%m%d%H%i%s') INTO currentDate ; -- 訂單編號形式：前綴+年月日時分秒+流水號，如：SH2013011010050700001,個人不推薦使用這種方法生成流水號

else -- 根據(jù)年月日時分生成訂單編號

SELECT DATE_FORMAT(NOW(), '%Y%m%d%H%i') INTO currentDate ;-- 訂單形式：前綴+年月日時分+流水號,如：SH20130110100900005

end if ;

SELECT IFNULL(orderNo, '') INTO oldOrderNo

FROM test_orders

WHERE SUBSTRING(orderNo, 3, num) = currentDate

AND SUBSTRING(orderNo, 1, 2) = orderNamePre

and length(orderNo) = 7 + num

ORDER BY id DESC LIMIT 1 ; -- 有多條時只顯示離現(xiàn)在最近的一條

IF oldOrderNo != '' THEN

SET maxNo = CONVERT(SUBSTRING(oldOrderNo, -5), DECIMAL) ;-- SUBSTRING(oldOrderNo, -5)：訂單編號如果不為‘‘截取訂單的最后5位

END IF ;

SELECT

CONCAT(orderNamePre, currentDate, LPAD((maxNo + 1), 5, '0')) INTO newOrderNo ; -- LPAD((maxNo + 1), 5, '0')：如果不足5位，將用0填充左邊

INSERT INTO test_orders (orderNo, orderName) VALUES (newOrderNo, 'testNo') ; -- 向訂單表中插入數(shù)據(jù)

-- set newOrderNo = l_orderNo;

SELECT

newOrderNo ;

END

參數(shù)說明：orderNamePre：(輸入)訂單編號的前綴,這里設(shè)定為兩個字符

num：(輸入)將按什么規(guī)則生成流水號(生成規(guī)則有：年月日、年月日時分秒、年月日時分三種),可選的num有：8、12、14

newOrderNo：(輸出)新生成的訂單編號

生成中的一些說明在存儲過程中已經(jīng)寫得很明確了，這里不再重復(fù)。

調(diào)用存儲過程向表中插入數(shù)據(jù):

[sql] view plain copy

SET @orderNo = '';

CALL `generate_orderNo`('SH', 12, @orderNo);

SELECT @orderNo;

mysql生成訂單號

這個只能程序做的。數(shù)據(jù)庫只提供了數(shù)據(jù)的插入，修改，刪除和查詢等操作，沒有提供完備的計算功能

當(dāng)前文章：mysql怎么生成訂單,mysql 訂單表
本文地址：http://jinyejixie.com/article46/hojheg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站排名、定制網(wǎng)站、Google、網(wǎng)站設(shè)計、手機網(wǎng)站建設(shè)、云服務(wù)器

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)