SpringBoot+AOP實(shí)現(xiàn)多數(shù)據(jù)源動態(tài)切換

• 背景
• 設(shè)計(jì)總體思路
• 步驟

背景

系統(tǒng)后端需要訪問多個數(shù)據(jù)庫,現(xiàn)有的數(shù)據(jù)庫連接配置寫入配置文件中。后端需要從一個數(shù)據(jù)庫的配置表里動態(tài)的讀取其它mysql數(shù)據(jù)庫的鏈接配置信息，并根據(jù)鏈接信息動態(tài)創(chuàng)建數(shù)據(jù)庫鏈接，發(fā)起請求，而且還要能使用現(xiàn)在的一些連接池

設(shè)計(jì)總體思路

SpringBoot+AOP方式實(shí)現(xiàn)多數(shù)據(jù)源切換，繼承AbstractRoutingDataSource實(shí)現(xiàn)數(shù)據(jù)源動態(tài)的獲取，在service層使用注解指定數(shù)據(jù)源

步驟

對數(shù)據(jù)源庫表進(jìn)行設(shè)計(jì)，相關(guān)SQL語句如下所示：CREATE TABLE "YUDB"."DOM_DATABASE" ("DB_ID" NUMBER NOT NULL ENABLE,"SRC_ID" NUMBER,"DB_NAME" VARCHAR2 ( 30 ),"DB_C_NAME" VARCHAR2 ( 60 ),"NOTE" VARCHAR2 ( 60 ),"TAB_NUM" NUMBER,"DB_SIZE" NUMBER,"UD_TIME" DATE NOT NULL ENABLE,"MD_FILE_ID" VARCHAR2 ( 32 ),CONSTRAINT "PK_DATABASE" PRIMARY KEY ( "DB_ID" ) USING INDEX PCTFREE 10 INITRANS 2 MAXTRANS 255 COMPUTE STATISTICS STORAGE ( INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645 PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1 BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT ) TABLESPACE "USERS" ENABLE,CONSTRAINT "SYS_C0011295" CHECK ( "DB_ID" IS NOT NULL ) ENABLE,CONSTRAINT "SYS_C0011296" CHECK ( "UD_TIME" IS NOT NULL ) ENABLE,CONSTRAINT "FK_DATABASE" FOREIGN KEY ( "SRC_ID" ) REFERENCES "YUDB"."DOM_DATASOURCE" ( "SRC_ID" ) ON DELETE CASCADE ENABLE ) SEGMENT CREATION IMMEDIATE PCTFREE 10 PCTUSED 40 INITRANS 1 MAXTRANS 255 NOCOMPRESS LOGGING STORAGE ( INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645 PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1 BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT ) TABLESPACE "YU" CREATE TABLE "YUDB"."DOM_DATASOURCE" ("SRC_ID" NUMBER NOT NULL ENABLE,"CHG_ID" NUMBER,"SRC_SID" VARCHAR2 ( 20 ),"TABLE_SPACE" VARCHAR2 ( 20 ),"IP_ADDR" VARCHAR2 ( 30 ),"SRC_PORT" VARCHAR2 ( 10 ),"SRC_USER" VARCHAR2 ( 20 ),"SRC_PSW" VARCHAR2 ( 20 ),"ORGID" NUMBER,"DBTYPE" VARCHAR2 ( 100 ),CONSTRAINT "PK_DATASOURCE" PRIMARY KEY ( "SRC_ID" ) USING INDEX PCTFREE 10 INITRANS 2 MAXTRANS 255 COMPUTE STATISTICS STORAGE ( INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645 PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1 BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT ) TABLESPACE "USERS" ENABLE, CONSTRAINT "SYS_C0011298" CHECK ( "SRC_ID" IS NOT NULL ) ENABLE ) SEGMENT CREATION IMMEDIATE PCTFREE 10 PCTUSED 40 INITRANS 1 MAXTRANS 255 NOCOMPRESS LOGGING STORAGE ( INITIAL 65536 NEXT 1048576 MINEXTENTS 1 MAXEXTENTS 2147483645 PCTINCREASE 0 FREELISTS 1 FREELIST GROUPS 1 BUFFER_POOL DEFAULT FLASH_CACHE DEFAULT CELL_FLASH_CACHE DEFAULT ) TABLESPACE "YU" DataBase庫表設(shè)計(jì)

