Mybatis中如何配置多数据源

一 什么情况下会用到多数据库？

场景1：

一个商城网站，一个游戏网站，商城网站已经做好，游戏网站正在开发，游戏网站上的很多道具需要用到商城网站的产品数据，这种情况最好是用两个数据库，商城网站更多的是设计直接交易，涉及金钱方面较多，需要较安全的数据库和网络环境，而游戏网站一般人流量比较大，若和商城放一起占用的数据库、网络、带宽资源较大，而且更容易被攻击，这样很容易影响商城 的正常使用。而把他们独立开虽然可能成本稍高，但是能够保证其中一个网站或数据库挂掉不会影响另一个，大大降低安全风险。

场景2：

随着时间和业务的发展，数据库中的数据量增长是不可控的，库和表中的数据会越来越大，随之带来的是更高的磁盘、IO、系统开销，甚至性能上的瓶颈，而一台服务的资源终究是有限的，因此需要对数据库和表进行拆分，从而更好的提供数据服务。
MySQL单库数据量在5000万以内性能比较好,超过阈值后性能会随着数据量的增大而变弱。MySQL单表的数据量是500w-1000w之间性能比较好,超过1000w性能也会下降。mysql的分库分表是在数据量大后的一个常用数据库优化方法。

二 多数据库需求解决方案

对于海量数据来说，比如 100 亿条频繁查询的记录需要在 3 秒内查询出来结果，除了基于主键的查询，还可能存在范围查询或其他属性查询，首选分布式数据库中间件 MyCat 去解决分库分表的问题。

但对于一些简单的需求，比如数据库量不大，只是用到不同的数据库，可以配置多数据源来解决。 配置多数据源有两种方法：分包和AOP。

本章给大家讲解的是分包方式，Aop方式和MyCat会在后续章节再讲解。

三 Mybatis中配置多数据源

1.新建工程

添加Mybatis，Mysql驱动，lombok依赖

2.配置多数据源

之前整合Mybatis时，我们配置了一个数据源DataSource，配置多个数据源，其实就是配置多个DataSource。

首页准备两个数据库boot1,boot2

2.1 application.properties中添加数据源

#数据源1
spring.datasource.one.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.one.username=root
spring.datasource.one.password=root
spring.datasource.one.jdbc-url=jdbc:mysql://localhost:3306/boot1?characterEncoding=utf8&serverTimezone=GMT%2B8

#需要注意的是，springboot2.0以上配置双数据源，配置文件中不能写url，而是要改成jdbc-url，否则会出错。

#数据源2
spring.datasource.two.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.two.username=root
spring.datasource.two.password=root
spring.datasource.two.jdbc-url=jdbc:mysql://localhost:3306/boot2?characterEncoding=utf8&serverTimezone=GMT%2B8

这里通过 one 和 two 对数据源进行了区分，但是加了 one 和 two 之后，这里的配置就没法被 SpringBoot 自动加载了（因为前面的 key 变了），需要我们自己去加载 DataSource 了，此时，需要自己配置一个 DataSourceConfig，用来提供两个 DataSource Bean，如下：

2.2 创建DataSourceConfig文件

@Configuration
public class DataSourceConfig {
@Bean
@ConfigurationProperties(prefix = "spring.datasource.one")
DataSource dsOne() {
return DataSourceBuilder.create().build();
}
@Bean
@ConfigurationProperties(prefix = "spring.datasource.two")
DataSource dsTwo() {
return DataSourceBuilder.create().build();
}
}

这里提供了两个 Bean，其中 @ConfigurationProperties 是 Spring Boot 提供的类型安全的属性绑定，以第一个Bean为例， @ConfigurationProperties(prefix = "spring.datasource.one") 表示使用 spring.datasource.one 前缀的数据库配置去创建一个 DataSource，这样配置之后，我们就有了两个不同的 DataSource，接下来再用这两个不同的 DataSource 去创建两个不同的 SqlSessionFactory 。

2.3 创建两个Mybatis配置文件类

Mybatis配置文件类1：

@Configuration
@MapperScan(basePackages = "com.test.multidatasource.mapper1",sqlSessionTemplateRef = "sqlSessionTemplate1")
public class MyBatisConfigOne {
@Resource(name = "dsOne")
DataSource dsOne;
@Bean
SqlSessionFactory sqlSessionFactory1() {
SqlSessionFactory sessionFactory = null;
try {
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(dsOne);
bean.setTypeAliasesPackage("com.test.multidatasource.pojo");
sessionFactory = bean.getObject();
} catch (Exception e) {
e.printStackTrace();
}
return sessionFactory;
}
@Bean
SqlSessionTemplate sqlSessionTemplate1() {
return new SqlSessionTemplate(sqlSessionFactory1());
}
}

创建 MyBatisConfigOne 类，首先指明该类是一个配置类，配置类中要扫描的包是 com.test.ssm.mapper1 ，即该包下的 Mapper 接口将操作 dsOne 中的数据，对应的 SqlSessionFactory 和 SqlSessionTemplate 分别是 sqlSessionFactory1 和 sqlSessionTemplate1，在 MyBatisConfigOne 内部，分别提供 SqlSessionFactory 和 SqlSessionTemplate 即可， SqlSessionFactory 根据 dsOne 创建，然后再根据创建好的SqlSessionFactory 创建一个 SqlSessionTemplate。

Mybatis配置文件类2：

@Configuration
@MapperScan(basePackages = "com.test.multidatasource.mapper2",sqlSessionTemplateRef = "sqlSessionTemplate2")
public class MyBatisConfigTwo {
@Resource(name = "dsTwo")
DataSource dsTwo;
@Bean
SqlSessionFactory sqlSessionFactory2() {
SqlSessionFactory sessionFactory = null;
try {
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(dsTwo);
bean.setTypeAliasesPackage("com.test.multidatasource.pojo");
sessionFactory = bean.getObject();
} catch (Exception e) {
e.printStackTrace();
}
return sessionFactory;
}
@Bean
SqlSessionTemplate sqlSessionTemplate2() {
return new SqlSessionTemplate(sqlSessionFactory2());
}
}

这样 MyBatis 多数据源基本上就配置好了，接下来只需要在 com.test.multidatasource.mapper1 和 com.test.multidatasource.mapper2  包中提供不同的 Mapper，Service 中注入不同的 Mapper 就可以操作不同的数据源。

3.创建Mapper层

com.test.multidatasource.mapper1 包下创建

public interface UserMapperOne {
List selectUsers();
}

对应的Mapper.xml文件

    select * from users;

com.test.multidatasource.mapper2 包下创建

public interface UserMapperTwo{
List selectGoods();
}

对应的Mapper.xml文件:

    select * from goods;

2.4 pom.xml文件中添加

    
        src/main/java
        
            **/*.xml
        
    
    
        src/main/resources
    

3.创建pojo，service层，controller层测试