Skip to content

Commit a320f2c

Browse files
committed
新增 getConnection(String key) 和 putConnection(String key, Connection connection)
1 parent 2ef0657 commit a320f2c

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

APIJSONORM/src/main/java/apijson/orm/AbstractSQLExecutor.java

+10-2
Original file line numberDiff line numberDiff line change
@@ -1284,16 +1284,24 @@ public Map<String, Connection> getConnectionMap() {
12841284
}
12851285

12861286
protected Connection connection;
1287+
@NotNull
1288+
public Connection getConnection(String key) throws Exception {
1289+
return getConnectionMap().get(key);
1290+
}
1291+
public Connection putConnection(String key, Connection connection) throws Exception {
1292+
return getConnectionMap().put(key, connection);
1293+
}
1294+
12871295
@NotNull
12881296
@Override
12891297
public Connection getConnection(@NotNull SQLConfig<T, M, L> config) throws Exception {
12901298
String connectionKey = getConnectionKey(config);
1291-
connection = getConnectionMap().get(connectionKey);
1299+
connection = getConnection(connectionKey);
12921300
if (connection == null || connection.isClosed()) {
12931301
Log.i(TAG, "select connection " + (connection == null ? " = null" : ("isClosed = " + connection.isClosed()))) ;
12941302
// PostgreSQL 不允许 cross-database
12951303
connection = DriverManager.getConnection(config.gainDBUri(), config.gainDBAccount(), config.gainDBPassword());
1296-
getConnectionMap().put(connectionKey, connection);
1304+
putConnection(connectionKey, connection);
12971305
}
12981306

12991307
// TDengine 驱动内部事务处理方法都是空实现,手动 commit 无效

0 commit comments

Comments
 (0)