DataSource庫表設(shè)計(jì)：

ER圖如下圖所示：

往yu數(shù)據(jù)庫中的表dataSource里增加數(shù)據(jù)庫的相關(guān)配置信息。

在配置文件application-dev.yml中，進(jìn)行多數(shù)據(jù)源配置spring:devtools:restart:enabled: true #設(shè)置開啟熱部署additional-paths: src/main/java #重啟目錄exclude: WEB-INF/**datasource:main:username: YUDBpassword: YUDB_HHurl: jdbc:oracle:thin:@xxx.xxx.xxx.xxx:1521/RAC1driver-class-name: oracle.jdbc.driver.OracleDriverzyml:username: xxxxxxpassword: xxxxxxurl: jdbc:oracle:thin:@xxx.xxx.xxx.xxx:1521/HHUdriver-class-name: oracle.jdbc.driver.OracleDriverbjobj:username: xxxxxxpassword: xxxxxxurl: jdbc:oracle:thin:@xxx.xxx.xxx.xxx:1521/BJOBJdriver-class-name: oracle.jdbc.driver.OracleDriver#####DruidDataSource配置#####################type: com.alibaba.druid.pool.DruidDataSourceinitialSize: 5minIdle: 5maxActive: 20# 配置獲取連接等待超時的時間maxWait: 60000# 配置間隔多久才進(jìn)行一次檢測，檢測需要關(guān)閉的空閑連接，單位是毫秒timeBetweenEvictionRunsMillis: 60000# 配置一個連接在池中最小生存的時間，單位是毫秒minEvictableIdleTimeMillis: 300000validationQuery: SELECT 1 FROM DUALtestWhileIdle: truetestOnBorrow: falsetestOnReturn: false# 打開PSCache，并且指定每個連接上PSCache的大小poolPreparedStatements: truemaxPoolPreparedStatementPerConnectionSize: 20# 配置監(jiān)控統(tǒng)計(jì)攔截的filters，去掉后監(jiān)控界面sql無法統(tǒng)計(jì)，'wall'用于防火墻filters: stat,wall,log4j# 通過connectProperties屬性來打開mergeSql功能；慢SQL記錄connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000#合并多個DruidDataSource的監(jiān)控?cái)?shù)據(jù)useGlobalDataSourceStat: true###############以上為配置druid添加的配置########################################

