private ResultSet getQuery(String query) {
        PreparedStatement preparedStatement;
        ResultSet resultSet;
        try {
            preparedStatement = getConnection().prepareStatement(query);
            resultSet = preparedStatement.executeQuery();
            return resultSet;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

    public void query(String query, Consumer<ResultSet> consumer) {
        executorService.execute(() -> {
            ResultSet resultSet = getQuery(query);
            plugin.getServer().getScheduler().runTask(plugin, () -> consumer.accept(resultSet));
        });
    }