package api.general.sql;

import java.io.File;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;

import org.bukkit.configuration.file.YamlConfiguration;

import api.general.main.GeneralAPI;

public class MySQL {

	private static String user;
	private static String database;
	private static String password;
	private static String port;
	private static String hostname;
	private static Connection connection = null;

	public static boolean checkTable(String name) {

		boolean exists = false;
		try {
			DatabaseMetaData meta = MySQL.getConnection().getMetaData();
			ResultSet res;

			res = meta.getTables(null, null, "", new String[] { "TABLE" });
			while (res.next()) {
				if (res.getString("TABLE_NAME").equals(name))
					exists = true;
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return exists;
	}

	public static void loadMySQLSettings() {

		File file = new File(GeneralAPI.getInstance().getDataFolder(), "mysql.yml");
		YamlConfiguration ymc = YamlConfiguration.loadConfiguration(file);

		hostname = ymc.getString("mysql.hostname");
		port = ymc.getString("mysql.port");
		user = ymc.getString("mysql.user");
		password = ymc.getString("mysql.password");
		database = ymc.getString("mysql.database");

	}

	public static Connection getConnection() {

		if (isConnected())
			return connection;
		else {
			System.out.println("[GeneralAPI-MySQL] Lost MySQL Connection. Reconnecting...");
			connect();
			return connection;
		}

	}

	public static boolean isConnected() {
		try {
			return connection != null && connection.isValid(120);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return false;
	}

	public static void connect() {

		if (isConnected()) {
			try {
				connection.close();
			} catch (SQLException e) {
			}
		}

		try {
			Class.forName("com.mysql.jdbc.Driver");
			connection = DriverManager.getConnection("jdbc:mysql://" + hostname + ":" + port + "/" + database, user,
					password);
			System.out.println("[GeneralAPI-MySQL] Connected to database!");
		} catch (SQLException e) {
			System.out.println("[GeneralAPI-MySQL] Could not connect to MySQL server! Because: " + e.getMessage());
		} catch (ClassNotFoundException e) {
			System.out.println("[GeneralAPI-MySQL] JDBC Driver not found!");
		}

	}

	public static void closeConnection() {
		if (connection != null) {
			try {
				connection.close();
				connection = null;
			} catch (SQLException e) {
				System.out.println("[GeneralAPI-MySQL] Error while closing the MySQL Connection!");
				e.printStackTrace();
			}
		}
	}
}