package de.officialwayn.qsg.mysql;

import java.io.File;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import org.bukkit.configuration.file.YamlConfiguration;

public class MySQL {

	private static String HOST;
	private static String DATABASE;
	private static String USER;
	private static String PASSWORD;
	public static Connection con;

	public static void registerMySQLConfig() {
		File file = new File("plugins//QSG", "mysql.yml");
		YamlConfiguration cfg = YamlConfiguration.loadConfiguration(file);

		cfg.addDefault("HOST", "localhost");
		cfg.addDefault("DATABASE", "qsgstats");
		cfg.addDefault("USER", "root");
		cfg.addDefault("PASSWORD", "password");
		cfg.addDefault("PORT", 3306);

		cfg.options().copyDefaults(true);

		try {
			cfg.save(file);
		} catch (IOException e) {
			e.printStackTrace();
		}

		String host = cfg.getString("HOST");
		HOST = host;
		String database = cfg.getString("DATABASE");
		DATABASE = database;
		String user = cfg.getString("USER");
		USER = user;
		String password = cfg.getString("PASSWORD");
		PASSWORD = password;

	}

	public MySQL() {

		connect();
	}

	public void connect() {
		try {
			con = DriverManager.getConnection("jdbc:mysql://" + HOST + ":3306/" + DATABASE + "?autoReconnect=true",
					USER, PASSWORD);
			System.out.println("MySQL - Erfolgreich hergestellt");
		} catch (SQLException e) {
			System.out.println("MySQL - Fehler | Fehler: " + e.getMessage());
		}
	}

	public void close() {
		try {
			if (con != null) {
				con.close();
				System.out.println("[MySQL] Die Verbindung zur MySQL wurde Erfolgreich beendet!");
			}
		} catch (SQLException e) {
			System.out.println("[MySQL] Fehler beim beenden der Verbindung zur MySQL! Fehler: " + e.getMessage());
		}
	}

	public void update(String qry) {
		try {
			Statement st = con.createStatement();
			st.executeUpdate(qry);
			st.close();
		} catch (SQLException e) {
			connect();
			System.err.println(e);
		}
	}

	public ResultSet query(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 int getRank(String uuid) {
		int rank = 0;
		try {
			PreparedStatement ps = (PreparedStatement) con
					.prepareStatement("SELECT * FROM qsgstats ORDER BY POINTS DESC");
			ResultSet result = ps.executeQuery();
			while (result.next()) {
				rank++;
				String uuid2 = result.getString("UUID");
				if (uuid2.equalsIgnoreCase(uuid)) {
					return rank;

				}
			}
			result.close();
			ps.close();
		} catch (Exception ex) {
			ex.printStackTrace();
		}
		return rank;
	}

	public void reconnect() {
		if (con == null) {
			connect();
		}

	}
}