package me.vertcode.topkills.mysql;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.UUID;

import org.bukkit.entity.Player;

import me.vertcode.topkills.MainCore;
import me.vertcode.topkills.stats.StatsEntry;

public class MysqlUtils {

	static MysqlUtils mysqlUtils = new MysqlUtils();

	private Connection connection;
	public String host, database, username, password;
	public int port;

	public void mysqlSetup(MainCore pl) {

		host = "localhost";
		port = 3306;
		database = "topkills";
		username = "admin";
		password = "123";

		try {
			synchronized (this) {
				if (getConnection() != null && !getConnection().isClosed()) {
					return;
				}

				Class.forName("com.mysql.jdbc.Driver");
				setConnection(
						DriverManager.getConnection("jdbc:mysql://" + this.host + ":" + this.port + "/" + this.database,
								this.username, this.password));

				System.out.print("[VERTCODE-API] MYSQL Connected");

			}
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}

	}

	public Integer getRank(UUID uuid) {
		try {
			Statement e = getConnection().createStatement();
			ResultSet rs = e.executeQuery(
					"SELECT COUNT(*) from `topkills_stats` WHERE kills > " + getStatsEntry(uuid).getKills());
			rs.next();
			return Integer.valueOf(rs.getInt(1) + 1);
		} catch (SQLException var4) {
			var4.printStackTrace();
		}
		return Integer.valueOf(999);
	}

	public Integer getRank(Player ply) {
		try {
			Statement e = getConnection().createStatement();
			ResultSet rs = e.executeQuery(
					"SELECT COUNT(*) from `topkills_stats` WHERE kills > " + getStatsEntry(ply).getKills());
			rs.next();
			return Integer.valueOf(rs.getInt(1) + 1);
		} catch (SQLException var4) {
			var4.printStackTrace();
		}
		return Integer.valueOf(999);
	}

	public Boolean insertStatsEntry(Player ply) {
		try {
			Statement e = getConnection().createStatement();
			ResultSet rs = e
					.executeQuery("SELECT * from `topkills_stats` WHERE uuid='" + ply.getUniqueId().toString() + "'");
			if (!rs.next()) {
				e = getConnection().createStatement();
				e.execute("INSERT INTO `topkills_stats` (uuid, name, kills, deaths) VALUES ('"
						+ ply.getUniqueId().toString() + "', '" + ply.getName() + "', 0, 0)");
				return Boolean.valueOf(true);
			}
		} catch (SQLException var4) {
			var4.printStackTrace();
		}
		return Boolean.valueOf(false);
	}

	public void addDeath(Player ply) {
		addDeaths(ply, Integer.valueOf(1));
	}

	public void addDeaths(Player ply, Integer deaths) {
		try {
			Statement e = getConnection().createStatement();
			e.execute("UPDATE `topkills_stats` SET deaths=deaths+" + deaths + " WHERE uuid='"
					+ ply.getUniqueId().toString() + "'");
		} catch (SQLException var4) {
			var4.printStackTrace();
		}
	}

	public void addKill(Player ply) {
		addKills(ply, Integer.valueOf(1));
	}

	public void addKills(Player ply, Integer kills) {
		try {
			Statement e = getConnection().createStatement();
			e.execute("UPDATE `topkills_stats` SET kills=kills+" + kills + " WHERE uuid='"
					+ ply.getUniqueId().toString() + "'");
		} catch (SQLException var4) {
			var4.printStackTrace();
		}
	}

	public ArrayList<StatsEntry> getTopStats() {
		return getTopStats(Integer.valueOf(10));
	}

	public ArrayList<StatsEntry> getTopStats(Integer limit) {
		ArrayList<StatsEntry> statsEnties = new ArrayList<>();
		try {
			Statement e = getConnection().createStatement();
			ResultSet rs = e.executeQuery("SELECT * from `topkills_stats` ORDER BY kills DESC LIMIT " + limit);
			while (rs.next()) {
				statsEnties.add(new StatsEntry(rs.getString("name"), UUID.fromString(rs.getString("uuid")),
						Integer.valueOf(rs.getInt("kills")), Integer.valueOf(rs.getInt("deaths"))));
			}
		} catch (SQLException var5) {
			var5.printStackTrace();
		}
		return statsEnties;
	}

	public StatsEntry getStatsEntry(Player ply) {
		return getStatsEntry(ply.getUniqueId());
	}

	public StatsEntry getStatsEntry(UUID uuid) {
		try {
			Statement e = getConnection().createStatement();
			ResultSet rs = e.executeQuery("SELECT * from `topkills_stats` WHERE uuid='" + uuid.toString() + "'");
			if (rs.next()) {
				return new StatsEntry(rs.getString("name"), UUID.fromString(rs.getString("uuid")),
						Integer.valueOf(rs.getInt("kills")), Integer.valueOf(rs.getInt("deaths")));
			}
		} catch (SQLException var4) {
			var4.printStackTrace();
		}
		return new StatsEntry("", uuid, Integer.valueOf(0), Integer.valueOf(0));
	}

	public StatsEntry getStatsEntry(String userName) {
		try {
			Statement e = getConnection().createStatement();
			ResultSet rs = e.executeQuery("SELECT * from `topkills_stats` WHERE name='" + userName + "'");
			if (rs.next()) {
				return new StatsEntry(rs.getString("name"), UUID.fromString(rs.getString("uuid")),
						Integer.valueOf(rs.getInt("kills")), Integer.valueOf(rs.getInt("deaths")));
			}
		} catch (SQLException var4) {
			var4.printStackTrace();
		}
		return new StatsEntry("", UUID.randomUUID(), Integer.valueOf(0), Integer.valueOf(0));
	}

	public Connection getConnection() {
		return connection;
	}

	public void setConnection(Connection connection) {
		this.connection = connection;
	}

	public static MysqlUtils getInstance() {
		return mysqlUtils;
	}

}