package net.warpixel.bungeesystem.mysql;

import net.md_5.bungee.BungeeCord;
import net.warpixel.bungeesystem.main.Main;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;

public class MySQL {
    public static String username;
    public static String password;
    public static String database;
    public static String host;
    public static String port;
    public static Connection con;

    public static void connect() {
        if (!isconnected()) {
            try {
                con = DriverManager.getConnection(
                        "jdbc:mysql://" + host + ":" + port + "/" + database + "?autoReconnect=true", username,
                        password);
                con.setAutoCommit(true);
                BungeeCord.getInstance().getConsole().sendMessage("§8[§aMysql-§4Ban§8] §aVerbunden");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static void close() {
        if (isconnected()) {
            try {
                con.close();
                BungeeCord.getInstance().getConsole().sendMessage("§8[§aMysql-§4Ban§8] §cGeschlossen");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

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

    public static void createTable() {
        if (isconnected()) {
            try {
                con.createStatement().executeUpdate(
                        "CREATE TABLE IF NOT EXISTS Wartung (Spielername VARCHAR(100), Type VARCHAR(10))");
                con.createStatement().executeUpdate(
                        "CREATE TABLE IF NOT EXISTS OnlineTime (Name VARCHAR(100), UUID VARCHAR(100), Time BIGINT)");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static void update(String qry) {
        if (MySQL.isconnected()) {
            try {
                con.createStatement().executeUpdate(qry);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static ResultSet getResult(String qry) {
        if (MySQL.isconnected()) {
            try {
                return con.createStatement().executeQuery(qry);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return null;
    }

    public static void addWartung(String s) {
        BungeeCord.getInstance().getScheduler().runAsync(Main.instance, new Runnable() {

            @Override
            public void run() {
                update("INSERT INTO Wartung (Spielername, Type) VALUES ('" + s + "', 'wartung')");
            }
        });
    }

    public static void addBeta(String s) {
        BungeeCord.getInstance().getScheduler().runAsync(Main.instance, new Runnable() {

            @Override
            public void run() {
                update("INSERT INTO Wartung (Spielername, Type) VALUES ('" + s + "', 'beta')");
            }
        });
    }

    public static void removeBeta(String s) {
        BungeeCord.getInstance().getScheduler().runAsync(Main.instance, new Runnable() {

            @Override
            public void run() {
                update("DELETE FROM Wartung WHERE Spielername='" + s + "' AND Type='beta'");
            }
        });
    }

    public static void removeWartung(String s) {
        BungeeCord.getInstance().getScheduler().runAsync(Main.instance, new Runnable() {

            @Override
            public void run() {
                update("DELETE FROM Wartung WHERE Spielername='" + s + "' AND Type='wartung'");
            }

        });
    }

    public static boolean containsBeta(String s) {
        try {
            ResultSet rs = getResult("SELECT * FROM Wartung WHERE Spielername='" + s + "' AND Type='beta'");

            return rs.next();

        } catch (SQLException e) {
            e.printStackTrace();
        }
        return false;

    }

    public static boolean containsWartung(String s) {
        try {
            ResultSet rs = getResult("SELECT * FROM Wartung WHERE Spielername='" + s + "' AND Type='wartung'");

            return rs.next();

        } catch (SQLException e) {
            e.printStackTrace();
        }
        return false;

    }

    public static ArrayList<String> getBetaList() {

        try {

            ResultSet rs = getResult("SELECT * FROM Wartung WHERE Type='beta'");

            ArrayList<String> list = new ArrayList<>();

            while (rs.next()) {
                list.add(rs.getString("Spielername").toLowerCase());
            }

            return list;

        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;

    }

    public static ArrayList<String> getWartungList() {
        try {

            ResultSet rs = getResult("SELECT * FROM Wartung WHERE Type='wartung'");

            ArrayList<String> list = new ArrayList<>();

            while (rs.next()) {
                list.add(rs.getString("Spielername").toLowerCase());
            }

            return list;

        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;
    }

}