Database Controller

/*
 * Copyright © 2014 Jacob Keep (Jnk1296). All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 *  * Redistributions of source code must retain the above copyright notice,
 *   this list of conditions and the following disclaimer.
 *
 *  * Redistributions in binary form must reproduce the above copyright notice,
 *   this list of conditions and the following disclaimer in the documentation
 *   and/or other materials provided with the distribution.
 *
 *  * Neither the name of JuNK Software nor the names of its contributors may
 *   be used to endorse or promote products derived from this software without
 *   specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
 * POSSIBILITY OF SUCH DAMAGE.
 */

package net.risenphoenix.ipcheck.database;

import net.risenphoenix.commons.Plugin;
import net.risenphoenix.commons.database.DatabaseManager;
import net.risenphoenix.commons.database.QueryFilter;
import net.risenphoenix.commons.database.StatementObject;
import net.risenphoenix.ipcheck.objects.IPObject;
import net.risenphoenix.ipcheck.objects.UserObject;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;

public class DatabaseController extends DatabaseManager {

    // SQ-Lite Initializer
    public DatabaseController(final Plugin plugin) {
        super(plugin, "ip-check");

        // Enable Debugging to allow us to view the dynamic SQL queries
        //this.enableDebug(true);
        this.dropTables(); // Attempt Table Drop
        this.initializeSQLiteTables();
    }

    // MySQL Initializer
    public DatabaseController(final Plugin plugin, String hostname, int port,
                              String database, String username, String pwd
                              /* int poolSize */) {
        super(plugin, hostname, port, database, username, pwd/*, poolSize */);


        // Enable Debugging to allow us to view the dynamic SQL queries
        //this.enableDebug(true);
        this.dropTables(); // Attempt Table Drop
        this.initializeMySQLTables(); // Initialize Tables
    }

    private void dropTables() {
        if (!getPlugin().getConfigurationManager().getBoolean("dbGenerated")) {
            // SQL Strings
            String SQL_0 = "DROP TABLE IF EXISTS ipcheck_log;";
            String SQL_1 = "DROP TABLE IF EXISTS ipcheck_user;";
            String SQL_2 = "DROP TABLE IF EXISTS ipcheck_ip;";

            // Execute SQL
            executeStatement(new StatementObject(getPlugin(), SQL_0));
            executeStatement(new StatementObject(getPlugin(), SQL_1));
            executeStatement(new StatementObject(getPlugin(), SQL_2));

            // Save Configuration Option
            getPlugin().getConfigurationManager()
                    .setConfigurationOption("dbGenerated", true);
        }
    }

    // Initialize Tables for SQ-Lite
    public void initializeSQLiteTables() {
        String TABLE_IPC_LOG = "CREATE TABLE IF NOT EXISTS ipcheck_log ( " +
                "ip TEXT," +
                "username TEXT," +
                "timestamp TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP," +
                "PRIMARY KEY(username,ip));";

        String TABLE_IPC_USER = "CREATE TABLE IF NOT EXISTS ipcheck_user ( " +
                "username TEXT," +
                "timestamp TIMESTAMP DEFAULT CURRENT_TIMESTAMP," +
                "banmessage TEXT," +
                "banned INTEGER DEFAULT 0," +
                "exempted INTEGER DEFAULT 0," +
                "rejoinexempt INTEGER DEFAULT 0," +
                "protected INTEGER DEFAULT 0," +
                "PRIMARY KEY(username));";

        String TABLE_IPC_IP = "CREATE TABLE IF NOT EXISTS ipcheck_ip ( " +
                "ip TEXT," +
                "timestamp TIMESTAMP DEFAULT CURRENT_TIMESTAMP," +
                "banned INTEGER DEFAULT 0," +
                "exempted INTEGER DEFAULT 0," +
                "rejoinexempt INTEGER DEFAULT 0," +
                "PRIMARY KEY(ip));";

        this.executeStatement(new StatementObject(this.getPlugin(),
                TABLE_IPC_IP));
        this.executeStatement(new StatementObject(this.getPlugin(),
                TABLE_IPC_LOG));
        this.executeStatement(new StatementObject(this.getPlugin(),
                TABLE_IPC_USER));

        executeColumnUpdate();
    }

