package me.poiu47.banmanager.mysql;
 import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.sql.Statement;
 import org.bukkit.Bukkit;
 import org.bukkit.command.ConsoleCommandSender;

import me.poiu47.banmanager.main.Main;







 public class MySQL
 {
   public static String username;
   public static String password;
   public static String datebase;
   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 + "/" + datebase, username, password);
         Main.getInstance();Bukkit.getConsoleSender().sendMessage(Main.prefix + "MySQL Verbindung aufgebaut!");
       } catch (SQLException e) {
         e.printStackTrace();
       }
     }
   }

   public static void close() {
     if (isConnected()) {
       try {
         con.close();
         Main.getInstance();Bukkit.getConsoleSender().sendMessage(Main.prefix + "MySQL Verbindung geschlossen!");
       } catch (SQLException e) {
         e.printStackTrace();
       }
     }
   }


   private 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), Ende VARCHAR(100), Grund VARCHAR(100))");
         con.createStatement().executeUpdate("CREATE TABLE IF NOT EXISTS MutePlayers (Spielername VARCHAR(100), UUID 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;
   }
 }