package Mars.PVP.SQL;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import org.bukkit.Bukkit;
import org.bukkit.command.ConsoleCommandSender;

public class MySQL {
    public static String username;
    public static String password;
    public static String database;
    public static String host;
    public static int port;
    public static Connection con;
    public static MySQL mysql;

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

    public static void connect() {
        if (!isConnected()) {
            try {
                con = java.sql.DriverManager.getConnection("jdbc:mysql://" + host + ":" + port + "/" + database,
                        username, password);
                Bukkit.getConsoleSender().sendMessage("§aMySQL connection established succesfully");
            } catch (SQLException e) {
                e.printStackTrace();
                Bukkit.getConsoleSender().sendMessage("§cMySQL connection failed!");
            }
        }
    }

    public static void close() {
        if (isConnected()) {
            try {
                con.close();
                Bukkit.getConsoleSender().sendMessage("§2MySQL connection closed succesfully!");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

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

    public static java.sql.ResultSet getResult(String qry) {
        if (isConnected()) {
            try {
                PreparedStatement pt = con.prepareStatement(qry);

                return pt.executeQuery();
            } catch (SQLException e) {
                e.printStackTrace();
                return null;
            }
        }
        return null;
    }

    public static void createTables() {
        if (isConnected()) {
            try {
                con.createStatement().executeUpdate(
                        "CREATE TABLE IF NOT EXISTS FFA (Playername VARCHAR(100), Kills int, Deaths int,Souls int,Selector VARCHAR(100), Points int)");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static void createTableKillStreaks() {
        if (isConnected()) {
            try {
                con.createStatement().executeUpdate(
                        "CREATE TABLE IF NOT EXISTS KillStreakSQL (Playername VARCHAR(100), KillStreak int)");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static void createTableShop() {
        if (isConnected()) {
            try {
                con.createStatement().executeUpdate(
                        "CREATE TABLE IF NOT EXISTS FFASHOP (Playername VARCHAR(100), Item VARCHAR(100), Buy VARCHAR(100))");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public ResultSet query(String s) {
        ResultSet executeQuery = null;
        try {
            executeQuery = this.con.createStatement().executeQuery(s);
        } catch (SQLException ex) {
            connect();
            System.err.println(ex);
        }
        return executeQuery;
    }

    public static Integer getKills1(String s) {
        Integer n = Integer.valueOf(0);
        if (Stats.exists(s)) {
            try {
                ResultSet query = Mars.PVP.SQL.MySQL.mysql.query("SELECT * FROM FFA WHERE Playername '" + s + "'");
                if (query.next())
                    Integer.valueOf(query.getInt("KILLS"));
                n = Integer.valueOf(query.getInt("KILLS"));
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
        } else {
            Stats.createPlayer(s);
            Stats.getKills(s);
        }
        return n;
    }

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

    public static Connection getConnection() {
        return con;
    }

}