package WebOnline;

/* import java.util.Calendar; */
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Set;

import org.bukkit.Bukkit;
import org.bukkit.ChatColor;
import org.bukkit.command.Command;
import org.bukkit.command.CommandSender;
import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.player.PlayerJoinEvent;
import org.bukkit.event.player.PlayerKickEvent;
import org.bukkit.event.player.PlayerQuitEvent;
import org.bukkit.permissions.Permission;
import org.bukkit.permissions.PermissionAttachmentInfo;
import org.bukkit.plugin.PluginManager;
import org.bukkit.plugin.java.JavaPlugin;

import ru.tehkode.permissions.bukkit.PermissionsEx;

/* p.sendMessage("§e[Slots]:§7 " + getConfig().getInt(".Slots")); */


public class WebOnlineList extends JavaPlugin  implements Listener{


		    @Override
		    public void onEnable() {

		    	System.out.println("WebOnlineList Aktiviert");
		    	PluginManager pm = Bukkit.getServer().getPluginManager();
		        pm.registerEvents(this, this);


		    }

		    @Override
		    public void onDisable() {

		    	System.out.println("WebOnlineList Deaktiviert");

		    }


	public static void main(String[] args)  {



	}


	public boolean onCommand(CommandSender sender, Command cmd, String label, String[] args) {
		Player player = null;
		if (sender instanceof Player) {
			player = (Player) sender;
		}

		if (cmd.getName().equalsIgnoreCase("webonlinelist")){
			if(player.hasPermission("WebOnlineList.help")) {

				player.sendMessage(ChatColor.GRAY + "/dbconn" + ChatColor.GOLD + "  Datenbank Verbindung cheken");
				player.sendMessage(ChatColor.GRAY + "/tbcreate" + ChatColor.GOLD + "  Datenbanktabelle erstellen");
				player.sendMessage(ChatColor.GRAY + "/tbdelete" + ChatColor.GOLD + "  Datenbanktabelle löschen");


			}
			else{
				player.sendMessage(ChatColor.RED + "Du hast nicht die benötigten Berechtigungen um das zu tun!");
			}
				return true;
			}

		if (cmd.getName().equalsIgnoreCase("tbcreate")){
			if(player.hasPermission("WebOnlineList.create")) {


				final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
			    final String DB_URL = "jdbc:mysql://localhost:3306/ni210329_2_DB";

			    final String USER = "ni210329_2_DB";
			    final String PASS = "90EgubkU";

			   Connection conn = null;
			   Statement stmt = null;
			   try{
			      Class.forName("com.mysql.jdbc.Driver");

			      System.out.println("Erstelle Verbindung zur Datenbank");
			      player.sendMessage(ChatColor.YELLOW + "Erstelle Verbindung zur Datenbank");

			      conn = DriverManager.getConnection(DB_URL, USER, PASS);
			      System.out.println("Verbindung zur Datenbank hergestellt");
			      player.sendMessage(ChatColor.YELLOW + "Verbindung zur Datenbank hergestellt");

			      System.out.println("Erstellt Tabelle");

			      stmt = conn.createStatement();

			      String sql = "CREATE TABLE users ("
			    		    + "InGameName VARCHAR(100),"
			    		    + "uuid VARCHAR(100),"
			    		    + "Rang VARCHAR(100),"
			    		    + "PRIMARY KEY(InGameName)"
			    		    + ")";

			      stmt.executeUpdate(sql);
			      System.out.println("Erstellt DatenbankTabelle in der Datenbank");
			      player.sendMessage(ChatColor.YELLOW + "Erstellt DatenbankTabelle in der Datenbank");

			   }catch(SQLException se){
			      se.printStackTrace();
			   }catch(Exception e){
			      e.printStackTrace();
			   }finally{
			      try{
			         if(stmt!=null)
			            conn.close();
			      }catch(SQLException se){
			      }
			      try{
			         if(conn!=null)
			            conn.close();
			      }catch(SQLException se){
			         se.printStackTrace();
			      }
			   }
			   System.out.println("DatenbankTabelle erfolgreich erstellt");
			   player.sendMessage(ChatColor.GREEN + "DatenbankTabelle erfolgreich erstellt");
			}

			return true;
		}

		if (cmd.getName().equalsIgnoreCase("tbdelete")){
			if(player.hasPermission("WebOnlineList.delete")) {


				   final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
				   final String DB_URL = "jdbc:mysql://localhost/ni210329_2_DB";

				   final String USER = "ni210329_2_DB";
				   final String PASS = "90EgubkU";

				   Connection conn = null;
				   Statement stmt = null;
				   try{
				      Class.forName("com.mysql.jdbc.Driver");

				      System.out.println("Erstelle Verbindung zur Datenbank");
				      player.sendMessage(ChatColor.YELLOW + "Erstelle Verbindung zur Datenbank");
				      conn = DriverManager.getConnection(DB_URL, USER, PASS);
				      System.out.println("Verbindung zur Datenbank erstellt");
				      player.sendMessage(ChatColor.YELLOW + "Verbindung zur Datenbank erstellt");
				      stmt = conn.createStatement();

				      String sql = "DROP TABLE IF EXISTS users";

				      stmt.executeUpdate(sql);
				      System.out.println("DatenbankTabelle wurde gelöscht");
				      player.sendMessage(ChatColor.GREEN + "DatenbankTabelle wurde gelöscht");
				   }catch(SQLException se){
				      se.printStackTrace();
				   }catch(Exception e){
				      e.printStackTrace();
				   }finally{
				      try{
				         if(stmt!=null)
				            conn.close();
				      }catch(SQLException se){
				      }
				      try{
				         if(conn!=null)
				            conn.close();
				      }catch(SQLException se){
				         se.printStackTrace();
				      }
				   }
			}

			return true;
		}

	if (cmd.getName().equalsIgnoreCase("dbconn")){
		if(player.hasPermission("WebOnlineList.verbunden")) {


			final String hostname = "localhost";
	        final String port = "3306";
	        final String dbname = "ni210329_2_DB";
	        final String user = "ni210329_2_DB";
	        final String password = "90EgubkU";

	        Connection conn = null;

	        try {
	        	player.sendMessage(ChatColor.DARK_BLUE + "* Treiber laden");
	        	System.out.println("* Treiber laden");
	      	    Class.forName("com.mysql.jdbc.Driver").newInstance();
	        }
	        catch (Exception e) {
	            System.err.println("Treiber konnte nicht geladen werden.");
	            player.sendMessage(ChatColor.RED + "* Treiber konnte nicht geladen werden.");
	            e.printStackTrace();
	        }
	        try {
	        	player.sendMessage(ChatColor.DARK_BLUE + "* Verbindung aufbauen");
	        	System.out.println("* Verbindung aufbauen");
		    String url = "jdbc:mysql://"+hostname+":"+port+"/"+dbname;
		    conn = DriverManager.getConnection(url, user, password);

		    System.out.println("* Datenbank verbindung erfolgreich");
		    player.sendMessage(ChatColor.YELLOW +"* Datenbank verbindung erfolgreich");
		    conn.close();
	        }
	        catch (SQLException sqle) {
	            System.out.println("SQLException: " + sqle.getMessage());
	            System.out.println("SQLState: " + sqle.getSQLState());
	            System.out.println("VendorError: " + sqle.getErrorCode());
	            player.sendMessage(ChatColor.RED + "* Fehler beim Verbinden, siehe Konsole");
	            sqle.printStackTrace();
	        }

	    }
		} else {

			player.sendMessage(ChatColor.RED + "Du hast nicht die benötigten Berechtigungen um das zu tun!");

		}
		return true;
	}


