SpringBoot整合Mybatis多数据源
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文件
com.test.multidatasource.mapper2 包下创建 public interface UserMapperTwo{ List selectGoods(); }
对应的Mapper.xml文件: 2.4 pom.xml文件中添加 src/main/java **/*.xml src/main/resources 3.创建pojo,service层,controller层测试