Add exception print statements. Might remove later.

Author: Fernthedev

core/src/main/java/com/github/fernthedev/fernapi/universal/mysql/DatabaseListener.java

@@ -7,10 +7,7 @@
 import com.github.fernthedev.fernapi.universal.data.chat.ChatColor;
 import com.github.fernthedev.fernapi.universal.data.database.*;
 import com.github.fernthedev.fernapi.universal.exceptions.database.DatabaseException;
-import lombok.AccessLevel;
-import lombok.Getter;
-import lombok.NonNull;
-import lombok.Setter;
+import lombok.*;
 import org.intellij.lang.annotations.Language;
 import org.panteleyev.mysqlapi.MySqlProxy;
 import org.panteleyev.mysqlapi.annotations.Column;
@@ -144,7 +141,7 @@ public CompletableFuture<List<DbRow>> getTableRows(String name) {
         @Language("SQL") String sql = "SELECT * FROM " + name + ";";
         Universal.debug(ChatColor.GREEN + "Executing {}", sql);
 
-        return database.getResultsAsync(sql);
+        return database.getResultsAsync(sql).handle(this::handleException);
     }
 
     /**
@@ -167,7 +164,7 @@ public <T extends RowData> CompletableFuture<Void> removeRowIfColumnContainsValu
             } catch (SQLException throwables) {
                 throwables.printStackTrace();
             }
-        });
+        }).handle(this::handleException);
 
     }
 
@@ -200,7 +197,7 @@ public <T extends RowData> CompletableFuture<Integer> insertIntoTable(TableInfo<
                     }
 
                     return dbStatement;
-                });
+                }).handle(this::handleException);
 
     }
 
@@ -224,7 +221,7 @@ public <T extends RowData> CompletableFuture<Integer> updateRow(TableInfo<T> tab
                     Universal.debug(ChatColor.GREEN + "Fully Executed {} {} ({}) {} {}", sql, tableInfo.getTableName(), columnValues, conditionKey, conditionValue);
                     tableInfo.loadFromDB(DatabaseListener.this);
                     return integer;
-                });
+                }).handle(this::handleException);
 
 
     }
@@ -239,7 +236,7 @@ public <T extends RowData> CompletableFuture<Integer> removeTable(TableInfo<T> t
 
         Universal.debug("Executing {}", sql);
 
-        return database.executeUpdateAsync(sql);
+        return database.executeUpdateAsync(sql).handle(this::handleException);
     }
 
     /**
@@ -398,7 +395,7 @@ public <T extends RowData> CompletableFuture<Void> createTable(@NonNull TableInf
             }
 
             tableDataInfo.loadFromDB(DatabaseListener.this);
-        });
+        }).handle(this::handleException);
 
 
     }
@@ -407,4 +404,14 @@ protected Logger getLogger() {
         return Universal.getMethods().getAbstractLogger();
     }
 
+    @SneakyThrows
+    protected <T> T handleException(T t, Throwable throwable) {
+        if (throwable != null) {
+            Universal.getLogger().error(throwable.getMessage(), t);
+            throw throwable;
+        }
+
+        return t;
+    }
+
 }