From 23df933504b51b40b47cb87e4757c473ecb19faf Mon Sep 17 00:00:00 2001
From: EmilMeindl <emeindl@htl-steyr.ac.at>
Date: Fri, 17 Apr 2020 18:28:10 +0200
Subject: [PATCH] finished statement db reconnect

---
 .../com/wasteinformationserver/db/JDBC.java   | 28 +++++++++++++++----
 1 file changed, 23 insertions(+), 5 deletions(-)

diff --git a/src/java/com/wasteinformationserver/db/JDBC.java b/src/java/com/wasteinformationserver/db/JDBC.java
index d771cce..2d3ed81 100644
--- a/src/java/com/wasteinformationserver/db/JDBC.java
+++ b/src/java/com/wasteinformationserver/db/JDBC.java
@@ -1,5 +1,6 @@
 package com.wasteinformationserver.db;
 
+import com.mysql.cj.exceptions.ConnectionIsClosedException;
 import com.wasteinformationserver.basicutils.Log;
 import com.wasteinformationserver.basicutils.Storage;
 
@@ -135,12 +136,19 @@ public class JDBC {
      */
     public ResultSet executeQuery(String sql) {
         try {
+            conn.isValid(5);
             PreparedStatement stmt = conn.prepareStatement(sql);
             return stmt.executeQuery();
+        } catch (SQLNonTransientConnectionException ee){
+            if (logintodb(usernamec, passwordc, dbnamec, ipc, portc)) {
+                return this.executeQuery(sql);
+            } else {
+                return null;
+            }
         } catch (SQLException e) {
-            e.printStackTrace();
+            return null;
         }
-        return null;
+
     }
 
     /**
@@ -151,9 +159,19 @@ public class JDBC {
      * @throws SQLException
      */
     public int executeUpdate(String sql) throws SQLException {
-        PreparedStatement stmt = conn.prepareStatement(sql);
-
-        return stmt.executeUpdate();
+        try {
+            conn.isValid(5);
+            PreparedStatement stmt = conn.prepareStatement(sql);
+            return stmt.executeUpdate();
+        } catch (SQLNonTransientConnectionException ee){
+            if (logintodb(usernamec, passwordc, dbnamec, ipc, portc)) {
+                return this.executeUpdate(sql);
+            } else {
+                throw new SQLException();
+            }
+        } catch (SQLException e){
+            throw new SQLException();
+        }
     }
 
     /**