package net.azuriarp.api.data;

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;

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

    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 Players(uuid,ecus,grade) VALUES(?,?,?)");

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

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

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

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

    public boolean hasAccount(Player player) {

        try {
            PreparedStatement query = connection.prepareStatement("SELECT uuid FROM Players 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;
    }
}