spring:
 datasource:
  type: com.alibaba.druid.pool.DruidDataSource
  druid:
   # 主庫數(shù)據(jù)源
   master:
    url: jdbc:mysql://localhost:3308/<數(shù)據(jù)庫名>?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
    username: root
    password: 123456
   # 從庫數(shù)據(jù)源
   slave:
    # 從數(shù)據(jù)源開關(guān)/默認關(guān)閉
    enabled: true
    url: jdbc:mysql://localhost:3308/<數(shù)據(jù)庫名>?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
    username: root
    password: 123456
   # 初始連接數(shù)
   initialSize: 5
   # 最小連接池數(shù)量
   minIdle: 10
   # 最大連接池數(shù)量
   maxActive: 20
   # 配置獲取連接等待超時的時間
   maxWait: 60000
   # 配置間隔多久才進行一次檢測，檢測需要關(guān)閉的空閑連接，單位是毫秒
   timeBetweenEvictionRunsMillis: 60000
   # 配置一個連接在池中最小生存的時間，單位是毫秒
   minEvictableIdleTimeMillis: 300000
   # 配置一個連接在池中最大生存的時間，單位是毫秒
   maxEvictableIdleTimeMillis: 900000
   # 配置檢測連接是否有效
   validationQuery: SELECT 1 FROM DUAL
   testWhileIdle: true
   testOnBorrow: false
   testOnReturn: false
   webStatFilter: 
    enabled: true
   statViewServlet:
    enabled: true
    # 設(shè)置白名單，不填則允許所有訪問
    allow:
    url-pattern: /druid/*
    # 控制臺管理用戶名和密碼
    login-username: 
    login-password: 
   filter:
    stat:
     enabled: true
     # 慢SQL記錄
     log-slow-sql: true
     slow-sql-millis: 1000
     merge-sql: true
    wall:
     config:
      multi-statement-allow: true

second:
 spring:
  datasource:
   type: com.alibaba.druid.pool.DruidDataSource
   driver-class-name: com.ibm.db2.jcc.DB2Driver
   url: jdbc:db2://<DB2的IP>:<端口>/<數(shù)據(jù)庫名>:currentSchema=<所要連接的schema名>;
   username: <用戶名>
   password: <密碼>
   # 初始連接數(shù)
   initialSize: 5
   # 最小連接池數(shù)量
   minIdle: 10
   # 最大連接池數(shù)量
   maxActive: 20
   # 配置獲取連接等待超時的時間
   maxWait: 60000
   # 配置間隔多久才進行一次檢測，檢測需要關(guān)閉的空閑連接，單位是毫秒
   timeBetweenEvictionRunsMillis: 60000
   # 配置一個連接在池中最小生存的時間，單位是毫秒
   minEvictableIdleTimeMillis: 300000
   # 配置一個連接在池中最大生存的時間，單位是毫秒
   maxEvictableIdleTimeMillis: 900000
   # 配置檢測連接是否有效  注意這里DUAL是檢測的表名，可以是當前schema下的任意一張表
   validationQuery: SELECT 1 FROM **<檢測表名>**
   testWhileIdle: true
   testOnBorrow: false
   testOnReturn: false
   webStatFilter:
    enabled: true
   statViewServlet:
    enabled: true
    # 設(shè)置白名單，不填則允許所有訪問
    allow:
    url-pattern: /druid/*
    # 控制臺管理用戶名和密碼
    login-username:
    login-password:
   filter:
    stat:
     enabled: true
     # 慢SQL記錄
     log-slow-sql: true
     slow-sql-millis: 1000
     merge-sql: true
    wall:
     config:
      multi-statement-allow: true

package com.map.framework.config;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.sql.DataSource;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
import com.alibaba.druid.spring.boot.autoconfigure.properties.DruidStatProperties;
import com.alibaba.druid.util.Utils;
import com.map.common.enums.DataSourceType;
import com.map.common.utils.spring.SpringUtils;
import com.map.framework.config.properties.DruidProperties;
import com.map.framework.datasource.DynamicDataSource;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;

/**
 * druid 配置多數(shù)據(jù)源
 * 
 *
 */
@Configuration
public class DruidConfig
{

 @Bean
 @ConfigurationProperties("spring.datasource.druid.master")
 public DataSource masterDataSource(DruidProperties druidProperties)
 {
  DruidDataSource dataSource = DruidDataSourceBuilder.create().build();
  return druidProperties.dataSource(dataSource);
 }

 @Bean
 @ConfigurationProperties("spring.datasource.druid.slave")
 @ConditionalOnProperty(prefix = "spring.datasource.druid.slave", name = "enabled", havingValue = "true")
 public DataSource slaveDataSource(DruidProperties druidProperties)
 {
  DruidDataSource dataSource = DruidDataSourceBuilder.create().build();
  return druidProperties.dataSource(dataSource);
 }

 @Bean
 @ConfigurationProperties("second.spring.datasource")
 public DataSource db2DataSource(DruidProperties druidProperties)
 {
  DruidDataSource dataSource = DruidDataSourceBuilder.create().build();
  return druidProperties.dataSource(dataSource);
 }

 @Bean(name = "dynamicDataSource")
 @Primary
 public DynamicDataSource dataSource(DataSource masterDataSource)
 {
  Map<Object, Object> targetDataSources = new HashMap<>();
  targetDataSources.put(DataSourceType.MASTER.name(), masterDataSource);
  setDataSource(targetDataSources, DataSourceType.SLAVE.name(), "slaveDataSource");
  setDataSource(targetDataSources, DataSourceType.DB2.name(), "db2DataSource");
  return new DynamicDataSource(masterDataSource, targetDataSources);
 }

 /**
  * 設(shè)置數(shù)據(jù)源
  * 
  * @param targetDataSources 備選數(shù)據(jù)源集合
  * @param sourceName 數(shù)據(jù)源名稱
  * @param beanName bean名稱
  */
 public void setDataSource(Map<Object, Object> targetDataSources, String sourceName, String beanName)
 {
  try
  {
   DataSource dataSource = SpringUtils.getBean(beanName);
   targetDataSources.put(sourceName, dataSource);
  }
  catch (Exception e)
  {
  }
 }
}