package me.timlampen.killrecorder;

import org.bukkit.Bukkit;
import org.bukkit.plugin.java.JavaPlugin;

import java.sql.*;
import java.util.HashMap;
import java.util.UUID;

/**
 * Created by Primary on 2/28/2016.
 */
public class Main extends JavaPlugin{

    String ip = "localhost";
    String databaseName = "stats";
    String username = "admin";
    String password = "1234";
    String databaseURL = "jdbc:mysql://" + ip + ":3306/" + databaseName;
    Connection connection;
    Statement state;

    HashMap<UUID, Integer> kills = new HashMap<UUID, Integer>();
    @Override
    public void onEnable(){
        Bukkit.getPluginManager().registerEvents(new KillListener(), this);
        getCommand("stats").setExecutor(new CommandHandler(this));

        try {
            Class.forName("com.mysql.jdbc.Driver");
            connection = DriverManager.getConnection(databaseURL, username, password);
            state = connection.createStatement();
        }
        catch(Exception ex) {
            ex.printStackTrace();
        }
        //start mysql

        try{
            PreparedStatement ps = connection.prepareStatement("CREATE TABLE IF NOT EXISTS " + "killData" + "(UUID VARCHAR(36) PRIMARY KEY, kills INT);");
        }catch(SQLException e) {
            e.printStackTrace();
        }
        //create table if not exist

        try{
            ResultSet res = state.executeQuery("SELECT * FROM killData");
            while(res.next()){
                UUID uuid = UUID.fromString(res.getString("UUID"));
                int killAmt = res.getInt("kills");
                kills.put(uuid, killAmt);
            }
        }catch(SQLException e) {
            e.printStackTrace();
        }
        //open connection
        //add data to hashmap
    }

    @Override
    public void onDisable(){

        for(UUID uuid : kills.keySet()){
            int killAmt = kills.get(uuid);
            try{
                state.executeUpdate("INSERT INTO killData (`UUID`, `kills`) VALUES ('" + uuid + "', '" + killAmt + "');");
            }catch(SQLException e) {
                e.printStackTrace();
            }
        }
    }
}