package ru.lisenochek.mcrust.sql;

import org.bukkit.Bukkit;
import ru.lisenochek.mcrust.Main;
import ru.lisenochek.mcrust.utils.Logger;

import java.sql.*;

public class SQL {

    private static SQL sql;

    private Connection connection;
    private ResultSet resultSet;

    private SQL() {
        sql = this;
    }

    public static SQL getSQL() {
        return sql == null ? new SQL() : sql;
    }

    public void connect() throws SQLException, ClassNotFoundException {
        Class.forName("org.h2.Driver");
        connection = DriverManager.getConnection("jdbc:h2://" + Main.getPlugin().getDataFolder().getAbsolutePath() + "/Database;mode=MySQL", "sa", "");
    }

    public void close() throws SQLException {
        if (connection != null) connection.close();
    }

    public void execute(String query) {

        if (query == null || query.equals("")) {
            Logger.getLogger("Невозможно выполнить запрос! Он равен null или пуст!").error();
            return;
        }

        try {
            Statement statement = connection.createStatement();
            statement.executeUpdate(query);
            statement.close();
        } catch (SQLException e) {
            Logger.getLogger("Что-то пошло не так и при запросе появилось исключение:").error();
            e.printStackTrace();
        }
    }

    public void asyncExecute(String query) {
        Bukkit.getScheduler().runTaskLaterAsynchronously(Main.getPlugin(), () -> execute(query), 0);
    }

    public ResultSet executeQuery(String query) {

        if (query == null || query.equals("")) {
            Logger.getLogger("Невозможно выполнить запрос! Он равен null или пуст!").error();
            return null;
        }

        try {
            resultSet = connection.createStatement().executeQuery(query);
        } catch (SQLException e) {
            Logger.getLogger("Что-то пошло не так и при запросе появилось исключение:").error();
            e.printStackTrace();
        }

        return resultSet;
    }
}