怎么在mybatis plus中動(dòng)態(tài)切換數(shù)據(jù)源？很多新手對(duì)此不是很清楚，為了幫助大家解決這個(gè)難題，下面小編將為大家詳細(xì)講解，有這方面需求的人可以來(lái)學(xué)習(xí)下，希望你能有所收獲。

“只有客戶(hù)發(fā)展了，才有我們的生存與發(fā)展！”這是創(chuàng)新互聯(lián)建站的服務(wù)宗旨！把網(wǎng)站當(dāng)作互聯(lián)網(wǎng)產(chǎn)品，產(chǎn)品思維更注重全局思維、需求分析和迭代思維，在網(wǎng)站建設(shè)中就是為了建設(shè)一個(gè)不僅審美在線，而且實(shí)用性極高的網(wǎng)站。創(chuàng)新互聯(lián)對(duì)做網(wǎng)站、成都網(wǎng)站制作、網(wǎng)站制作、網(wǎng)站開(kāi)發(fā)、網(wǎng)頁(yè)設(shè)計(jì)、網(wǎng)站優(yōu)化、網(wǎng)絡(luò)推廣、探索永無(wú)止境。

mybatis plus多數(shù)據(jù)源切換

mybatis plus多數(shù)據(jù)源切換使用注解 @DS
DS注解作為多數(shù)據(jù)源切點(diǎn)，具體實(shí)現(xiàn)作用主要由兩個(gè)類(lèi)完成
DynamicDataSourceAnnotationAdvisor
DynamicDataSourceAnnotationInterceptor

DS多數(shù)據(jù)源切換實(shí)現(xiàn)

1.DynamicDataSourceAnnotationAdvisor類(lèi)實(shí)現(xiàn)切面配置，其中AnnotationMatchingPointcut用于尋找切點(diǎn)，進(jìn)入可看到支持類(lèi)和方法的切點(diǎn)，多個(gè)切點(diǎn)會(huì)執(zhí)行多次，根據(jù)代碼順序，方法的切點(diǎn)執(zhí)行晚于類(lèi)切點(diǎn)，所以方法的切點(diǎn)會(huì)覆蓋類(lèi)，但是都會(huì)被執(zhí)行

2.DynamicDataSourceAnnotationInterceptor 實(shí)現(xiàn)切面功能，匹配到切點(diǎn)后，根據(jù)切點(diǎn)值（數(shù)據(jù)源id）設(shè)置當(dāng)前線程有效數(shù)據(jù)源私有變量，用于執(zhí)行查詢(xún)時(shí)動(dòng)態(tài)數(shù)據(jù)源能獲取，執(zhí)行完畢會(huì)清楚此變量，此存儲(chǔ)功能由DynamicDataSourceContextHolder提供

3.執(zhí)行時(shí)動(dòng)態(tài)數(shù)據(jù)源確定，mybatisplus動(dòng)態(tài)數(shù)據(jù)源實(shí)現(xiàn)類(lèi)為DynamicRoutingDataSource，其維護(hù)一個(gè)map保存所有配置的數(shù)據(jù)源，以數(shù)據(jù)源ID作為key，執(zhí)行查詢(xún)時(shí)，獲取連接，交由spring事務(wù)管理器SpringManagedTransaction進(jìn)行連接獲取，若當(dāng)前存在連接則直接返回，不存在是創(chuàng)建連接，只有創(chuàng)建連接時(shí)，才有機(jī)會(huì)切換數(shù)據(jù)源，此處需要注意的是，同一事務(wù)下，使用的同一個(gè)sqlSession，執(zhí)行查詢(xún)時(shí)使用的是同一個(gè)執(zhí)行器executor，最終使用的是同一個(gè)事務(wù)管理器，所以獲取連接時(shí)無(wú)法創(chuàng)建新連接，mybatisplus切換數(shù)據(jù)源功能失效，代碼無(wú)法被執(zhí)行

此處邏輯較多，一筆帶過(guò)有點(diǎn)草率，后續(xù)附帶mybatisplus查詢(xún)過(guò)程，感興趣的老鐵一會(huì)在看。

