package ch.lucas.pvpbox.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;

import ch.lucas.pvpbox.Main;

public class SqlConnection {

	private Connection connection;
	private String urlbase,host,database,user,pass;
	private Main main;

	public SqlConnection(Main main, String urlbase, String host, String database, String user, String pass) {
		this.main = main;
		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();
			}
		}
	}

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

	public Connection getConnection() {
		return connection;
	}

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

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


		}
	}

	public boolean hasAccount(Player player){

		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 PlayerData createPlayerData(Player player){

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

                int coins = 0;
                int kit = 0;

                while(resultats.next()){
                    coins = resultats.getInt("coins");
                    kit = resultats.getInt("kit");
                }

                PlayerData dataP = new PlayerData();
                dataP.setCoins(coins);
                dataP.setKit(kit);
                return dataP;


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

        return new PlayerData();

    }

    public void updatePlayerData(Player player){

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

            PlayerData dataP = main.dataPlayers.get(player);
            int coins = dataP.getCoins();
            int kit = dataP.getKit();

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


        }

    }

}