package Donate;

import cn.nukkit.command.ConsoleCommandSender;
import cn.nukkit.plugin.PluginBase;
import cn.nukkit.utils.Config;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;

public class SQL {

    private static String url;
    private static String username;
    private static String password;
    private static Config config;

    private static void init(PluginBase plugin){
        config = plugin.getConfig();
        url = "jdbc:mysql://" + config.getString("sql.host") + ":" + config.getString("sql.port") + "/" + config.getString("sql.db");
        username = config.getString("sql.user");
        password = config.getString("sql.pass");

    }

    public static ResultSet executeSelect(String query) throws SQLException {
        List<String> list = new ArrayList<String>();
        Connection connection = DriverManager.getConnection(url, username, password);
        if (connection == null) return null;
        Statement statement = connection.prepareStatement(query);
        if (statement == null) return null;
        ResultSet resultSet = statement.executeQuery(query);
        statement.close();
        connection.close();
        return resultSet;
    }

    public static void executeUpdate (String query) throws SQLException {
        Connection connection = DriverManager.getConnection(url, username, password);
        if (connection == null) return;
        Statement statement = connection.prepareStatement(query);
        statement.executeUpdate(query);
        statement.close();
        connection.close();
    }



    public static void check(String name) throws SQLException {
        ResultSet result = executeSelect("SELECT * FROM permissions WHERE name='" + name + "' ORDER BY id DESC");
        if (result == null) return;
        Donate.getInstance().getLogger().info(name + " Entered!");
        while (result.next()){
            long date = result.getLong("date"); // если я правильно понимаю, колонка у вас называется date
            if (System.currentTimeMillis()>date) {
                Donate.getInstance().getLogger().info(name + " deop!");
                executeUpdate("DELETE FROM permissions WHERE name='" + name + "'");
                Donate.getInstance().getServer().dispatchCommand(new ConsoleCommandSender(), "setgroup player " + name);
            } else {
                Donate.getInstance().getServer().dispatchCommand(new ConsoleCommandSender(), "setgroup player "+result.getString("permission"));
            }
        }
    }

}