package fr.mrjuiceboy.omeganetwork.apimoney;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import org.bukkit.Bukkit;
import org.bukkit.configuration.file.FileConfiguration;
import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.player.PlayerJoinEvent;
import org.bukkit.plugin.java.JavaPlugin;

public class Main extends JavaPlugin
  implements Listener
{
  private FileConfiguration config = getConfig();
  private static Connection conn;
  private static String host;
  private static int port;
  private static String user;
  private static String pass;
  private static String database;
  private String prefix = "§7[§e§lOmega-Network - APIMoney§7] ";

  public void onEnable()
  {
    this.config.addDefault("FirstJoinCoins", Integer.valueOf(0));
    this.config.addDefault("host", "149.202.45.139");
    this.config.addDefault("port", Integer.valueOf(3306));
    this.config.addDefault("user", "MrJuiceBoy");
    this.config.addDefault("pass", "JxyxuNE37QcUeACS");
    this.config.addDefault("database", "omegadb");
    this.config.options().copyDefaults(true);
    saveConfig();
    host = this.config.getString("host");
    port = this.config.getInt("port");
    user = this.config.getString("user");
    pass = this.config.getString("pass");
    database = this.config.getString("database");
    conn = openConnection();
    createTable();
    Bukkit.getServer().getPluginManager().registerEvents(this, this);
  }

  public static Connection openConnection()
  {
    try
    {
      Class.forName("com.mysql.jdbc.Driver");
    }
    catch (ClassNotFoundException e1)
    {
      System.err.println(e1);
      e1.printStackTrace();
    }
    try
    {
      Connection conn = DriverManager.getConnection("jdbc:mysql://" + host + ":" + port + "/" + database, user, pass);
      System.out.println("[Omega-Network - APIMoney] Database connect");
      return conn;
    }
    catch (SQLException e)
    {
      System.out.println("[Omega-Network - APIMoney] Database no connect");
      System.err.println(e);
      e.printStackTrace();
    }
    return null;
  }

  public static void createTable()
  {
    try
    {
      Statement state = conn.createStatement();
      state.executeUpdate("CREATE TABLE IF NOT EXISTS `joueurs` (`user_points` VARCHAR(16), `user_pseudo` INT)");
    }
    catch (SQLException e)
    {
      System.out.println("The table could not be created");
      System.err.println(e);
      e.printStackTrace();
    }
  }

  public static void Update(String qry)
  {
    try
    {
      Statement stmt = conn.createStatement();
      stmt.executeUpdate(qry);

      stmt.close();
    }
    catch (Exception ex)
    {
      openConnection();
      System.err.println(ex);
    }
  }

  public static Connection getConnection()
  {
    return conn;
  }

  public static ResultSet Query(String qry)
  {
    ResultSet rs = null;
    try
    {
      Statement stmt = conn.createStatement();
      rs = stmt.executeQuery(qry);
    }
    catch (Exception ex)
    {
      openConnection();
      System.err.println(ex);
    }
    return rs;
  }

  @EventHandler
  public void onJoin(PlayerJoinEvent e)
  {
    Player p = e.getPlayer();
    boolean exist = false;
    try
    {
      ResultSet rs = Query("SELECT `coins` FROM `players_coins` WHERE `player_name`='" + p.getName() + "'");
      while (rs.next()) {
        exist = Boolean.valueOf(true).booleanValue();
      }
    }
    catch (Exception err)
    {
      System.err.println(err);
      err.printStackTrace();
    }
    if (!exist)
      Update("INSERT INTO `joueurs` (`user_pseudo`, `user_points`) VALUES ('" + p.getName() + "', '" + this.config.getInt("startCoins") + "')");
  }
}