前言

業(yè)務(wù)需求中需要連接兩個(gè)數(shù)據(jù)庫處理數(shù)據(jù)，需要用動(dòng)態(tài)數(shù)據(jù)源。通過了解mybatis的框架，計(jì)劃 使用分包的方式進(jìn)行數(shù)據(jù)源的區(qū)分。

原理

前提：

我們使用mybatis都會(huì)有四個(gè)步驟

1：構(gòu)建SqlSessionFactory

2：通過SqlSessionFactory 獲取到sqlSession 對(duì)象

3：通過sqlSession對(duì)象獲取Mapper的動(dòng)態(tài)代理對(duì)象

4：通過執(zhí)行動(dòng)態(tài)代理對(duì)象獲取返回值

其實(shí)點(diǎn)開sqlSessionFactory就的Configuration對(duì)象中的Environment對(duì)象綁定了我們的dataSource對(duì)象

同樣，我們通過debug發(fā)現(xiàn)，動(dòng)態(tài)代理后的mapper對(duì)象是同樣持有Configuration對(duì)象，綁定我們的連接信息。

猜想

需要分包實(shí)現(xiàn)不同數(shù)據(jù)源的話，需要對(duì)不同的mapper指定不同的sqlSessionFactroy，查看mapperScan的注解源碼，

通過理解注釋，我們是可以指定maper動(dòng)態(tài)代理對(duì)象的sqlSessionFactory對(duì)象的。然后結(jié)果basePackages就可以對(duì)不同的包使用不同的sqlSessionFactory從而實(shí)現(xiàn)不同包使用不同的數(shù)據(jù)源。

實(shí)現(xiàn)

1：定義兩個(gè)數(shù)據(jù)源

兩個(gè)數(shù)據(jù)源分別命名位ds01，ds02,這里采用都是德魯伊的數(shù)據(jù)庫連接池。為了簡介，詳細(xì)配置沒有展示了。

2：定義兩個(gè)SqlSessionFactory

定義兩個(gè)sqlSessionFactory，分別綁定兩個(gè)數(shù)據(jù)源。

3：不同包實(shí)現(xiàn)綁定不同的sqlSessionFactory

通過@MapperScan指定掃描的包，通知指定SqlSessionFactory

@MapperScan(basePackages = "com.lenven.demo.dao.ds02",sqlSessionFactoryRef = "salveSqlSessionFactory")
@MapperScan(basePackages = "com.lenven.demo.dao.ds01",sqlSessionFactoryRef = "masterSqlSessionFactory")

4：測試

對(duì)兩個(gè)不同的包的mapper測試，都可以正確查詢出數(shù)據(jù)

拓展：

通過實(shí)現(xiàn)

AbstractRoutingDataSource也可以實(shí)現(xiàn)動(dòng)態(tài)數(shù)據(jù)源。

該類實(shí)現(xiàn)DataSource的接口，可以配置對(duì)各數(shù)據(jù)源在

 @Nullable
    private Map<Object, DataSource> resolvedDataSources;

這個(gè)屬性里面。

讓后通過暴露一個(gè)determineCurrentLookupKey 獲取需要使用的數(shù)據(jù)源的key。但是需要注意事務(wù)的問題。

總結(jié)

到此這篇關(guān)于Mybatis實(shí)現(xiàn)分包定義數(shù)據(jù)庫的原理與過程的文章就介紹到這了,更多相關(guān)Mybatis分包定義數(shù)據(jù)庫內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論