SpringBoot+Mybatis-Plus實現動態數據源

- 一、前言
- 二、代碼實現
- - 1）工程結構
  - 2）相關依賴
  - 3）數據源攔截切面
  - 4）動態數據源切換
  - 5）核心配置類
  - 6）使用
- 三、原理分析
- - 1）mapper接口注入流程
  - 2）動態數據源切換執行流程
- 四、聲明式事務導致切換失效
- - 1）場景復現
  - 2）原因
  - 3）解決方法
- 五、自調用導致數據源失效
- - 1）場景復現
  - 2）原因
  - 3）解決方法
- 六、總結

代碼倉庫：

https://gitee.com/zhszstudy/dynamic-datasource
https://github.com/zhszstudy/dynamic-datasource

一、前言

這段時間剛好有需求，需要在當前的一個模塊中直連其他系統的數據庫，但是當前系統并不支持多數據源，只支持單數據源。這也可以通過新建一個模塊來編寫該需求，但是總感覺不是特別方便，萬一后續又要連接其他數據庫，又要新建一個個模塊。或者可以引入mybatis-plus的多數據源支持依賴，雖說簡單，但總有不妥的地方。因此，在這個需求下，實現了比較輕量的數據源切換組件。

二、代碼實現

1）工程結構

在這里插入圖片描述

2）相關依賴

springboot版本：2.2.7.RELEASE

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-configuration-processor</artifactId><optional>true</optional></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-autoconfigure</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-aop</artifactId></dependency><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>2.1.2</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.19</version></dependency><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.2.0</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.1.21</version></dependency>
</dependencies>

3）數據源攔截切面

主要用于攔截標注了**@DataSourceType**注解的Bean，并將注解中的值存入數據源上下文中