4.動(dòng)態(tài)數(shù)據(jù)源敲定，接第3步，若當(dāng)前事務(wù)管理器還未創(chuàng)建連接，那就打開(kāi)一個(gè)連接，使用DataSourceUtils獲取一個(gè)連接，入?yún)閙ybatisplus的動(dòng)態(tài)數(shù)據(jù)源DynamicRoutingDataSource，一步步往下巴拉，忽略不需要代碼，最終執(zhí)行到了這一句：
Connection con = dataSource.getConnection();
使用DynamicRoutingDataSource獲取連接，瞧，兜兜轉(zhuǎn)轉(zhuǎn)，最終怎么找連接，敲定數(shù)據(jù)源又交給了mybatisplus，getConnection方法在其父級(jí)AbstractRoutingDataSource中，使用this.determineDataSource().getConnection()獲取連接，.getConnection()是數(shù)據(jù)源獲取連接方法，那確定數(shù)據(jù)源顧名思義就是determineDataSource方法了，這個(gè)方法的實(shí)現(xiàn)就在DynamicRoutingDataSource中，來(lái)瞧瞧！是不是瞬間舒服了，根據(jù)第二部切面設(shè)置的數(shù)據(jù)源，這個(gè)返回對(duì)應(yīng)的數(shù)據(jù)源。

5.主要邏輯已經(jīng)清楚了，那么來(lái)延伸下，如何手動(dòng)切換數(shù)據(jù)源mybatisplus切換數(shù)據(jù)源主要是使用DynamicDataSourceContextHolder的線程獨(dú)享變量，那么如果沒(méi)有DS切點(diǎn)，無(wú)法自動(dòng)切換數(shù)據(jù)源，需要切換數(shù)據(jù)源時(shí)就可以使用DynamicDataSourceContextHolder.setDataSourceLookupKey 設(shè)置數(shù)據(jù)源，使用完后再清除掉（默認(rèn)數(shù)據(jù)源生效），這個(gè)方法同第4步所提的事務(wù)問(wèn)題，存在事務(wù)則無(wú)法切換（壓根就不執(zhí)行 只設(shè)置無(wú)法執(zhí)行切換代碼），如果將要執(zhí)行的代碼已存在切點(diǎn)，則執(zhí)行前手動(dòng)設(shè)置也是無(wú)效的，因?yàn)榍悬c(diǎn)會(huì)覆蓋你的設(shè)置。

注：如果需要在事務(wù)存在的情況下切換數(shù)據(jù)源，則估計(jì)要覆蓋掉或替換掉spring的事務(wù)管理器，此處待后續(xù)再議。如果事務(wù)內(nèi)仍需要切換數(shù)據(jù)源，則需要單獨(dú)定義service并設(shè)置切點(diǎn)，設(shè)置此切點(diǎn)的事務(wù)傳播行為為PROPAGATION__REQUIRES_NEW，則執(zhí)行切面方法時(shí)單獨(dú)創(chuàng)建一個(gè)事務(wù)，數(shù)據(jù)源會(huì)自動(dòng)切換。

mybatisplus執(zhí)行查詢(xún)過(guò)程

現(xiàn)分析mybatisplus執(zhí)行查詢(xún)過(guò)程

1.執(zhí)行selectById方法，執(zhí)行return this.baseMapper.selectById(id);經(jīng)過(guò)springaop切面進(jìn)行一系列巴拉巴拉的處理，最終進(jìn)入mybatisplus PageMapperMethod類(lèi)中執(zhí)行execute方法，根據(jù)sql類(lèi)型進(jìn)行不同處理，分新增，修改，刪除，查詢(xún),我們本次只關(guān)注查詢(xún)，查詢(xún)里也有很多東西。

可以看到此處提供多種返回值的查詢(xún)，有空返回值，多個(gè)，map，游標(biāo)，及啥也不是。空值查詢(xún)猜測(cè)是另有處理器直接處理返回值，此處不做延伸了，有需要再議，回到按照ID查詢(xún)及進(jìn)入啥也不是分支，本次查詢(xún)不是分頁(yè)查詢(xún)，直接進(jìn)入selectOne ，result = sqlSession.selectOne(this.command.getName(), param); 這里的sqlSession是SqlSessionTemplate,執(zhí)行selectOne時(shí)首先獲取sqlSession（默認(rèn)為DefaultSelSession）

2.獲取真正的sqlSession并執(zhí)行selectOne查詢(xún)，首先使用事務(wù)管理器獲取緩存的sqlSession的持有者（sqlSession包裝類(lèi)）,不存在則創(chuàng)建并緩存注冊(cè)。

得到真正的sqlSession后，執(zhí)行selectOne，發(fā)現(xiàn)還是執(zhí)行的selectList，然后就是大眾寫(xiě)法，size=1返回get(0),否則為空或者報(bào)錯(cuò)結(jié)果集太多。

