package de.MongolenKeks.MySQL;

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

import org.bukkit.Bukkit;

public class MySQL {

	public Connection con;
	public String host;
	public String port;
	public String database;
	public String username;
	public String password;

	public MySQL(String host, String port, String database, String username, String password) {
		this.host = host;
		this.port = port;
		this.database = database;
		this.username = username;
		this.password = password;
	}

	public void connect() {
		if (!(isConnected())) {
			try {
				con = DriverManager.getConnection("jdbc:mysql://" + host + ":" + port + "/" + database, username,
						password);
				//Bukkit.getConsoleSender().sendMessage("§8» §eMySQL §8» §aVerbindung erfolgreich hergestellt!");
			} catch (SQLException e) {
				Bukkit.getConsoleSender().sendMessage("");
				Bukkit.getConsoleSender().sendMessage("§7+§8-----------------§2LobbySystem§8-----------------------§7+");
				Bukkit.getConsoleSender().sendMessage("§7|       §c Das Plugin wurde nicht Aktiviert         §7  |");
				Bukkit.getConsoleSender().sendMessage("§7+§8---------------------------------------------------§7+");
				Bukkit.getConsoleSender().sendMessage("");
				//e.printStackTrace();
				Bukkit.getConsoleSender().sendMessage("§8» §eMySQL §8» §cMySQL-Verbindung fehlgeschlagen!");
				Bukkit.getConsoleSender().sendMessage("§8» §eMySQL §8» §cCheck MySQL.yml");
			}
		}
	}

	public void disconnect() {
		if (isConnected()) {
			try {
				con.close();
				Bukkit.getConsoleSender().sendMessage("§8» §eMySQL §8» §aVerbindung wurde erfolgreich getrennt!");
			} catch (SQLException e) {
				e.printStackTrace();
				Bukkit.getConsoleSender().sendMessage("§8» §eMySQL §8» §cCouldn't disconnect from database!");
			}
		}
	}

	public void update(String qry) {
		try {
			con.createStatement().executeUpdate(qry);
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}

	public ResultSet getResult(String qry) {
		try {
			return con.prepareStatement(qry).executeQuery();
		} catch (SQLException e) {
			e.printStackTrace();
		}

		return null;
	}

	public boolean isConnected() {
		return (con != null ? true : false);
	}

}