MyBatis多數據源配置(讀寫分離)

MyBatis多數據源配置(讀寫分離)

首先說明，本文的配置使用的最直接的方式，實際用起來可能會很麻煩。

實際應用中可能存在多種結合的情況，你可以理解本文的含義，不要死板的使用。

多數據源的可能情況

1.主從

通常是MySQL一主多從的情況，本文的例子就是主從的情況，但是只有兩個數據源，所以采用直接配置不會太麻煩，但是不利于后續擴展，主要是作為一個例子來說明，實際操作請慎重考慮。

針對這種情況，一個更好的解決方法可以參考（本人沒有實際嘗試過）：

http://blog.csdn.net/lixiucheng005/article/details/17391857

還有一個通過SpringAbstractRoutingDataSource路由接口的方式：

http://blog.csdn.net/xtj332/article/details/43953699

2.分庫

當業務獨立性強，數據量大的時候的，為了提高并發，可能會對表進行分庫，分庫后，每一個數據庫都需要配置一個數據源。

這種情況可以參考本文，但是需要注意每一個數據庫對應的Mapper要在不同的包下方便區分和配置。

另外分庫的情況下也會存在主從的情況，如果你的數據庫從庫過多，就參考上面提供的方法，或者尋找其他方式解決。

Mapper分包

分庫的情況下，不同的數據庫的Mapper一定放在不同的包下。

主從的情況下，同一個Mapper會同時存在讀寫的情況，創建兩個并不合適，使用同一個即可。但是這種情況下需要注意，Spring對Mapper自動生成的名字是相同的，而且類型也相同，這是就不能直接注入Mapper接口。需要通過SqlSession來解決。

Spring基礎配置

applicationContext.xml

<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:context="http://www.springframework.org/schema/context"xmlns:aop="http://www.springframework.org/schema/aop"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd"><context:component-scan base-package="com.isea533.mybatis.service"/><context:property-placeholder location="classpath:config.properties"/><aop:aspectj-autoproxy/><import resource="spring-datasource-master.xml"/><import resource="spring-datasource-slave.xml"/>
</beans>
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18

這個文件，主要是引入了spring-datasource-master.xml和spring-datasource-slave.xml。

spring-datasource-master.xml

