package me.freaktube.nico.mysql;

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

  public static void connect()
  {
    if (!isConnected())
      try {
        con = DriverManager.getConnection("jdbc:mysql://" + host + ":" + port + "/" + database, username, password);
        Bukkit.getConsoleSender().sendMessage("§8[§6SurvivalSystem§8] §aMySQL Verbindubg wurde erfolgreich hergestellt!");
      } catch (SQLException e) {
        e.printStackTrace();
      }
  }

  public static void close() {
    if (isConnected())
      try {
        con.close();
        Bukkit.getConsoleSender().sendMessage("§8[§6SurvivalSystem§8] §aMySQL Verbindung wurde erfolgreich getrennt!");
      } catch (SQLException e) {
        e.printStackTrace();
      }
  }

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

  public static Connection getConnection() {
    return con;
  }

  public static void createTable() {
    if (isConnected())
      try {
        con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS STATS (UUID VARCHAR(100), KILLS int, DEATHS int, MÜNZEN int, SPIN int)");
        con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS BANSYSTEM (UUID VARCHAR(100), VON VARCHAR(100), GRUND VARCHAR(100), ENDE VARCHAR(100))");
        con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS MUTESYSTEM (UUID VARCHAR(100), VON VARCHAR(100), GRUND VARCHAR(100), ENDE VARCHAR(100))");
        con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS Bounty (id INT AUTO_INCREMENT PRIMARY KEY, UUID VARCHAR(100), NAME VARCHAR(100), HASBOUNTY int, STARTBOUNTY int , BOUNTY int , SETTER VARCHAR(100) , KILLER VARCHAR(100))");
        Bukkit.getConsoleSender().sendMessage("§8[§6SurvivalSystem§8] §aMySQL Tabele wurde erstellt!");
      } 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/SurvivalSystem", "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");
  }
}