最近更新：2020年7月21日

1.介绍

当系统不满足只是一个数据源的时候，还有一部门业务需要设计到其他的数据库的时候，去修改驱动，配置文件，重启系统会很麻烦，不易于部署实施，本文以Mysql和Oracle两种数据源不同切换介绍了基于@RefreshScope注解和Nacos配置的方式就可以达到不需要去修改代码，灵活切换不同数据源操作。

2.RefreshScope注解介绍

  1. 当有方法或者在类上添加@RefreshScope，Spring在初始化Bean的时候会使该Bean加载为惰性代理，使bean不一下加入到IOC容器当中，而是一个代理加入，在使用时（即，在调用方法时）才会进行初始化，并且作用域充当初始化值的缓存。要强制Bean在下一个方法调用上重新初始化，它有一个它有一个公共的方法 refreshAll()通过清除目标缓存刷新范围内的所有Bean。还有refresh(String)一种通过名称刷新单个bean 的方法。而Nacos本身会监听配置文件里面的内容，一旦配置文件被更改，那么就会刷新从配置文件里读取到的新内容，从而去刷新销毁上一个连接池，重新创建初始化连接池，达到动态切换数据源操作

    3.依赖管理

    以Mysql和Oracle两种数据源为示例切换，如有需要可另外添加，实现方式都是一样
    1. <!-- Mysql驱动-->
    2. <dependency>
    3.          <groupId>mysql</groupId>
    4.          <artifactId>mysql-connector-java</artifactId>
    5. </dependency>
    6. <!-- Oracle驱动-->
    7. <dependency>
    8.          <groupId>com.oracle</groupId>
    9.          <artifactId>ojdbc6</artifactId>
    10.          <version>11.2.0.4.0-atlassian-hosted</version>
    11. </dependency>

    3.1完整项目依赖

    ```xml 
    1.  <artifactId>spring-cloud-highzap-dependencies</artifactId>
    2.  <groupId>com.highzap.cloud</groupId>
    3.  <version>1.0.0-SNAPSHOT</version>
    4.  <relativePath/>
     com.alibaba.cloud spring-cloud-starter-alibaba-nacos-config org.springframework.boot spring-boot-starter-actuator mysql mysql-connector-java com.oracle ojdbc6 11.2.0.4.0-atlassian-hosted 
  1. <a name="x4EPP"></a>
  2. ## 4.配置文件
  3. 配置文件分为本地配置文件和Nacos配置中心配置文件，本文介绍的是从本地配置文件去读取Nacos配置中心远端读取动态配置文件来加载，实现动态切换
  4. <a name="5AF3F"></a>
  5. ### 4.1本地配置文件
  6. ```yaml
  7. spring:
  8.   application:
  9.     name: zap-orgmanagement-service
  10.   cloud:
  11.     nacos:
  12.       config:
  13.         server-addr: 127.0.0.1:8848
  14.         file-extension: yml
  15.   profiles:
  16.     active: wangl-test
  17. management:
  18.   endpoints:
  19.     web:
  20.       exposure:
  21.         include: refresh,health
  22.     enabled-by-default: true

4.2Nacos配置中心配置文件

本文使用的是读取Nacos配置文件中的连接字符串，配合@RefreshScope注解实现代码注入数据源，通过Nacos动态加载配置实现切换不同数据源

  1. server:
  2.     # 端口号
  3.   port: 8082
  4. spring:
  5.   application:
  6.       # 应用名称
  7.     name: zap-orgmanagement-service
  8.   cloud:
  9.     nacos:
  10.       discovery:
  11.         server-addr: 127.0.0.1:8848
  13. #配置自定义连接字符串
  15. # Oracle连接字符串
  16. # dbUrl: jdbc:oracle:thin:@demo.highzap.com:1521:zapsoft
  17. # username: zapsoftuser
  18. # password: zapsoftuser!123
  19. # driverClassName: oracle.jdbc.driver.OracleDriver
  21. # Mysql连接字符串
  22. dbUrl: jdbc:mysql://127.0.0.1:3306/org?serverTimezone=GMT%2B8&useSSL=false&useUnicode=true&characterEncoding=utf-8&allowPublicKeyRetrieval=true
  23. username: root
  24. password: root
  25. driverClassName: com.mysql.cj.jdbc.Driver
  27. # mybatis-plus配置
  28. mybatis-plus:
  29.   mapper-locations: classpath:mapper/*Mapper.xml
  30.   configuration:
  31.     # 控制台打印SQL语句
  32.     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
  33.   global-config:
  34.     db-config:
  35.       #数据库ID自增"
  36.       id-type: none
  37.       #数据库大写下划线转换
  38.       capital-mode: false
  39.       #驼峰下划线转换
  40.       table-underline: true
  41.       #字段策略 :"忽略判断","非 NULL 判断"),"非空判断"
  42.       field-strategy: ignored

5.配置连接池

读取Nacos配置中心配置文件自定义连接字符串，注入数据源，再配置@RefreshScope注解实现不同数据源切换

  1. package com.highzap.adminweb.configuration;
  3. import com.zaxxer.hikari.HikariDataSource;
  4. import org.mybatis.spring.annotation.MapperScan;
  5. import org.springframework.beans.factory.annotation.Value;
  6. import org.springframework.cloud.context.config.annotation.RefreshScope;
  7. import org.springframework.context.annotation.Bean;
  8. import org.springframework.context.annotation.Configuration;
  10. import javax.sql.DataSource;
  12. /**
  13.  * <p>描述: 类型描述 </p>
  14.  * <p>创建时间: 2020/7/21 </p>
  15.  *
  16.  * @author <a href="mailto:wangl@highzap.com" rel="nofollow">王浪</a>
  17.  * @version v1.0
  18.  */
  19. @Configuration
  20. @RefreshScope
  21. @MapperScan(basePackages = "com.highzap.adminweb.mapper",sqlSessionFactoryRef ="sqlSessionFactory",sqlSessionTemplateRef = "sqlSessionTemplate")
  22. public class DataSourceConfig {
  24.     // 对应Nacos配置中心配置的dbUrl
  25.     @Value("${dbUrl}")
  26.     private String dbUrl;
  28.     // 对应Nacos配置中心配置的username
  29.     @Value("${username}")
  30.     private String username;
  32.     // 对应Nacos配置中心配置的password
  33.     @Value("${password}")
  34.     private String password;
  36.     // 对应Nacos配置中心配置的driverClassName
  37.     @Value("${driverClassName}")
  38.     private String driverClassName;
  41.     @Bean(value = "dataSource")
  42.     // RefreshScope动态刷新bean
  43.     @RefreshScope
  44.     public DataSource dataSource(){
  45.         HikariDataSource dataSource = new HikariDataSource();
  46.         dataSource.setUsername(username);
  47.         dataSource.setPassword(password);
  48.         dataSource.setJdbcUrl(dbUrl);
  49.         dataSource.setDriverClassName(driverClassName);
  50.         return dataSource;
  51.     }
  52. }