    // Initialize Tables for MySQL
    public void initializeMySQLTables() {
        String TABLE_IPC_LOG = "CREATE TABLE IF NOT EXISTS ipcheck_log ( " +
                "ip varchar(15) NOT NULL," +
                "username varchar(255) NOT NULL," +
                "timestamp timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP," +
                "PRIMARY KEY (ip,username)" +
                ");";

        String TABLE_IPC_USER = "CREATE TABLE IF NOT EXISTS ipcheck_user ( " +
                "username varchar(255) NOT NULL," +
                "timestamp timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP," +
                "banmessage varchar(255)," +
                "banned bit(1) NOT NULL DEFAULT b'0'," +
                "exempted bit(1) NOT NULL DEFAULT b'0'," +
                "rejoinexempt bit(1) NOT NULL DEFAULT b'0'," +
                "protected bit(1) NOT NULL DEFAULT b'0'," +
                "PRIMARY KEY (username)" +
                ");";

        String TABLE_IPC_IP = "CREATE TABLE IF NOT EXISTS ipcheck_ip ( " +
                "ip varchar(15) NOT NULL," +
                "timestamp timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP," +
                "banned bit(1) NOT NULL DEFAULT b'0'," +
                "exempted bit(1) NOT NULL DEFAULT b'0'," +
                "rejoinexempt bit(1) NOT NULL DEFAULT b'0'," +
                "PRIMARY KEY (ip)" +
                ");";

        this.executeStatement(new StatementObject(this.getPlugin(),
                TABLE_IPC_IP));
        this.executeStatement(new StatementObject(this.getPlugin(),
                TABLE_IPC_LOG));
        this.executeStatement(new StatementObject(this.getPlugin(),
                TABLE_IPC_USER));

        executeColumnUpdate();
    }

    public final void log(String player, String ip) {
        this.addIP(ip);
        this.addPlayer(player);

        String SQL = "replace into ipcheck_log (ip,username) VALUES (?, ?)";
        this.executeStatement(new StatementObject(this.getPlugin(),
                SQL, new Object[]{ip, player.toLowerCase()}));
    }

    public final void addIP(String ip) {
        String SQL = "insert " + ((this.getPlugin().getConfigurationManager()
                .getBoolean("use-mysql")) ? "" : "or ") + "ignore into " +
                "ipcheck_ip (ip) values (?)";

        this.executeStatement(new StatementObject(this.getPlugin(),
                SQL, new Object[]{ip}));
    }

    public final void addPlayer(String player) {
        String SQL = "insert " + ((this.getPlugin().getConfigurationManager()
                .getBoolean("use-mysql")) ? "" : "or ") + "ignore into " +
                "ipcheck_user (username) values (?)";

        this.executeStatement(new StatementObject(this.getPlugin(),
                SQL, new Object[]{player.toLowerCase()}));
    }

    /* Player Methods */

    public final void purgePlayer(String player) {
        String STMT_1 = "delete from ipcheck_user where lower(username) = ?";
        String STMT_2 = "delete from ipcheck_log where lower(username) = ?";

        this.executeStatement(new StatementObject(this.getPlugin(),
                STMT_1, new Object[]{player.toLowerCase()}));

        this.executeStatement(new StatementObject(this.getPlugin(),
                STMT_2, new Object[]{player.toLowerCase()}));
    }

    // Exemption Methods

    public final void exemptPlayer(String player) {
        String SQL = "update ipcheck_user set exempted=1 where " +
                "lower(username) = ?";

        this.executeStatement(new StatementObject(this.getPlugin(),
                SQL, new Object[]{player.toLowerCase()}));
    }

