import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

import net.md_5.bungee.BungeeCord;
import net.md_5.bungee.api.ChatColor;

public class MySQL
{
    private static Connection con;

    public static Connection getConnection() {
        return MySQL.con;
    }

    public static void setConnection(final String host, final String user, final String password, final String database, final String port) {
        if (host == null || user == null || password == null || database == null) {
            return;
        }
        disconnect(false);
        try {
            MySQL.con = DriverManager.getConnection("jdbc:mysql://" + host + ":" + port + "/" + database, user, password);
        }
        catch (Exception e) {
        }
    }

    public static void connect() {
        connect(true);
    }

	private static void connect(final boolean message) {
        final String host = "";
        final String user = "";
        final String password = "";
        final String database = "";
        final String port = "3306";
        setConnection(host, user, password, database, port);
    }

    public static void disconnect() {
        disconnect(true);
    }

    @SuppressWarnings("deprecation")
	private static void disconnect(final boolean message) {
        try {
            if (isConnected()) {
                MySQL.con.close();
                BungeeCord.getInstance().getConsole().sendMessage(ChatColor.GREEN + "MySQL disconnected.");
            }
            else if (message) {
            	BungeeCord.getInstance().getConsole().sendMessage(ChatColor.RED + "MySQL Disconnect Error: No existing connection");
            }
        }
        catch (Exception e) {
            if (message) {
            	BungeeCord.getInstance().getConsole().sendMessage(ChatColor.RED + "MySQL Disconnect Error: " + e.getMessage());
            }
        }
        MySQL.con = null;
    }

    public static void reconnect() {
        disconnect();
        connect();
    }

    public static boolean isConnected() {
        return getConnection() != null;
    }

    @SuppressWarnings("deprecation")
	public static void update(final String command) {
        if (command == null) {
            return;
        }
        connect(false);
        try {
            final Statement st = getConnection().createStatement();
            st.executeUpdate(command);
            st.close();
        }
        catch (Exception e) {
        	BungeeCord.getInstance().getConsole().sendMessage(ChatColor.RED + "MySQL Update:");
        	BungeeCord.getInstance().getConsole().sendMessage(ChatColor.RED + "Command: " + command);
        	BungeeCord.getInstance().getConsole().sendMessage(ChatColor.RED + "Error: " + e.getMessage());
        }
    }

    @SuppressWarnings("deprecation")
	public static ResultSet query(final String command) {
        if (command == null) {
            return null;
        }
        connect(false);
        ResultSet rs = null;
        try {
            final Statement st = getConnection().createStatement();
            rs = st.executeQuery(command);
        }
        catch (Exception e) {
        	BungeeCord.getInstance().getConsole().sendMessage(ChatColor.RED + "MySQL Query:");
        	BungeeCord.getInstance().getConsole().sendMessage(ChatColor.RED + "Command: " + command);
        	BungeeCord.getInstance().getConsole().sendMessage(ChatColor.RED + "Error: " + e.getMessage());
        }
        return rs;
    }
}