import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.logging.Logger;

import at.clienterrxr.bansystem.main.Main;

public class MySQL {

    private static String username;
    private static String password;
    private static String database;
    private static String host;
    public static String port;
    private static Connection con;

    private static final Logger logger = Logger.getLogger("BAN-SYSTEM");

	public static void connect() {
        if (!isConnected())
            try {
				con = DriverManager.getConnection("jdbc:mysql://" + host + ":3306/" + database, username, password);
			} catch (SQLException e) {
                logger.severe(e.getMessage());
            }
    }

	public static void close() {
        if (isConnected())
            try {
				con.close();
                logger.info(Main.PREFIX + "MySQL Verbindung geschlossen!");
            } catch (SQLException e) {
                logger.severe(e.getMessage());
            }
    }

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

	public static void createTable() {
        // Syntax: Spielername, UUID, KILLS, DEATHS, COINS LEVEL
        if (isConnected())
            try {
				con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS active_ban(LAST_PLAYER_NAME VARCHAR(100), UUID VARCHAR(100), REASON VARCHAR(100), END VARCHAR(100), WHO_BANNED VARCHAR(100), LEVEL VARCHAR(100)");
				con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS history_table(LAST_PLAYER_NAME VARCHAR(100), UUID VARCHAR(100), TYPE VARCHAR(100), END VARCHAR(100), WHO_BANNED VARCHAR(100), LEVEL VARCHAR(100)");
			} catch (SQLException e) {
                logger.severe(e.getMessage());
            }
    }

    public static void update(String query) {
        if (isConnected())
            try {
                con.createStatement().executeUpdate(query);
            } catch (SQLException e) {
                logger.severe(e.getMessage());
            }
    }

    public static ResultSet getResult(String query) {
        if (isConnected())
            try {
                return con.createStatement().executeQuery(query);
            } catch (SQLException e) {
                logger.severe(e.getMessage());
            }
        return null;
	}
}