网站主持人制作网站代言人,php网站如何导入数据库,电子行业网站,马鞍山网站建设咨有个需求需要通过开关控制需要访问的数据源#xff0c;此处参考DS多数据源#xff0c;采用注解加aop切面实现此功能。
配置文件开关#xff1a;
slave-config:mainSlaveSwitch: true
配置开关类#xff1a;
Component
RefreshScope
Data
ConfigurationProperties(此处参考DS多数据源采用注解加aop切面实现此功能。
配置文件开关
slave-config:mainSlaveSwitch: true
配置开关类
Component
RefreshScope
Data
ConfigurationProperties(slave-config)
public class SlaveConfig {private boolean mainSlaveSwitchfalse;
}多数据源配置 datasource:dynamic:primary: masterdatasource:master:url: jdbc:mysql://xxxx:3306/order?useUnicodetruecharacterEncodingutf-8useSSLfalseusername: gac_travel_devpassword: gac6666driverClassName: com.mysql.jdbc.Drivertype: com.alibaba.druid.pool.DruidDataSourcedruid:initialSize: 10maxActive: 20minIdle: 5maxWait: 1000minEvictableIdleTimeMillis: 300000useGlobalDataSourceStat: truetimeBetweenEvictionRunsMillis: 60000validationQuery: select xtestOnBorrow: truetestOnReturn: truetestWhileIdle: trueslave:url: jdbc:mysql://xxxx:3306/order/gac_order?useUnicodetruecharacterEncodingutf-8useSSLfalseusername: gac_dev_readpassword: gac6666type: com.alibaba.druid.pool.DruidDataSourcedruid:initialSize: 10maxActive: 20minIdle: 5maxWait: 1000minEvictableIdleTimeMillis: 300000useGlobalDataSourceStat: truetimeBetweenEvictionRunsMillis: 60000validationQuery: select xtestOnBorrow: truetestOnReturn: truetestWhileIdle: truemainslave:url: jdbc:mysql://xxxx:3306/order/gac_order?useUnicodetruecharacterEncodingutf-8useSSLfalseusername: gac_travel_testpassword: gac6666type: com.alibaba.druid.pool.DruidDataSourcedruid:initialSize: 10maxActive: 20minIdle: 5maxWait: 1000minEvictableIdleTimeMillis: 300000useGlobalDataSourceStat: truetimeBetweenEvictionRunsMillis: 60000validationQuery: select xtestOnBorrow: truetestOnReturn: truetestWhileIdle: true
多数据源静态类不是必须的:
public interface DBTypeConst {/*** 主库*/String MASTER master;/*** 主库的从库*/String MAIN_SLAVE mainslave;/*** 从库*/String SLAVE slave;}
多数据源注解
Target({ElementType.METHOD, ElementType.TYPE})
Retention(RetentionPolicy.RUNTIME)
public interface DynamicDataSource {
}
AOP切面:
import com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder;Aspect
Component
Slf4j
public class DynamicDataSourceAspect {AutowiredSlaveConfig slaveConfig;Around(annotation(dynamicDataSource))public Object switchDataSource(ProceedingJoinPoint joinPoint, DynamicDataSource dynamicDataSource) throws Throwable {if(slaveConfig.isMainSlaveSwitch()){log.info(DynamicDataSourceAspect:{},DBTypeConst.MAIN_SLAVE);DynamicDataSourceContextHolder.push(DBTypeConst.MAIN_SLAVE);}else{log.info(DynamicDataSourceAspect:{},DBTypeConst.SLAVE);DynamicDataSourceContextHolder.push(DBTypeConst.SLAVE);}try {return joinPoint.proceed();} finally {DynamicDataSourceContextHolder.clear();}}
}
此处使用时要多测试防止异常
