package fr.hardmc;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import net.md_5.bungee.api.ProxyServer;
import net.md_5.bungee.api.chat.TextComponent;
import net.md_5.bungee.api.connection.ProxiedPlayer;

public class MySQL {

	static String url_base, host, name, username, password, table, coins_table;
	static java.sql.Connection connection;

	@SuppressWarnings("static-access")
	public MySQL(String url_base, String host, String name, String username, String password, String table)
	{
		this.url_base = url_base;
		this.host = host;
		this.name = name;
		this.username = username;
		this.password = password;
		this.table = table;
	}

	public void Connection()
	{
		if(!isConnected())
		{
			try{
				connection = DriverManager.getConnection(url_base + host + "/" + name, username, password);
			}catch (SQLException e){
				e.printStackTrace();
			}
		}
	}

	public boolean isConnected()
	{
		try{
			if((connection == null) || (connection.isClosed()) || (!connection.isValid(5)))
			{
				return false;
			}
			else
			{
				return true;
			}
		}catch(SQLException e)
		{
			e.printStackTrace();
		}
		return false;
	}

	public void deconnection()
	{
		if(isConnected())
		{
			try{
				connection.close();
			}catch (SQLException e)
			{
				e.printStackTrace();
			}
		}
	}

	private static java.sql.Connection getConnection()
	{
		return connection;
	}

	static void AddFriend(ProxiedPlayer p, ProxiedPlayer pp)
	{
		try{
				PreparedStatement sts = getConnection().prepareStatement("SELECT * FROM "+table+" WHERE UUID1 = ? AND UUID2 = ?");
				sts.setString(1, p.getName());
				sts.setString(2, pp.getName());
				ResultSet rs = sts.executeQuery();
			if(!(rs.next()))
			{
				rs.close();

				PreparedStatement sts1 = getConnection().prepareStatement("INSERT INTO "+table+" (UUID1, UUID2) VALUES (?, ?)");
				sts1.setString(1, p.getName());
				sts1.setString(2, pp.getName());
				sts1.executeUpdate();
				sts1.close();

				pp.sendMessage(new TextComponent("§c"+ p.getName()+ " §6vous à ajouté dans à sa liste d'amis."));
				pp.sendMessage(new TextComponent("§a/friend add "+p.getName()+" §apour ajouter §c"+p.getName()+" §aà votre liste d'amis."));

				p.sendMessage(new TextComponent("§c"+pp.getName()+" §6a été prévenu de son ajout dans votre liste d'amis !"));
				p.sendMessage(new TextComponent("§c"+pp.getName()+" §aa bien été ajouter dans votre liste d'amis !"));
			}
			else
			{
				rs.close();

				p.sendMessage(new TextComponent("§c"+pp.getName()+" §6est déjà dans votre liste d'amis !"));
			}

		}catch (SQLException e)
		{
			e.printStackTrace();
		}
	}

	static void RemoveFriend(ProxiedPlayer p, ProxiedPlayer pp)
	{
		try{
			PreparedStatement sts = getConnection().prepareStatement("SELECT * FROM "+table+" WHERE UUID1 = ? AND UUID2 = ?");
			sts.setString(1, p.getName());
			sts.setString(2, pp.getName());
			ResultSet rs = sts.executeQuery();

			if(rs.next())
			{
				rs.close();

				PreparedStatement sts1 = getConnection().prepareStatement("DELETE FROM "+table+" WHERE UUID1 = ? AND UUID2 = ?");
				sts1.setString(1, p.getName());
				sts1.setString(2, pp.getName());
				sts1.executeUpdate();
				sts1.close();

				p.sendMessage(new TextComponent("§c"+pp.getName()+" §ca bien été supprimer de votre liste d'amis !"));
			}
			else
			{
				rs.close();

				p.sendMessage(new TextComponent("§c"+pp.getName()+" §6n'est pas dans votre liste d'amis !"));
			}


		}catch (SQLException e)
		{
			e.printStackTrace();
		}
	}

	//corriger l erreur de la liste
	public static void ListFriend(ProxiedPlayer p)
	{
		String list_online = "§a{En Ligne} §6Ami(s) >> ";
		String list_offline = "§c{Hors Ligne} §6Amis(s) >> ";
		try{
			PreparedStatement sts = getConnection().prepareStatement("SELECT UUID2 FROM "+table+" WHERE UUID1 = ?");
			sts.setString(1, p.getName());
			ResultSet rs = sts.executeQuery();
			java.sql.ResultSetMetaData meta = rs.getMetaData();
			while(rs.next())
			{
				for(int i = 1; i <= meta.getColumnCount(); i++)
				{
					if(!(ProxyServer.getInstance().getPlayer(rs.getString(i)) == null))
					{
						list_online += rs.getString(i)+" ";
					}
					else
					{
						list_offline += rs.getString(i)+" ";
					}
				}
			}

			p.sendMessage(new TextComponent(list_online));
			p.sendMessage(new TextComponent(list_offline));

			sts.close();
			rs.close();

		}catch (SQLException e)
		{
			e.printStackTrace();
		}
	}



	public static int NmbFriend(ProxiedPlayer p)
	{
		int col = 0;
		try{
			PreparedStatement sts = getConnection().prepareStatement("SELECT * FROM "+table+" WHERE UUID1 = ?");
			sts.setString(1, p.getName());
			ResultSet rs = sts.executeQuery();
			while(rs.next())
			{
				col++;
			}

			sts.close();
			rs.close();
		} catch(SQLException e)
		{
			e.printStackTrace();
		}
		return col;
	}

	public static boolean IsFriend(ProxiedPlayer p, ProxiedPlayer pp)
	{
		boolean re = true;
		try{
			PreparedStatement sts = getConnection().prepareStatement("SELECT * FROM"+table+" WHERE UUID1 = ? AND UUID2 = ?");
			sts.setString(1, p.getName());
			sts.setString(2, pp.getName());
			ResultSet rs = sts.executeQuery();

			if(!(rs.next()))
			{
				re = false;
			}
		}catch(SQLException e)
		{
			e.printStackTrace();
		}

		return re;

	}

	public static int ConectFriend(ProxiedPlayer p)
	{
		int col = 0;
		try{
			PreparedStatement sts = getConnection().prepareStatement("SELECT UUID2 FROM "+table+" WHERE UUID1 = ?");
			sts.setString(1, p.getName());
			ResultSet rs = sts.executeQuery();
			java.sql.ResultSetMetaData meta = rs.getMetaData();
			while(rs.next())
			{
				for(int i = 1; i <= meta.getColumnCount(); i++){
					if(!(ProxyServer.getInstance().getPlayer(rs.getString(i)) == null)){
						col++;
					}
				}
			}

			sts.close();
			rs.close();
		} catch(SQLException e)
		{
			e.printStackTrace();
		}
		return col;
	}
}