package me.himc.bany.managers;

import java.io.PrintStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import me.himc.bany.managers.FilesManager;

import org.bukkit.configuration.file.YamlConfiguration;

public class MySQL {
    public static String url = "jdbc:mysql://" + FilesManager.ymlconfig.getString("MySQL.Host") + ":" + FilesManager.ymlconfig.getInt("MySQL.Port") + "/";
    public static String database = FilesManager.ymlconfig.getString("MySQL.Database");
    public static String user = FilesManager.ymlconfig.getString("MySQL.User");
    public static String password = FilesManager.ymlconfig.getString("MySQL.Password");

    public MySQL() {
        if (FilesManager.ymlconfig.getBoolean("MySQL.Enable")) {
            MySQL.createTable();
        }
    }

    public static void createTable() {
        try {
            Connection con = DriverManager.getConnection(String.valueOf(url) + database, user, password);
            Statement st = con.createStatement();
            try {
                st.execute("CREATE TABLE IF NOT EXISTS HimcBany(nick VARCHAR(16), powod VARCHAR(100), czas INT(23), admin CHAR(16))");
            }
            catch (SQLException sqle) {
                System.out.print(" > Tabela nie zostala stworzona");
            }
        }
        catch (SQLException sqle) {
            System.out.print(" > Nie udalo sie polaczyc z baza danych");
        }
    }

    public static void addRecord(String nick, String powod, String czas, String admin) {
        block5 : {
            try {
                Connection con = DriverManager.getConnection(String.valueOf(url) + database, user, password);
                Statement st = con.createStatement();
                try {
                    ResultSet rs = st.executeQuery("SELECT * FROM hugoBans WHERE nick='" + nick + "'");
                    if (rs.next()) {
                        st.execute("UPDATE hugoBans SET powod='" + powod + "', czas='" + czas + "', admin='" + admin + "' WHERE nick='" + nick + "'");
                        break block5;
                    }
                    st.execute("INSERT INTO hugoBans VALUES('" + nick + "', '" + powod + "', '" + czas + "', '" + admin + "')");
                }
                catch (SQLException sqle) {
                    sqle.printStackTrace();
                    System.out.print(" > Nie mozna dodac rekordu");
                }
            }
            catch (SQLException sqle) {
                System.out.print(" > Nie udalo sie polaczyc z baza danych");
            }
        }
    }

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