創(chuàng)建實(shí)體類DataSource和DataBase
DataBase表和DataSource表通過外鍵src_id鏈接，先創(chuàng)建DataBase實(shí)體類package org.hhu.yu.system.rdbms.entity;import lombok.Data;import javax.persistence.*; import java.util.Date;@Data public class DataBase {private Long db_id;@JoinColumn(name="SRC_ID")@ManyToOne(cascade = CascadeType.ALL)//數(shù)據(jù)庫名private String db_name;//數(shù)據(jù)庫中文名private String db_c_nname;//數(shù)據(jù)庫描述private String db_desc;//表數(shù)量private Long table_num;//數(shù)據(jù)庫大小private Long data_size;//數(shù)據(jù)庫更新時間private Date update_time;private String metaId; } 然后創(chuàng)建DataSource實(shí)體類import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; import lombok.*;@ApiModel(description = "數(shù)據(jù)源對象Model") @Data @AllArgsConstructor @NoArgsConstructor @RequiredArgsConstructor public class DataSource{@NonNull@ApiModelProperty(value = "數(shù)據(jù)源id",name ="src_id" )private Long src_id;@NonNull@ApiModelProperty(value= "數(shù)據(jù)源實(shí)例名",name="src_sid",required=true)private String src_sid;//數(shù)據(jù)源表空間private String table_space;@ApiModelProperty(value= "數(shù)據(jù)源ip地址",name="ip_addr",required=true)private String ip_addr;@ApiModelProperty(value= "數(shù)據(jù)源端口",name="src_port",required=true)private String src_port;@ApiModelProperty(value= "數(shù)據(jù)源用戶名",name="src_user",required=true)private String src_user;@ApiModelProperty(value= "數(shù)據(jù)源密碼",name="src_pwd",required=true)private String src_pwd;@ApiModelProperty(value= "數(shù)據(jù)庫類型",name="db_type",required=true)private String db_type;@NonNullprivate DataBase dataBase; }

創(chuàng)建DruidDBConfig.java，配置Druid數(shù)據(jù)庫連接池

@Configuration public class DruidDBConfig {@Bean@Qualifier("mainDataSource")@ConfigurationProperties(prefix = "spring.datasource.main")DataSource mainConfig() throws SQLException{DruidDataSource build = DruidDataSourceBuilder.create().build();List<Filter> filters = new ArrayList<>();filters.add(statFilter());filters.add(logFilter());build.setProxyFilters(filters);return build;}@Bean@Qualifier("zymlDataSource")@ConfigurationProperties(prefix = "spring.datasource.zyml")DataSource zymlConfig(){return DruidDataSourceBuilder.create().build();}@Bean@Qualifier("bjobjDataSource")@ConfigurationProperties(prefix = "spring.datasource.bjobj")DataSource bjobjConfig(){return DruidDataSourceBuilder.create().build();}@Bean(name = "dynamicDataSource")@Primary //優(yōu)先使用，多數(shù)據(jù)源@Qualifier("dynamicDataSource")public DynamicDataSource dynamicDataSource() throws SQLException {DynamicDataSource dynamicDataSource = new DynamicDataSource();dynamicDataSource.setDebug(false);// 默認(rèn)數(shù)據(jù)源配置 DefaultTargetDataSourcedynamicDataSource.setDefaultTargetDataSource(mainConfig());Map<Object, Object> targetDataSources = new HashMap<Object, Object>();//多數(shù)據(jù)源配置 TargetDataSourcestargetDataSources.put("mainDataSource", mainConfig());targetDataSources.put("zymlDataSource", zymlConfig());targetDataSources.put("bjobjDataSource", mainConfig());dynamicDataSource.setTargetDataSources(targetDataSources);return dynamicDataSource;} }

創(chuàng)建DBContextHolder類，實(shí)現(xiàn)數(shù)據(jù)源的切換服務(wù)

@Slf4j public class DBContextHolder {// 對當(dāng)前線程的操作-線程安全的private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();// 調(diào)用此方法，切換數(shù)據(jù)源public static void setDataSource(String dataSource) {contextHolder.set(dataSource);log.info("已切換到數(shù)據(jù)源:{}",dataSource);}// 獲取數(shù)據(jù)源public static String getDataSource() {return contextHolder.get();}// 刪除數(shù)據(jù)源public static void clearDataSource() {contextHolder.remove();log.info("已切換到主數(shù)據(jù)源");} }

創(chuàng)建核心的動態(tài)數(shù)據(jù)源配置類，該類繼承AbstractRoutingDataSource實(shí)現(xiàn)數(shù)據(jù)源動態(tài)的獲取。

@Slf4j public class DynamicDataSource extends AbstractRoutingDataSource {private boolean debug = true;private Map<Object, Object> dynamicTargetDataSources;private Object dynamicDefaultTargetDataSource;@Overrideprotected Object determineCurrentLookupKey() {String datasource = DBContextHolder.getDataSource();if (!StringUtils.isEmpty(datasource)) {Map<Object, Object> dynamicTargetDataSources2 = this.dynamicTargetDataSources;if (dynamicTargetDataSources2.containsKey(datasource)) {log.info("---當(dāng)前數(shù)據(jù)源：" + datasource + "---");} else {log.info("不存在的數(shù)據(jù)源：");throw new ADIException("不存在的數(shù)據(jù)源："+datasource,500);return null; }} else {log.info("---當(dāng)前數(shù)據(jù)源：默認(rèn)數(shù)據(jù)源---");}return datasource;}@Overridepublic void setTargetDataSources(Map<Object, Object> targetDataSources) {super.setTargetDataSources(targetDataSources);this.dynamicTargetDataSources = targetDataSources;}@Overridepublic void setDefaultTargetDataSource(Object defaultTargetDataSource) {super.setDefaultTargetDataSource(defaultTargetDataSource);this.dynamicDefaultTargetDataSource = defaultTargetDataSource;}/*** @param debug* @description the debug to set*/public void setDebug(boolean debug) {this.debug = debug;}/*** @return the debug*/public boolean isDebug() {return debug;}/*** @return the dynamicTargetDataSources*/public Map<Object, Object> getDynamicTargetDataSources() {return dynamicTargetDataSources;}/*** @param dynamicTargetDataSources* the dynamicTargetDataSources to set*/public void setDynamicTargetDataSources(Map<Object, Object> dynamicTargetDataSources) {this.dynamicTargetDataSources = dynamicTargetDataSources;}/*** @return the dynamicDefaultTargetDataSource*/public Object getDynamicDefaultTargetDataSource() {return dynamicDefaultTargetDataSource;}/*** @param dynamicDefaultTargetDataSource* the dynamicDefaultTargetDataSource to set*/public void setDynamicDefaultTargetDataSource(Object dynamicDefaultTargetDataSource) {this.dynamicDefaultTargetDataSource = dynamicDefaultTargetDataSource;}/*** @param dataSource* @throws Exception* @description 創(chuàng)建新數(shù)據(jù)源時檢查數(shù)據(jù)源是否存在*/public void createDataSourceWithCheck(DataSource dataSource) throws Exception {@NonNull Long src_id = dataSource.getSrc_id();log.info("正在檢查數(shù)據(jù)源："+src_id);Map<Object, Object> currentDynamicTargetDataSources = this.dynamicTargetDataSources;if (currentDynamicTargetDataSources.containsKey(src_id)) {log.info("數(shù)據(jù)源"+src_id+"之前已經(jīng)創(chuàng)建，準(zhǔn)備測試數(shù)據(jù)源是否正常...");DruidDataSource druidDataSource = (DruidDataSource) currentDynamicTargetDataSources.get(src_id);boolean rightFlag = true;Connection connection = null;try {log.info(src_id+"數(shù)據(jù)源的概況->當(dāng)前閑置連接數(shù)："+druidDataSource.getPoolingCount());long activeCount = druidDataSource.getActiveCount();log.info(src_id+"數(shù)據(jù)源的概況->當(dāng)前活動連接數(shù)："+activeCount);if(activeCount > 0) {log.info(src_id+"數(shù)據(jù)源的概況->活躍連接堆棧信息："+druidDataSource.getActiveConnectionStackTrace());}log.info("準(zhǔn)備獲取數(shù)據(jù)庫連接...");connection = druidDataSource.getConnection();log.info("數(shù)據(jù)源"+src_id+"正常");} catch (Exception e) {log.error(e.getMessage(),e); //把異常信息打印到日志文件rightFlag = false;log.info("緩存數(shù)據(jù)源"+src_id+"已失效，準(zhǔn)備刪除...");if(delDatasources(src_id)) {log.info("緩存數(shù)據(jù)源刪除成功");} else {log.info("緩存數(shù)據(jù)源刪除失敗");}} finally {if(null != connection) {connection.close();}}if(rightFlag) {log.info("不需要重新創(chuàng)建數(shù)據(jù)源");return;} else {log.info("準(zhǔn)備重新創(chuàng)建數(shù)據(jù)源...");createDataSource(dataSource);log.info("重新創(chuàng)建數(shù)據(jù)源完成");}} else {createDataSource(dataSource);}}private void createDataSource(DataSource dataSource) throws Exception {DBUtils dbUtils = SpringUtils.getBean(DBUtils.class);@NonNull Long src_id = dataSource.getSrc_id();log.info("準(zhǔn)備創(chuàng)建數(shù)據(jù)源"+src_id);String db_type = dataSource.getDb_type();String username = dataSource.getSrc_user();String password = dataSource.getSrc_pwd();String ip_addr = dataSource.getIp_addr();String src_port = dataSource.getSrc_port();@NonNull String src_sid = dataSource.getSrc_sid();String url = null;String driveClass = null;if("mysql".equalsIgnoreCase(db_type)) {driveClass = DBUtils.MYSQL_DRIVER;dbUtils.setMySQLYUrl(ip_addr,src_port,src_sid);url = dbUtils.getMySQLYUrl();} else if("oracle".equalsIgnoreCase(db_type)){driveClass = DBUtils.ORACLE_DRIVER;dbUtils.setOracleUrl(ip_addr,src_port,src_sid);url = dbUtils.getOracleUrl();} else if("dm".equalsIgnoreCase(db_type)){driveClass = DBUtils.DM_DRIVER;dbUtils.setDMUrl(ip_addr,src_port,src_sid);url = dbUtils.getDMUrl();} else if("sqlserver".equalsIgnoreCase(db_type)){driveClass = DBUtils.SQLSERVER_DRIVER;dbUtils.setSQLserverUrl(ip_addr,src_port,src_sid);url = dbUtils.getSQLserverUrl();}if(testDatasource(src_id.toString(),driveClass,url,username,password)) {boolean result = this.createDataSource(src_id.toString(), driveClass, url, username, password, db_type);if(!result) {log.error("數(shù)據(jù)源"+src_id+"配置正確，但是創(chuàng)建失敗");throw new ADIException("數(shù)據(jù)源"+src_id+"配置正確，但是創(chuàng)建失敗",500);}} else {log.error("數(shù)據(jù)源配置有錯誤");throw new ADIException("數(shù)據(jù)源配置有錯誤",500);}}/*** @description 自定義創(chuàng)建數(shù)據(jù)源* @param key* @param driveClass* @param url* @param username* @param password* @param db_type* @return*/public boolean createDataSource(String key, String driveClass, String url, String username, String password, String db_type) {try {try { // 排除連接不上的錯誤Class.forName(driveClass);DriverManager.getConnection(url, username, password);//連接數(shù)據(jù)庫} catch (Exception e) {return false;}@SuppressWarnings("resource") // HikariDataSource druidDataSource = new HikariDataSource();DruidDataSource druidDataSource = new DruidDataSource();druidDataSource.setName(key);druidDataSource.setDriverClassName(driveClass);druidDataSource.setUrl(url);druidDataSource.setUsername(username);druidDataSource.setPassword(password);druidDataSource.setInitialSize(1); //初始化時建立物理連接的個數(shù)。初始化發(fā)生在顯示調(diào)用init方法，或者第一次getConnection時druidDataSource.setMaxActive(20); //最大連接池?cái)?shù)量druidDataSource.setMaxWait(60000); //獲取連接時最大等待時間，單位毫秒。當(dāng)鏈接數(shù)已經(jīng)達(dá)到了最大鏈接數(shù)的時候，應(yīng)用如果還要獲取鏈接就會出現(xiàn)等待的現(xiàn)象，等待鏈接釋放并回到鏈接池，如果等待的時間過長就應(yīng)該踢掉這個等待，不然應(yīng)用很可能出現(xiàn)雪崩現(xiàn)象druidDataSource.setMinIdle(5); //最小連接池?cái)?shù)量String validationQuery = "select 1 from dual";if("mysql".equalsIgnoreCase(db_type)) {driveClass = DBUtils.MYSQL_DRIVER;validationQuery = "select 1";} else if("oracle".equalsIgnoreCase(db_type)){driveClass = DBUtils.ORACLE_DRIVER;druidDataSource.setPoolPreparedStatements(true); //是否緩存preparedStatement,PSCache對支持游標(biāo)的ORACLE數(shù)據(jù)庫性能提升巨大,在mysql下建議關(guān)閉。druidDataSource.setMaxPoolPreparedStatementPerConnectionSize(50);druidDataSource.setConnectionProperties("oracle.net.CONNECT_TIMEOUT=6000;oracle.jdbc.ReadTimeout=300000");//對于耗時長的查詢sql，會受限于ReadTimeout的控制，單位毫秒} else if("dm".equalsIgnoreCase(db_type)){driveClass = DBUtils.DM_DRIVER;validationQuery = "select 1";} else if("sqlserver".equalsIgnoreCase(db_type)){driveClass = DBUtils.SQLSERVER_DRIVER;validationQuery = "select 1";}//申請連接時執(zhí)行validationQuery檢測連接是否有效，這里建議配置為TRUE，防止取到的連接不可用druidDataSource.setTestOnBorrow(true);//申請連接的時候檢測，如果空閑時間大于timeBetweenEvictionRunsMillis，執(zhí)行validationQuery檢測連接是否有效。druidDataSource.setTestWhileIdle(true);//用來檢測連接是否有效的sql，要求是一個查詢語句。如果validationQuery為null，testOnBorrow、testOnReturn、testWhileIdle都不會起作用。druidDataSource.setValidationQuery(validationQuery);//屬性類型是字符串，通過別名的方式配置擴(kuò)展插件，常用的插件有：監(jiān)控統(tǒng)計(jì)用的filter:stat日志用的filter:log4j防御sql注入的filter:walldruidDataSource.setFilters("stat");//配置間隔多久才進(jìn)行一次檢測，檢測需要關(guān)閉的空閑連接，單位是毫秒druidDataSource.setTimeBetweenEvictionRunsMillis(60000);//配置一個連接在池中最小生存的時間，單位是毫秒，這里配置為3分鐘180000druidDataSource.setMinEvictableIdleTimeMillis(180000);//打開druid.keepAlive之后，當(dāng)連接池空閑時，池中的minIdle數(shù)量以內(nèi)的連接，空閑時間超過minEvictableIdleTimeMillis，// 則會執(zhí)行keepAlive操作，即執(zhí)行druid.validationQuery指定的查詢SQL，一般為select * from dual，只要// minEvictableIdleTimeMillis設(shè)置的小于防火墻切斷連接時間，就可以保證當(dāng)連接空閑時自動做保活檢測，不會被防火墻切斷druidDataSource.setKeepAlive(true);//是否移除泄露的連接/超過時間限制是否回收。druidDataSource.setRemoveAbandoned(true);//泄露連接的定義時間(要超過最大事務(wù)的處理時間)；單位為秒。這里配置為1小時druidDataSource.setRemoveAbandonedTimeout(3600);//移除泄露連接發(fā)生是是否記錄日志druidDataSource.setLogAbandoned(true);druidDataSource.init();this.dynamicTargetDataSources.put(key, druidDataSource);// 將map賦值給父類的TargetDataSourcessetTargetDataSources(this.dynamicTargetDataSources);super.afterPropertiesSet();// 將TargetDataSources中的連接信息放入resolvedDataSources管理log.info(key+"數(shù)據(jù)源初始化成功");//log.info(key+"數(shù)據(jù)源的概況："+druidDataSource.dump());return true;} catch (Exception e) {log.error(e + "");return false;}}/*** 刪除數(shù)據(jù)源* @param db_id* @return*/public boolean delDatasources(Long db_id) {Map<Object, Object> currentDynamicTargetDataSources = this.dynamicTargetDataSources;if (currentDynamicTargetDataSources.containsKey(db_id)) {Set<DruidDataSource> druidDataSourceInstances = DruidDataSourceStatManager.getDruidDataSourceInstances();for (DruidDataSource l : druidDataSourceInstances) {if (db_id.equals(l.getName())) {currentDynamicTargetDataSources.remove(db_id);DruidDataSourceStatManager.removeDataSource(l);// 將map賦值給父類的TargetDataSourcessetTargetDataSources(currentDynamicTargetDataSources);// 將TargetDataSources中的連接信息放入resolvedDataSources管理super.afterPropertiesSet();return true;}}return false;} else {return false;}}/*** 測試數(shù)據(jù)源連接* @param driveClass* @param url* @param username* @param password* @return*/public boolean testDatasource(String key,String driveClass, String url, String username, String password) {try {Class.forName(driveClass);DriverManager.getConnection(url, username, password);return true;} catch (Exception e) {return false;}}} 與50位技術(shù)專家面對面20年技術(shù)見證，附贈技術(shù)全景圖

總結(jié)

以上是生活随笔為你收集整理的SpringBoot+AOP实现多数据源动态切换的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。