mcMMO/src/main/java/com/gmail/nossr50/database/runnables/SQLConversionTask.java

package com.gmail.nossr50.database.runnables;

import java.io.BufferedReader;
import java.io.FileReader;

import com.gmail.nossr50.mcMMO;
import com.gmail.nossr50.config.Config;
import com.gmail.nossr50.database.Database;
import com.gmail.nossr50.util.Misc;
import com.gmail.nossr50.util.StringUtils;

public class SQLConversionTask implements Runnable {
    private String tablePrefix = Config.getInstance().getMySQLTablePrefix();

    @Override
    public void run() {
        String location = mcMMO.getUsersFilePath();

        try {
            FileReader file = new FileReader(location);
            BufferedReader in = new BufferedReader(file);
            String line = "";
            String playerName = null;
            //String party = null;
            String mining = null;
            String woodcutting = null;
            String repair = null;
            String unarmed = null;
            String herbalism = null;
            String excavation = null;
            String archery = null;
            String swords = null;
            String axes = null;
            String acrobatics = null;
            String taming = null;
            String fishing = null;
            String miningXP = null;
            String woodCuttingXP = null;
            String repairXP = null;
            String unarmedXP = null;
            String herbalismXP = null;
            String excavationXP = null;
            String archeryXP = null;
            String swordsXP = null;
            String axesXP = null;
            String acrobaticsXP = null;
            String tamingXP = null;
            String fishingXP = null;
            int id = 0;
            int theCount = 0;

            while ((line = in.readLine()) != null) {

                //Find if the line contains the player we want.
                String[] character = line.split(":");
                playerName = character[0];

                //Check for things we don't want put in the DB
                if (playerName == null || playerName.equals("null") || playerName.equals("#Storage place for user information")) {
                    continue;
                }

                if (character.length > 1) {
                    mining = character[1];
                }
                
                /*
                 * Looks like we still have party as the 4th string in the array but we don't use it anymore
                if (character.length > 3) {
                    party = character[3];
                }
                */

                if (character.length > 4) {
                    miningXP = character[4];
                }

                if (character.length > 5) {
                    woodcutting = character[5];
                }

                if (character.length > 6) {
                    woodCuttingXP = character[6];
                }

                if (character.length > 7) {
                    repair = character[7];
                }

                if (character.length > 8) {
                    unarmed = character[8];
                }

                if (character.length > 9) {
                    herbalism = character[9];
                }

                if (character.length > 10) {
                    excavation = character[10];
                }

                if (character.length > 11) {
                    archery = character[11];
                }

                if (character.length > 12) {
                    swords = character[12];
                }

                if (character.length > 13) {
                    axes = character[13];
                }

                if (character.length > 14) {
                    acrobatics = character[14];
                }

                if (character.length > 15) {
                    repairXP = character[15];
                }

                if (character.length > 16) {
                    unarmedXP = character[16];
                }

                if (character.length > 17) {
                    herbalismXP = character[17];
                }

                if (character.length > 18) {
                    excavationXP = character[18];
                }

                if (character.length > 19) {
                    archeryXP = character[19];
                }

                if (character.length > 20) {
                    swordsXP = character[20];
                }

                if (character.length > 21) {
                    axesXP = character[21];
                }

                if (character.length > 22) {
                    acrobaticsXP = character[22];
                }

                if (character.length > 24) {
                    taming = character[24];
                }

                if (character.length > 25) {
                    tamingXP = character[25];
                }

                if (character.length > 34) {
                    fishing = character[34];
                }

                if (character.length > 35) {
                    fishingXP = character[35];
                }

                //Check to see if the user is in the DB
                id = Database.getInt("SELECT id FROM "
                        + tablePrefix
                        + "users WHERE user = '" + playerName + "'");

                if (id > 0) {
                    theCount++;

                    //Update the skill values
                    Database.write("UPDATE "
                            + tablePrefix
                            + "users SET lastlogin = " + 0
                            + " WHERE id = " + id);
                    Database.write("UPDATE "
                            + tablePrefix
                            + "skills SET "
                            + "  taming = taming+" + StringUtils.getInt(taming)
                            + ", mining = mining+" + StringUtils.getInt(mining)
                            + ", repair = repair+" + StringUtils.getInt(repair)
                            + ", woodcutting = woodcutting+" + StringUtils.getInt(woodcutting)
                            + ", unarmed = unarmed+" + StringUtils.getInt(unarmed)
                            + ", herbalism = herbalism+" + StringUtils.getInt(herbalism)
                            + ", excavation = excavation+" + StringUtils.getInt(excavation)
                            + ", archery = archery+" + StringUtils.getInt(archery)
                            + ", swords = swords+" + StringUtils.getInt(swords)
                            + ", axes = axes+" + StringUtils.getInt(axes)
                            + ", acrobatics = acrobatics+" + StringUtils.getInt(acrobatics)
                            + ", fishing = fishing+" + StringUtils.getInt(fishing)
                            + " WHERE user_id = " + id);
                    Database.write("UPDATE "
                            + tablePrefix
                            + "experience SET "
                            + "  taming = " + StringUtils.getInt(tamingXP)
                            + ", mining = " + StringUtils.getInt(miningXP)
                            + ", repair = " + StringUtils.getInt(repairXP)
                            + ", woodcutting = " + StringUtils.getInt(woodCuttingXP)
                            + ", unarmed = " + StringUtils.getInt(unarmedXP)
                            + ", herbalism = " + StringUtils.getInt(herbalismXP)
                            + ", excavation = " + StringUtils.getInt(excavationXP)
                            + ", archery = " + StringUtils.getInt(archeryXP)
                            + ", swords = " + StringUtils.getInt(swordsXP)
                            + ", axes = " + StringUtils.getInt(axesXP)
                            + ", acrobatics = " + StringUtils.getInt(acrobaticsXP)
                            + ", fishing = " + StringUtils.getInt(fishingXP)
                            + " WHERE user_id = " + id);
                }
                else {
                    theCount++;

                    //Create the user in the DB
                    Database.write("INSERT INTO "
                            + tablePrefix
                            + "users (user, lastlogin) VALUES ('"
                            + playerName + "',"
                            + System.currentTimeMillis() / Misc.TIME_CONVERSION_FACTOR + ")");
                    id = Database.getInt("SELECT id FROM "
                            + tablePrefix
                            + "users WHERE user = '"
                            + playerName + "'");
                    Database.write("INSERT INTO "
                            + tablePrefix
                            + "skills (user_id) VALUES (" + id + ")");
                    Database.write("INSERT INTO "
                            + tablePrefix
                            + "experience (user_id) VALUES (" + id
                            + ")");
                    //Update the skill values
                    Database.write("UPDATE "
                            + tablePrefix
                            + "users SET lastlogin = " + 0
                            + " WHERE id = " + id);
                    /*
                    Database.write("UPDATE "
                            + tablePrefix
                            + "users SET party = '" + party
                            + "' WHERE id = " + id);
                    */
                    Database.write("UPDATE "
                            + tablePrefix
                            + "skills SET "
                            + "  taming = taming+" + StringUtils.getInt(taming)
                            + ", mining = mining+" + StringUtils.getInt(mining)
                            + ", repair = repair+" + StringUtils.getInt(repair)
                            + ", woodcutting = woodcutting+" + StringUtils.getInt(woodcutting)
                            + ", unarmed = unarmed+" + StringUtils.getInt(unarmed)
                            + ", herbalism = herbalism+" + StringUtils.getInt(herbalism)
                            + ", excavation = excavation+" + StringUtils.getInt(excavation)
                            + ", archery = archery+" + StringUtils.getInt(archery)
                            + ", swords = swords+" + StringUtils.getInt(swords)
                            + ", axes = axes+" + StringUtils.getInt(axes)
                            + ", acrobatics = acrobatics+" + StringUtils.getInt(acrobatics)
                            + ", fishing = fishing+" + StringUtils.getInt(fishing)
                            + " WHERE user_id = " + id);
                    Database.write("UPDATE "
                            + tablePrefix
                            + "experience SET "
                            + "  taming = " + StringUtils.getInt(tamingXP)
                            + ", mining = " + StringUtils.getInt(miningXP)
                            + ", repair = " + StringUtils.getInt(repairXP)
                            + ", woodcutting = " + StringUtils.getInt(woodCuttingXP)
                            + ", unarmed = " + StringUtils.getInt(unarmedXP)
                            + ", herbalism = " + StringUtils.getInt(herbalismXP)
                            + ", excavation = " + StringUtils.getInt(excavationXP)
                            + ", archery = " + StringUtils.getInt(archeryXP)
                            + ", swords = " + StringUtils.getInt(swordsXP)
                            + ", axes = " + StringUtils.getInt(axesXP)
                            + ", acrobatics = " + StringUtils.getInt(acrobaticsXP)
                            + ", fishing = " + StringUtils.getInt(fishingXP)
                            + " WHERE user_id = " + id);
                }
            }

            mcMMO.p.getLogger().info("[mcMMO] MySQL Updated from users file, " + theCount + " items added/updated to MySQL DB");
            in.close();
        }
        catch (Exception e) {
            mcMMO.p.getLogger().severe("Exception while reading " + location + " (Are you sure you formatted it correctly?)" + e.toString());
        }
    }
}