package mertero.coinapi;

import java.io.File;
import java.sql.ResultSet;
import java.sql.SQLException;

import org.bukkit.Bukkit;
import org.bukkit.configuration.file.FileConfiguration;
import org.bukkit.configuration.file.YamlConfiguration;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.player.AsyncPlayerPreLoginEvent;
import org.bukkit.plugin.java.JavaPlugin;




public class Main extends JavaPlugin implements Listener {

	public static MySQL mysql;


	public void onEnable() {
		Bukkit.getPluginManager().registerEvents(this, this);
		loadConfig();
		ConnectMySQL();
	}

	public void loadConfig() {

		FileConfiguration cfg = this.getConfig();

		cfg.addDefault("mysql.host", "localhost");
		cfg.addDefault("mysql.database", "skypvp");
		cfg.addDefault("mysql.user", "root");
		cfg.addDefault("mysql.password", "123456");


		cfg.options().copyDefaults(true);

		saveConfig();
	}

	private void ConnectMySQL() {


		File file = new File("plugins//CoinsAPI//config.yml");
		FileConfiguration mcfg = YamlConfiguration.loadConfiguration(file);

		String host = mcfg.getString("mysql.host");
	    String database = mcfg.getString("mysql.database");
	    String user = mcfg.getString("mysql.user");
	    String password = mcfg.getString("mysql.password");
	    mysql = new MySQL(host, database, user, password);
		mysql.connect();
		mysql.update("CREATE TABLE IF NOT EXISTS coins(name varchar(100) UNIQUE, coins int)");
	}

	public static int getCoins(String name) {

		ResultSet rs = Main.mysql.query("SELECT coins FROM coins WHERE name = '" + name + "' LIMIT 1");

		try {
			while (rs.next()){
			return rs.getInt("coins"); }
		} catch (SQLException e) {
		}
		return -1;
	}

	public static void setCoins(String name, int amount) {
		Main.mysql.update("UPDATE coins SET coins = " + amount + " WHERE name = '" + name + "'");
	}

	public static boolean isRegistered(String name) {

		ResultSet rs = Main.mysql.query("SELECT * FROM coins WHERE name = '" + name + "' LIMIT 1");
		System.out.println(rs == null);
		try {
			return rs.next();
		} catch (SQLException e) {
		}
		return false;
	}

	public static void register(String name) {
		Main.mysql.update("INSERT INTO coins (name, coins) VALUES ('" + name + "', 0)");

	}

	@EventHandler
	public void onJoin(AsyncPlayerPreLoginEvent e) {
		if (!MySQLStats.isRegistered(e.getName())) {
			MySQLStats.register(e.getName());
		}


	}

}