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

Browse Source
This commit is contained in:
Redkale
2018-04-25 11:38:05 +08:00
parent e64d522707
commit 3f340a3f7e
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/org/redkale/source/PoolJdbcSource.java
View File

@@ -46,7 +46,15 @@ public class PoolJdbcSource extends PoolSource<Connection> {
@Override @Override
public void connectionClosed(ConnectionEvent event) { public void connectionClosed(ConnectionEvent event) {
PooledConnection pc = (PooledConnection) event.getSource(); PooledConnection pc = (PooledConnection) event.getSource();
if (queue.offer(pc)) saveCounter.incrementAndGet(); if (queue.offer(pc)) {
saveCounter.incrementAndGet();
} else {
try {
pc.close();
} catch (Exception e) {
dataSource.logger.log(Level.INFO, DataSource.class.getSimpleName() + " " + pc + " close error", e);
}
}
} }
@Override @Override