package mysql;

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

import org.bukkit.Bukkit;

import com.mysql.jdbc.Connection;

import 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 = (Connection) DriverManager.getConnection("jdbc:mysql://" + host + ":" + port +"/" + database, username, password);
			Bukkit.getConsoleSender().sendMessage(Main.getInstance().prefix + "MySQL verbunden!");
		}catch (SQLException e){
			e.printStackTrace();
		}

	}
	}
	public static void close(){
		if(isConnected()){
			try {
				con.close();
				Bukkit.getConsoleSender().sendMessage(Main.getInstance().prefix + "MySQL verbindung getrennt!");
			} 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), Ende 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 getResult(String qry){
		if(isConnected()){
			try {
				 return con.createStatement().executeQuery(qry);
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		return null;
	}
}