SpringBoot入門建站全系列（三十）Mybatis多數(shù)據(jù)源進(jìn)行數(shù)據(jù)庫(kù)操作

一、概述

多數(shù)據(jù)源，就是有多個(gè)數(shù)據(jù)庫(kù)的配置。

多數(shù)據(jù)源配置并不麻煩，使用起來(lái)和單數(shù)據(jù)源基本相同，但是，重要的是事務(wù)的控制。

這就牽扯到分布式事務(wù)控制，本篇只是講述多數(shù)據(jù)源的使用，下一篇再講述如何使用分布式事務(wù)控制中間件。

首發(fā)地址： 品茗IT-首發(fā)

如果大家正在尋找一個(gè)java的學(xué)習(xí)環(huán)境，或者在開發(fā)中遇到困難，可以加入我們的java學(xué)習(xí)圈，點(diǎn)擊即可加入，共同學(xué)習(xí)，節(jié)約學(xué)習(xí)時(shí)間，減少很多在學(xué)習(xí)中遇到的難題。

二、配置

本文假設(shè)你已經(jīng)引入spring-boot-starter-web。已經(jīng)是個(gè)SpringBoot項(xiàng)目了,如果不會(huì)搭建，可以打開這篇文章看一看《SpringBoot入門建站全系列（一）項(xiàng)目建立》。

2.1 Maven依賴

引入mybatis、數(shù)據(jù)庫(kù)連接池、mysql-connector.

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId> </dependency> <dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId> </dependency> <dependency><groupId>org.apache.commons</groupId><artifactId>commons-dbcp2</artifactId> </dependency>

2.2 配置文件

在application.properties 中需要配置數(shù)據(jù)庫(kù)相關(guān)信息的信息，如：

spring.datasource.master.type=org.apache.commons.dbcp2.BasicDataSource spring.datasource.master.max-wait-millis=60000 spring.datasource.master.min-idle=20 spring.datasource.master.initial-size=2 spring.datasource.master.validation-query=SELECT 1 spring.datasource.master.connection-properties=characterEncoding=utf8 spring.datasource.master.validation-query=SELECT 1 spring.datasource.master.test-while-idle=true spring.datasource.master.test-on-borrow=true spring.datasource.master.test-on-return=falsespring.datasource.master.driverClassName = com.mysql.jdbc.Driver spring.datasource.master.url=jdbc:mysql://127.0.0.1:3306/boot?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC spring.datasource.master.username=cff spring.datasource.master.password=123456spring.datasource.slave.type=org.apache.commons.dbcp2.BasicDataSource spring.datasource.slave.max-wait-millis=60000 spring.datasource.slave.min-idle=20 spring.datasource.slave.initial-size=2 spring.datasource.slave.validation-query=SELECT 1 spring.datasource.slave.connection-properties=characterEncoding=utf8 spring.datasource.slave.validation-query=SELECT 1 spring.datasource.slave.test-while-idle=true spring.datasource.slave.test-on-borrow=true spring.datasource.slave.test-on-return=falsespring.datasource.slave.driverClassName = com.mysql.jdbc.Driver spring.datasource.slave.url=jdbc:mysql://127.0.0.1:3306/boot?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC spring.datasource.slave.username=cff spring.datasource.slave.password=123456mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl

注意，這里的配置：

• 雖然是spring.datasource開頭，但是已經(jīng)不是需要Spring自動(dòng)裝配的配置了；
• spring.datasource.master開頭的配置，是需要我手動(dòng)配置master數(shù)據(jù)源的配置；
• spring.datasource.slave開頭的配置，是需要我手動(dòng)配置slave數(shù)據(jù)源的配置；
• master和slave只是個(gè)名字而已，根據(jù)自己需要修改任何名稱都行；
• mybatis.configuration.log-impl是mybatis自動(dòng)裝配的配置。

三、配置數(shù)據(jù)源

配置多個(gè)數(shù)據(jù)源，需要DataSource、TransactionManager、SqlSessionFactory

3.1 Master數(shù)據(jù)源

配置Master數(shù)據(jù)源，需要Master自己的DataSource、TransactionManager、SqlSessionFactory。

同時(shí)，指定MapperScan掃描的包路徑，和對(duì)應(yīng)的sqlSessionFactory。

