package me.MySQL;

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;

public class MySQL {

    String host = "localhost";
    String database = "minecraft";
    String user = "root";
    String pass = "";
    String port = "3306";

    private static Connection connection;



    public synchronized void openConnection() {
        try {
            connection = DriverManager.getConnection("jdbc:mysql://" +host + ":3306/" + database, user, pass);
            System.out.println("§2Successfully connected to MySQL Database!");
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }



    public static void closeConnection(){
        try{
            connection.close();
        }catch (SQLException e){
            e.printStackTrace();
        }
    }



    public static void createTables(){
        try {
            String query = "CREATE TABLE IF NOT EXISTS `nombre` (`uuid` varchar(36) UNIQUE, `coins` int(999999));";
            PreparedStatement p = connection.prepareStatement(query);
            p.execute();
            p.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }



    public static void createPlayer(Player player){
        try {
            String query = "INSERT IGNORE INTO pets (uuid,coins) VALUES(?, ?);";
            PreparedStatement p = connection.prepareStatement(query);
            p.setString(1, player.getUniqueId().toString());
            p.setInt(2, 0);
            p.execute();
            p.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }



    @SuppressWarnings("finally")
    public static Integer getCoins(Player p){
        Integer temp = 0;
        String query = "SELECT * FROM nombre WHERE `uuid` = '" + p.getUniqueId() + "'";
        try {
            ResultSet res = connection.prepareStatement(query).executeQuery();
            while (res.next()) {
                temp = res.getInt("coins");
            }
            res.close();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            return temp;
        }
    }



    public static void setCoins(Player player, int coins){
        try {
            String query = "UPDATE nombre SET coins=? WHERE uuid=?;";
            PreparedStatement p = connection.prepareStatement(query);
            p.setInt(1, coins);
            p.setString(2, player.getUniqueId().toString());
            p.execute();
            p.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }



   public static void removeCoins(Player player, int removedcoins) {
   setCoins(getCoins(player) - removedcoins); // ESTO DA ERROR, ESTA LINEA
   }