package eu.Pingugames.main;

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

import org.bukkit.Bukkit;


public class MySQL {

	public static Connection con;

	String host;
	String name;
	String password;
	String database;

	public MySQL(String host, String user, String pw, String db) {
		this.host = host;
		this.name = user;
		this.password = pw;
		this.database = db;
	}

	public void connect() {
		if(!isConnected()) {
			try {
				con = DriverManager.getConnection("jdbc:mysql://" + host + ":3306/" + database + "?autoReconnect=true", name, password);
				Bukkit.getConsoleSender().sendMessage("[MySQL] Verbindung zur MySQL erfolgreich!");
			} catch (SQLException e) {
				e.printStackTrace();
				Bukkit.getConsoleSender().sendMessage("[MySQL] §4Fehler: §c" + e.getMessage());

			}

		}
	}

	public void close() {
		if(isConnected()) {
			try {
				con.close();
				Bukkit.getConsoleSender().sendMessage("[MySQL] Verbindung zur MySQL beendet!");

				} catch (SQLException e) {
				e.printStackTrace();
				Bukkit.getConsoleSender().sendMessage("[MySQL] §4Fehler: §c" + e.getMessage());

			}
		}
	}

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

	}

	public void createTable(String name, String table) {
		try {
			con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS " + name + "(" + table + ")");
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}

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

	public ResultSet getResult(String qry) {
		if(isConnected()) {
			try {
				return con.createStatement().executeQuery(qry);
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		return null;
	}

}