package com.cff.springbootwork.atomikos.config;import org.apache.commons.dbcp2.BasicDataSource; import org.apache.ibatis.session.SqlSessionFactory; import org.mybatis.spring.SqlSessionFactoryBean; import org.mybatis.spring.annotation.MapperScan; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Primary; import org.springframework.jdbc.datasource.DataSourceTransactionManager;@Configuration @MapperScan(basePackages = MasterDataSourceConfiguration.PACKAGE, sqlSessionFactoryRef = "masterSqlSessionFactory") public class MasterDataSourceConfiguration {static final String PACKAGE = "com.cff.springbootwork.atomikos.dao.master";@Bean(name = "masterDataSource")@ConfigurationProperties(prefix = "spring.datasource.master")@Primarypublic BasicDataSource masterDataSource() {BasicDataSource dataSource = new BasicDataSource();return dataSource;}@Bean(name = "masterTransactionManager")@Primarypublic DataSourceTransactionManager masterTransactionManager() {return new DataSourceTransactionManager(masterDataSource());}@Bean(name = "masterSqlSessionFactory")@Primarypublic SqlSessionFactory masterSqlSessionFactory() throws Exception {final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();sessionFactory.setDataSource(masterDataSource());return sessionFactory.getObject();} }

這里面，

• 新建了一個(gè)BasicDataSource，bean名稱加個(gè)master以做區(qū)分，BasicDataSource的屬性通過@ConfigurationProperties(prefix = "spring.datasource.master")注入，同時(shí)，加上@Primary標(biāo)明它是首選。
• @Primary注解只能加在某一個(gè)數(shù)據(jù)源上，不能所有數(shù)據(jù)源配置都加，不然會(huì)報(bào)錯(cuò)。
• 新建了一個(gè)masterTransactionManager，處理masterDataSource的事務(wù)。
• 新建了masterSqlSessionFactory，處理masterDataSource的SqlSession。

3.2 Slave數(shù)據(jù)源

配置Slave數(shù)據(jù)源，需要Slave自己的DataSource、TransactionManager、SqlSessionFactory。

同時(shí)，指定MapperScan掃描的包路徑，和對(duì)應(yīng)的sqlSessionFactory。

package com.cff.springbootwork.atomikos.config;import org.apache.commons.dbcp2.BasicDataSource; import org.apache.ibatis.session.SqlSessionFactory; import org.mybatis.spring.SqlSessionFactoryBean; import org.mybatis.spring.annotation.MapperScan; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.jdbc.datasource.DataSourceTransactionManager;@Configuration @MapperScan(basePackages = SlaveDataSourceConfiguration.PACKAGE, sqlSessionFactoryRef = "slaveSqlSessionFactory") public class SlaveDataSourceConfiguration {static final String PACKAGE = "com.cff.springbootwork.atomikos.dao.slave";@Bean(name = "slaveDataSource")@ConfigurationProperties(prefix = "spring.datasource.slave")public BasicDataSource slaveDataSource() {BasicDataSource dataSource = new BasicDataSource();return dataSource;}@Bean(name = "slaveTransactionManager")public DataSourceTransactionManager slaveTransactionManager() {return new DataSourceTransactionManager(slaveDataSource());}@Bean(name = "slaveSqlSessionFactory")public SqlSessionFactory slaveSqlSessionFactory() throws Exception {final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();sessionFactory.setDataSource(slaveDataSource());return sessionFactory.getObject();} }

這里面，

• 新建了一個(gè)BasicDataSource，bean名稱加個(gè)slave以做區(qū)分，BasicDataSource的屬性通過@ConfigurationProperties(prefix = "spring.datasource.slave")注入，注意，這個(gè)地方不能加上@Primary注解。
• 新建了一個(gè)slaveTransactionManager，處理slaveDataSource的事務(wù)。
• 新建了slaveSqlSessionFactory，處理slaveDataSource的SqlSession。

四、測(cè)試Mapper

Mapper的寫法無(wú)任何改變，只不過，要注意不同mapper放在上面不同數(shù)據(jù)源指定的包路徑下。

4.1 Master數(shù)據(jù)源的Mapper

新建一個(gè)UserInfoMasterDao，處理master數(shù)據(jù)源的用戶表。

UserInfoMasterDao：

package com.cff.springbootwork.atomikos.dao.master;import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Select; import org.apache.ibatis.annotations.Update;import com.cff.springbootwork.atomikos.domain.UserInfo;@Mapper public interface UserInfoMasterDao {@Select({"<script>","SELECT ","user_name as userName,passwd,name,mobile,valid, user_type as userType","FROM user_info","WHERE user_name = #{userName,jdbcType=VARCHAR}","</script>"})UserInfo findByUserName(@Param("userName") String userName);@Update({"<script>"," update user_info set"," name = #{name, jdbcType=VARCHAR}, mobile = #{mobile, jdbcType=VARCHAR}"," where user_name=#{userName}","</script>"})int update(UserInfo userInfo); }

4.2 Slave數(shù)據(jù)源的Mapper

