package de.zexception.mysql;

import java.io.File;
import java.io.IOException;
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.configuration.file.FileConfiguration;
import org.bukkit.configuration.file.YamlConfiguration;

import de.zexception.main.Main;

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 + ":3306/" + database + "?autoReconnect=true", username, password);
        Bukkit.getConsoleSender().sendMessage(Main.prefix + "§4MySQL MySQL connected");
      }
      catch (SQLException e)
      {
        e.printStackTrace();
      }
    }
  }

  public static void close()
  {
    if (isConnected()) {
      try
      {
        con.close();
        Bukkit.getConsoleSender().sendMessage(Main.prefix + "§4MySQL 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 Mute(UUID VARCHAR(100), STATUS int, VON VARCHAR(100), GRUND VARCHAR(100))");
        con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS CoinsAPI (UUID VARCHAR(100), COINS int)");
        con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS Kopfgeld(UUID VARCHAR(100), STATUS int, AMOUNT int)");
        con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS Stats (UUID VARCHAR(100), ID VARCHAR(100), KILLS int, DEATHS int , WIN int , LOSE int , COINS FLOAT)");
        con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS Players (UUID VARCHAR(100), NAME VARCHAR(100))");
        con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS AMS (UUID VARCHAR(100), AMOUNT int, UPGRADE int)");
        //con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS Clan (NAME VARCHAR(100), INHABER VARCHAR(100), PREMIUM int, ANZAHL int, Spieler1 VARCHAR(100), Spieler2 VARCHAR(100),Spieler3 VARCHAR(100),Spieler4 VARCHAR(100),Spieler5 VARCHAR(100),Spieler6 VARCHAR(100),Spieler7 VARCHAR(100),Spieler8 VARCHAR(100),Spieler9 VARCHAR(100),Spieler10 VARCHAR(100))");


        Bukkit.getConsoleSender().sendMessage(Main.prefix + "§4MySQL 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 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/System", "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");
  }
}