package me.kkiomen.pl;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

import org.bukkit.ChatColor;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.entity.PlayerDeathEvent;
import org.bukkit.plugin.java.JavaPlugin;

public class Main extends JavaPlugin implements Listener{

    String zamordowany;
    String morderca;

    private Connection conn;

    @Override
    public void onEnable() {
        System.out.println("Plugin ON");
        checkTable();
        try {
            saveData();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        getServer().getPluginManager().registerEvents(this, this);

    }

    @Override
    public void onDisable() {
        System.out.println("Plugin OFF");
        try {
            saveData();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

    private void checkTable(){
        openConnection();
        StringBuilder sb = new StringBuilder();
        sb.append("create table if not exists kill(");
        sb.append("killer varchar(50) not null,");
        sb.append("killed varchar(50) not null,");
        sb.append("primary key(killer));");
        try {
            conn.createStatement().executeUpdate(sb.toString());
        } catch (SQLException e) {
            e.printStackTrace();
        }
        closeConnection();
    }




    @EventHandler
   public void onKill(PlayerDeathEvent e)
   {
   morderca = e.getEntity().getName();
   zamordowany = e.getEntity().getKiller().getName();
   e.setDeathMessage(ChatColor.RED + zamordowany + " zostal zabitt przez " + morderca);
   }


    private void saveData() throws SQLException{
        openConnection();
        StringBuilder sb = new StringBuilder();
        sb.append("INSERT INTO kill (killer, killed) VALUES (");
        sb.append("’"+ morderca +"’,");
        sb.append("’"+ zamordowany +"’");
        sb.append(");");
        conn.createStatement().executeUpdate(sb.toString());
        closeConnection();
    }


    private synchronized void openConnection(){
        if(!isConnected()){
            try{
                conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/rank?user=rank&password=RANK");
            }catch(SQLException e){
                e.printStackTrace();
            }
        }
    }

    private synchronized void closeConnection(){
        if(isConnected()){
            try{
                conn.close();
            }catch(SQLException e){
                e.printStackTrace();
            }
        }
    }
    public boolean isConnected(){
        try{
            if(conn == null) return false;
            if(conn.isClosed()) return false;
        }catch(SQLException e){
            e.printStackTrace();
        }
        return false;
    }

}