iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Verify if the connection is still alive (#9246)

Browse Source
This commit is contained in:
kwoyke 2020-05-05 22:27:16 +02:00 committed by GitHub
parent 0f78e9a073
commit 50208fb013
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
persistence-modules/core-java-persistence/src/main/java/com/baeldung/connectionpool/BasicConnectionPool.java
View File

@ -14,7 +14,8 @@ public class BasicConnectionPool implements ConnectionPool {
private final List<Connection> connectionPool; private final List<Connection> connectionPool;
private final List<Connection> usedConnections = new ArrayList<>(); private final List<Connection> usedConnections = new ArrayList<>();
private static final int INITIAL_POOL_SIZE = 10; private static final int INITIAL_POOL_SIZE = 10;
private final int MAX_POOL_SIZE = 20; private static final int MAX_POOL_SIZE = 20;
private static final int MAX_TIMEOUT = 5;
public static BasicConnectionPool create(String url, String user, String password) throws SQLException { public static BasicConnectionPool create(String url, String user, String password) throws SQLException {
List<Connection> pool = new ArrayList<>(INITIAL_POOL_SIZE); List<Connection> pool = new ArrayList<>(INITIAL_POOL_SIZE);
@ -42,6 +43,11 @@ public class BasicConnectionPool implements ConnectionPool {
} }
Connection connection = connectionPool.remove(connectionPool.size() - 1); Connection connection = connectionPool.remove(connectionPool.size() - 1);
if(!connection.isValid(MAX_TIMEOUT)){
connection = createConnection(url, user, password);
}
usedConnections.add(connection); usedConnections.add(connection);
return connection; return connection;
} }