package cz.eNcoo.ChatManager;

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 org.bukkit.event.Listener;
import org.bukkit.plugin.java.JavaPlugin;

public class Levels extends JavaPlugin implements Listener {
    private static Connection connection;

    public void onEnable() {
        getServer().getPluginManager().registerEvents(this, this);
    }

    public void onDisable() {
        try {
            if ((connection != null) && (connection.isClosed())) {
                connection.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public static synchronized void openConnection() {
        try {
            connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/Levels", "Levels",
                    "Upf0njHjprmx76rg");
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

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

    public static synchronized boolean playerData(Player player) {
        try {
            PreparedStatement sql = connection.prepareStatement("SELECT * FROM `levels` WHERE nick=?;");
            sql.setString(1, player.getName());
            ResultSet resultSet = sql.executeQuery();
            boolean containsPlayer = resultSet.next();

            sql.close();
            resultSet.close();
            return containsPlayer;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return false;
    }

    public static synchronized int playerLevel(Player player) {
        try {
            PreparedStatement sql = connection.prepareStatement("SELECT * FROM `levels` WHERE nick=?;");
            sql.setString(1, player.getName());
            ResultSet resultSet = sql.executeQuery();
            int level = resultSet.getInt("level");

            resultSet.close();
            sql.close();
            return level;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return 0;
    }

    public static synchronized int playerXP(Player player) {
        try {
            PreparedStatement sql = connection.prepareStatement("SELECT * FROM `levels` WHERE nick=?;");
            sql.setString(1, player.getName());
            ResultSet resultSet = sql.executeQuery();
            int xp = resultSet.getInt("xp");

            resultSet.close();
            sql.close();
            return xp;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return 0;
    }
}