lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

DataJdbcSource优化

Browse Source
This commit is contained in:
redkale
2023-04-18 08:51:07 +08:00
parent d56af6043d
commit 0fca7cd47b
1 changed files with 15 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/org/redkale/source/DataJdbcSource.java
View File

@@ -2792,9 +2792,15 @@ public class DataJdbcSource extends AbstractDataSqlSource {
this.queue = newQueue; this.queue = newQueue;
this.maxConns = newMaxconns; this.maxConns = newMaxconns;
this.canNewSemaphore = new Semaphore(this.maxConns); this.canNewSemaphore = new Semaphore(this.maxConns);
Connection conn; Connection c;
while ((conn = oldQueue.poll()) != null) { while ((c = oldQueue.poll()) != null) {
offerConnection(conn, oldSemaphore); try {
if (c.getClientInfo() != null) {
c.getClientInfo().put("version", "-1");
}
} catch (SQLException e) {
}
offerConnection(c, oldSemaphore);
} }
} }
} }
@@ -2830,6 +2836,12 @@ public class DataJdbcSource extends AbstractDataSqlSource {
this.canNewSemaphore = new Semaphore(this.maxConns); this.canNewSemaphore = new Semaphore(this.maxConns);
Connection c; Connection c;
while ((c = oldQueue.poll()) != null) { while ((c = oldQueue.poll()) != null) {
try {
if (c.getClientInfo() != null) {
c.getClientInfo().put("version", "-1");
}
} catch (SQLException e) {
}
offerConnection(c, oldSemaphore); offerConnection(c, oldSemaphore);
} }
} }