package pl.klaudiusz.core.utils;

import pl.klaudiusz.core.managers.SlotManager;
import pl.klaudiusz.core.yml.Config;

import java.sql.*;

public class MySQL
{
    public static String url;
    public static String database;
    public static String user;
    public static String password;

    static {
        MySQL.url = "jdbc:mysql://" + Config.MYSQL_HOST + ":" + ("3306") + "/";
        MySQL.database =
        MySQL.user = Config.MYSQL_USER;
        MySQL.password = Config.MYSQL_PASS;
    }

    public MySQL() {
            createTable();
        }


    public static void createTable() {
        try {
            final Connection con = DriverManager.getConnection(String.valueOf(MySQL.url) + MySQL.database, MySQL.user, MySQL.password);
            final Statement st = con.createStatement();
            try {
                st.execute("CREATE TABLE IF NOT EXISTS Sloty(sloty CHAR(16))");
            }
            catch (SQLException sqle) {
                System.out.print(" > Tabela nie zostala stworzona");
            }
        }
        catch (SQLException sqle2) {
            System.out.print(" > Nie udalo sie polaczyc z baza danych");
        }
    }

    public static void addRecord(int Sloty) {
        try {
            final Connection con = DriverManager.getConnection(String.valueOf(MySQL.url) + MySQL.database, MySQL.user, MySQL.password);
            final Statement st = con.createStatement();
            try {
                final ResultSet rs = st.executeQuery("SELECT * FROM Sloty WHERE slot='" + SlotManager.getSlots()+ "'");
                if (rs.next()) {
                    st.execute("UPDATE Sloty SET slot='" + SlotManager.getSlots() + "'");
                }
                else {
                    st.execute("INSERT INTO Sloty VALUES('" + SlotManager.getSlots() +"')");
                }
            }
            catch (SQLException sqle) {
                sqle.printStackTrace();
                System.out.print(" > Nie mozna dodac rekordu");
            }
        }
        catch (SQLException sqle2) {
            System.out.print(" > Nie udalo sie polaczyc z baza danych");
        }
    }

    public static void removeRecord(final String nick) {
        try {
            final Connection con = DriverManager.getConnection(String.valueOf(MySQL.url) + MySQL.database, MySQL.user, MySQL.password);
            final Statement st = con.createStatement();
            try {
                st.execute("DELETE FROM Sloty WHERE slot='" + SlotManager.getSlots()+ "'");
            }
            catch (SQLException sqle) {
                sqle.printStackTrace();
                System.out.print(" > Nie mozna usunac rekordu");
            }
        }
        catch (SQLException sqle2) {
            System.out.print(" > Nie udalo sie polaczyc z baza danych");
        }
    }
}