package mysql;

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

import org.bukkit.Bukkit;
import org.bukkit.event.Listener;



public class Connector implements Listener {

	public static String host = "localhost";
	public static String port = "3306";
	public static String database = "";
	public static String user = "";
	public static String password = "";
	public static java.sql.Connection con;

	public static void connect(){
		if(!isConnect()){
			try{
				con = DriverManager.getConnection("jdbc:mysql://"+ host+ ":" + port+ "/"+ database,user, password);
				Bukkit.getConsoleSender().sendMessage("§4MySQL verbunden.");
			} catch (SQLException e){
				e.printStackTrace();
			}
		}

	}

public static void disconnect(){

	if(isConnect()){
		try {
			con.close();
			Bukkit.getConsoleSender().sendMessage("§4MySQL getrennt.");
		} catch (SQLException e) {

			e.printStackTrace();
		}

	}
	}

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

}

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

}

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

	}
	return null;

}

}