3.來(lái)看看selectList在干嘛，先獲取查詢(xún)語(yǔ)句相關(guān)的MappedStatement，然后使用執(zhí)行器executor執(zhí)行查詢(xún) this.executor.query
執(zhí)行器是啥？怎么來(lái)的？

執(zhí)行器是sqlSession內(nèi)部的一個(gè)屬性，sqlSession其實(shí)也是個(gè)外包裝，提供了一堆規(guī)范化的操作，但是并不直接實(shí)現(xiàn)這些操作，而是交給執(zhí)行器，執(zhí)行器來(lái)執(zhí)行增刪改查，默認(rèn)使用的是SimpleExecutor，就以他入手，SimpleExecutor繼承抽象類(lèi)BaseExecutor，BaseExecutor實(shí)現(xiàn)了Executor接口，這個(gè)query就在BaseExecutor中：這里主要是獲取執(zhí)行的sql，以及根據(jù)執(zhí)行語(yǔ)句和入?yún)?lái)生成一個(gè)緩存的key，會(huì)緩存查詢(xún)結(jié)果，如果下次再來(lái)個(gè)一毛一樣的查詢(xún) 就直接用緩存了，不查了，這個(gè)就是mybatis的一級(jí)緩存，緩存使用的是一個(gè)封裝的類(lèi)PerpetualCache，最終對(duì)應(yīng)的就是一個(gè)map :
private Map<Object, Object> cache = new HashMap();

4.執(zhí)行數(shù)據(jù)庫(kù)查詢(xún)queryFromDatabase -> doQuery，這里和spring一個(gè)習(xí)慣，真正做事情的都是doXXX前面都是鋪墊前戲，看的人云里霧里的
這個(gè)doQuery的實(shí)現(xiàn)在SimpleExecutor中，進(jìn)入查看，
先創(chuàng)建了一個(gè)Statement，這個(gè)我知道，是jdbc里的東西，jdbc大概就是加載驅(qū)動(dòng)，獲取連接，打開(kāi)一個(gè)執(zhí)行語(yǔ)句塊，然后執(zhí)行獲取結(jié)果。具體這個(gè)東西學(xué)名和作用還是百度下吧：
Statement 對(duì)象用于把 SQL 語(yǔ)句發(fā)送到 DBMS。你只須簡(jiǎn)單地創(chuàng)建一個(gè) Statement 對(duì)象并且然后執(zhí)行它，使用適當(dāng)?shù)姆椒▓?zhí)行你發(fā)送的 SQL 語(yǔ)句。
這個(gè)也就是jdbc層面的sqlSession了吧。

創(chuàng)建完Statement后就會(huì)執(zhí)行查詢(xún)，先看來(lái)看Statement如何創(chuàng)建

5.Statement創(chuàng)建，創(chuàng)建第一步獲取connection,這個(gè)就涉及到數(shù)據(jù)源了吧，進(jìn)入查看，使用事務(wù)管理器Transaction獲取連接，默認(rèn)的事務(wù)管理器是SpringManagedTransaction,然后獲取數(shù)據(jù)源，最終創(chuàng)建或使用一個(gè)已有的連接并返回，進(jìn)而創(chuàng)建出一個(gè)Statement，其他細(xì)節(jié)已無(wú)心再細(xì)究，不影響本次分析目的。

6.執(zhí)行查詢(xún)，直接略過(guò)看最終執(zhí)行處，doFinish-> query ，執(zhí)行jdbc的PreparedStatement.execute，之后的代碼就先不看了，看意思就是將原始ResultSet結(jié)果集轉(zhuǎn)化為list。

看完上述內(nèi)容是否對(duì)您有幫助呢？如果還想對(duì)相關(guān)知識(shí)有進(jìn)一步的了解或閱讀更多相關(guān)文章，請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝您對(duì)創(chuàng)新互聯(lián)網(wǎng)站建設(shè)公司，的支持。

分享名稱(chēng)：怎么在mybatisplus中動(dòng)態(tài)切換數(shù)據(jù)源-創(chuàng)新互聯(lián)
網(wǎng)站鏈接：http://vcdvsql.cn/article0/iepoo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供營(yíng)銷(xiāo)型網(wǎng)站建設(shè)、網(wǎng)站建設(shè)、網(wǎng)站內(nèi)鏈、微信小程序、網(wǎng)站設(shè)計(jì)公司、網(wǎng)站改版

廣告

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