package eu.fantasiacraft.dev.spacetube.sql;

import eu.fantasiacraft.dev.spacetube.Main;
import eu.fantasiacraft.dev.spacetube.utils.Varriables;
import org.bukkit.entity.Player;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;


public class SQLConnection {

    private Connection conn;

    public void connect(String host, int port, String database, String user, String password){
        if(!isConnected()){
            try {
                this.conn = DriverManager.getConnection("jdbc:mysql://" + host + ":" + port + "/" + database, user, password);
                Main.getInstance().getServer().getConsoleSender().sendMessage(new Varriables().sqlConnected);
            } catch (SQLException e) {
                e.printStackTrace();
                System.out.println("Connexion refuse avec la base de donnees");
            }
        }
    }

    public void disconnect(){
        if(isConnected()){
            try {
                conn.close();
                Main.getInstance().getServer().getConsoleSender().sendMessage(new Varriables().sqlDisconnected);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    private boolean isConnected(){
        return this.conn != null;

    }

    public void createAccount(Player player){

        try {

            PreparedStatement q = conn.prepareStatement("INSERT INTO players(playerName,playerNickname,rank,coins,fantasiaCoins) VALUES (?,?,?,?,?)");

            q.setString(1, player.getName());
            q.setString(2, player.getDisplayName());
            q.setString(3, "$Rank");
            q.setString(4, "0");
            q.setString(5, "0");

            q.execute();
            q.close();

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

    }

    public Connection getConnection(){
        return conn;
    }

}