package de.DevEyes.MySQL;

import java.io.File;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.UUID;

import org.bukkit.Bukkit;
import org.bukkit.configuration.file.FileConfiguration;
import org.bukkit.configuration.file.YamlConfiguration;


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 MySQL(String user, String pass, String host2, String dB) {}

  public static void connect()
  {
    if (!isConnected()) {
      try
      {
        con = DriverManager.getConnection("jdbc:mysql://" + host + ":" + port + "/" + database + "?autoReconnect=true", username, password);
        Bukkit.getConsoleSender().sendMessage("MySQL MySQL connected");
      }
      catch (SQLException e)
      {
        e.printStackTrace();
      }
    }
  }

  public static void close()
  {
    if (isConnected()) {
      try
      {
        con.close();
        Bukkit.getConsoleSender().sendMessage("MySQL MySQL disconnected");
      }
      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 SkyPvP (UUID VARCHAR(100), NAME VARCHAR(80), KILLS int, DEATHS int , POINTS int)");
        con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS BannedPlayers (Spielername VARCHAR(100), UUID VARCHAR(100), Ende VARCHAR(100), Grund VARCHAR(100))");
        con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS MutedPlayers (Spielername VARCHAR(100), UUID VARCHAR(100), Ende VARCHAR(100), Grund VARCHAR(100))");
        Bukkit.getConsoleSender().sendMessage("MySQL MySQL Table created");
      }
      catch (SQLException e)
      {
        e.printStackTrace();
      }
    }
  }

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

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

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

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

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

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

    cfg.options().copyDefaults(true);
    cfg.addDefault("username", "root");
    cfg.addDefault("password", "password");
    cfg.addDefault("database", "localhost");
    cfg.addDefault("host", "localhost");
    cfg.addDefault("port", "3306");
    try
    {
      cfg.save(getMySQLFile());
    }
    catch (IOException e)
    {
      e.printStackTrace();
    }
  }

  public static void readMySQL()
  {
    FileConfiguration cfg = getMySQLFileConfiguration();
    username = cfg.getString("username");
    password = cfg.getString("password");
    database = cfg.getString("database");
    host = cfg.getString("host");
    port = cfg.getString("port");
  }

  public static String getPlayerGroup(UUID uuid)
  {
    try
    {
      PreparedStatement ps = con.prepareStatement("SELECT * FROM permissions_inheritance WHERE child = ?");
      ps.setString(1, uuid.toString());
      ResultSet result = ps.executeQuery();
      result.next();
      String rank = result.getString("parent");
      result.close();
      ps.close();
      return rank;
    }
    catch (SQLException localSQLException) {}
    return "Spieler";
  }
}