新增 getConnection(String key) 和 putConnection(String key, Connection c… · APIJSON/APIJSON@a320f2c · GitHub

APIJSON / APIJSON Public

• Notifications You must be signed in to change notification settings
• Fork 2.3k
• Star 18.4k

• Code
• Issues 236
• Pull requests 1
• Actions
• Wiki
• Security and quality
• Insights

Additional navigation options

Commit a320f2c

Browse filesBrowse the repository at this point in the historyBrowse files

TommyLemon

committed

新增 getConnection(String key) 和 putConnection(String key, Connection connection)

1 parent 2ef0657 commit a320f2c
Copy full SHA for a320f2c

1 file changed

+10-2Lines changed: 10 additions & 2 deletions

File tree

Expand file treeCollapse file tree

Open diff view settings

Filter options

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

Expand file treeCollapse file tree

Open diff view settings

Collapse file

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

Copy file name to clipboardExpand all lines: APIJSONORM/src/main/java/apijson/orm/AbstractSQLExecutor.java

+10-2Lines changed: 10 additions & 2 deletions

Original file line number	Diff line number	Diff line change
@@ -1284,16 +1284,24 @@ public Map<String, Connection> getConnectionMap() {
1284	1284	}
1285	1285
1286	1286	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	+
1287	1295	@NotNull
1288	1296	@Override
1289	1297	public Connection getConnection(@NotNull SQLConfig<T, M, L> config) throws Exception {
1290	1298	String connectionKey = getConnectionKey(config);
1291		- connection = getConnectionMap().get(connectionKey);
	1299	+ connection = getConnection(connectionKey);
1292	1300	if (connection == null || connection.isClosed()) {
1293	1301	Log.i(TAG, "select connection " + (connection == null ? " = null" : ("isClosed = " + connection.isClosed()))) ;
1294	1302	// PostgreSQL 不允许 cross-database
1295	1303	connection = DriverManager.getConnection(config.gainDBUri(), config.gainDBAccount(), config.gainDBPassword());
1296		- getConnectionMap().put(connectionKey, connection);
	1304	+ putConnection(connectionKey, connection);
1297	1305	}
1298	1306
1299	1307	// TDengine 驱动内部事务处理方法都是空实现，手动 commit 无效

0 commit comments

Comments

0 (0)