public class DynamicDataSource extends AbstractRoutingDataSource
{
private Map<Object, Object> targetDataSources;\/\/\u5b9e\u73b0\u52a8\u6001\u6dfb\u52a0<\/p>\n\n\n\n
public DynamicDataSource(DataSource defaultTargetDataSource, Map<Object, Object> targetDataSources)
{
this.targetDataSources = targetDataSources;
super.setDefaultTargetDataSource(defaultTargetDataSource);
super.setTargetDataSources(targetDataSources);
super.afterPropertiesSet();
}<\/p>\n\n\n\n
@Override
protected Object determineCurrentLookupKey()
{
return DynamicDataSourceContextHolder.getDataSourceType();
}<\/p>\n\n\n\n
public Map<Object, Object> getTargetDataSources() {
return targetDataSources;
}<\/p>\n\n\n\n
}
1.\u641e\u4e00\u4e2a\u7c7b\u7ee7\u627fAbstractRoutingDataSource\uff0c\u628a\u8fd9\u4e2atargetDataSources\u66b4\u9732\u51fa\u6765\uff0c\u5728 filter\u91cc\u9762\u53ef\u4ee5\u5bf9\u5b83\u8fdb\u884c\u52a8\u6001\u6dfb\u52a0\u7684\u64cd\u4f5c<\/p>\n\n\n\n
@Configuration
public class DruidConfig {
@Bean
@ConfigurationProperties(“spring.datasource.druid.master”)
public DataSource masterDataSource(DruidProperty druidProperties)
{
DruidDataSource dataSource = DruidDataSourceBuilder.create().build();
return druidProperties.dataSource(dataSource);
}<\/p>\n\n\n\n
@Bean(name = “dynamicDataSource”)
@Primary
public DynamicDataSource dataSource(DataSource masterDataSource)
{
Map<Object, Object> targetDataSources = new HashMap<>();
targetDataSources.put(DataSourceType.MASTER.name(), masterDataSource);
return new DynamicDataSource(masterDataSource, targetDataSources);
}
}
2.\u641e\u4e00\u4e2aconfig,\u521d\u59cb\u5316\u4e00\u4e0b\u8fd9\u4e2adynamicDataSource<\/p>\n\n\n\n
\/\/\u5207\u6362\u5230\u65b0\u7684\u6570\u636e\u6e90
Map m = apps.get(0);
String driver = “com.mysql.jdbc.Driver”;
String host = (String) m.get(“f_dbhost”);
String user = (String) m.get(“f_dbusername”);
String dbname = (String) m.get(“f_dbname”);
String password = (String) m.get(“f_dbpassword”);
DruidDataSource newDataSource = druidProperty.dataSource(new DruidDataSource());
newDataSource.setDriverClassName(driver);
String url = “jdbc:mysql:\/\/”+host+”\/”+dbname+”?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8″;
newDataSource.setUrl(url);
newDataSource.setUsername(user);
newDataSource.setPassword(password);<\/p>\n\n\n\n
\/\/\u52a8\u6001\u6dfb\u52a0\u65b0\u7684\u79df\u6237
tgetTargetDataSources.put(domain, newDataSource);
dynamicDataSource.setTargetDataSources(tgetTargetDataSources);
dynamicDataSource.afterPropertiesSet();<\/p>\n\n\n\n
DynamicDataSourceContextHolder.setDataSourceType(domain);<\/p>\n\n\n\n
3.\u5199\u4e00\u4e2a\u62e6\u622a\u5668\uff0c\u6839\u636e\u60c5\u51b5\u5904\u7406\uff0c\u5b58\u5728\u7684\u79df\u6237\uff0c\u76f4\u63a5\u5207\u6362\uff0c\u65b0\u52a0\u7684\u79df\u6237\u52a8\u6001\u6dfb\u52a0\uff0c\u7136\u540e\u6267\u884cafterPropertiesSet\uff0c\u76f8\u5f53\u4e8e\u5237\u65b0\u6570\u636e\u6e90\u5217\u8868\u3002<\/p>\n\n\n\n
4.DynamicDataSourceContextHolder\u7684\u4ee3\u7801\u4e5f\u5b58\u4e00\u4e0b\u3002
public class DynamicDataSourceContextHolder
{
public static final Logger log = LoggerFactory.getLogger(DynamicDataSourceContextHolder.class);<\/p>\n\n\n\n
\/**
* \u4f7f\u7528ThreadLocal\u7ef4\u62a4\u53d8\u91cf\uff0cThreadLocal\u4e3a\u6bcf\u4e2a\u4f7f\u7528\u8be5\u53d8\u91cf\u7684\u7ebf\u7a0b\u63d0\u4f9b\u72ec\u7acb\u7684\u53d8\u91cf\u526f\u672c\uff0c
* \u6240\u4ee5\u6bcf\u4e00\u4e2a\u7ebf\u7a0b\u90fd\u53ef\u4ee5\u72ec\u7acb\u5730\u6539\u53d8\u81ea\u5df1\u7684\u526f\u672c\uff0c\u800c\u4e0d\u4f1a\u5f71\u54cd\u5176\u5b83\u7ebf\u7a0b\u6240\u5bf9\u5e94\u7684\u526f\u672c\u3002
*\/
private static final ThreadLocal<String> CONTEXT_HOLDER = new ThreadLocal<>();<\/p>\n\n\n\n
\/**
* \u8bbe\u7f6e\u6570\u636e\u6e90\u7684\u53d8\u91cf
*\/
public static void setDataSourceType(String dsType)
{
log.info(“\u5207\u6362\u5230{}\u6570\u636e\u6e90”, dsType);
CONTEXT_HOLDER.set(dsType);
}<\/p>\n\n\n\n
\/**
* \u83b7\u5f97\u6570\u636e\u6e90\u7684\u53d8\u91cf
*\/
public static String getDataSourceType()
{
return CONTEXT_HOLDER.get();
}<\/p>\n\n\n\n
\/**
* \u6e05\u7a7a\u6570\u636e\u6e90\u53d8\u91cf
*\/
public static void clearDataSourceType()
{
CONTEXT_HOLDER.remove();
}
}<\/p>\n","protected":false},"excerpt":{"rendered":"
public class DynamicDataSource extends AbstractRoutingD […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[10],"tags":[69,68],"_links":{"self":[{"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/1244"}],"collection":[{"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=1244"}],"version-history":[{"count":7,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/1244\/revisions"}],"predecessor-version":[{"id":1251,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/1244\/revisions\/1251"}],"wp:attachment":[{"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=1244"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=1244"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=1244"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}