关键词：
前言
MyBatis 多数据源配置，最近在项目建设中，需要在原有系统上扩展一个新的业务模块，特意将数据库分库，以便减少复杂度。本文直接以简单的代码示例，如何对 MyBatis 多数据源配置。
准备
创建数据库
db_test
SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;
-- ----------------------------
-- Table structure for t_user
-- ----------------------------
DROP TABLE IF EXISTS `t_user`;
CREATE TABLE `t_user` (
`id` int(8) NOT NULL AUTO_INCREMENT COMMENT 'ID',
`user_name` varchar(20) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '用户姓名',
`user_sex` char(1) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL COMMENT '用户性别',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=23 DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of t_user
-- ----------------------------
BEGIN;
INSERT INTO `t_user` VALUES (1, '刘备', '男');
INSERT INTO `t_user` VALUES (2, '孙尚香', '女');
INSERT INTO `t_user` VALUES (3, '周瑜', '男');
INSERT INTO `t_user` VALUES (4, '小乔', '女');
INSERT INTO `t_user` VALUES (5, '诸葛亮', '男');
INSERT INTO `t_user` VALUES (6, '黄月英', '女');
INSERT INTO `t_user` VALUES (7, '关羽', '男');
INSERT INTO `t_user` VALUES (8, '张飞', '男');
INSERT INTO `t_user` VALUES (9, '赵云', '男');
INSERT INTO `t_user` VALUES (10, '黄总', '男');
INSERT INTO `t_user` VALUES (11, '曹操', '男');
INSERT INTO `t_user` VALUES (12, '司马懿', '男');
INSERT INTO `t_user` VALUES (13, '貂蝉', '女');
INSERT INTO `t_user` VALUES (14, '吕布', '男');
INSERT INTO `t_user` VALUES (15, '马超', '男');
INSERT INTO `t_user` VALUES (16, '魏延', '男');
INSERT INTO `t_user` VALUES (17, '孟获', '男');
INSERT INTO `t_user` VALUES (18, '大乔', '女');
INSERT INTO `t_user` VALUES (19, '刘婵', '男');
INSERT INTO `t_user` VALUES (20, '姜维', '男');
INSERT INTO `t_user` VALUES (21, '廖化', '男');
INSERT INTO `t_user` VALUES (22, '关平', '男');
COMMIT;
SET FOREIGN_KEY_CHECKS = 1;dbb_test2
SET NAMES utf8mb4;
SET FOREIGN_KEY_CHECKS = 0;
-- ----------------------------
-- Table structure for t_hero
-- ----------------------------
DROP TABLE IF EXISTS `t_hero`;
CREATE TABLE `t_hero` (
`id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID',
`hero_code` varchar(32) DEFAULT NULL COMMENT '英雄编码',
`hero_name` varchar(20) DEFAULT NULL COMMENT '英雄名称',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of t_hero
-- ----------------------------
BEGIN;
INSERT INTO `t_hero` VALUES (1, '001', '德玛西亚');
COMMIT;
SET FOREIGN_KEY_CHECKS = 1;构建项目，项目目录结构
pom 文件
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.9.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>cn.zwqh</groupId>
<artifactId>spring-boot-mybatis-mulidatasource</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>spring-boot-mybatis-mulidatasource</name>
<description>spring-boot-mybatis-mulidatasource</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<!-- 热部署模块 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
<optional>true</optional> <!-- 这个需要为 true 热部署才有效 -->
</dependency>
<!-- mysql 数据库驱动. -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
</dependency>
<!-- mybaits -->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.1.0</version>
</dependency>
<!-- alibaba的druid数据库连接池 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.1.20</version>
</dependency>
<!-- pagehelper -->
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper-spring-boot-starter</artifactId>
<version>1.2.12</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
这里使用了alibaba的druid数据库连接池，Druid 能够提供强大的监控和扩展功能。这里我们暂时只做简单的应用。
配置文件
#master 数据源配置
master.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
master.datasource.url=jdbc:mysql://127.0.0.1:3306/db_test?useUnicode=true&characterEncoding=UTF-8&useSSL=true
master.datasource.username=root
master.datasource.password=zwqh@0258
#slave 数据源配置
slave.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
slave.datasource.url=jdbc:mysql://127.0.0.1:3306/db_test2?useUnicode=true&characterEncoding=UTF-8&useSSL=true
slave.datasource.username=root
slave.datasource.password=zwqh@0258
#mybatis
mybatis.mapper-locations=classpath:/mapper/**/*Mapper.xml
数据源配置
MasterDataSourceConfig 对应数据库 db_test
@Configuration
@MapperScan(basePackages = "cn.zwqh.springboot.dao.master", sqlSessionFactoryRef = "masterSqlSessionFactory")
public class MasterDataSourceConfig {
@Value("${master.datasource.driver-class-name}")
private String driverClassName;
@Value("${master.datasource.url}")
private String url;
@Value("${master.datasource.username}")
private String username;
@Value("${master.datasource.password}")
private String password;
@Bean(name = "masterDataSource")
@Primary
public DataSource dataSource() {
DruidDataSource dataSource = new DruidDataSource();
dataSource.setDriverClassName(this.driverClassName);
dataSource.setUrl(this.url);
dataSource.setUsername(this.username);
dataSource.setPassword(this.password);
return dataSource;
}
@Bean(name = "masterSqlSessionFactory")
@Primary
public SqlSessionFactory sqlSessionFactory(@Qualifier("masterDataSource") DataSource dataSource) throws Exception {
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(dataSource);
bean.setMapperLocations(
new PathMatchingResourcePatternResolver().getResources("classpath*:/mapper/master/*Mapper.xml"));
return bean.getObject();
}
@Bean(name = "masterTransactionManager")
@Primary
public DataSourceTransactionManager transactionManager(@Qualifier("masterDataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
@Bean(name = "masterSqlSessionTemplate")
@Primary
public SqlSessionTemplate testSqlSessionTemplate(
@Qualifier("masterSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
return new SqlSessionTemplate(sqlSessionFactory);
}
}SlaveDataSourceConfig 对应数据库 db_test2
@Configuration
@MapperScan(basePackages = "cn.zwqh.springboot.dao.slave", sqlSessionFactoryRef = "slaveSqlSessionFactory")
public class SlaveDataSourceConfig {
@Value("${slave.datasource.driver-class-name}")
private String driverClassName;
@Value("${slave.datasource.url}")
private String url;
@Value("${slave.datasource.username}")
private String username;
@Value("${slave.datasource.password}")
private String password;
@Bean(name = "slaveDataSource")
public DataSource dataSource() {
DruidDataSource dataSource = new DruidDataSource();
dataSource.setDriverClassName(this.driverClassName);
dataSource.setUrl(this.url);
dataSource.setUsername(this.username);
dataSource.setPassword(this.password);
return dataSource;
}
@Bean(name = "slaveSqlSessionFactory")
public SqlSessionFactory sqlSessionFactory(@Qualifier("slaveDataSource") DataSource dataSource) throws Exception {
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(dataSource);
bean.setMapperLocations(
new PathMatchingResourcePatternResolver().getResources("classpath*:/mapper/slave/*Mapper.xml"));
return bean.getObject();
}
@Bean(name = "slaveTransactionManager")
public DataSourceTransactionManager transactionManager(@Qualifier("slaveDataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
@Bean(name = "slaveSqlSessionTemplate")
public SqlSessionTemplate testSqlSessionTemplate(
@Qualifier("masterSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
return new SqlSessionTemplate(sqlSessionFactory);
}
}多个数据源在使用的过程中必须指定主库，不然会报错。
@MapperScan(basePackages = "cn.zwqh.springboot.dao.slave") 指定对应 Dao 层的扫描路径。
dao 层和 xml 层
db_test 数据库的 dao 层在 cn.zwqh.springboot.dao.master 包下，db_test2 数据库的 dao 层在 cn.zwqh.springboot.dao.slave 包下。
UserDao
public interface UserDao {
List<UserEntity> getAll();
}HeroDao
public interface HeroDao {
List<Hero> getAllHero();
}db_test 数据库的 xml 层在 /mapper/master/ 文件路径下，db_test2 数据库的 xml 层在 /mapper/slave/ 文件路径下。
UserMapper.xml
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.4//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.zwqh.springboot.dao.master.UserDao">
<resultMap type="cn.zwqh.springboot.model.UserEntity" id="user">
<id property="id" column="id"/>
<result property="userName" column="user_name"/>
<result property="userSex" column="user_sex"/>
</resultMap>
<!-- 获取所有用户 -->
<select id="getAll" resultMap="user">
select * from t_user
</select>
</mapper>HeroMapper.xml
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.4//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.zwqh.springboot.dao.slave.HeroDao">
<resultMap type="cn.zwqh.springboot.model.Hero" id="hero">
<id property="id" column="id"/>
<result property="heroCode" column="hero_code"/>
<result property="heroName" column="hero_name"/>
</resultMap>
<!-- 获取所有用户 -->
<select id="getAllHero" resultMap="hero">
select * from t_hero
</select>
</mapper>测试
测试可以使用 SpringBootTest,也可以放到 Controller中，个人习惯用 Controller。
@RestController
@RequestMapping("/test")
public class TestController {
@Autowired
private UserDao userDao;
@Autowired
private HeroDao heroDao;
/**
* 查找所有用户
* @return
*/
@RequestMapping("/getAllUser")
public List<UserEntity> getAllUser(){
return userDao.getAll();
}
/**
* 查找所有英雄
* @return
*/
@RequestMapping("/getAllHero")
public List<Hero> getAllHero(){
return heroDao.getAllHero();
}
}浏览器直接访问：http://127.0.0.1:8080/test/ 加上相关测试路径即可。
总结
多数据源一般用于主从模式或者按业务分库。
示例代码
非特殊说明，本文版权归 朝雾轻寒 所有，转载请注明出处.
原文标题：Spring Boot 2.X(五)：MyBatis 多数据源配置
原文地址：https://www.zwqh.top/article/info/12
springboot2.x基础教程：springboot整合mybatis附源码(代码片段)
微信号：hzy1014211086，如果你正在学习SpringBoot，可以加入我们的Spring技术交流群，共同成长文章目录一、准备数据表二、添加依赖三、配置数据源四、编写领域对象五、注解配置方式新增修改查询删除六、XML配置... 查看详情
springboot2.x系列教程48--多数据源配置之aop动态切换数据源
SpringBoot2.x系列教程48--多数据源配置之AOP动态切换数据源作者：一一哥在上一节中，我通过分包的方式实现了多数据源的配置，接下来我通过AOP切面的方式，带领大家实现第二种多数据源配置方式，该方式是在前面案例的基础上... 查看详情
springboot2.x系列教程48--多数据源配置之aop动态切换数据源
SpringBoot2.x系列教程48--多数据源配置之AOP动态切换数据源作者：一一哥在上一节中，我通过分包的方式实现了多数据源的配置，接下来我通过AOP切面的方式，带领大家实现第二种多数据源配置方式，该方式是在前面案例的基础上... 查看详情
springboot2.x：整合mybatis-plus
简介Mybatis-Plus是在Mybatis的基础上，国人开发的一款持久层框架。并且荣获了2018年度开源中国最受欢迎的中国软件TOP5同样以简化开发为宗旨的SpringBoot与Mybatis-Plus放在一起会产生什么样的化学反应呢？下面我们来领略一下两者配... 查看详情
springboot2.x+maven+mybatis+shiro+redis
...的一哥们的springboot1.X整合shiro和redis的demo，我用的是springboot2.X，改了下，添加了druid和swagger2,部分，公司屏蔽git，只能上传csdn备份。那位哥们的原文找不到了，sorry。部署resource/sql/shiro.sql&# 查看详情
springboot2.x：集成mybatis-plus高效开发
参考技术A本文将介绍mybats-plus的常用实例，简化常规的CRUD操作。MyBatis-Plus（简称MP）是一个MyBatis的增强工具，在MyBatis的基础上只做增强不做改变，为简化开发、提高效率而生。继承BaseMapper,T表示对应实体类在启动内添加@MapperSca... 查看详情
用idea基于springboot2+mybatis+redis实现一个秒杀系统
实现一个秒杀系统，采用springboot2.x+mybatis+redis+swagger2+lombok实现。先说说基本流程，就是提供一个秒杀接口，然后针对秒杀接口进行限流，限流的方式目前我实现了两种，上次实现的是累计计数方式，这次还有这个功能，并且我... 查看详情
springboot2.x+quartz定时任务模块(代码片段)
...目也可以将本模块直接移植进自己的项目中软件涉及技术SpringBoot2.x +MyBatis3+MyBatis3-Plus+MySQL8+Quartz(定时任务框架) +Swagger2（接口文档框架） 效果截图 项目整体结构： 项 查看详情
springboot2.x+minio文件服务器简单使用(代码片段)
...目也可以将本模块直接移植进自己的项目中软件涉及技术SpringBoot2.x+MyBatis3+MyBatis3-Plus+MySQL8+Minio(文件服务器)+Swagger2（接口文档框架）项目效果截图 Minio文件服务 查看详情
springboot2.x+mybatis-plus+mysql5.7动态拼接sql语句分页查询自定义sql查询条件分组排序
在使用srpingboot2.x+mybatis-plus框架是遇到特殊需求时研究mybatis-plus的条件构造器动态拼接sql查询，这个查询接口涉及到了自定义sql，动态拼接sql，分页，求和，分组，排序。可以直接看业务实现方法首先说一下接口的需求：入参JSON... 查看详情
springboot2.x+maven+mybatis+shiro+redis
...的一哥们的springboot1.X整合shiro和redis的demo，我用的是springboot2.X，改了下，添加了druid和swagger2,部分，公司屏蔽git，只能上传csdn备份。那位哥们的原文找不到了，sorry。部署resource/sql/shiro.sql；修改applicati... 查看详情
《深入浅出springboot2.x》pdf下载在线阅读全文，求百度网盘云资源
参考技术A《深入浅出SpringBoot2.x》百度网盘pdf最新全集下载:链接：https://pan.baidu.com/s/1RWXSkgD2z8hY7Yjxb08YBw?pwd=wmqm提取码：wmqm简介：Spring框架是JavaEE开发的强有力的工具和事实标准，而SpringBoot采用“约定优于配置”的原则简化了Sprin... 查看详情
springboot2.x基础教程：使用jdbctemplate访问mysql数据库
在第2章节中，我们介绍了如何通过SpringBoot来实现HTTP接口，以及围绕HTTP接口相关的单元测试、文档生成等实用技能。但是，这些内容还不足以帮助我们构建一个动态应用的服务端程序。不论我们是要做App、小程序、还是传统的We... 查看详情
《springboot免费教程》连载目录
...Star关注支持一下，随时获得更新信息！快速入门SpringBoot2.x基础教程：版本关系SpringBoot2.x基础教程：快速入门SpringBoot2.x基础教程：工程结构推荐配置详解SpringBoot2.x基础教程：配置文件详解SpringBoot2.x基础教... 查看详情
《springboot免费教程》连载目录
...Star关注支持一下，随时获得更新信息！快速入门SpringBoot2.x基础教程：版本关系SpringBoot2.x基础教程：快速入门SpringBoot2.x基础教程：工程结构推荐配置详解SpringBoot2.x基础教程：配置文件详解SpringBoot2.x基础教... 查看详情
springboot2.x版本整合redis(单机/集群)(使用lettuce)
在springboot1.x系列中，其中使用的是jedis,但是到了springboot2.x其中使用的是Lettuce。此处springboot2.x，所以使用的是Lettuce。关于jedis跟lettuce的区别：Lettuce和Jedis的定位都是Redis的client，所以他们当然可以直接连接redisserver。Jedis在实现... 查看详情
springboot2.x之h2数据库(代码片段)
1.SpringBoot下H2数据库的常用配置项#指定数据库的类型spring.datasource.platform=h2#数据库连接地址（文件模式）##AUTO_SERVER=TRUE，启动自动混合模式，允许开启多个连接，该参数不支持在内存中运行模式##DB_CLOSE_ON_EXIT=FALSE，当虚拟机退出... 查看详情
springboot2.x：springboot集成redis
Redis简介什么是RedisRedis是目前使用的非常广泛的免费开源内存数据库，是一个高性能的key-value数据库。Redis与其他key-value缓存（如Memcached）相比有以下三个特点:1.Redis支持数据的持久化，它可以将内存中的数据保存在磁盘中，重... 查看详情