Tried to add testing

Author: JanHolger

pom.xml

@@ -50,7 +50,7 @@
         <dependency>
             <groupId>mysql</groupId>
             <artifactId>mysql-connector-java</artifactId>
-            <version>5.1.6</version>
+            <version>8.0.22</version>
             <scope>test</scope>
         </dependency>
         <dependency>

src/main/java/org/javawebstack/orm/wrapper/BaseSQL.java

@@ -18,10 +18,11 @@ public abstract class BaseSQL implements SQL {
     public abstract Connection getConnection();
 
     public int write(String queryString, Object... parameters) throws SQLException {
+        Connection connection = getConnection();
         ORM.LOGGER.log(Level.ALL, queryString);
         ORM.LOGGER.log(Level.ALL, Arrays.stream(parameters).map(o -> o == null ? "null" : o.toString()).collect(Collectors.joining(",")));
         if (queryString.toLowerCase(Locale.ROOT).startsWith("insert")) {
-            PreparedStatement ps = setParams(getConnection().prepareStatement(queryString, Statement.RETURN_GENERATED_KEYS), parameters);
+            PreparedStatement ps = setParams(connection.prepareStatement(queryString, Statement.RETURN_GENERATED_KEYS), parameters);
             ps.executeUpdate();
             ResultSet rs = ps.getGeneratedKeys();
             int id = 0;
@@ -32,17 +33,18 @@ public int write(String queryString, Object... parameters) throws SQLException {
             ps.close();
             return id;
         } else {
-            PreparedStatement ps = setParams(getConnection().prepareStatement(queryString), parameters);
+            PreparedStatement ps = setParams(connection.prepareStatement(queryString), parameters);
             ps.executeUpdate();
             ps.close();
         }
         return 0;
     }
 
     public ResultSet read(String queryString, Object... parameters) throws SQLException {
+        Connection connection = getConnection();
         ORM.LOGGER.log(Level.ALL, queryString);
         ORM.LOGGER.log(Level.ALL, Arrays.stream(parameters).map(o -> o == null ? "null" : o.toString()).collect(Collectors.joining(",")));
-        PreparedStatement ps = setParams(getConnection().prepareStatement(queryString), parameters);
+        PreparedStatement ps = setParams(connection.prepareStatement(queryString), parameters);
         ResultSet rs = ps.executeQuery();
         statementMap.put(rs, ps);
         return rs;

src/main/java/org/javawebstack/orm/wrapper/MySQL.java

@@ -1,5 +1,8 @@
 package org.javawebstack.orm.wrapper;
 
+import org.javawebstack.orm.exception.ORMQueryException;
+
+import java.io.IOException;
 import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.SQLException;
@@ -55,8 +58,8 @@ public Connection getConnection() {
             e.printStackTrace();
         }
         try {
-            if (c != null && c.isClosed())
-                return null;
+            if (c == null || c.isClosed())
+                throw new ORMQueryException("Connection failed!");
         } catch (SQLException e) {
             e.printStackTrace();
         }