Changes to mysql

Author: BenCodez

AdvancedCore/src/com/bencodez/advancedcore/api/user/userstorage/mysql/MySQL.java

@@ -123,7 +123,18 @@ public ArrayList<Column> load(String key) {
 		if (tablePrefix != null) {
 			name = tablePrefix + tableName;
 		}
-		mysql = new com.bencodez.advancedcore.api.user.userstorage.mysql.api.MySQL(maxThreads);
+		mysql = new com.bencodez.advancedcore.api.user.userstorage.mysql.api.MySQL(maxThreads) {
+
+			@Override
+			public void severe(String string) {
+				plugin.getLogger().severe(string);
+			}
+
+			@Override
+			public void debug(SQLException e) {
+				plugin.debug(e);
+			}
+		};
 		if (!mysql.connect(hostName, "" + port, user, pass, database, useSSL, lifeTime, str, publicKeyRetrieval)) {
 			plugin.getLogger().warning("Failed to connect to MySQL");
 		}

AdvancedCore/src/com/bencodez/advancedcore/api/user/userstorage/mysql/api/MySQL.java

@@ -1,9 +1,10 @@
 package com.bencodez.advancedcore.api.user.userstorage.mysql.api;
 
+import java.sql.SQLException;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
-public class MySQL {
+public abstract class MySQL {
 
 	private ConnectionManager connectionManager;
 	private int maxConnections;
@@ -64,4 +65,8 @@ public ConnectionManager getConnectionManager() {
 	public ExecutorService getThreadPool() {
 		return threadPool;
 	}
+
+	public abstract void severe(String string);
+
+	public abstract void debug(SQLException e);
 }

AdvancedCore/src/com/bencodez/advancedcore/api/user/userstorage/mysql/api/queries/Query.java

@@ -6,7 +6,6 @@
 import java.util.HashMap;
 import java.util.Map.Entry;
 
-import com.bencodez.advancedcore.AdvancedCorePlugin;
 import com.bencodez.advancedcore.api.user.userstorage.mysql.api.MySQL;
 
 public class Query {
@@ -153,11 +152,11 @@ public int executeUpdate() throws SQLException {
 			return num;
 
 		} catch (SQLException e) {
-			AdvancedCorePlugin.getInstance().getLogger().severe("Failed to send query: " + this.sql);
+			mysql.severe("Failed to send query: " + this.sql);
 			if (!e.getMessage().contains("Duplicate entry")) {
 				e.printStackTrace();
 			} else {
-				AdvancedCorePlugin.getInstance().debug(e);
+				mysql.debug(e);
 			}
 
 		}