Java：APIJSONBoot-MultiDataSource 中 Druid 连接池配置新增测试 test 和线上 online 两个环境的配置

Author: TommyLemon

APIJSON-Java-Server/APIJSONBoot-MultiDataSource/src/main/java/apijson/boot/DemoDataSourceConfig.java

@@ -41,16 +41,16 @@ public DruidDataSource druidDataSource() {
 	      return new DruidDataSource();
 	  }
 
-//	  @Bean
-//	  @ConfigurationProperties(prefix = "spring.datasource.druid-test")
-//	  public DruidDataSource druidTestDataSource(){
-//		  return new DruidDataSource();
-//	  }
-//	  
-//	  @Bean
-//	  @ConfigurationProperties(prefix = "spring.datasource.druid-online")
-//	  public DruidDataSource druidOnlineDataSource(){
-//		  return new DruidDataSource();
-//	  }
+	  @Bean
+	  @ConfigurationProperties(prefix = "spring.datasource.druid-test")
+	  public DruidDataSource druidTestDataSource(){
+		  return new DruidDataSource();
+	  }
+	  
+	  @Bean
+	  @ConfigurationProperties(prefix = "spring.datasource.druid-online")
+	  public DruidDataSource druidOnlineDataSource(){
+		  return new DruidDataSource();
+	  }
 
 }

APIJSON-Java-Server/APIJSONBoot-MultiDataSource/src/main/java/apijson/demo/DemoSQLExecutor.java

@@ -15,6 +15,7 @@
 package apijson.demo;
 
 import java.sql.Connection;
+import java.util.Map;
 
 import javax.sql.DataSource;
 
@@ -52,36 +53,37 @@ public class DemoSQLExecutor extends APIJSONSQLExecutor {
 	public Connection getConnection(SQLConfig config) throws Exception {
 		String datasource = config.getDatasource();
 		Log.d(TAG, "getConnection  config.getDatasource() = " + datasource);
-		
+
 		Connection c = connectionMap.get(datasource);
 		if (datasource != null && (c == null || c.isClosed())) {
 			try {
 				DataSource ds;
 				switch (datasource) {
 				case "HIKARICP":
 					ds = DemoApplication.getApplicationContext().getBean(HikariDataSource.class);
-					// 另一种方式是 DemoHikariCPConfig 初始化获取到 Datasource 后给静态变量 DATA_SOURCE 赋值： ds = DemoHikariCPConfig.DATA_SOURCE.getConnection();
+					// 另一种方式是 DemoDataSourceConfig 初始化获取到 DataSource 后给静态变量 DATA_SOURCE_HIKARICP 赋值： ds = DemoDataSourceConfig.DATA_SOURCE_HIKARICP.getConnection();
 					break;
 				case "DRUID":
 				case "DRUID-TEST":
 				case "DRUID-ONLINE":
-					ds = DemoApplication.getApplicationContext().getBean(DruidDataSource.class);
-//					switch (datasource) {
-//					case "DRUID-TEST":
-//						
-//					case "DRUID-ONLINE":
-//						// 另一种方式是 DemoDruidConfig 初始化获取到 Datasource 后给静态变量 DATA_SOURCE 赋值： ds = DemoDruidConfig.DATA_SOURCE.getConnection();
-//						break;
-//					default:
-//						ds = null;
-//						break;
-//					}
+					Map<String, DruidDataSource> dsMap = DemoApplication.getApplicationContext().getBeansOfType(DruidDataSource.class);
+					// 另一种方式是 DemoDataSourceConfig 初始化获取到 DataSource 后给静态变量 DATA_SOURCE_DRUID 赋值： ds = DemoDataSourceConfig.DATA_SOURCE_DRUID.getConnection();
+					switch (datasource) {
+					case "DRUID-TEST":
+						ds = dsMap.get("druidTestDataSource");
+					case "DRUID-ONLINE":
+						ds = dsMap.get("druidOnlineDataSource");
+						break;
+					default:
+						ds = dsMap.get("druidDataSource");
+						break;
+					}
 					break;
 				default:
 					ds = null;
 					break;
 				}
-				
+
 				connectionMap.put(datasource, ds == null ? null : ds.getConnection());
 			} catch (Exception e) {
 				Log.e(TAG, "getConnection   try { "

APIJSON-Java-Server/APIJSONBoot-MultiDataSource/src/main/resources/application.yml

@@ -40,3 +40,45 @@ spring:
       # filters: stat,wall,log4j
       connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
       useGlobalDataSourceStat: true    
+    druid-test:
+      driverClassName: com.mysql.cj.jdbc.Driver
+      url: jdbc:mysql://localhost:3306?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=UTF-8
+      username: root
+      password: apijson
+      type: com.alibaba.druid.pool.DruidDataSource
+      initialSize: 5
+      minIdle: 5
+      maxActive: 20
+      maxWait: 60000
+      timeBetweenEvictionRunsMillis: 60000
+      minEvictableIdleTimeMillis: 300000
+      validationQuery: SELECT 1 FROM DUAL
+      testWhileIdle: true
+      testOnBorrow: false
+      testOnReturn: false
+      poolPreparedStatements: true
+      maxPoolPreparedStatementPerConnectionSize: 20
+      # filters: stat,wall,log4j
+      connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
+      useGlobalDataSourceStat: true    
+    druid-online:
+      driverClassName: com.mysql.cj.jdbc.Driver
+      url: jdbc:mysql://apijson.cn:3306?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=UTF-8
+      username: root
+      password: apijson
+      type: com.alibaba.druid.pool.DruidDataSource
+      initialSize: 5
+      minIdle: 5
+      maxActive: 20
+      maxWait: 60000
+      timeBetweenEvictionRunsMillis: 60000
+      minEvictableIdleTimeMillis: 300000
+      validationQuery: SELECT 1 FROM DUAL
+      testWhileIdle: true
+      testOnBorrow: false
+      testOnReturn: false
+      poolPreparedStatements: true
+      maxPoolPreparedStatementPerConnectionSize: 20
+      # filters: stat,wall,log4j
+      connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
+      useGlobalDataSourceStat: true