只需要在當前Service的實現類的操作方法內，使用DatasourceUtil.changeDb() 指那打那； 注意：使用多數據為了保證事務傳播性，請@DSTransactional 注解。 ***** 具體如下： ``` /** * 切換到指定數據源 */ @DSTransactional @Override public void add(ProjectGroupEntity projectGroup) { // 切換到-指定數據源 DatasourceUtil.changeDb(DatasourceContext.me().getDbName()); // 校驗參數 checkParam(projectGroup, false); // 保存 this.save(projectGroup); } /** * 同時操作-主數據源和從數據源 */ @Override public List<ProTableEntity> getProTableList(ProTableSearch proTableQuery) { // 切換到-指定數據源 DatasourceUtil.changeDb(DatasourceContext.me().getDbName()); /** * 先查詢當前數據源-項目表List */ // 創建查詢包裝器 LambdaQueryWrapper<ProjectTableEntity> queryWrapper = new LambdaQueryWrapper<>(); // 設置條件 queryWrapper.eq(ProjectTableEntity::getDelFlag, CommonDelFlagEnum.NOT_DELETE.getCode()); // 設置排序 queryWrapper.orderByAsc(ProjectTableEntity::getSort); // 查詢 List<ProjectTableEntity> projectTableList = this.list(queryWrapper); // 獲取數據集標識的List List<String> domainKeyList = projectTableList.stream().map(projectTable -> projectTable.getDomainKey()).collect(Collectors.toList()); /** * 再查詢主庫數據源-項目基礎表List */ DatasourceUtil.changeMasterDb(); // 獲取參數 String domainName = proTableQuery.getDomainName(); String domainCode = proTableQuery.getDomainCode(); // 創建查詢包裝器 LambdaQueryWrapper<ProTableEntity> proTableQueryWrapper = new LambdaQueryWrapper<>(); // 設置條件 proTableQueryWrapper.eq(ProTableEntity::getDataFlag, CommonDataFlagEnum.NORMAL.getCode()) .eq(ProTableEntity::getDelFlag, CommonDelFlagEnum.NOT_DELETE.getCode()); // 判斷 if (domainKeyList != null && domainKeyList.size() > 0) { // 設置條件 proTableQueryWrapper.notIn(ProTableEntity::getDomainKey, domainKeyList); } // 設置排序 proTableQueryWrapper.orderByAsc(ProTableEntity::getSort); // 條件查詢 if (StrUtil.isNotBlank(domainName)) { proTableQueryWrapper.like(ProTableEntity::getDomainName, domainName); } if (StrUtil.isNotBlank(domainCode)) { proTableQueryWrapper.like(ProTableEntity::getDomainCode, domainCode); } // 返回 return proTableService.list(proTableQueryWrapper); }