本文相关库说明：
vue（若依自带库）
db_game多数据源从库1
db_paystore 多数据源从库2
多数据源的情况下，想生成其他从库下数据库表对应的代码，但是若依自带的导入表中 是不会查询到从库各数据表信息的(只查询到若依框架对应的数据库各表信息)：
一、生成代码的controller中 切换数据源(配置多数据源)
参考若依文档 配置多数据源及多数据源的切换使用：http://doc.ruoyi.vip/ruoyi/document/htsc.html#%E5%A4%9A%E6%95%B0%E6%8D%AE%E6%BA%90%E4%BD%BF%E7%94%A8
1.配置多数据源
application-druid.yml 数据源新增从库 并开启（注意数据源名称全小写）
# 数据源配置
spring:
datasource:
type: com.alibaba.druid.pool.DruidDataSource
driverClassName: com.mysql.cj.jdbc.Driver
druid:
# 主库数据源
master:
url: jdbc:mysql://localhost:3306/vue?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
username: root
password: 123456
# 从库数据源 对应库名 db_game 注意 yml文件中：数据库配置不要使用驼峰命名或者下划线：slaveDbaGame、slave_db_game；下面数据库配置 全使用小写,如： slavedbagame
slavedbgame:
# 从数据源开关/默认关闭
enabled: true
url: jdbc:mysql://localhost:3306/db_game?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
username: root
password: 123456
# 从库数据源 充值库
slavedbpaystore:
# 从数据源开关/默认关闭
enabled: true
url: jdbc:mysql://localhost:3306/db_paystore?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
username: root
password: 123456
# 初始连接数
initialSize: 5
# 最小连接池数量
minIdle: 10
# 最大连接池数量
maxActive: 20
# 配置获取连接等待超时的时间
maxWait: 60000
# 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
timeBetweenEvictionRunsMillis: 60000
# 配置一个连接在池中最小生存的时间，单位是毫秒
minEvictableIdleTimeMillis: 300000
# 配置一个连接在池中最大生存的时间，单位是毫秒
maxEvictableIdleTimeMillis: 900000
# 配置检测连接是否有效
validationQuery: SELECT 1 FROM DUAL
testWhileIdle: true
testOnBorrow: false
testOnReturn: false
webStatFilter:
enabled: true
statViewServlet:
enabled: true
# 设置白名单，不填则允许所有访问
allow:
url-pattern: /druid/*
# 控制台管理用户名和密码
login-username: ruoyi
login-password: 123456
filter:
stat:
enabled: true
# 慢SQL记录
log-slow-sql: true
slow-sql-millis: 1000
merge-sql: true
wall:
config:
multi-statement-allow: trueDataSourceType.java 数据源枚举中，配置了从库
package com.ruoyi.common.enums;
/**
* 数据源
*
* @author ruoyi
*/
public enum DataSourceType
{
/**
* 主库
*/
MASTER,
/**
* 从库 对应库名 db_game
*/
SLAVE_DB_GAME,
/**
* 从库 充值库 db_paystore
*/
SLAVE_DB_PAYSTORE
}
DruidConfig.java 配置了从库
package com.ruoyi.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.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.ruoyi.common.enums.DataSourceType;
import com.ruoyi.common.utils.spring.SpringUtils;
import com.ruoyi.framework.config.properties.DruidProperties;
import com.ruoyi.framework.datasource.DynamicDataSource;
/**
* druid 配置多数据源
*
* @author ruoyi
*/
@Configuration
public class DruidConfig
{
/**
* 主数据源
* @param druidProperties
* @return
*/
@Bean
@ConfigurationProperties("spring.datasource.druid.master")
public DataSource masterDataSource(DruidProperties druidProperties)
{
DruidDataSource dataSource = DruidDataSourceBuilder.create().build();
return druidProperties.dataSource(dataSource);
}
/**
* 从库 对应yml中的数据源 slavedbgame
* @param druidProperties
* @return
*/
@Bean
@ConfigurationProperties("spring.datasource.druid.slavedbgame")
@ConditionalOnProperty(prefix = "spring.datasource.druid.slavedbgame", name = "enabled", havingValue = "true")
public DataSource slaveDbGameDataSource(DruidProperties druidProperties)
{
DruidDataSource dataSource = DruidDataSourceBuilder.create().build();
return druidProperties.dataSource(dataSource);
}
/**
* 从库 对应yml中的数据源 slavedbpaystore
* @param druidProperties
* @return
*/
@Bean
@ConfigurationProperties("spring.datasource.druid.slavedbpaystore")
@ConditionalOnProperty(prefix = "spring.datasource.druid.slavedbpaystore", name = "enabled", havingValue = "true")
public DataSource slaveDbPaystoreDataSource(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_DB_GAME.name(), "slaveDbGameDataSource");
setDataSource(targetDataSources, DataSourceType.SLAVE_DB_PAYSTORE.name(), "slaveDbPaystoreDataSource");
return new DynamicDataSource(masterDataSource, targetDataSources);
}
/**
* 设置数据源
*
* @param targetDataSources 备选数据源集合
* @param sourceName 数据源名称
* @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)
{
}
}
/**
* 去除监控页面底部的广告
*/
@SuppressWarnings({ "rawtypes", "unchecked" })
@Bean
@ConditionalOnProperty(name = "spring.datasource.druid.statViewServlet.enabled", havingValue = "true")
public FilterRegistrationBean removeDruidFilterRegistrationBean(DruidStatProperties properties)
{
// 获取web监控页面的参数
DruidStatProperties.StatViewServlet config = properties.getStatViewServlet();
// 提取common.js的配置路径
String pattern = config.getUrlPattern() != null ? config.getUrlPattern() : "/druid/*";
String commonJsPattern = pattern.replaceAll("\\*", "js/common.js");
final String filePath = "support/http/resources/js/common.js";
// 创建filter进行过滤
Filter filter = new Filter()
{
@Override
public void init(javax.servlet.FilterConfig filterConfig) throws ServletException
{
}
@Override
public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)
throws IOException, ServletException
{
chain.doFilter(request, response);
// 重置缓冲区，响应头不会被重置
response.resetBuffer();
// 获取common.js
String text = Utils.readFromResource(filePath);
// 正则替换banner, 除去底部的广告信息
text = text.replaceAll("<a.*?banner\"></a><br/>", "");
text = text.replaceAll("powered.*?shrek.wang</a>", "");
response.getWriter().write(text);
}
@Override
public void destroy()
{
}
};
FilterRegistrationBean registrationBean = new FilterRegistrationBean();
registrationBean.setFilter(filter);
registrationBean.addUrlPatterns(commonJsPattern);
return registrationBean;
}
}
2. 使用多数据源
生成代码模块 ruoyi-generator 里GenController控制器上 新增一个DataSource注解，指定当前控制器所有操作 都走指定的数据源SLAVE_DB_GAME ：后续生成哪个数据源的代码 只要指定对应的数据源就行，不指定 则默认主库
二、 从库(其他数据源) 新增两个生成代码必要的表
此时如果运行项目，点 代码生成 菜单，会报错：在切换的数据源所在库 找不到gen_table表
### SQL: SELECT count(0) FROM gen_table
### Cause: java.sql.SQLSyntaxErrorException: Table 'db_game.gen_table' doesn't exist
; bad SQL grammar []; nested exception is java.sql.SQLSyntaxErrorException: Table 'db_game.gen_table' doesn't exist
因为生成代码模块，需要在当前库中添加两个表 用于存放生成代码时导入的数据库下表信息及表中字段信息：将若依框架自带库的gen_table、gen_table_column 两个表导出数据结构，并在上面数据源对应的库中 将两个表结构导入
导入到数据源对应库中(只需要导 gen_table、gen_table_column 两个表的结构就行 里边的数据不用导)
重新运行项目，控制台会有切换数据源的日志打印
导入 - 选择需要导入的表 - 确定
