package com.legendarygames.fr.SQL;

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 SQL {

    private String url, host, name, user, password, table;
    private static Connection connection;

    public SQL(String url, String host, String name, String user, String password, String table){
        this.url = url;
        this.host = host;
        this.name = name;
        this.user = user;
        this.password = password;
        this.table = table;
    }

    public void connection(){
        if(!isConnected()){
            try {
                connection = DriverManager.getConnection(url + host + "/" + name, user, password);
                System.out.println("Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite   Connexion réussite");
            } catch(SQLException e){
                e.printStackTrace();
            }
        }
    }

    public void deconnection() {
        if(isConnected()){
            try {
                connection.close();
            } 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 static Connection getConnection(){
        return connection;
    }

/*    public void CreateAccount(Player p){

        try{
            PreparedStatement sts = getConnection().prepareStatement("SELECT rank FROM " + table + " WHERE uuid = ?");
            sts.setString(1, p.getUniqueId().toString());
            ResultSet rs = sts.executeQuery();
            if(!rs.next()){
                sts.close();
                PreparedStatement sts2 = getConnection().prepareStatement("INSERT INTO " + table + " (uuid, player, rank,connection, coins) VALUES(?, ?)");
                sts2.setString(1, p.getUniqueId().toString());
                sts2.setString(2, p.getName());
                sts2.setInt(3, 10);
                sts2.setInt(4, 1);
                sts2.setInt(5,10);

                sts2.executeUpdate();
                sts2.close();
          }

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


    }*/

    public void createAccount(Player p){
        try{
            PreparedStatement sts = getConnection().prepareStatement("SELECT rank FROM" + table + " WHERE uuid = ?");
            sts.setString(1, p.getUniqueId().toString());
            ResultSet rs = sts.executeQuery();
            if(!rs.next()){
                sts.close();
                sts = getConnection().prepareStatement("INSERT INTO" + table + "(uuid, player, rank, connection, coins) VALUES (?, ?)");
                sts.setString(1, p.getUniqueId().toString());
                sts.setInt(1, 10);
                sts.executeUpdate();
                sts.close();
            }
        }catch (SQLException e){
            e.printStackTrace();
        }
    }

    public Rank getRank(String uuid){
        Rank rank = null;

        try {
            PreparedStatement sts = getConnection().prepareStatement("SELECT rank FROM " + table + " WHERE uuid = ?");
            sts.setString(1, uuid);
            ResultSet rs = sts.executeQuery();
            if(!rs.next()){
                return null;
            }
            rank = Rank.getFromPower(rs.getInt("rank"));
            sts.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }

        return rank;
    }

    public void setRank(Player p, Rank rank){
        try {
            PreparedStatement sts = getConnection().prepareStatement("UPDATE " + table + " SET rank = ? WHERE uuid = ?");
            sts.setInt(1, rank.getPower());
            sts.setString(2, p.getUniqueId().toString());
            sts.executeUpdate();
            sts.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public void addNumberOfConnection(Player p, int add){
        try{
            PreparedStatement sts = getConnection().prepareStatement("UPDATE " + table + " SET connection = connection + ? WHERE uuid = ?");
            sts.setInt(1, add);
            sts.setString(2, p.getUniqueId().toString());
            sts.executeUpdate();
            sts.close();
        } catch(SQLException e){
            e.printStackTrace();
        }

    }

    public Integer getNumberOfConnection(Player p){
        int connection = 0;
        try {
            PreparedStatement sts = getConnection().prepareStatement("SELECT connection FROM " + table + " WHERE uuid = ?");
            sts.setString(1, p.getUniqueId().toString());
            ResultSet rs = sts.executeQuery();
            if(!rs.next()){
                return null;
            }
            connection = rs.getInt("connection");
            sts.close();
        } catch (SQLException e){
            e.printStackTrace();
        }
        return connection;
    }


    public boolean hasPermission(Player player, String permission){
        try{
            PreparedStatement sts = getConnection().prepareStatement("SELECT permissions FROM " + table + " WHERE uuid = ?");
            sts.setString(1, player.getUniqueId().toString());
            ResultSet rs = sts.executeQuery();
            while(rs.next()){
                if(permission.equalsIgnoreCase(rs.getString("permissions"))){
                    return true;
                }

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


    public void addCoins(String uuid, int nombre){
        try{
            PreparedStatement sts = getConnection().prepareStatement("UPDATE " + table + " SET coins = coins + ? WHERE uuid = ?");
            sts.setInt(1, nombre);
            sts.setString(2, uuid);
            sts.executeUpdate();
            sts.close();
        } catch(SQLException e){
            e.printStackTrace();
        }
    }

    public void removeCoins(String uuid, int coins){
        try{
            PreparedStatement sts = getConnection().prepareStatement("UPDATE " + table + " SET coins = coins - ? WHERE uuid = ?");
            sts.setInt(1, coins);
            sts.setString(2, uuid);
            sts.executeUpdate();
            sts.close();
        } catch(SQLException e){
            e.printStackTrace();
        }
    }

    public void SetCoins(String uuid, int coins){
        try{
            PreparedStatement sts = getConnection().prepareStatement("UPDATE " + table + " SET coins = ? WHERE uuid = ?");
            sts.setInt(1, coins);
            sts.setString(2, uuid);
            sts.executeUpdate();
            sts.close();
        } catch(SQLException e){
            e.printStackTrace();
        }
    }

    public Integer getCoins(String uuid){
        int coins = 0;

        try{
            PreparedStatement sts = getConnection().prepareStatement("SELECT coins FROM " + table + " WHERE uuid = ? ");
            sts.setString(1, uuid);
            ResultSet rs = sts.executeQuery();
            if(!rs.next()){
                return null;
            }
            coins = rs.getInt("coins");
            sts.close();

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

        return coins;
    }

}