package pl.hugozvplayz.hugobans.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 org.bukkit.configuration.file.YamlConfiguration;

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

  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 static void createTable()
  {
    try
    {
      Connection con = DriverManager.getConnection(url + database, user, password);
      Statement st = con.createStatement();
      try
      {
        st.execute("CREATE TABLE IF NOT EXISTS hugoBans(nick CHAR(16), powod VARCHAR(100), czas CHAR(23), admin CHAR(16))");
      }
      catch (SQLException sqle)
      {
        System.out.print(" > Tabela nie zostala stworzona");
      }
      return;
    }
    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)
  {
    try
    {
      Connection con = DriverManager.getConnection(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 + "'");
        } else {
          st.execute("INSERT INTO hugoBans VALUES('" + nick + "', '" + powod + "', '" + czas + "', '" + admin + "')");
        }
      }
      catch (SQLException sqle)
      {
        sqle.printStackTrace();
        System.out.print(" > Nie mozna dodac rekordu");
      }
      return;
    }
    catch (SQLException sqle)
    {
      System.out.print(" > Nie udalo sie polaczyc z baza danych");
    }
  }

  public static void removeRecord(String nick)
  {
    try
    {
      Connection con = DriverManager.getConnection(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");
      }
      return;
    }
    catch (SQLException sqle)
    {
      System.out.print(" > Nie udalo sie polaczyc z baza danych");
    }
  }
}