package MySQL;

import Main.DekaMain;
import java.io.File;
import java.io.IOException;
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.Bukkit;
import org.bukkit.command.ConsoleCommandSender;
import org.bukkit.configuration.file.FileConfiguration;
import org.bukkit.configuration.file.FileConfigurationOptions;
import org.bukkit.configuration.file.YamlConfiguration;

public class MySQL
{
  public static String Host;
  public static String Datenbank;
  public static String Port;
  public static String Username;
  public static String Password;
  public static Connection con;

  public MySQL(String user, String pass, String host2, String dB) {}

  public static void Connect()
  {
    if (!isConnected()) {
      try
      {
        con = DriverManager.getConnection("jdbc:mysql://" + Host + ":" + Port + "/" + Datenbank + "?user=" + Username + "&password=" + Password + "&autoReconnect=true");
        Bukkit.getConsoleSender().sendMessage(DekaMain.Prefix + "�aDie Verbindung zur MySQL wurde hergestellt!");
      }
      catch (SQLException ex)
      {
        Bukkit.getConsoleSender().sendMessage(DekaMain.Error + "�cDie Verbindung zur MySQL ist fehlgeschlagen!");
      }
    }
  }

  public static void close()
  {
    if (isConnected()) {
      try
      {
        con.close();
        Bukkit.getConsoleSender().sendMessage(DekaMain.Prefix + "�aDie Verbindung zur MySQL wurde erfolgreich beendet!");
      }
      catch (SQLException ex)
      {
        Bukkit.getConsoleSender().sendMessage(DekaMain.Error + "�cFehler beim beenden der Verbindung zur MySQL!");
      }
    }
  }

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

  public static void update(String qry)
  {
    if (isConnected()) {
      try
      {
        con.createStatement().executeUpdate(qry);
      }
      catch (SQLException ex)
      {
        Bukkit.getConsoleSender().sendMessage(DekaMain.Error + "�cKonnte das Update �7(�e" + qry + "�7) �cnicht ausf��hren!");
      }
    }
  }

  public static void createTable()
  {
    if (isConnected()) {
      try
      {
        con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS Knockbackffa (UUID VARCHAR(100), KILLS int, TODE int, COINS int)");
        Bukkit.getConsoleSender().sendMessage("�aDie Table wurde erstellt!");
      }
      catch (SQLException localSQLException) {}
    }
  }

  public static ResultSet query(String qry)
  {
    ResultSet rs = null;
    try
    {
      Statement st = con.createStatement();
      rs = st.executeQuery(qry);
    }
    catch (SQLException ex)
    {
      Connect();
      System.err.println(ex);
    }
    return rs;
  }

  public static File getMySQLFile()
  {
    return new File("plugins/Knockbackffa", "MySQL.yml");
  }

  public static FileConfiguration getMySQLFileConfiguration()
  {
    return YamlConfiguration.loadConfiguration(getMySQLFile());
  }

  public static void setStandardMySQL()
  {
    FileConfiguration cfg = getMySQLFileConfiguration();

    cfg.options().copyDefaults(true);
    cfg.addDefault("Host", "localhost");
    cfg.addDefault("Datenbank", "Datenbank");
    cfg.addDefault("Port", "3306");
    cfg.addDefault("Username", "root");
    cfg.addDefault("Password", "Password");
    try
    {
      cfg.save(getMySQLFile());
    }
    catch (IOException localIOException) {}
  }

  public static void readMySQL()
  {
    FileConfiguration cfg = getMySQLFileConfiguration();
    Host = cfg.getString("Host");
    Datenbank = cfg.getString("Datenbank");
    Port = cfg.getString("Port");
    Username = cfg.getString("Username");
    Password = cfg.getString("Password");
  }
}