package fr.lordgames.dev.lordlogin.sql;

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

import org.bukkit.Bukkit;
import org.bukkit.entity.Player;

import fr.lordgames.dev.lordlogin.utils.Messages;

public class SqlConnection {

	private Connection con;
	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 connect() {
		if(isConnected()) {
			try {
				con = DriverManager.getConnection(urlbase+host+"/"+database,user,pass);
				Bukkit.getServer().getConsoleSender().sendMessage(Messages.CONNECTION_SUCCESS_FOR_DATABASE.getMessage());
			}catch(SQLException e) {e.printStackTrace();}}
	}

	public void disconect() {
		if(isConnected()) {
			try {
				con.close();
				Bukkit.getConsoleSender().sendMessage(Messages.DISCONNECT_WITH_DATABASE.getMessage());
			}catch(SQLException e) {e.printStackTrace();}}
	}

	public void createAccount(Player player) {
		if(!hasAccount(player)) {
			try {
				PreparedStatement q = con.prepareStatement("INSERT INTO players_info(user,password,rank,coins) VALUES (?,?,?,?)");
				q.setString(1, player.getName().toString());
				q.setString(2, "null");
				q.setString(3, "JOUEUR");
				q.setInt(4, 0);
				q.execute();
				q.close();
			}catch(SQLException e) {e.printStackTrace();}
		}
	}

	public boolean hasAccount(Player player) {
		try {
			PreparedStatement q = con.prepareStatement("SELECT user FROM players_info WHERE user = ?");
			q.setString(1, player.getName().toString());
			ResultSet rs = q.executeQuery();
			boolean hasAccount = rs.next();
			q.close();
			return hasAccount;
		}catch(SQLException e) {e.printStackTrace();}
		return false;
	}

	public void setPassword(String player, String password) {
		try {
			PreparedStatement q = con.prepareStatement("UPDATE players_info SET password = ? WHERE user = ?");
			q.setString(1, password);
			q.setString(2, player);
			q.executeUpdate();
			q.close();
		}catch(SQLException e) {e.printStackTrace();}
	}

	public String getPassword(Player player){
	    try{
	      PreparedStatement q = this.con.prepareStatement("SELECT password FROM players_info WHERE user = ?");
	      q.setString(1, player.getUniqueId().toString());
	      String motdepasse = "0";
	      ResultSet rs = q.executeQuery();
	      while (rs.next()) {
	        motdepasse = rs.getString("motdepasse");
	      }
	      q.close();
	      return motdepasse;
	    }
	    catch (SQLException e){
	      e.printStackTrace();
	    }
	    return "null";
	  }

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