    public final void unexemptPlayer(String player) {
        String SQL = "update ipcheck_user set exempted=0 where " +
                "lower(username) = ?";

        this.executeStatement(new StatementObject(this.getPlugin(),
                SQL, new Object[]{player.toLowerCase()}));
    }

    public final boolean isExemptPlayer(String player) {
        String SQL = "select exempted from ipcheck_user where " +
                "lower(username) = ?";

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                boolean isExempt = false;

                try {
                    while (res.next()) {
                        int exempt = Integer.parseInt(res.getString(1));
                        isExempt = (exempt == 1);
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return isExempt;
            }
        };

        return (Boolean) this.executeQuery(new StatementObject(this.getPlugin(),
                SQL, new Object[]{player.toLowerCase()}), filter);
    }

    public ArrayList<String> getPlayerExemptList() {
        String SQL = "select username from ipcheck_user where exempted=1";

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                ArrayList<String> users = new ArrayList<String>();

                try {
                    while (res.next()) {
                        users.add(res.getString(1));
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return users;
            }
        };

        return (ArrayList<String>) this.executeQuery(new StatementObject(
                this.getPlugin(), SQL), filter);
    }

    // Ban Methods

    public final void banPlayer(String player, String message) {
        String SQL = "update ipcheck_user set banned=1, banmessage = ? where " +
                "lower(username) = ?";

        this.executeStatement(new StatementObject(this.getPlugin(),
                SQL, new Object[]{message, player.toLowerCase()}));
    }

    public final void batchBanPlayers(String list, String msg, Boolean ban) {
        String SQL = "update ipcheck_user set banned = ?, banmessage = ? " +
                "where lower(username) = '" + list.toLowerCase();

        int bit = (ban) ? 1 : 0;

        this.executeStatement(new StatementObject(this.getPlugin(),
                SQL, new Object[]{bit, msg}));
    }

    public final void unbanPlayer(String player) {
        String SQL = "update ipcheck_user set banned = 0 where " +
                "lower(username) = ?";

        this.executeStatement(new StatementObject(this.getPlugin(),
                SQL, new Object[]{player.toLowerCase()}));
    }

    public final boolean isBannedPlayer(String player) {
        String SQL = "select banned from ipcheck_user where " +
                "lower(username) = ?";

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                boolean isBanned = false;

                try {
                    while (res.next()) {
                        int banned = Integer.parseInt(res.getString(1));
                        isBanned = (banned == 1);
                        break;
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return isBanned;
            }
        };

        return (Boolean) this.executeQuery(new StatementObject(this.getPlugin(),
                SQL, new Object[]{player.toLowerCase()}), filter);
    }

    public final boolean isValidPlayer(String player) {
        String SQL = "select username from ipcheck_user where " +
                "lower(username) = ?";

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                try {
                    return (res.next());
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return false;
            }
        };

