package fr.gunterlucas.box.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 fr.gunterlucas.box.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("[PvP-BOX] 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 void createAccount(Player player) {

		if(!hasAccount(player)) {

			try {
				PreparedStatement q = connection.prepareStatement("INSERT INTO joueurs(uuid,coins,kit) VALUES (?,?,?)");
				q.setString(1, player.getUniqueId().toString());
				q.setInt(2, 10);
				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 Connection getConnection() {
		return connection;
	}

	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();
			}

		}

	}

}