Highscores.java

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.concurrent.ArrayBlockingQueue;

import com.ventyz.server.character.Client;

public class Highscores {

    /*
     * @author: Pax M
     */

    /** The con. */
    public static Connection con;

    /** The connected. */
    public static boolean connected;

    /** The count. */
    public static int count = 0;

    /** The db statements. */
    private static ArrayBlockingQueue<Statement> dbStatements = new ArrayBlockingQueue<Statement>(
            1);

    /** The statement. */
    private static transient Statement statement;

    /** The stmt. */
    public static Statement stmt;

    public static boolean error = false;

    /**
     * Destroy.
     */
    public static void destroy() {
        try {
            stmt.close();
            con.close();
            connected = false;
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * Execute query.
     *
     * @param query
     *            the query
     * @return the result set
     */
    public static ResultSet executeQuery(String query) {
        try {
            if (error == true) {
                init();
                error = false;
                System.err
                        .println("Error detected in Highscores DB, attempting to restart.");
            }
            statement = dbStatements.poll();
            ResultSet results = statement.executeQuery(query);
            dbStatements.offer(statement);
            return results;
        } catch (SQLException e) {
            error = true;
            e.printStackTrace();
        }
        return null;
    }

    /**
     * Query.
     *
     * @param query
     *            the query
     * @return the result set
     */
    public static int executeUpdate(String query) {
        try {
            statement = dbStatements.poll();
            int results = statement.executeUpdate(query);
            dbStatements.offer(statement);
            return results;
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return -1;
    }

    /**
     * Gets the next statement.
     *
     * @return the next statement
     */
    public static Statement getNextStatement() {
        return dbStatements.poll();
    }

    /**
     * Gets the statement.
     *
     * @return the statement
     */
    public static Statement getStatement() {
        return statement;
    }

    /**
     * Inits the.
     */
    public static void init() {
        try {
            Class.forName("com.mysql.jdbc.Driver").newInstance();
            Connection conn = DriverManager.getConnection(
                    "jdbc:mysql://scape-deadman.com/scape-hs",
                    "scape-hs", "p~mr4sWVu3PW");
            // gVUWQBtXs
            statement = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
                    ResultSet.CONCUR_UPDATABLE);
            statement.setEscapeProcessing(true);
            dbStatements.offer(statement);
        } catch (Exception e) {
            e.printStackTrace();
            System.err.println("Could not connect to Highscores SQL Database.");
        }
    }

    /**
     * Save high score.
     *
     * @param player
     *            the player
     * @return true, if successful
     */
    public static boolean save(Client player) {
        int tot = (player.playerLevel[0]) + (player.playerLevel[1])
                + (player.playerLevel[2]) + (player.playerLevel[3])
                + (player.playerLevel[4]) + (player.playerLevel[5])
                + (player.playerLevel[6]) + (player.playerLevel[7])
                + (player.playerLevel[8]) + (player.playerLevel[9])
                + (player.playerLevel[10]) + (player.playerLevel[11])
                + (player.playerLevel[12]) + (player.playerLevel[13])
                + (player.playerLevel[14]) + (player.playerLevel[15])
                + (player.playerLevel[16]) + (player.playerLevel[17])
                + (player.playerLevel[18]) + (player.playerLevel[19])
                + (player.playerLevel[20]);
        if (player.permission >= 2) {
            return false;
        }
        try {
            String username = player.username;
            ResultSet rs = executeQuery("SELECT * FROM hs_users WHERE username='"
                    + username + "' LIMIT 1");
            if (!rs.next()) {
                rs.moveToInsertRow();
                rs.updateString("username", username);
                rs.updateInt("rights", 0);
                int totalLevel = (player.playerXP[0]) + (player.playerXP[1])
                        + (player.playerXP[2]) + (player.playerXP[3])
                        + (player.playerXP[4]) + (player.playerXP[5])
                        + (player.playerXP[6]) + (player.playerXP[7])
                        + (player.playerXP[8]) + (player.playerXP[9])
                        + (player.playerXP[10]) + (player.playerXP[11])
                        + (player.playerXP[12]) + (player.playerXP[13])
                        + (player.playerXP[14]) + (player.playerXP[15])
                        + (player.playerXP[16]) + (player.playerXP[17])
                        + (player.playerXP[18]) + (player.playerXP[19])
                        + (player.playerXP[20]);
                rs.updateString("overall_xp", "" + totalLevel + "");
                rs.updateString("attack_xp", "" + player.playerXP[0] + "");
                rs.updateString("defence_xp", "" + player.playerXP[1] + "");
                rs.updateString("strength_xp", "" + player.playerXP[2] + "");
                rs.updateString("constitution_xp", "" + player.playerXP[3] + "");
                rs.updateString("ranged_xp", "" + player.playerXP[4] + "");
                rs.updateString("magic_xp", "" + player.playerXP[6] + "");
                rs.updateString("prayer_xp", "" + player.playerXP[5] + "");
                rs.updateString("slayer_xp", "" + player.playerXP[18] + "");
                rs.updateString("runecrafting_xp", "" + player.playerXP[20]
                        + "");
                rs.updateString("thieving_xp", "" + player.playerXP[17] + "");
                rs.updateString("crafting_xp", "" + player.playerXP[12] + "");
                rs.updateString("herblore_xp", "" + player.playerXP[15] + "");
                rs.updateString("fletching_xp", "" + player.playerXP[9] + "");
                rs.updateString("woodcutting_xp", "" + player.playerXP[8] + "");
                rs.updateString("fishing_xp", "" + player.playerXP[10] + "");
                rs.updateString("mining_xp", "" + player.playerXP[14] + "");
                rs.updateString("smithing_xp", "" + player.playerXP[13] + "");
                rs.updateString("cooking_xp", "" + player.playerXP[7] + "");
                rs.updateString("farming_xp", "" + player.playerXP[19] + "");
                rs.updateString("agility_xp", "" + player.playerXP[16] + "");
                rs.updateString("firemaking_xp", "" + player.playerXP[11] + "");
                rs.updateString("quest_points", "" + player.questPoints + "");
                rs.insertRow();
                /*
                 * System.err.println("Saved highscores for " +
                 * Utils.fixChatMessage(player.username) + ".");
                 */
            } else {
                rs.updateString("username", username);
                rs.updateInt("rights", 0);
                int totalLevel = (player.playerXP[0]) + (player.playerXP[1])
                        + (player.playerXP[2]) + (player.playerXP[3])
                        + (player.playerXP[4]) + (player.playerXP[5])
                        + (player.playerXP[6]) + (player.playerXP[7])
                        + (player.playerXP[8]) + (player.playerXP[9])
                        + (player.playerXP[10]) + (player.playerXP[11])
                        + (player.playerXP[12]) + (player.playerXP[13])
                        + (player.playerXP[14]) + (player.playerXP[15])
                        + (player.playerXP[16]) + (player.playerXP[17])
                        + (player.playerXP[18]) + (player.playerXP[19])
                        + (player.playerXP[20]);
                rs.updateString("overall_xp", "" + totalLevel + "");
                rs.updateString("attack_xp", "" + player.playerXP[0] + "");
                rs.updateString("defence_xp", "" + player.playerXP[1] + "");
                rs.updateString("strength_xp", "" + player.playerXP[2] + "");
                rs.updateString("constitution_xp", "" + player.playerXP[3] + "");
                rs.updateString("ranged_xp", "" + player.playerXP[4] + "");
                rs.updateString("magic_xp", "" + player.playerXP[6] + "");
                rs.updateString("prayer_xp", "" + player.playerXP[5] + "");
                rs.updateString("slayer_xp", "" + player.playerXP[18] + "");
                rs.updateString("runecrafting_xp", "" + player.playerXP[20]
                        + "");
                rs.updateString("thieving_xp", "" + player.playerXP[17] + "");
                rs.updateString("crafting_xp", "" + player.playerXP[12] + "");
                rs.updateString("herblore_xp", "" + player.playerXP[15] + "");
                rs.updateString("fletching_xp", "" + player.playerXP[9] + "");
                rs.updateString("woodcutting_xp", "" + player.playerXP[8] + "");
                rs.updateString("fishing_xp", "" + player.playerXP[10] + "");
                rs.updateString("mining_xp", "" + player.playerXP[14] + "");
                rs.updateString("smithing_xp", "" + player.playerXP[13] + "");
                rs.updateString("cooking_xp", "" + player.playerXP[7] + "");
                rs.updateString("farming_xp", "" + player.playerXP[19] + "");
                rs.updateString("agility_xp", "" + player.playerXP[16] + "");
                rs.updateString("firemaking_xp", "" + player.playerXP[11] + "");
                rs.updateString("quest_points", "" + player.questPoints + "");
                rs.updateRow();
                /*
                 * System.err.println("Saved highscores for " +
                 * Utils.fixChatMessage(player.username) + ".");
                 */
            }
        } catch (Exception e) {
            e.printStackTrace();
            player.sendMessage(e + ".");
            System.err.println("Error while updating highscores.");
            return false;
        }
        return true;
    }

    /** The c. */
    private Client c;
}