        return (Boolean) this.executeQuery(new StatementObject(this.getPlugin(),
                SQL, new Object[]{player.toLowerCase()}), filter);
    }

    public final String getBanMessage(String player) {
        String SQL = "select banmessage from ipcheck_user where " +
                "lower(username) = ?";

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                String message = null;

                try {
                    while (res.next()) {
                        message = res.getString("banmessage");
                        break;
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return message;
            }
        };

        return (String) this.executeQuery(new StatementObject(this.getPlugin(),
                SQL, new Object[]{player.toLowerCase()}), filter);
    }

    /* IP Methods */

    public final void purgeIP(String ip) {
        String STMT_1 = "delete from ipcheck_ip where ip = ?";
        String STMT_2 = "delete from ipcheck_log where ip = ?";

        this.executeStatement(new StatementObject(this.getPlugin(),
                STMT_1, new Object[]{ip}));

        this.executeStatement(new StatementObject(this.getPlugin(),
                STMT_2, new Object[]{ip}));
    }

    public final void exemptIP(String ip) {
        String SQL = "update ipcheck_ip set exempted = 1 where ip = ?";

        this.executeStatement(new StatementObject(this.getPlugin(),
                SQL, new Object[]{ip}));
    }

    public final void unexemptIP(String ip) {
        String SQL = "update ipcheck_ip set exempted = 0 where ip = ?";

        this.executeStatement(new StatementObject(this.getPlugin(),
                SQL, new Object[]{ip}));
    }

    public final boolean isExemptIP(String ip) {
        String SQL = "select exempted from ipcheck_ip where ip = ?";

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                boolean isExempt = false;

                try {
                    while (res.next()) {
                        int exempt = Integer.parseInt(res.getString(1));
                        isExempt = (exempt == 1);
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return isExempt;
            }
        };

        return (Boolean) this.executeQuery(new StatementObject(this.getPlugin(),
                SQL, new Object[]{ip}), filter);
    }

    public ArrayList<String> getIPExemptList() {
        String SQL = "select ip from ipcheck_ip where exempted=1";

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                ArrayList<String> ips = new ArrayList<String>();

                try {
                    while (res.next()) {
                        ips.add(res.getString(1));
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return ips;
            }
        };

        return (ArrayList<String>) this.executeQuery(new StatementObject(
                this.getPlugin(), SQL), filter);
    }

    public final void banIP(String ip) {
        String SQL = "update ipcheck_ip set banned = 1 where ip = ?";

        this.executeStatement(new StatementObject(this.getPlugin(),
                SQL, new Object[]{ip}));
    }

    public final void batchBanIPs(String list, boolean banning) {
        String SQL = "update ipcheck_ip set banned = ? where ip = '"
                + list.toLowerCase();

        int bit = (banning) ? 1 : 0;

        this.executeStatement(new StatementObject(this.getPlugin(),
                SQL, new Object[]{bit}));
    }

    public final void unbanIP(String ip) {
        String SQL = "update ipcheck_ip set banned = 0 where ip = ?";

        this.executeStatement(new StatementObject(this.getPlugin(),
                SQL, new Object[]{ip}));
    }

    public final boolean isBannedIP(String ip) {
        String SQL = "select banned from ipcheck_ip where ip = ?";

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                boolean isBanned = false;

                try {
                    while (res.next()) {
                        int banned = Integer.parseInt(res.getString(1));
                        isBanned = (banned == 1);
                        break;
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return isBanned;
            }
        };

        return (Boolean) this.executeQuery(new StatementObject(this.getPlugin(),
                SQL, new Object[]{ip}), filter);
    }

    /* Other Methods */

    public final IPObject getIPObject(String ip) {
        String SQL = "select username from ipcheck_log where ip = ?";

        QueryFilter filter = new QueryFilter(new Object[]{ip, this}) {
            @Override
            public Object onExecute(ResultSet res) {
                DatabaseController dbC = (DatabaseController) this.getData()[1];
                ArrayList<String> users = new ArrayList<String>();
                String ip = (String) this.getData()[0];

                try {
                    while (res.next()) {
                        users.add(res.getString(1));
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return new IPObject(ip, users, dbC.isBannedIP(ip),
                        dbC.isExemptIP(ip), dbC.isRejoinExemptIP(ip));
            }
        };

        return (IPObject) this.executeQuery(new StatementObject(
                this.getPlugin(), SQL, new Object[]{ip}), filter);
    }

    public final UserObject getUserObject(String player) {
        String SQL = "select ip from ipcheck_log where lower(username) = ?";
        boolean isBanned = this.isBannedPlayer(player);
        boolean isExempt = this.isExemptPlayer(player);
        boolean isRejoin = this.isRejoinExemptPlayer(player);
        boolean isProtec = this.isProtectedPlayer(player);

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                ArrayList<String> ips = new ArrayList<String>();

                try {
                    while (res.next()) {
                        if (!ips.contains(res.getString(1))) {
                            ips.add(res.getString(1));
                        }
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return ips;
            }
        };

        ArrayList<String> ips = (ArrayList<String>) this.executeQuery(
                new StatementObject(this.getPlugin(), SQL, new Object[]{
                        player.toLowerCase()}), filter);

        return new UserObject(player.toLowerCase(), ips, isBanned, isExempt,
                isRejoin, isProtec);
    }

    public final String getLastKnownIP(String player) {
        String SQL = "select ip from ipcheck_log where lower(username) = ? " +
                "order by timestamp desc limit 1;";

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                String returning = "NO_FIND";

                try {
                    if (res.next()) returning = res.getString(1);
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return returning;
            }
        };

        return (String) this.executeQuery(new StatementObject(this.getPlugin(),
                SQL, new Object[]{player.toLowerCase()}), filter);
    }

    public final boolean isValidIP(String ip) {
        String SQL = "select ip from ipcheck_ip where ip = ?";

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                try {
                    return (res.next());
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return false;
            }
        };

        if (ip.equals("NO_FIND")) return false;

        return (Boolean) this.executeQuery(new StatementObject(this.getPlugin(),
                SQL, new Object[]{ip}), filter);
    }

    public final String getLogTime(String player) {
        String SQL = "select timestamp from ipcheck_user where " +
                "lower(username) = ?";

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                String returning = null;

                try {
                    if (res.next()) returning = res.getString(1);
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return returning;
            }
        };

        return (String) this.executeQuery(new StatementObject(this.getPlugin(),
                SQL, new Object[]{player.toLowerCase()}), filter);
    }

    public final String getLastTime(String player) {
        String SQL = "select timestamp from ipcheck_log where " +
                "lower(username) = ? order by timestamp desc limit 1;";

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                String returning = null;

                try {
                    if (res.next()) returning = res.getString(1);
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return returning;
            }
        };

        return (String) this.executeQuery(new StatementObject(this.getPlugin(),
                SQL, new Object[]{player.toLowerCase()}), filter);
    }

    public final String getCurrentTimeStamp() {
        String SQL = "select CURRENT_TIMESTAMP";

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                String date = null;

                try {
                    res.next();
                    date = res.getString(1);
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return date;
            }
        };

        return (String) this.executeQuery(new StatementObject(this.getPlugin(),
                SQL), filter);
    }

    public final ArrayList<UserObject> getPlayersByDate(String dateOne,
                                                        String dateTwo) {
        String SQL = "select username from ipcheck_user where timestamp >= ? " +
                "and timestamp <= ?";

        QueryFilter filter = new QueryFilter(new Object[]{this}) {
            @Override
            public Object onExecute(ResultSet res) {
                DatabaseController dbC = (DatabaseController) this.getData()[0];
                ArrayList<UserObject> users = new ArrayList<UserObject>();

                try {
                    while (res.next()) {
                        String user = res.getString(1);
                        users.add(new UserObject(user,
                                dbC.isBannedPlayer(user)));
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return users;
            }
        };

        return (ArrayList<UserObject>) this.executeQuery(new StatementObject(
                this.getPlugin(), SQL, new Object[]{dateOne, dateTwo}), filter);
    }

    public final ArrayList<UserObject> fetchAllPlayers() {
        String SQL = "select * from ipcheck_user";

        QueryFilter filter = new QueryFilter(new Object[]{this}) {
            @Override
            public Object onExecute(ResultSet res) {
                DatabaseController dbC = (DatabaseController) this.getData()[0];
                ArrayList<UserObject> users = new ArrayList<UserObject>();

                try {
                    while (res.next()) {
                        String user = res.getString(1);
                        users.add(new UserObject(user,
                                dbC.isBannedPlayer(user)));
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return users;
            }
        };

        return (ArrayList<UserObject>) this.executeQuery(new StatementObject(
                this.getPlugin(), SQL), filter);
    }

    public final ArrayList<UserObject> fetchBannedPlayers() {
        String SQL = "select * from ipcheck_user";

        QueryFilter filter = new QueryFilter(new Object[]{this}) {
            @Override
            public Object onExecute(ResultSet res) {
                DatabaseController dbC = (DatabaseController) this.getData()[0];
                ArrayList<UserObject> users = new ArrayList<>();

                try {
                    while (res.next()) {
                        if (res.getString(4).equals("1")) {
                            String user = res.getString(1);
                            users.add(new UserObject(user,
                                    dbC.isBannedPlayer(user)));
                        }
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return users;
            }
        };

        return (ArrayList<UserObject>) this.executeQuery(new StatementObject(
                this.getPlugin(), SQL), filter);
    }


    public final ArrayList<IPObject> fetchAllIPs() {
        String SQL = "select * from ipcheck_ip";

        QueryFilter filter = new QueryFilter(new Object[]{this}) {
            @Override
            public Object onExecute(ResultSet res) {
                DatabaseController dbC = (DatabaseController) this.getData()[0];
                ArrayList<IPObject> ips = new ArrayList<IPObject>();

                try {
                    while (res.next()) {
                        String ip = res.getString(1);
                        ips.add(new IPObject(ip, dbC.isBannedIP(ip)));
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return ips;
            }
        };

        return (ArrayList<IPObject>) this.executeQuery(new StatementObject(
                this.getPlugin(), SQL), filter);
    }

    public final ArrayList<IPObject> fetchBannedIPs() {
        String SQL = "select * from ipcheck_ip";

        QueryFilter filter = new QueryFilter(new Object[]{this}) {
            @Override
            public Object onExecute(ResultSet res) {
                DatabaseController dbC = (DatabaseController) this.getData()[0];
                ArrayList<IPObject> ips = new ArrayList<IPObject>();

                try {
                    while (res.next()) {
                        if (res.getString(3).equals("1")) {
                            String ip = res.getString(1);
                            ips.add(new IPObject(ip, dbC.isBannedIP(ip)));
                        }
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return ips;
            }
        };

        return (ArrayList<IPObject>) this.executeQuery(new StatementObject(
                this.getPlugin(), SQL), filter);
    }

    public final void setRejoinExemptPlayer(String player, boolean exempt) {
        String SQL = "update ipcheck_user set rejoinexempt = ? " +
                "where username = ?";
        int value = (exempt) ? 1 : 0;

        this.executeStatement(new StatementObject(this.getPlugin(),
                SQL, new Object[]{value, player.toLowerCase()}));
    }

    public final boolean isRejoinExemptPlayer(String player) {
        String SQL = "select rejoinexempt from ipcheck_user where username = ?";

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                boolean isExempt = false;

                try {
                    if (res.next()) {
                        isExempt = (res.getString(1).equals("1"));
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return isExempt;
            }
        };

        return (boolean) this.executeQuery(new StatementObject(this.getPlugin(),
                SQL, new Object[]{player.toLowerCase()}), filter);
    }

    public final void setRejoinExemptIP(String ip, boolean exempt) {
        String SQL = "update ipcheck_ip set rejoinexempt = ? where ip = ?";
        int value = (exempt) ? 1 : 0;

        this.executeStatement(new StatementObject(this.getPlugin(),
                SQL, new Object[]{value, ip}));
    }

    public final boolean isRejoinExemptIP(String ip) {
        String SQL = "select rejoinexempt from ipcheck_ip where ip = ?";

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                boolean isExempt = false;

                try {
                    if (res.next()) {
                        isExempt = (res.getString(1).equals("1"));
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return isExempt;
            }
        };

        return (boolean) this.executeQuery(new StatementObject(this.getPlugin(),
                SQL, new Object[]{ip}), filter);
    }

    public final ArrayList<UserObject> fetchRejoinExemptPlayers() {
        String SQL = "select username FROM ipcheck_user WHERE rejoinexempt = 1";

        QueryFilter filter = new QueryFilter(new Object[]{this}){
            @Override
            public Object onExecute(ResultSet res) {
                // IPO Storage
                ArrayList<UserObject> upos = new ArrayList<>();

                // Fetch DatabaseController from Data
                DatabaseController dbc = (DatabaseController) getData()[0];

                // Fetch UPOs and append to storage
                try {
                    while (res.next())
                        upos.add(dbc.getUserObject(res.getString(1)));
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return upos;
            }
        };

        // Fetch Return Value
        return (ArrayList<UserObject>) executeQuery(new StatementObject(
                this.getPlugin(), SQL), filter);
    }

    public final ArrayList<IPObject> fetchRejoinExemptIPs() {
        String SQL = "select ip FROM ipcheck_ip WHERE rejoinexempt = 1";

        QueryFilter filter = new QueryFilter(new Object[]{this}){
            @Override
            public Object onExecute(ResultSet res) {
                // IPO Storage
                ArrayList<IPObject> ipos = new ArrayList<>();

                // Fetch DatabaseController from Data
                DatabaseController dbc = (DatabaseController) getData()[0];

                // Fetch IPOs and append to storage
                try {
                    while (res.next())
                        ipos.add(dbc.getIPObject(res.getString(1)));
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return ipos;
            }
        };

        // Fetch Return Value
        return (ArrayList<IPObject>) executeQuery(new StatementObject(
                this.getPlugin(), SQL), filter);
    }

    public final void protectPlayer(String player) {
        String SQL = "update ipcheck_user set protected=1 where " +
                "lower(username) = ?";

        executeStatement(new StatementObject(this.getPlugin(), SQL,
                new Object[]{player.toLowerCase()}));
    }

    public final void unprotectPlayer(String player) {
        String SQL = "update ipcheck_user set protected=0 where " +
                "lower(username) = ?";

        executeStatement(new StatementObject(this.getPlugin(), SQL,
                new Object[]{player.toLowerCase()}));
    }

    public final boolean isProtectedPlayer(String player) {
        String SQL = "select protected FROM ipcheck_user WHERE " +
                "lower(username) = ?";

        QueryFilter filter = new QueryFilter() {
            @Override
            public Object onExecute(ResultSet res) {
                boolean result = false;

                try {
                    if (res.next()) result = res.getString(1).equals("1");
                } catch (SQLException e) {
                    e.printStackTrace();
                }

                return result;
            }
        };

        return (boolean) executeQuery(new StatementObject(this.getPlugin(), SQL,
                new Object[]{player.toLowerCase()}), filter);
    }

    private void executeColumnUpdate() {
        // Check for Missing Columns (Required for those upgrading from pre-2.0)
        boolean hasRejoinPlayer = true;
        boolean hasRejoinIP = true;
        boolean hasProtectedPlayer = true;

        // SQLite
        if (getDatabaseType() == DatabaseType.SQLITE) {
            String SQL_P = "PRAGMA table_info(ipcheck_user);";

            QueryFilter filter = new QueryFilter() {
                @Override
                public Object onExecute(ResultSet res) {
                    boolean[] flags = new boolean[2];
                    // 0 = Rejoin, 1 = Protection
                    try {
                        while (res.next()) {
                            if (res.getString(2).equals("rejoinexempt"))
                                flags[0] = true;
                            if (res.getString(2).equals("protected"))
                                flags[1] = true;
                        }
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }

                    return flags;
                }
            };

            // Fetch Boolean Array from Database
            boolean[] res = (boolean[]) this.executeQuery(
                    new StatementObject(this.getPlugin(), SQL_P), filter);

            hasRejoinPlayer = res[0];
            hasProtectedPlayer = res[1];

            String SQL_I = "PRAGMA table_info(ipcheck_ip);";

            QueryFilter filter_two = new QueryFilter() {
                @Override
                public Object onExecute(ResultSet res) {
                    boolean flag = false;
                    // 0 = Rejoin, 1 = Protection
                    try {
                        while (res.next()) {
                            if (res.getString(2).equals("rejoinexempt"))
                                flag = true;
                        }
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }

                    return flag;
                }
            };

            // Fetch Boolean from Database
            hasRejoinIP = (boolean) this.executeQuery(
                    new StatementObject(this.getPlugin(), SQL_I), filter_two);

            // Execute Results
            if (!hasRejoinPlayer) {
                String SQL_ZERO = "ALTER TABLE ipcheck_user ADD COLUMN " +
                        "rejoinexempt INTEGER DEFAULT 0";

                this.executeStatement(new StatementObject(this.getPlugin(),
                        SQL_ZERO));
            }

            if (!hasProtectedPlayer) {
                String SQL_ZERO = "ALTER TABLE ipcheck_user ADD COLUMN " +
                        "protected INTEGER DEFAULT 0";

                this.executeStatement(new StatementObject(this.getPlugin(),
                        SQL_ZERO));
            }

            if (!hasRejoinIP) {
                String SQL_ZERO = "ALTER TABLE ipcheck_ip ADD COLUMN " +
                        "rejoinexempt INTEGER DEFAULT 0";

                this.executeStatement(new StatementObject(this.getPlugin(),
                        SQL_ZERO));
            }


        // MySQL
        } else {
            String SQL_P = "SHOW COLUMNS FROM " +
                    getPlugin().getConfigurationManager().getString("dbName") +
                    ".ipcheck_user";

            QueryFilter filter = new QueryFilter() {
                @Override
                public Object onExecute(ResultSet res) {
                    boolean[] flags = new boolean[2];
                    // 0 = Rejoin, 1 = Protection
                    try {
                        while (res.next()) {
                            if (res.getString(1).equals("rejoinexempt"))
                                flags[0] = true;
                            if (res.getString(1).equals("protected"))
                                flags[1] = true;
                        }
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }

                    return flags;
                }
            };

            // Fetch Boolean Array from Database
            boolean[] res = (boolean[]) this.executeQuery(
                    new StatementObject(this.getPlugin(), SQL_P), filter);

            hasRejoinPlayer = res[0];
            hasProtectedPlayer = res[1];

            String SQL_I = "SHOW COLUMNS FROM " +
                    getPlugin().getConfigurationManager().getString("dbName") +
                    ".ipcheck_ip";

            QueryFilter filter_two = new QueryFilter() {
                @Override
                public Object onExecute(ResultSet res) {
                    boolean flag = false;
                    // 0 = Rejoin, 1 = Protection
                    try {
                        while (res.next()) {
                            if (res.getString(1).equals("rejoinexempt"))
                                flag = true;
                        }
                    } catch (SQLException e) {
                        e.printStackTrace();
                    }

                    return flag;
                }
            };

            // Fetch Boolean from Database
            hasRejoinIP = (boolean) this.executeQuery(
                    new StatementObject(this.getPlugin(), SQL_I), filter_two);

            // Execute Results
            if (!hasRejoinPlayer) {
                String SQL_ZERO = "ALTER TABLE ipcheck_user ADD COLUMN " +
                        "rejoinexempt bit(1) NOT NULL DEFAULT b'0'";

                this.executeStatement(new StatementObject(this.getPlugin(),
                        SQL_ZERO));
            }

            if (!hasProtectedPlayer) {
                String SQL_ZERO = "ALTER TABLE ipcheck_user ADD COLUMN " +
                        "protected bit(1) NOT NULL DEFAULT b'0'";

                this.executeStatement(new StatementObject(this.getPlugin(),
                        SQL_ZERO));
            }

            if (!hasRejoinIP) {
                String SQL_ZERO = "ALTER TABLE ipcheck_ip ADD COLUMN " +
                        "rejoinexempt bit(1) NOT NULL DEFAULT b'0'";

                this.executeStatement(new StatementObject(this.getPlugin(),
                        SQL_ZERO));
            }
        }
    }

}