package be.darthania.darthaentreprise.bdd;

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

import org.bukkit.entity.Player;

public class SqlConnection
{
	private Connection connection;
	private String urlbase, host, database, user, pass;

	public SqlConnection(String urlbase, String host, String database, String user, String pass)
	{
		this.urlbase = urlbase;
		this.host = host;
		this.database = database;
		this.user = user;
		this.pass = pass;
	}

	public void connection()
	{
		if(!isConnected())
		{
			try
			{
				connection = DriverManager.getConnection(urlbase + host + "/" + database, user, pass);
				System.out.println("[DARTHA-ENTREPRISE] Connection a la BDD..");
			}
			catch (SQLException e)
			{
				e.printStackTrace();
			}
		}
	}

	public void disconnect()
	{
		if(isConnected())
		{
			try
			{
				connection.close();
				System.out.println("[DARTHA-ENTREPRISE] Deconnection de la BDD..");
			}
			catch (SQLException e)
			{
				e.printStackTrace();
			}
		}
	}

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

	public void createAccount(Player joueur)
	{
		if(!hasAccount(joueur))
		{
			try
			{
				PreparedStatement q = connection.prepareStatement("INSERT INTO ent_joueurs (uuid, joueur) VALUES(?, ?)");
				q.setString(1, joueur.getUniqueId().toString());
				q.setString(2, joueur.getName());;
				q.execute();
				q.close();
			}
			catch (SQLException e)
			{
				e.printStackTrace();
			}
		}
	}

	public boolean hasAccount(Player joueur)
	{
		try
		{
			PreparedStatement q = connection.prepareStatement("SELECT uuid FROM ent_joueurs WHERE uuid = ?");
			q.setString(1,  joueur.getUniqueId().toString());
			ResultSet resultat = q.executeQuery();
			boolean hasAccount = resultat.next();
			q.close();
			return hasAccount;

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

	public void createEnterprise(Player joueur)
	{
		if(!hasEnterprise(joueur))
		{
			try
			{
				PreparedStatement rs = connection.prepareStatement("UPDATE ent_joueur SET hasEntreprise = ? WHERE uuid = ?");
				rs.setBoolean(1, true);
				rs.setString(2, joueur.getUniqueId().toString());
				rs.executeUpdate();
				rs.close();
			}
			catch (SQLException e)
			{
				e.printStackTrace();
			}
		}
	}

	public boolean hasEnterprise(Player joueur)
	{
		if(hasAccount(joueur))
		{
			try
			{
				PreparedStatement q = connection.prepareStatement("SELECT uuid FROM ent_joueurs WHERE uuid = ?");
				q.setString(1,  joueur.getUniqueId().toString());

				boolean hasEnterprise = false;
				ResultSet rs = q.executeQuery();

				while(rs.next())
				{
					hasEnterprise = rs.getBoolean("entreprise");
				}
				q.close();
				return hasEnterprise;

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