package me.Klezh.FFA.MySQL;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import me.Klezh.FFA.Main;

import org.bukkit.Bukkit;

public class MySQL
{
  public static String username = Main.getInstance().getConfig().getString("MySQL.username");
  public static String password = Main.getInstance().getConfig().getString("MySQL.password");
  public static String database = Main.getInstance().getConfig().getString("MySQL.database");
  public static String host = Main.getInstance().getConfig().getString("MySQL.host");
  public static String port = Main.getInstance().getConfig().getString("MySQL.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, username, password);
        Main.getInstance();
        Bukkit.getConsoleSender().sendMessage("§6FFA §aMySQL connected");
      }
      catch (SQLException e) {
        e.printStackTrace();
      }
    }
  }

  public static void close() {
    if (isConnected()) {
      try {
        con.close();
        Main.getInstance();
        Bukkit.getConsoleSender().sendMessage("§6FFA §cMySQL 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 FFA (UUID VARCHAR(100), NAME VARCHAR(16), KILLS int, DEATHS int)");
        Main.getInstance();
        Bukkit.getConsoleSender().sendMessage("§6FFA §aMySQL 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;
  }
}