創(chuàng)新互聯(lián)www.cdcxhl.cn八線動(dòng)態(tài)BGP香港云服務(wù)器提供商,新人活動(dòng)買多久送多久,劃算不套路!
成都創(chuàng)新互聯(lián)制作網(wǎng)站網(wǎng)頁(yè)找三站合一網(wǎng)站制作公司,專注于網(wǎng)頁(yè)設(shè)計(jì),網(wǎng)站設(shè)計(jì)、網(wǎng)站制作,網(wǎng)站設(shè)計(jì),企業(yè)網(wǎng)站搭建,網(wǎng)站開(kāi)發(fā),建網(wǎng)站業(yè)務(wù),680元做網(wǎng)站,已為成百上千家服務(wù),成都創(chuàng)新互聯(lián)網(wǎng)站建設(shè)將一如既往的為我們的客戶提供最優(yōu)質(zhì)的網(wǎng)站建設(shè)、網(wǎng)絡(luò)營(yíng)銷推廣服務(wù)!springboot 基于mybatis如何實(shí)現(xiàn)配置多數(shù)據(jù)源?很多新手對(duì)此不是很清楚,為了幫助大家解決這個(gè)難題,下面小編將為大家詳細(xì)講解,有這方面需求的人可以來(lái)學(xué)習(xí)下,希望你能有所收獲。
在實(shí)際開(kāi)發(fā)中,我們一個(gè)項(xiàng)目可能會(huì)用到多個(gè)數(shù)據(jù)庫(kù),通常一個(gè)數(shù)據(jù)庫(kù)對(duì)應(yīng)一個(gè)數(shù)據(jù)源。
代碼結(jié)構(gòu):
簡(jiǎn)要原理:
1)DatabaseType列出所有的數(shù)據(jù)源的key---key
2)DatabaseContextHolder是一個(gè)線程安全的DatabaseType容器,并提供了向其中設(shè)置和獲取DatabaseType的方法
3)DynamicDataSource繼承AbstractRoutingDataSource并重寫(xiě)其中的方法determineCurrentLookupKey(),在該方法中使用DatabaseContextHolder獲取當(dāng)前線程的DatabaseType
4)MyBatisConfig中生成2個(gè)數(shù)據(jù)源DataSource的bean---value
5)MyBatisConfig中將1)和4)組成的key-value對(duì)寫(xiě)入到DynamicDataSource動(dòng)態(tài)數(shù)據(jù)源的targetDataSources屬性(當(dāng)然,同時(shí)也會(huì)設(shè)置2個(gè)數(shù)據(jù)源其中的一個(gè)為DynamicDataSource的defaultTargetDataSource屬性中)
6)將DynamicDataSource作為primary數(shù)據(jù)源注入到SqlSessionFactory的dataSource屬性中去,并且該dataSource作為transactionManager的入?yún)?lái)構(gòu)造DataSourceTransactionManager
7)使用的時(shí)候,在dao層或service層先使用DatabaseContextHolder設(shè)置將要使用的數(shù)據(jù)源key,然后再調(diào)用mapper層進(jìn)行相應(yīng)的操作,建議放在dao層去做(當(dāng)然也可以使用spring aop+自定注解去做)
注意:在mapper層進(jìn)行操作的時(shí)候,會(huì)先調(diào)用determineCurrentLookupKey()方法獲取一個(gè)數(shù)據(jù)源(獲取數(shù)據(jù)源:先根據(jù)設(shè)置去targetDataSources中去找,若沒(méi)有,則選擇defaultTargetDataSource),之后在進(jìn)行數(shù)據(jù)庫(kù)操作。
1、假設(shè)有兩個(gè)數(shù)據(jù)庫(kù),配置如下
application.properties
#the first datasource jdbc.driverClassName = com.mysql.jdbc.Driver jdbc.url = jdbc:mysql://xxx:3306/mytestdb?zeroDateTimeBehavior=convertToNull&useUnicode=true&characterEncoding=utf-8 jdbc.username = root jdbc.password = 123 #the second datasource jdbc2.driverClassName = com.mysql.jdbc.Driver jdbc2.url = jdbc:mysql://xxx:3306/mytestdb2?zeroDateTimeBehavior=convertToNull&useUnicode=true&characterEncoding=utf-8 jdbc2.username = root jdbc2.password = 123