	@EventHandler
	public void onPlayerJoin(PlayerJoinEvent event) throws SQLException, Exception {

		 try
		    {
		      String myDriver = "com.mysql.jdbc.Driver";
		      String myUrl = "jdbc:mysql://localhost/ni210329_2_DB";
		      String uuid = event.getPlayer().getUniqueId().toString();
		      Player player = event.getPlayer();
			  String name = player.getName();
			  String Rang = PermissionsEx.getUser(player).getGroups()[0].getName();

		      Class.forName(myDriver);
		      Connection conn = DriverManager.getConnection(myUrl, "ni210329_2_DB", "90EgubkU");


		      String query = " insert into users (InGameName, uuid, Rang)"
		        + " values (?, ?, ?)";

		      PreparedStatement preparedStmt = conn.prepareStatement(query);
		      preparedStmt.setString (1, "" + name);
		      preparedStmt.setString (2, "" + uuid);
		      preparedStmt.setString (3, "" + Rang);

		      preparedStmt.execute();

		      System.out.println("Erfolgreich");

		      conn.close();
		    }
		    catch (Exception e)
		    {
		      System.err.println("Got an exception!");
		      System.err.println(e.getMessage());
		    }
	}


	@EventHandler
	public void onPlayerQuit(PlayerQuitEvent event) throws SQLException, Exception{

		 try
		    {
		      String myDriver = "com.mysql.jdbc.Driver";
		      String myUrl = "jdbc:mysql://localhost/ni210329_2_DB";
		      Player player = event.getPlayer();
			  String name = player.getName();
		      Class.forName(myDriver);
		      Connection conn = DriverManager.getConnection(myUrl, "ni210329_2_DB", "90EgubkU");

		      String query = "delete from users where InGameName = ?";
		      PreparedStatement preparedStmt = conn.prepareStatement(query);
		      preparedStmt.setString(1, "" + name);

		      preparedStmt.execute();

		      conn.close();
		    }
		    catch (Exception e)
		    {
		      System.err.println("Got an exception! ");
		      System.err.println(e.getMessage());
		    }
		  }

	@EventHandler
	public void onPlayerKick(PlayerKickEvent event) throws SQLException, Exception{

		try
	    {
	      String myDriver = "com.mysql.jdbc.Driver";
	      String myUrl = "jdbc:mysql://localhost/ni210329_2_DB";
	      Player player = event.getPlayer();
		  String name = player.getName();
	      Class.forName(myDriver);
	      Connection conn = DriverManager.getConnection(myUrl, "ni210329_2_DB", "90EgubkU");

	      String query = "delete from users where InGameName = ?";
	      PreparedStatement preparedStmt = conn.prepareStatement(query);
	      preparedStmt.setString(1, "" + name);

	      preparedStmt.execute();

	      conn.close();
	    }
	    catch (Exception e)
	    {
	      System.err.println("Got an exception! ");
	      System.err.println(e.getMessage());
	    }


	/* Das Plugin WebOnlineList darf nicht verändert werden! */

}
}