package me.lukas3482.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 static String username = "SeaStrike";
	public static String password = "cJj7zxx33n3eXK";
	public static String database = "SeaStrike";
	public static String host = "localhost";
	public static String port = "3306";
	public static Connection con;

	public static void Connect()
	{
		if(!isConnected())
		{
			try {
				con = DriverManager.getConnection("jdbc:mysql://" + host + ":" + port + "/" + database, username, password);
				System.out.println("[SeaStrike-Schematic] MySQL Verbindung aufgebaut!");
				Bukkit.getConsoleSender().sendMessage("§4MYSQL");
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	public static void close()
	{
		if(isConnected())
		{
			try {
				System.out.println("[SeaStrike-Schematic]MySQL verbindung geschlossen!");
				con.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

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

	public static void createTable()
	{
		try {
			con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS Mute (Spielername VARCHAR(100), UUID VARCHAR(100), Ende VARCHAR(100), Grund VARCHAR(100))");
			con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS BannedPlayers (Spielername VARCHAR(100), UUID VARCHAR(100), Ende VARCHAR(100), Grund VARCHAR(100))");
			con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS BanHistory (Spielername VARCHAR(100), UUID VARCHAR(100), Grund VARCHAR(100), Bannedby VARCHAR(100))");
			con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS PlayerHistory (id int(11) AUTO_INCREMENT NOT NULL primary key, Spielername VARCHAR(100), UUID VARCHAR(100), FirstJoin VARCHAR(100), IP VARCHAR(100))");
			con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS Ranks (id int(11) AUTO_INCREMENT NOT NULL primary key, Spielername VARCHAR(100), UUID VARCHAR(100), Rank VARCHAR(100))");
			con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS Warn (id int(11) AUTO_INCREMENT NOT NULL primary key, Spielername VARCHAR(100), UUID VARCHAR(100), warns int(11))");
			con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS BanPoints (id int(11) AUTO_INCREMENT NOT NULL primary key, Spielername VARCHAR(100), UUID VARCHAR(100), banpoints int(11))");
			con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS Schems (id int(11) AUTO_INCREMENT NOT NULL primary key, Spielername VARCHAR(100), UUID VARCHAR(100), schemname VARCHAR(100), schemid VARCHAR(100), regelkonform boolean, grund VARCHAR(100), typ VARCHAR(100), gesperrt boolean)");
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}

	public static void Update(String qry)
	{
		if(isConnected())
		{
			try {
				java.sql.PreparedStatement ps = con.prepareStatement(qry);
				ps.executeUpdate(qry);
				con.createStatement().executeUpdate(qry);
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	public static Connection getConnection()
	{
		return con;
	}

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