/*** @author zhou22* @desc 數據源選擇切面* @Date 2025-02-19 10:25:15*/
@Aspect
public class DynamicDataSourceAspect {@Pointcut("@annotation(com.zhou.annotation.DataSourceType)")public void pointCut() {}@Around("pointCut() && @annotation(dataSourceType)")public Object selectDataSource(ProceedingJoinPoint joinPoint, DataSourceType dataSourceType) throws Throwable {if (!StringUtils.isBlank(dataSourceType.dataSourceName())) {// 將要切換的數據源名稱存入上下文中DataSourceContextHolder.setDatasource(dataSourceType.dataSourceName());}try {return joinPoint.proceed();} finally {DataSourceContextHolder.clearDatasource();}}}

4）動態數據源切換

①自定義數據源

繼承了AbstractRoutingDataSource ，主要在獲取數據庫連接時，會根據這里的值，去選擇要切換的數據源

/*** @author zhou22* @desc 動態數據源獲取* @Date 2025-02-19 10:33:19*/
public class DynamicDataSource extends AbstractRoutingDataSource {@Value("${dynamic.jdbc.datasource.default}")private String defaultDataSource;@Overrideprotected Object determineCurrentLookupKey() {// 從數據源上下文獲取要切換的數據源String datasource = DataSourceContextHolder.getDatasource();// 如果沒有配置注解，則選擇默認數據源return datasource != null ? datasource : defaultDataSource;}
}

②數據源上下文

用于存儲線程執行此次CRUD操作要切換的數據源名稱

/*** @author zhou22* @desc 數據源上下文* @Date 2025-02-19 10:14:10*/
public class DataSourceContextHolder {private static final ThreadLocal<String> dataSourceName = new ThreadLocal<>();public static String getDatasource() {return dataSourceName.get();}public static void setDatasource(String datasource) {dataSourceName.set(datasource);}public static void clearDatasource() {dataSourceName.remove();}}

5）核心配置類

項目啟動時會根據spring.factories文件的配置信息，來加載這個配置類，主要用于裝配實現動態數據源的相關bean，以及讀取配置文件中的配置

/*** @author zhou22* @desc 動態數據源切換配置* @Date 2025-02-19 10:37:08*/
@Configuration
public class DynamicDataSourceAutoConfig implements EnvironmentAware {// 數據源分組private final Map<String, Map<String, Object>> dataSourceMap = new HashMap<>();// 默認數據源名稱private String defaultDataSourceName;private Environment environment;/*** 讀取配置文件，**見下面①分析**** @param environment*/@Overridepublic void setEnvironment(Environment environment) {this.environment = environment;// 獲取默認數據源名稱this.defaultDataSourceName = PropertyUtil.convertToTarget(environment, DynamicDataSourceConstants.PREFIX + DynamicDataSourceConstants.DEFAULT_DATA_SOURCE, String.class);// 獲取數據源名稱列表String dataSources = PropertyUtil.convertToTarget(environment, DynamicDataSourceConstants.PREFIX + DynamicDataSourceConstants.DATA_SOURCE_LIST, String.class);for (String dataSource : dataSources.split(COMMA)) {// 挨個獲取數據源配置Map<String, Object> dataSourceProperties = PropertyUtil.convertToTarget(environment, DynamicDataSourceConstants.PREFIX + dataSource, Map.class);dataSourceMap.put(dataSource, dataSourceProperties);}}// 配置數據源切面@Beanpublic DynamicDataSourceAspect dynamicDataSourceAspect() {return new DynamicDataSourceAspect();}// 配置自定義數據源：動態數據源核心實現@Bean("dynamicDataSource")public DataSource dataSource() {DynamicDataSource dynamicDataSource = new DynamicDataSource();Map<Object, Object> targetDataSources = new HashMap<>();// 將讀取的數據源配置信息，依次轉為真實的數據源對象for (Map.Entry<String, Map<String, Object>> entry : dataSourceMap.entrySet()) {DataSource dataSource = createDataSource(entry.getValue());targetDataSources.put(entry.getKey(), dataSource);}// 設置配置的所有數據源，后續會根據這個map來實現數據源切換dynamicDataSource.setTargetDataSources(targetDataSources);// 設置默認數據源dynamicDataSource.setDefaultTargetDataSource(targetDataSources.get(defaultDataSourceName));return dynamicDataSource;}/*** 創建數據源** @param dataSourcePropertyMap* @return*/private DataSource createDataSource(Map<String, Object> dataSourcePropertyMap) {DataSourceProperties dataSourceProperties = new DataSourceProperties();dataSourceProperties.setUrl(dataSourcePropertyMap.get(DynamicDataSourceConstants.URL).toString());dataSourceProperties.setUsername(dataSourcePropertyMap.get(DynamicDataSourceConstants.USERNAME).toString());dataSourceProperties.setPassword(dataSourcePropertyMap.get(DynamicDataSourceConstants.PASSWORD).toString());dataSourceProperties.setDriverClassName(dataSourcePropertyMap.get(DynamicDataSourceConstants.DRIVER_CLASS_NAME).toString());String typeClassName = dataSourcePropertyMap.get(DynamicDataSourceConstants.TYPE_CLASS_NAME).toString();try {// 創建數據源DataSource dataSource = dataSourceProperties.initializeDataSourceBuilder().type((Class<DataSource>) Class.forName(typeClassName)).build();// 獲取連接池配置，支持多種連接池配置的關鍵實現Map<String, Object> poolProperties = (Map<String, Object>) (dataSourcePropertyMap.containsKey(DynamicDataSourceConstants.POOL_KEY) ? dataSourcePropertyMap.get(DynamicDataSourceConstants.POOL_KEY) : Collections.emptyMap());// 反射設置連接池配置信息MetaObject metaObject = SystemMetaObject.forObject(dataSource);for (Map.Entry<String, Object> poolProperty : poolProperties.entrySet()) {String key = MapKeyConvertUtils.middleLineToCamelHump(poolProperty.getKey());if (metaObject.hasSetter(key)) {metaObject.setValue(key, poolProperty.getValue());}}return dataSource;} catch (ClassNotFoundException e) {throw new IllegalStateException("數據源連接池配置失效，無法找到類：" + typeClassName);}}/*** SqlSession工廠配置，**見下面②分析**** @param dynamicDataSource* @return* @throws Exception*/@Beanpublic SqlSessionFactory sqlSessionFactory(DataSource dynamicDataSource) throws Exception {// 將配置映射到配置類MybatisScannerProperties mybatisScannerProperties = PropertyUtil.convertToTarget(environment, MybatisScannerConstants.PREFIX, MybatisScannerProperties.class);// 配置mybatis-plus掃描MybatisSqlSessionFactoryBean factory = new MybatisSqlSessionFactoryBean();// 指定數據源為配置的動態數據源factory.setDataSource(dynamicDataSource);factory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(mybatisScannerProperties.getMapperLocations()));factory.setTypeAliasesPackage(mybatisScannerProperties.getTypeAliasesPackage());MybatisConfiguration configuration = new MybatisConfiguration();// 是否開啟數據庫字段下劃線命名到Java屬性駝峰命名的自動映射configuration.setMapUnderscoreToCamelCase(mybatisScannerProperties.getMapUnderscoreToCamelCase());// 日志輸出類配置configuration.setLogImpl((Class<? extends Log>) Class.forName(mybatisScannerProperties.getLogImpl()));factory.setConfiguration(configuration);return factory.getObject();}@Beanpublic DataSourceTransactionManager transactionManager(DataSource dynamicDataSource) {// 指定數據源為配置的動態數據源return new DataSourceTransactionManager(dynamicDataSource);}/*** spring事務管理配置** @param transactionManager* @return*/@Beanpublic TransactionTemplate transactionTemplate(DataSourceTransactionManager transactionManager) {TransactionTemplate transactionTemplate = new TransactionTemplate();transactionTemplate.setTransactionManager(transactionManager);transactionTemplate.setPropagationBehaviorName("PROPAGATION_REQUIRED");return  transactionTemplate;}/*** druid監控頁面配置-帳號密碼配置，見下面③分析** @return servlet registration bean*/@ConditionalOnProperty(prefix = DruidMonitorConstants.STAT_PREFIX, name = "enabled", havingValue = "true")@Beanpublic ServletRegistrationBean druidStatViewServlet() {// 將配置映射到配置類DruidMonitorProperties.StatViewServlet statViewServlet = PropertyUtil.convertToTarget(environment, DruidMonitorConstants.STAT_PREFIX, DruidMonitorProperties.StatViewServlet.class);// druid監控帳號密碼配置ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new StatViewServlet(), statViewServlet.getUrlPattern());servletRegistrationBean.addInitParameter(DruidMonitorConstants.LOGIN_USERNAME, statViewServlet.getLoginUsername());servletRegistrationBean.addInitParameter(DruidMonitorConstants.LOGIN_PASSWORD, statViewServlet.getLoginPassword());servletRegistrationBean.addInitParameter(DruidMonitorConstants.RESET_ENABLE, String.valueOf(statViewServlet.isResetEnable()));return servletRegistrationBean;}/*** druid監控頁面配置-允許頁面正常瀏覽，見下面③分析** @return filter registration bean*/@ConditionalOnProperty(prefix = DruidMonitorConstants.WEB_PREFIX, name = "enabled", havingValue = "true")@Beanpublic FilterRegistrationBean druidWebStataFilter() {DruidMonitorProperties.WebStatFilter webStatFilter = PropertyUtil.convertToTarget(environment, DruidMonitorConstants.WEB_PREFIX, DruidMonitorProperties.WebStatFilter.class);FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean(new WebStatFilter());// 添加過濾規則.filterRegistrationBean.addUrlPatterns(webStatFilter.getUrlPattern());// 排除不需要統計的URL請求filterRegistrationBean.addInitParameter(DruidMonitorConstants.EXCLUSIONS, webStatFilter.getExclusions());return filterRegistrationBean;}}

解釋：

①setEnvironment方法

因為配置類實現了EnvironmentAware 接口，所以在配置類實例化之后，初始化之前，會執行重寫了該接口的setEnvironment方法，此時就可以拿到Environment對象信息，它里面包含了配置文件的配置信息，通過SpringBoot的Binder類，可以很輕松將配置信息映射到具體的實體類，使用的工具類如下：

/*** @author zhou22* @desc 屬性操作工具類* @Date 2025-02-19 10:38:14*/
public class PropertyUtil {/*** 如果沒有配置的信息，則拋出異常** @param environment* @param name* @param clz* @param <T>* @return*/public static <T> T convertToTarget(Environment environment, String name, Class<T> clz) {try {return Binder.get(environment).bind(name, clz).get();} catch (NoSuchElementException e) {throw new RuntimeException(e.getMessage(), e);}}/*** 如果沒有配置信息，返回一個空的對象** @param environment* @param name* @param clz* @param <T>* @return*/public static <T> T convertToTargetIfAbsent(Environment environment, String name, Class<T> clz) {return Binder.get(environment).bindOrCreate(name, clz);}
}

②為什么要配置這個bean

為了取代項目中原有的數據源配置，我直接把需要引入動態數據源的模塊中，原有的數據源配置刪掉了，也就是spring.datasource.jdbc 前綴的配置，然后啟動項目就會報錯，找不到url的信息。為了解決這個問題，在啟動類加上了如下的配置，排除框架原先的數據源自動裝配：

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class, DruidDataSourceAutoConfigure.class})

加上這些配置后，啟動項目，又報了mapper文件找不到的錯誤，因為我把自動裝配類給排除了，自然有一些bean沒有裝配到，為了解決這些問題，需要讓mybatis-plus掃描到這些mapper文件

③為什么要配置這兩個bean

因為原先模塊是支持druid監控配置的，因為我把DruidDataSourceAutoConfigure這個自動裝配類排除掉了，所以無法根據原先的druid監控配置來加載bean，為了實現druid監控，因此創建了這兩個bean，根據配置文件的信息來決定是否加載

6）使用

配置示例：

dynamic:jdbc:datasource:default: masterlist: master,slavemaster:url: jdbc:mysql://localhost:3306/your_database_name?useSSL=false&serverTimezone=UTCusername: your_usernamepassword: your_passworddriver-class-name: com.mysql.cj.jdbc.Drivertype-class-name: com.alibaba.druid.pool.DruidDataSourcepool: max-active: 10initial-size: 1max-wait: 30000min-idle: 1time-between-eviction-runs-millis: 30000min-evictable-idle-time-millis: 150000validation-query: select 'x'test-while-idle: truetest-on-borrow: falsetest-on-return: falsepool-prepared-statements: truemax-open-prepared-statements: 20filters: stat, walltestConnectionOnCheckout: falsetestConnectionOnCheckin: trueidleConnectionTestPeriod: 3600slave:url: jdbc:mysql://localhost:3306/your_database_name?useSSL=false&serverTimezone=UTCusername: your_usernamepassword: your_passworddriver-class-name: com.mysql.cj.jdbc.Drivertype-class-name: com.alibaba.druid.pool.DruidDataSourcepool: max-active: 20initial-size: 1max-wait: 3000min-idle: 1time-between-eviction-runs-millis: 6000min-evictable-idle-time-millis: 3000validation-query: select 'x'test-while-idle: truetest-on-borrow: falsetest-on-return: falsepool-prepared-statements: truemax-open-prepared-statements: 20filters: stat, walltestConnectionOnCheckout: falsetestConnectionOnCheckin: trueidleConnectionTestPeriod: 360
druid:monitor:web-stat-filter:# 是否開啟配置enabled: trueurl-pattern: /*exclusions: "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"stat-view-servlet:url-pattern: /druid/*reset-enable: false# 是否開啟配置enabled: truelogin-username: adminlogin-password: admin# mybatis 配置
mybatis:scanner:mapperLocations: classpath:mapper/*Mapper.xml# 實體類別名配置typeAliasesPackage: com.ikun.entitymapUnderscoreToCamelCase: truelogImpl: org.apache.ibatis.logging.stdout.StdOutImpl

方法或類中加入自定義的數據源注解，值為配置文件中數據源名稱：

比如下面的代碼，會切換至slave這個數據源來執行CRUD，如果沒有配置這個注解，默認用的是master數據源

@DataSourceType(dataSourceName = "slave")
@Override
public List<Student> queryStudentFromSlave() {return baseMapper.selectList(null);
}

訪問：http://localhost:8348/druid/sql.html，可以看到監控頁面：
在這里插入圖片描述

三、原理分析

以下流程圖的流程，可以自己打斷點看看

1）mapper接口注入流程

忽略引入mybatis-plus（只做增強，不做修改，加多了一層），以原有mybatis的邏輯來分析：

在這里插入圖片描述

2）動態數據源切換執行流程

忽略引入mybatis-plus（只做增強，不做修改，加多了一層），以原有mybatis的邏輯來分析：
在這里插入圖片描述
動態數據源切換關鍵邏輯，主要通過集成抽象父類AbstractRoutingDataSource ，重寫determineCurrentLookupKey方法實現，代碼如下：


public abstract class AbstractRoutingDataSource extends AbstractDataSource implements InitializingBean {// 在DynamicDataSourceAutoConfig配置中，設置的數據源對象@Nullableprivate Map<Object, Object> targetDataSources;@Nullableprivate Object defaultTargetDataSource;private boolean lenientFallback = true;private DataSourceLookup dataSourceLookup = new JndiDataSourceLookup();// 存儲所有配置的數據源對象@Nullableprivate Map<Object, DataSource> resolvedDataSources;// 默認數據源對象@Nullableprivate DataSource resolvedDefaultDataSource;public void setTargetDataSources(Map<Object, Object> targetDataSources) {this.targetDataSources = targetDataSources;}public void setDefaultTargetDataSource(Object defaultTargetDataSource) {this.defaultTargetDataSource = defaultTargetDataSource;}@Overridepublic void afterPropertiesSet() {if (this.targetDataSources == null) {throw new IllegalArgumentException("Property 'targetDataSources' is required");}this.resolvedDataSources = new HashMap<>(this.targetDataSources.size());// 將targetDataSources轉成數據源對象，存進resolvedDataSources中this.targetDataSources.forEach((key, value) -> {Object lookupKey = resolveSpecifiedLookupKey(key);DataSource dataSource = resolveSpecifiedDataSource(value);this.resolvedDataSources.put(lookupKey, dataSource);});if (this.defaultTargetDataSource != null) {this.resolvedDefaultDataSource = resolveSpecifiedDataSource(this.defaultTargetDataSource\);}}protected Object resolveSpecifiedLookupKey(Object lookupKey) {return lookupKey;}// 將targetDataSources的值轉DataSourceprotected DataSource resolveSpecifiedDataSource(Object dataSource) throws IllegalArgumentException {if (dataSource instanceof DataSource) {return (DataSource) dataSource;}else if (dataSource instanceof String) {return this.dataSourceLookup.getDataSource((String) dataSource);}else {throw new IllegalArgumentException("Illegal data source value - only [javax.sql.DataSource] and String supported: " + dataSource);}}// 獲取數據庫連接@Overridepublic Connection getConnection() throws SQLException {return determineTargetDataSource().getConnection();}@Overridepublic Connection getConnection(String username, String password) throws SQLException {return determineTargetDataSource().getConnection(username, password);}// 關鍵方法protected DataSource determineTargetDataSource() {Assert.notNull(this.resolvedDataSources, "DataSource router not initialized");// 獲取數據源名稱Object lookupKey = determineCurrentLookupKey();// 根據數據源名稱去resolvedDataSources中查找數據源DataSource dataSource = this.resolvedDataSources.get(lookupKey);if (dataSource == null && (this.lenientFallback || lookupKey == null)) {dataSource = this.resolvedDefaultDataSource;}if (dataSource == null) {throw new IllegalStateException("Cannot determine target DataSource for lookup key [" + lookupKey + "]");}return dataSource;}@Nullable// 子類DynamicDataSource實現了該方法，返回當前線程要切換的數據源名稱protected abstract Object determineCurrentLookupKey();}

四、聲明式事務導致切換失效

1）場景復現

如下的代碼標注了事務注解，也就是開啟了聲明式事務，在測試時發現數據源切換失效，一直返回了默認數據源的數據

@DataSourceType(dataSourceName = "slave")
@Transactional(rollbackFor = Exception.class)
@Override
public List<Student> queryStudentFromSlave() {return baseMapper.selectList(null);
}

2）原因

這里面就不畫流程圖，簡單說一下，當方法上標注@Transactional注解之后，會為當前類生成一個代理對象，具體事務處理邏輯由TransactionInterceptor 攔截器來實現，當調用上述的queryStudentFromSlave方法時，在這個方法執行之前，會先由TransactionInterceptor 開啟事務，然后才執行queryStudentFromSlave方法。

這似乎沒什么問題，但是調試斷點時，發現TransactionInterceptor 的邏輯先于DynamicDataSourceAspect 實現，并且TransactionInterceptor 在開啟事務時，會提前去獲取一個數據庫連接對象，也就是如下方法：

在這里插入圖片描述

其中獲取數據源的方法如下：

org.springframework.jdbc.datasource.DataSourceTransactionManager

protected DataSource obtainDataSource() {DataSource dataSource = getDataSource();Assert.state(dataSource != null, "No DataSource set");return dataSource;
}
// 這個dataSource就是DynamicDataSource，通過spring注入
public DataSource getDataSource() {return this.dataSource;
}

此時，還沒走切面邏輯，所以返回的是默認數據源對象，然后會將數據源對象保存到一個線程上下文中：
在這里插入圖片描述

接著會走到切面的處理邏輯，設置要切換的數據源名稱，當切面執行完之后，接著走我們的CRUD方法，也就是前面分析的流程圖，最終會通過DataSourceUtils來獲取數據庫連接對象：

在這里插入圖片描述

問題就出現在這里，由于開啟聲明式事務時，提前創建了一個數據庫連接對象存入上下文中，導致動態數據源失效，因為即使后續經過了切面處理，設置了要切換的數據源名稱，在DataSourceUtils 獲取數據庫連接對象時，優先從上下文中獲取！

3）解決方法

既然事務攔截器（TransactionInterceptor）執行比動態數據源切面（DynamicDataSourceAspect ）先執行，那我控制動態數據源切面先于事務攔截器執行不就好了嗎，于是在自動配置類加了Order注解來讓動態數據源切面優先執行：

@Bean
// 值越小，優先執行，Ordered.HIGHEST_PRECEDENCE的值為Integer.MIN_VALUE
@Order(Ordered.HIGHEST_PRECEDENCE)
public DynamicDataSourceAspect dynamicDataSourceAspect() {return new DynamicDataSourceAspect();
}

想法很美好，現實很骨感，重新加載依賴，啟動項目，發現還是沒有效果

**查閱相關資料：**https://www.jb51.net/article/139418.htm

發現TransactionInterceptor 和DynamicDataSourceAspect 是由不同的代理方式生成的：

DynamicDataSourceAspect 這種通過@Aspect注解標注的類是通過AnnotationAwareAspectJAutoProxyCreator進行代理的
TransactionInterceptor 是BeanNameAutoProxyCreator方式進行代理的

BeanNameAutoProxyCreator攔截優先級高于AnnotationAwareAspectJAutoProxyCreator，order注解只對同一類型的AOP攔截方式起作用

既然這種方式不行的話，那只能采用編程式事務來解決這個問題了，見下面的解決方法：

引入多數據源的模塊，不使用聲明式事務，改用編程式事務，示例如下：

@Service
public class UserService {@Autowiredprivate PlatformTransactionManager transactionManager;@Autowiredprivate UserRepository userRepository;public void createUser(User user) {// 定義事務屬性（如傳播行為、隔離級別等）TransactionDefinition definition = new DefaultTransactionDefinition();TransactionStatus status = transactionManager.getTransaction(definition);try {userRepository.save(user);// 其他數據庫操作transactionManager.commit(status); // 提交事務} catch (Exception e) {transactionManager.rollback(status); // 回滾事務throw e;}}
}

為了減少重復的事務處理代碼，可以在動態數據源切面中，加入上述的編程式事務處理。

五、自調用導致數據源失效

1）場景復現

@DataSourceType(dataSourceName = "slave")
//    @Transactional(rollbackFor = Exception.class)
@Override
public List<Student> queryStudentFromSlave() {return baseMapper.selectList(null);
}@Override
public List<Student> queryStudentWithSelf() {return queryStudentFromSlave();
}

當調用queryStudentWithSelf()方法時，會導致數據源切換失效

2）原因

出現這個問題的原因在于**@DataSourceType(dataSourceName = “slave”)是基于動態代理實現切面效果的，在本類方法調用注解方法時，這個this的引用為普通對象，所以沒有走切面的處理流程，只獲取了默認的數據源，這個失效原理和@Transactional**注解自調用失效一樣（除此之外還要注意注解標注的方法，修飾符不能帶有private、final）

3）解決方法

①獲取代理對象

通過獲取代理對象的方式來解決，方法如下：

1.啟動類開啟代理暴露：

@EnableAspectJAutoProxy(exposeProxy = true)

2.獲取代理對象執行方法：

@DataSourceType(dataSourceName = "slave")
//    @Transactional(rollbackFor = Exception.class)
@Override
public List<Student> queryStudentFromSlave() {return baseMapper.selectList(null);
}@Override
public List<Student> queryStudentWithSelf() {StudentService studentService = (StudentService) AopContext.currentProxy();return studentService.queryStudentFromSlave();
}