package tk.fastdragon.utils;


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.ChatColor;


	public class MySQL {

		public static String HOST = "";
		public static String DATABASE = "";
		public static String USER = "";
		public static String PASSWORD = "";

		private static Connection con;

		public MySQL(String host, String database, String user, String password) {
			HOST = host;
		    DATABASE = database;
		    USER = user;
		    PASSWORD = password;

		    connect();

		}

		public void connect() {
		    try {
		      MySQL.con = DriverManager.getConnection("jdbc:mysql://" + HOST + ":3306/" + DATABASE + "?autoReconnect=true", USER, PASSWORD);
		      Bukkit.getConsoleSender().sendMessage(ChatColor.DARK_GREEN + "[Lobby] Die Verbindung mit der MySQL Datenbank wurde hergestellt");
		    } catch (SQLException e) {
		      Bukkit.getConsoleSender().sendMessage(ChatColor.RED + "[Lobby] Es konnte keine Verbindung zur MySQL Datenbank hergestellt werden es ist folgender Fehler aufgetreten: " + e.getMessage());
		    }
		}

		public static Connection getConnection() {
			return con;
		}

		public static boolean isConnected() {
			if (con != null) {
				return true;
			} else {
				return false;
			}
		}

		public void disConnect() {
			if (con != null) {
				try {
					con.close();
				} catch (SQLException e) {
				}
			}
		}

		public void update(String sql) {
			try {
				Statement st = con.createStatement();
				st.executeUpdate(sql);
			} catch (SQLException e) {
			}

		}
		public ResultSet query(String qry) {
		    ResultSet rs = null;
		    try
		    {
		      Statement st = MySQL.con.createStatement();
		      rs = st.executeQuery(qry);
		    } catch (SQLException e) {
		      connect();
		      System.err.println(e);
		    }
		    return rs;
		  }
	}