<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd"><bean id="dataSourceMaster" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"><property name="driverClassName" value="${master.jdbc.driverClass}"/><property name="url" value="${master.jdbc.url}"/><property name="username" value="${master.jdbc.user}"/><property name="password" value="${master.jdbc.password}"/><property name="filters" value="stat"/><property name="maxActive" value="20"/><property name="initialSize" value="1"/><property name="maxWait" value="60000"/><property name="minIdle" value="1"/><property name="timeBetweenEvictionRunsMillis" value="60000"/><property name="minEvictableIdleTimeMillis" value="300000"/><property name="validationQuery" value="SELECT 'x'"/><property name="testWhileIdle" value="true"/><property name="testOnBorrow" value="false"/><property name="testOnReturn" value="false"/></bean><bean id="sqlSessionFactory1" class="org.mybatis.spring.SqlSessionFactoryBean"><property name="dataSource" ref="dataSourceMaster"/><property name="mapperLocations"><array><value>classpath:mapper/*.xml</value></array></property></bean><bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"><property name="basePackage" value="com.isea533.mybatis.mapper"/><property name="sqlSessionFactoryBeanName" value="sqlSessionFactory1"/></bean><bean id="sqlSessionMaster" class="org.mybatis.spring.SqlSessionTemplate" scope="prototype"><constructor-arg index="0" ref="sqlSessionFactory1"/></bean><aop:config><aop:pointcut id="appService" expression="execution(* com.isea533.mybatis.service..*Service*.*(..))"/><aop:advisor advice-ref="txAdvice1" pointcut-ref="appService"/></aop:config><tx:advice id="txAdvice1" transaction-manager="transactionManager1"><tx:attributes><tx:method name="select*" read-only="true"/><tx:method name="find*" read-only="true"/><tx:method name="get*" read-only="true"/><tx:method name="*"/></tx:attributes></tx:advice><bean id="transactionManager1" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSourceMaster"/></bean>
</beans>
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73

spring-datasource-slave.xml

和master區別不大，主要是id名字和數據源配置有區別。

<beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:tx="http://www.springframework.org/schema/tx"xmlns:aop="http://www.springframework.org/schema/aop"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx.xsdhttp://www.springframework.org/schema/aophttp://www.springframework.org/schema/aop/spring-aop.xsd"><bean id="dataSourceSlave" class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close"><property name="driverClassName" value="${slave.jdbc.driverClass}"/><property name="url" value="${slave.jdbc.url}"/><property name="username" value="${slave.jdbc.user}"/><property name="password" value="${slave.jdbc.password}"/><property name="filters" value="stat"/><property name="maxActive" value="20"/><property name="initialSize" value="1"/><property name="maxWait" value="60000"/><property name="minIdle" value="1"/><property name="timeBetweenEvictionRunsMillis" value="60000"/><property name="minEvictableIdleTimeMillis" value="300000"/><property name="validationQuery" value="SELECT 'x'"/><property name="testWhileIdle" value="true"/><property name="testOnBorrow" value="false"/><property name="testOnReturn" value="false"/></bean><bean id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean"><property name="dataSource" ref="dataSourceSlave"/><property name="mapperLocations"><array><value>classpath:mapper/*.xml</value></array></property></bean><bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"><property name="basePackage" value="com.isea533.mybatis.mapper"/><property name="sqlSessionFactoryBeanName" value="sqlSessionFactory2"/></bean><bean id="sqlSessionSlave" class="org.mybatis.spring.SqlSessionTemplate" scope="prototype"><constructor-arg index="0" ref="sqlSessionFactory2"/></bean><aop:config><aop:pointcut id="appService" expression="execution(* com.isea533.mybatis.service..*Service*.*(..))"/><aop:advisor advice-ref="txAdvice2" pointcut-ref="appService"/></aop:config><tx:advice id="txAdvice2" transaction-manager="transactionManager2"><tx:attributes><tx:method name="*" read-only="true"/></tx:attributes></tx:advice><bean id="transactionManager2" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSourceSlave"/></bean>
</beans>
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71

這里需要注意<tx:method name="*" read-only="true"/>是只讀的。如果不是從庫，可以按主庫進行配置。

在下面代碼中：

<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"><property name="basePackage" value="com.isea533.mybatis.mapper"/><property name="sqlSessionFactoryBeanName" value="sqlSessionFactory2"/>
</bean>
  • 1
  • 2
  • 3
  • 4
  • 1
  • 2
  • 3
  • 4

必須通過sqlSessionFactoryBeanName來指定不同的sqlSessionFactory。

config.properties

# 數據庫配置 - Master
master.jdbc.driverClass = com.mysql.jdbc.Driver
master.jdbc.url = jdbc:mysql://192.168.1.11:3306/test
master.jdbc.user = root
master.jdbc.password = jj# - Slave
slave.jdbc.driverClass = com.mysql.jdbc.Driver
slave.jdbc.url = jdbc:mysql://192.168.1.22:3306/test
slave.jdbc.user = root
slave.jdbc.password = jj
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11

使用Mapper

這里是針對主從的情況進行設置的，兩個配置掃描的Mapper是一樣的，所以沒法直接注入，需要通過下面的麻煩方式注入。

@Service
public class DemoService {private CountryMapper writeMapper;private CountryMapper readMapper;@Resource(name = "sqlSessionMaster")public void setWriteMapper(SqlSession sqlSession) {this.writeMapper = sqlSession.getMapper(CountryMapper.class);}@Resource(name = "sqlSessionSlave")public void setReadMapper(SqlSession sqlSession) {this.readMapper = sqlSession.getMapper(CountryMapper.class);}public int save(Country country){return writeMapper.insert(country);}public List<Country> selectPage(int pageNum, int pageSize) {PageHelper.startPage(pageNum, pageSize);return readMapper.select(null);}
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23

因為sqlSession能通過name區分開，所以這里從sqlSession獲取Mapper。

另外如果需要考慮在同一個事務中寫讀的時候，需要使用相同的writeMapper，這樣在讀的時候，才能獲取事務中的最新數據。

以上是主從的情況。

在分庫的情況時，由于不同Mapper在不同的包下，所以可以直接使用@Resource或者@Autowired注入Mapper，不需要通過sqlSession獲取。

本篇文章，只是一個多數據源的參考，實際應用時，請根據自己的情況進行考慮。

后續，我會利用業余時間，在本文和上面兩個相關鏈接的基礎上，針對MySql多數據源，嘗試開發可以自動切換數據源的插件，因為我對這方面的實際應用不是很熟，所以歡迎大家留言分享自己的解決方案，對這些了解的越多，就越有可能開發出通用的數據源切換插件。

本文來自互聯網用戶投稿，該文觀點僅代表作者本人，不代表本站立場。本站僅提供信息存儲空間服務，不擁有所有權，不承擔相關法律責任。
如若轉載，請注明出處：http://www.pswp.cn/news/387707.shtml
繁體地址，請注明出處：http://hk.pswp.cn/news/387707.shtml
英文地址，請注明出處：http://en.pswp.cn/news/387707.shtml

如若內容造成侵權/違法違規/事實不符，請聯系多彩編程網進行投訴反饋email:809451989@qq.com，一經查實，立即刪除！

相關文章

UI簡單工作

UI簡單工作

UI用戶界面 需求——效果圖——風格設計——高保證效果——html 網頁的寬度屏幕的寬度-縱向滾動條的寬度 企業網站一般是1280 根據百度流量研究所 目前我們的網頁注主要是1024和1200 這樣的寬度符合大體市場 首屏高度。 首屏的概念來源于出版領域 報紙折疊后販賣&…
閱讀更多...
MySQL分庫分表總結

MySQL分庫分表總結

MySQL分庫分表總結&#xff1a; 單庫單表 &#xff1a; 單庫單表是最常見的數據庫設計&#xff0c;例如&#xff0c;有一張用戶(user)表放在數據庫db中&#xff0c;所有的用戶都可以在db庫中的user表中查到。 單庫多表 &#xff1a; 隨著用戶數量的增加&#xff0c;user表的數…
閱讀更多...
3章 RxJava操作符

3章 RxJava操作符

本篇文章已授權微信公眾號 YYGeeker 獨家發布轉載請標明出處 CSDN學院課程地址 RxJava2從入門到精通-初級篇:edu.csdn.net/course/deta…RxJava2從入門到精通-中級篇:edu.csdn.net/course/deta…RxJava2從入門到精通-進階篇:edu.csdn.net/course/deta…RxJava2從入門到精通-源碼…
閱讀更多...
virtualbox 使用

virtualbox 使用

實現文件拖拽功能 1、設備 -- 安裝增強功能 -- /bin/sh VboxLinuxaddition.run -- reboot 2、設備 -- 拖放 -- 雙向 3、虛擬機 -- 設置 -- 存儲 -- 控制器&#xff1a;SATA -- 勾選 使用主機輸入輸出&#xff08;I\O 緩存&#xff09; 4、虛擬機硬盤 -- 勾選固態驅動器 轉載于…
閱讀更多...
linux安裝mysql 5.6.33

linux安裝mysql 5.6.33

.到MySQL官網下載mysql編譯好的二進制安裝包&#xff0c;在下載頁面Select Platform:選項選擇linux-generic&#xff0c;然后把頁面拉到底部&#xff0c;64位系統下載Linux - Generic (glibc 2.5) (x86, 64-bit)&#xff0c;下載后文件名&#xff1a;mysql-5.6.33-linux-glibc2…
閱讀更多...
Go 函數特性和網絡爬蟲示例

Go 函數特性和網絡爬蟲示例

爬取頁面 這篇通過網絡爬蟲的示例&#xff0c;來了解 Go 語言的遞歸、多返回值、延遲函數調用、匿名函數等方面的函數特性。首先是爬蟲的基礎示例&#xff0c;下面兩個例子展示通過 net/http 包來爬取頁面的內容。 獲取一個 URL 下面的程序展示從互聯網獲取信息&#xff0c;獲…
閱讀更多...
Qt的安裝和使用中的常見問題（詳細版）

Qt的安裝和使用中的常見問題（詳細版）

對于太長不看的朋友&#xff0c;可參考Qt的安裝和使用中的常見問題&#xff08;簡略版&#xff09;。 目錄 1、引入2、Qt簡介3、Qt版本 3.1 查看安裝的Qt版本3.2 查看當前項目使用的Qt版本3.3 查看當前項目使用的QtCreator版本3.4 Linux命令行下查看和使用不同版本的Qt4、Qt模塊…
閱讀更多...
python與C#的互相調用

python與C#的互相調用

python與C#的互相調用一、C#調用python新建一個項目&#xff0c;添加引用&#xff1a;IronPython.dll&#xff0c;Microsoft.Scripting.dll&#xff08;在IronPython的安裝目錄中&#xff09;。創建一個文本文件命名為hello.py,把該文件添加的當前的項目中,并設置為總是輸出。#…
閱讀更多...
各行業大數據可視化界面參考

各行業大數據可視化界面參考

轉載于:https://www.cnblogs.com/wangsongbai/p/10178096.html
閱讀更多...
mysql遠程連接 Host * is not allowed to connect to this MySQL server

mysql遠程連接 Host * is not allowed to connect to this MySQL server

localhost改成% 進入mysql的BIN目錄 代碼如下 復制代碼 mysql -u root -p mysql>use mysql; mysql>update user set host ’%where user ’root’; mysql>flush privileges; 具體分析 1、在本機登入mysql后&#xff0c;更改“mysql”數據庫里的“user”表里的“h…
閱讀更多...
今日聽聞這幾款手機軟件比較火爆 果然名不虛傳！

今日聽聞這幾款手機軟件比較火爆 果然名不虛傳！

如今的時代&#xff0c;智能手機已經成為我們生活中不可缺少的一部分&#xff0c;大家之所以這么愛玩手機&#xff0c;其實并不是手機本身有多么吸引人&#xff0c;而是安裝在手機上的各種各樣的APP&#xff0c;比如各種社交軟件、音頻軟件、購物軟件以及地圖軟件等等。下面我們…
閱讀更多...
setdefault()方法

setdefault()方法

setdefault()方法 描述 字典 setdefault() 方法和 get()方法類似,返回指定鍵的值&#xff0c;如果鍵不在字典中&#xff0c;將會添加鍵并將值設置為一個指定值&#xff0c;默認為None。 get() 和 setdefault() 區別&#xff1a; setdefault() 返回的鍵如果不在字典中&#xff0…
閱讀更多...
Hive2.1.1、Hadoop2.7.3 部署

Hive2.1.1、Hadoop2.7.3 部署

本文以遠程模式安裝Hive2.1.1將hive的元數據放置在MySQL數據庫中。 1 安裝mysql數據庫 sudo apt-get install mysql-server11 重啟mysql服務使得配置文件生效 sudo service mysql restart11 創建hive專用賬戶 CREATE USER hive% IDENTIFIED BY 123456;11 給hive賬戶授予所有權限…
閱讀更多...
Django 的簡單ajax

Django 的簡單ajax

需要通過ajax實現局部刷新 js代碼 $(#guo-sou-ajax).click(function(){ #獲取id為guo-sou-ajax點擊后的信號console.log($(this).attr("data-action")) $.ajax({ #調用ajaxurl: $(this).attr("data-action"), #url保存在標簽里面的data-actio…
閱讀更多...
postman提取返回值

postman提取返回值

Postman是做接口測試的&#xff0c;但是很多接口并不是直接就能測&#xff0c;有的需要一些預處理。比如說身份認證&#xff0c;需要傳遞一個token。如果做網頁測試&#xff0c;一般打開登陸界面的時候就會生成一個token&#xff0c;如果返回值是json格式&#xff0c;用Postman…
閱讀更多...
docker下用keepalived+Haproxy實現高可用負載均衡集群

docker下用keepalived+Haproxy實現高可用負載均衡集群

啟動keepalived后宿主機無法ping通用keepalived&#xff0c;報錯&#xff1a; [rootlocalhost ~]# ping 172.18.0.15 PING 172.18.0.15 (172.18.0.15) 56(84) bytes of data. From 172.18.0.1 icmp_seq1 Destination Host Unreachable From 172.18.0.1 icmp_seq2 Destination H…
閱讀更多...
hadoop hive 2.1.1 將Hive啟動為服務

hadoop hive 2.1.1 將Hive啟動為服務

我們之前使用的Shell方式與Hive交互只是Hive交互方式中的一種&#xff0c;還有一種就是將Hive啟動為服務&#xff0c;然后運行在一個節點上&#xff0c;那么剩下的節點就可以使用客戶端來連接它&#xff0c;從而也可以使用Hive的數據分析服務。 前臺模式 可以使用下面的命令來將…
閱讀更多...
大數據學習要知道的十大發展趨勢，以及學習大數據的幾點建議

大數據學習要知道的十大發展趨勢，以及學習大數據的幾點建議

2016年&#xff0c;近40%的公司正在實施和擴展大數據技術應用&#xff0c;另有30%的公司計劃在未來12個月內采用大數據技術&#xff0c;62.5%的公司現在至少有一個大數據項目投入生產&#xff0c;只有5.4%的公司沒有大數據應用計劃&#xff0c;或者是沒有正在進行的大數據項目&…
閱讀更多...
pickle 模塊

pickle 模塊

import pickle # class Elephant:def __init__(self, name, weight, height):self.name nameself.weight weightself.height heightdef tiaoxi(self):print(f"{self.name}大象特別喜歡調戲人")# e Elephant("寶寶", "185T", "175"…
閱讀更多...
Hiv:SQuirrel連接hive配置

Hiv:SQuirrel連接hive配置

熟悉了Sqlserver的sqlserver management studio、Oracle的PL/SQL可視化數據庫查詢分析工具&#xff0c;在剛開始使用hive、phoenix等類sql組件時&#xff0c;一直在苦苦搜尋是否也有類似的工具&#xff0c;不負所望&#xff0c;SQuirrel Sql client 可視化數據庫工具基本可滿足…
閱讀更多...
最新文章

Copyright @ 2022~2023