package Util;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

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

import main.MainClass;

public class MySQL {

	public static String username;
	public static String password;
	public static String database;
	public static String host;
	public static String port;

	public static Connection con;

	public static void connect() {
		if(!isConnected()) {

			try {
				con = DriverManager.getConnection("jdbc:mysql://" + host + ":" + port + "/" + database, username, password);
				ConsoleCommandSender sender = Bukkit.getConsoleSender();
				sender.sendMessage(MainClass.getInstance().pr + "§aMySQL-Verbindung wurde erfolgreich aufgebaut.");
			} catch (SQLException e) {
				e.printStackTrace();
			}

		}

	}
	public static void close() {
		if(isConnected()) {
			try {
				con.close();
				ConsoleCommandSender sender = Bukkit.getConsoleSender();
				sender.sendMessage(MainClass.getInstance().pr + "§aMySQL-Verbindung wurde erfolgreich beendet.");

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

		}

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

	}
	public static void createTable() {

		/*
		 *
		 * Syntax: Spielername, UUID, Ende, Grund
		 *
		 */

		if(isConnected()) {

			Statement stmt = null;

			try {

				String	sSQL	=	"CREATE TABLE IF NOT EXISTS BannedPlayers (Spielername VARCHAR(100), UUID VARCHAR(100), Ende VARCHAR(100), Grund VARCHAR(100))";
				stmt			=	con.createStatement();
				stmt.executeUpdate(sSQL);

			} catch (SQLException e) {

				ConsoleCommandSender sender = Bukkit.getConsoleSender();
				sender.sendMessage(MainClass.getInstance().pr + "§a Fehler in MySQL-Verbindung: "+e.getMessage()+", DB-Statement wurde zurückgesetzt.");

				// e.printStackTrace();

			} finally {
				try {
					stmt.close();
				} catch (Exception ignore) {

				}

			}

		}

	}
	public static void update(String qry) {
		if(isConnected()) {

			try {
				con.createStatement().executeUpdate(qry);
			} catch (SQLException e) {
				e.printStackTrace();
			}

		}

	}
	public static ResultSet getResult(String qry) {
		if(isConnected()) {

			try {
				con.createStatement().executeQuery(qry);
			} catch (SQLException e) {
				e.printStackTrace();

			}

		}
		return null;

	}

}