package fr.maxhf.stats;
import fr.maxhf.stats.events.KillDeath;
import org.bukkit.Bukkit;
import org.bukkit.event.Listener;
import org.bukkit.plugin.java.JavaPlugin;
import org.bukkit.scheduler.BukkitRunnable;

import java.sql.*;

public class Main extends JavaPlugin{
    public static Main instance;
    public Main() { instance = this; }
    public static String username="stats_factions";
    public static String password="JdA8K01ly";
    public static String url = "jdbc:mysql://hardfight.fr:3306/stats_factions";

    public static Connection connection;

    public static Main getInstance() {
        return Main.instance;
    }

    public void onEnable(){
        instance = this;
        System.out.println("[HardStats] Le plugin est synchronisé.");
        Bukkit.getPluginManager().registerEvents((Listener)new KillDeath(), this);
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
            System.err.println("jdbc driver unavailable!");
            return;
        }
        try {
            connection = DriverManager.getConnection(url,username,password);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    public void onDisable(){
        System.out.println("[HardStats] Le plugin s'éteint..");
        try {
            if (connection!=null && !connection.isClosed()){
                connection.close();
            }
        } catch(Exception e) {
            e.printStackTrace();
        }
    }

    public static void insertSQL(String insert){
        BukkitRunnable r = new BukkitRunnable() {
            @Override
            public void run() {
                try{
                    connection = DriverManager.getConnection(url, username, password);
                    PreparedStatement stmt = connection.prepareStatement(insert);
                    stmt.executeUpdate();
                }catch (SQLException e){
                    e.printStackTrace();
                }
            }
        };
        r.runTaskAsynchronously(getInstance());
    }


    public static ResultSet selectSQL(String select){
        try{
            connection = DriverManager.getConnection(url, username, password);
            Statement stmt = connection.createStatement();
            ResultSet rs = stmt.executeQuery(select);

            if(rs.next()){
                return rs;
            }
            rs.close();
        }catch(SQLException se){
            se.printStackTrace();
        }
        return null;
    }
}