package net.azuriarp.api.data;

import net.azuriarp.api.AzuriaAPI;
import net.azuriarp.api.PlayerInfo;
import net.azuriarp.api.game.rank.Rank;
import org.bukkit.entity.Player;

import java.sql.*;

/**
 * Created by invite on 08/07/2017.
 */
public class DataManager {

    private Connection connection;

    private String urlbase,host,database,user,pass;

    private PlayerDB playerDB;

    public DataManager(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;
        this.playerDB = new PlayerDB(this.connection);
    }

    public void connection() {

        if(!isConnected()) {

            try {
                connection = DriverManager.getConnection(urlbase + host + "/" + database, user, pass);
                System.out.println("[AzuriaAPI] SQL > connected");

            } catch (SQLException e) {
                System.out.println("[AzuriaAPI] SQL > Error : Can't connect to the database");
                e.printStackTrace();
            }
        }
    }

    public void disconnection() {

        if(isConnected()) {

            try {
                connection.close();
                System.out.println("[AzuriaAPI] SQL > disconnected");

            } catch (SQLException e) {
                System.out.println("[AzuriaAPI] SQL > Error : Can't connect to the database");
                e.printStackTrace();
            }
        }
    }

    public void createAccount(Player player) {

        if(hasAccount(player)) {

            try {
                PreparedStatement query = connection.prepareStatement("INSERT INTO PlayerInfo(uuid,ecus,grade) VALUES(?,?,?)");

                query.setString(1, player.getUniqueId().toString());
                query.setInt(2,100);
                query.setString(3, "joueur");

                query.execute();
                query.close();

                PlayerInfo playerInfo = new PlayerInfo(player, 100, Rank.Joueur);

                System.out.println("[AzuriaAPI] SQL > New Account !");

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

    public boolean hasAccount(Player player) {

        try {
            PreparedStatement query = connection.prepareStatement("SELECT uuid FROM PlayerInfo WHERE uuid = ?");

            query.setString(1, player.getUniqueId().toString());
            ResultSet result = query.executeQuery();
            boolean hasAccount = result.next();
            query.close();

            return hasAccount;

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

    public Connection getConnection() {
        return connection;
    }


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

    public PlayerDB getPlayerDB() {
        return this.playerDB;
    }
}