package fr.yowatsup.gestion;

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;

import fr.yowatsup.cache.PlayerData;
import fr.yowatsup.grades.Rank;

public class SqlConnection {

    private Connection connection;
    private String urlbase,host,database,user,pass;
    private Coins pl;


    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("connected ok");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public void disconnect(){
        if(isConnected()){
            try {
                connection.close();
                System.out.println("connected off");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    /*
     * INSERT
     * UPDATE
     * DELETE
     * SELECT
     *
     * PREPARER ?,?
     * REMPLACER LES ? PAR DES VALEURS
     * EXECUTE
     *
     */

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

    public void createAccount(Player player){
        if(!hasAccount(player)){
            //INSERT

            try {
                PreparedStatement q = connection.prepareStatement("INSERT INTO joueurs(uuid,coins,grade) VALUES (?,?,?)");
                q.setString(1, player.getUniqueId().toString());
                q.setInt(2, 100);
                q.setInt(3, Rank.JOUEUR.getPower());
                q.execute();
                q.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }


        }
    }

    public boolean hasAccount(Player player){
        //SELECT

        try {
            PreparedStatement q = connection.prepareStatement("SELECT uuid FROM joueurs WHERE uuid = ?");
            q.setString(1, player.getUniqueId().toString());
            ResultSet resultat = q.executeQuery();
            boolean hasAccount = resultat.next();
            q.close();
            return hasAccount;
        } catch (SQLException e) {
            e.printStackTrace();
        }

        return false;
    }

    public int getBalance(Player player){
          //SELECT
          if(pl.dataPlayers.containsKey(player)){
              PlayerData dataP = pl.dataPlayers.get(player);
              return dataP.getCoins();
          }

          return 0;
    }

    public void addMoney(Player player,int amount){

        if(pl.dataPlayers.containsKey(player)){
            PlayerData dataP = pl.dataPlayers.get(player);
            int coins = dataP.getCoins() + amount;
            dataP.setCoins(coins);
            pl.dataPlayers.remove(player);
            pl.dataPlayers.put(player, dataP);
        }

    }

    public void removeMoney(Player player,int amount){

        if(pl.dataPlayers.containsKey(player)){
            PlayerData dataP = pl.dataPlayers.get(player);
            int coins = dataP.getCoins() - amount;

            if(coins <= 0){
                return;
            }

            dataP.setCoins(coins);
            pl.dataPlayers.remove(player);
            pl.dataPlayers.put(player, dataP);
        }

    }

    public void setRank(Player player, Rank rank){

        if(pl.dataPlayers.containsKey(player)){
            PlayerData dataP = pl.dataPlayers.get(player);
            dataP.setRank(rank);
            pl.dataPlayers.remove(player);
            pl.dataPlayers.put(player, dataP);
        }

    }

    public Rank getRank(Player player){

      if(pl.dataPlayers.containsKey(player)){
          PlayerData dataP = pl.dataPlayers.get(player);
          return dataP.getRank();
      }

       return Rank.JOUEUR;
    }

    public PlayerData createPlayerData(Player player){

        if(!pl.dataPlayers.containsKey(player)){
            try {
                PreparedStatement rs = connection.prepareStatement("SELECT coins, grade FROM joueurs WHERE uuid = ?");
                rs.setString(1, player.getUniqueId().toString());
                ResultSet resultats = rs.executeQuery();

                int coins = 0;
                Rank rank = Rank.JOUEUR;

                while(resultats.next()){
                    coins = resultats.getInt("coins");
                    rank = Rank.powerToRank(resultats.getInt("grade"));
                }

                PlayerData dataP = new PlayerData();
                dataP.setCoins(coins);
                dataP.setRank(rank);
                return dataP;


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

        return new PlayerData();

    }

    public void updatePlayerData(Player player){

        if(pl.dataPlayers.containsKey(player)){

            PlayerData dataP = pl.dataPlayers.get(player);
            int coins = dataP.getCoins();
            Rank rank = dataP.getRank();
            int power = rank.getPower();

            try {
                PreparedStatement rs = connection.prepareStatement("UPDATE joueurs SET grade = ?, coins = ? WHERE uuid = ?");
                rs.setInt(1, power);
                rs.setInt(2, coins);
                rs.setString(3, player.getUniqueId().toString());
                rs.executeUpdate();
                rs.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }


        }

    }




}