Reconnect when connection times out

- Closes #5
AuraDevelopmentTeam · Apr 24, 2017 · 00ae88d · 00ae88d
1 parent ec3d3e5
commit 00ae88d
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/src/main/java/world/jnc/invsync/util/DatabaseConnection.java b/src/main/java/world/jnc/invsync/util/DatabaseConnection.java
@@ -82,6 +82,13 @@ private void connect(StringBuilder connectionURL) throws SQLException {
 		connection = getDataSource(connectionURLStr).getConnection();
 	}
 
+	private void reconnect() throws SQLException {
+		InventorySync.getLogger()
+				.debug("Reconnecting to: " + connectionURLStr.toString().replaceFirst(":[^:]*@", ":*****@"));
+
+		connection = getDataSource(connectionURLStr).getConnection();
+	}
+
 	public boolean isConnectionActive() {
 		try {
 			return (connection != null) && connection.isValid(0);
@@ -92,6 +99,12 @@ public boolean isConnectionActive() {
 		}
 	}
 
+	public void verifyConnection() throws SQLException {
+		if (!isConnectionActive()) {
+			reconnect();
+		}
+	}
+
 	public Statement getStatement() throws SQLException {
 		if (!isConnectionActive())
 			throw new SQLException("MySQL-connection is not active!");