package de.mcown.mysql;

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

import org.bukkit.Bukkit;

import de.mcown.main.main;



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);
				Bukkit.getConsoleSender().sendMessage(main.getInstance().Prefix+"§cMySQL verbindung aufgebaut!");
			} catch (SQLException e) {

				e.printStackTrace();
			}
		}
	}
	public static void close() {
		if(isconnected()) {
			try {
				con.close();
				Bukkit.getConsoleSender().sendMessage(main.getInstance().Prefix+"§cMySQL verbindung geschlossen!");
			} catch (SQLException e) {

				e.printStackTrace();
			}

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

	public static void createTable() {
		if(isconnected()) {
			try {
				con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS BannedPlayers (Spielername VARCHAR(100), UUID VARCHAR(100), Grund VARCHAR(100))");
			} catch (SQLException e) {

				e.printStackTrace();
			}
		}
	}


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

			e.printStackTrace();
		}
	}
	}
	public static ResultSet getResault(String qry) {
		if(isconnected()) {
			try {
				con.createStatement().executeQuery(qry);
			} catch (SQLException e) {

				e.printStackTrace();
			}
		}
		return null;
	}

}