解决依赖 APIJSON 4.7.2 + 时对接不上连接池

Author: TommyLemon

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

@@ -25,10 +25,10 @@
 import apijson.Log;
 import apijson.boot.DemoApplication;
 import apijson.framework.APIJSONSQLExecutor;
-import apijson.orm.SQLConfig;
+import apijson.orm.SQLConfig;
 
 
-/**SQL 执行
+/**SQL 执行
  * @author Lemon
  */
 public class DemoSQLExecutor extends APIJSONSQLExecutor {
@@ -48,15 +48,16 @@ public class DemoSQLExecutor extends APIJSONSQLExecutor {
 	//		super.removeCache(sql, type);
 	//	}
 
-	// 适配连接池，如果这里能拿到连接池的有效 Connection，则 SQLConfig 不需要配置 dbVersion, dbUri, dbAccount, dbPassword
-	@Override
+	// 适配连接池，如果这里能拿到连接池的有效 Connection，则 SQLConfig 不需要配置 dbVersion, dbUri, dbAccount, dbPassword
+	@Override
 	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 {
+
+		String key = datasource + "-" + config.getDatabase();
+		Connection c = connectionMap.get(key);
+		if (datasource != null && (c == null || c.isClosed())) {
+			try {
 				DataSource ds;
 				switch (datasource) {
 				case "HIKARICP":
@@ -80,18 +81,18 @@ public Connection getConnection(SQLConfig config) throws Exception {
 					}
 					break;
 				}
-
-				connectionMap.put(datasource, ds == null ? null : ds.getConnection());
-			} catch (Exception e) {
-				Log.e(TAG, "getConnection   try { "
-						+ "DataSource ds = DemoApplication.getApplicationContext().getBean(DataSource.class); .."
-						+ "} catch (Exception e) = " + e.getMessage());
-			}
-		}
-
-		// 必须最后执行 super 方法，因为里面还有事务相关处理。
-		// 如果这里是 return c，则会导致 增删改 多个对象时只有第一个会 commit，即只有第一个对象成功插入数据库表
-		return super.getConnection(config);
+
+				connectionMap.put(key, ds == null ? null : ds.getConnection());
+			} catch (Exception e) {
+				Log.e(TAG, "getConnection   try { "
+						+ "DataSource ds = DemoApplication.getApplicationContext().getBean(DataSource.class); .."
+						+ "} catch (Exception e) = " + e.getMessage());
+			}
+		}
+
+		// 必须最后执行 super 方法，因为里面还有事务相关处理。
+		// 如果这里是 return c，则会导致 增删改 多个对象时只有第一个会 commit，即只有第一个对象成功插入数据库表
+		return super.getConnection(config);
 	}
 
 
@@ -100,6 +101,6 @@ public Connection getConnection(SQLConfig config) throws Exception {
 	//	protected String getKey(SQLConfig config, ResultSet rs, ResultSetMetaData rsmd, int tablePosition, JSONObject table,
 	//			int columnIndex, Map<String, JSONObject> childMap) throws Exception {
 	//		return ColumnUtil.compatOutputKey(super.getKey(config, rs, rsmd, tablePosition, table, columnIndex, childMap), config.getTable(), config.getMethod());
-	//	}
-
+	//	}
+
 }