新建一個(gè)UserInfoSlaveDao，處理Slave數(shù)據(jù)源的用戶表。

UserInfoSlaveDao：

package com.cff.springbootwork.atomikos.dao.slave;import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Select; import org.apache.ibatis.annotations.Update;import com.cff.springbootwork.atomikos.domain.UserInfo;@Mapper public interface UserInfoSlaveDao {@Select({"<script>","SELECT ","user_name as userName,passwd,name,mobile,valid, user_type as userType","FROM user_info","WHERE user_name = #{userName,jdbcType=VARCHAR}","</script>"})UserInfo findByUserName(@Param("userName") String userName);@Update({"<script>"," update user_info set"," name = #{name, jdbcType=VARCHAR}, mobile = #{mobile, jdbcType=VARCHAR}"," where user_name=#{userName}","</script>"})int update(UserInfo userInfo); }

五、測(cè)試Service

寫一個(gè)普通的UserInfoService，注入兩個(gè)mapper即可使用。

UserInfoService:

package com.cff.springbootwork.atomikos.service;import java.util.ArrayList; import java.util.List;import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional;import com.cff.springbootwork.atomikos.dao.master.UserInfoMasterDao; import com.cff.springbootwork.atomikos.dao.slave.UserInfoSlaveDao; import com.cff.springbootwork.atomikos.domain.UserInfo;@Service public class UserInfoService {@AutowiredUserInfoMasterDao userInfoMasterDao;@AutowiredUserInfoSlaveDao userInfoSlaveDao;public List<UserInfo> getUserInfoByUserName(String userName) {UserInfo userInfoMaster = userInfoMasterDao.findByUserName(userName);UserInfo userInfoSlave = userInfoSlaveDao.findByUserName(userName);List<UserInfo> list = new ArrayList<>();list.add(userInfoMaster);list.add(userInfoSlave);return list;}@Transactional(rollbackFor = Exception.class)public List<UserInfo> update(UserInfo userInfo) {userInfoMasterDao.update(userInfo);userInfoSlaveDao.update(userInfo);int i = 1 / 0;return getUserInfoByUserName(userInfo.getUserName());} }

注意，我這里的update方法中，寫了一個(gè)int i = 1 / 0;,是為了測(cè)試無(wú)分布式事務(wù)支持的時(shí)候事務(wù)是如何處理的。

六、測(cè)試Web

package com.cff.springbootwork.atomikos.web;import java.util.List;import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RestController;import com.cff.springbootwork.atomikos.domain.UserInfo; import com.cff.springbootwork.atomikos.service.UserInfoService;@RestController @RequestMapping("/mybatis") public class MybatisRest {@AutowiredUserInfoService userInfoService;@RequestMapping(value = "/mybatis/{name}", method = { RequestMethod.GET })public List<UserInfo> testMybatis(@PathVariable("name") String name) {return userInfoService.getUserInfoByUserName(name);}@RequestMapping(value = "/update")public List<UserInfo> update(@RequestBody UserInfo userInfo) {return userInfoService.update(userInfo);} }

七、實(shí)體

UserInfo:

完整實(shí)體，請(qǐng)?jiān)L問《SpringBoot入門建站全系列（三十）Mybatis多數(shù)據(jù)源進(jìn)行數(shù)據(jù)庫(kù)操作》查看。

七、結(jié)論

• 多數(shù)據(jù)源的使用和普通使用方法完全一樣，只不過要多配置一下。
• 多數(shù)據(jù)源的事務(wù)無(wú)法正常回滾，需要分布式事務(wù)控制。
• 多數(shù)據(jù)源的事務(wù)，會(huì)回滾第一個(gè)，第二個(gè)回滾不了。

品茗IT-博客專題:https://www.pomit.cn/lecture.html匯總了Spring專題、Springboot專題、SpringCloud專題、web基礎(chǔ)配置專題。

快速構(gòu)建項(xiàng)目

Spring項(xiàng)目快速開發(fā)工具：

一鍵快速構(gòu)建Spring項(xiàng)目工具

一鍵快速構(gòu)建SpringBoot項(xiàng)目工具

一鍵快速構(gòu)建SpringCloud項(xiàng)目工具

一站式Springboot項(xiàng)目生成

Mysql一鍵生成Mybatis注解Mapper

Spring組件化構(gòu)建

SpringBoot組件化構(gòu)建

SpringCloud服務(wù)化構(gòu)建

喜歡這篇文章么，喜歡就加入我們一起討論SpringBoot使用吧！

總結(jié)

以上是生活随笔為你收集整理的spring boot 入门_SpringBoot入门建站全系列（三十）Mybatis多数据源进行数据库操作的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。