//CLASS 1

package fr.ronnay57.VersusSQL;

import fr.ronnay57.VersusSQL.API.VersusAPI;
import java.io.PrintStream;
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.Server;
import org.bukkit.command.Command;
import org.bukkit.command.CommandSender;
import org.bukkit.configuration.file.FileConfiguration;
import org.bukkit.configuration.file.FileConfigurationOptions;
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.PluginManager;
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§lVersusSQL§7] ";

  public void onEnable()
  {
    this.config.addDefault("host", "localhost");
    this.config.addDefault("port", Integer.valueOf(3306));
    this.config.addDefault("user", "lel");
    this.config.addDefault("pass", "lel");
    this.config.addDefault("database", "lel");
    this.config.addDefault("startPoints", Integer.valueOf(0));
    this.config.addDefault("activeCommands", Boolean.valueOf(true));
    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("VersusSQL it is connected to the database");
      return conn;
    }
    catch (SQLException e)
    {
      System.out.println("The connection to the database failed");
      System.err.println(e);
      e.printStackTrace();
    }
    return null;
  }

  public static void createTable()
  {
    try
    {
      Statement state = conn.createStatement();
      state.executeUpdate("CREATE TABLE IF NOT EXISTS `players` (`player_uuid` VARCHAR(36), `name` VARCHAR(36), `points` INT, `rang` INT, `grade` INT, `kill` INT, `death` INT, `Time_in_secs` 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();
    try
    {
      conn = openConnection();
    }
    catch (Exception err)
    {
      System.err.println(err);
      err.printStackTrace();
    }
    boolean exist = false;
    try
    {
      ResultSet rs = Query("SELECT `points` FROM `players` WHERE `name`='" + p.getName() + "'");
      Query("UPDATE `players` SET `player_uuid`='" + p.getUniqueId() + "' WHERE `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 `players` (`player_uuid`, `name`, `points` , `rang`, `grade`, `kill`, `death`, `Time_in_secs`) VALUES ('" + p.getUniqueId() + "', '" + p.getName() + "','" + this.config.getInt("startPoints") + "', '" + 1 + "', '" + 0 + "', '" + 0 + "', '" + 0 + "', '" + 0 + "')");
    }
  }

  public boolean onCommand(CommandSender sender, Command cmd, String label, String[] args)
  {
    Player p = (Player)sender;
    if (label.equalsIgnoreCase("SQL")) {
      if (this.config.getBoolean("activeCommands"))
      {
        if (p.hasPermission("SQL.use"))
        {
          if (args.length == 0) {
            p.sendMessage(this.prefix + "§aYou have " + VersusAPI.getPoints(p) + " points.");
          }
          if (args.length == 1) {
            if (args[0].equalsIgnoreCase("help"))
            {
              p.sendMessage("§2--- Help message for VersusSQL ---");
              p.sendMessage("/SQL help  §7| §aShow this message");
              p.sendMessage("/SQL add <player> <amount> §7| §aAdd points to the player");
              p.sendMessage("/SQL get <player> §7| §aShow the points of the player");
              p.sendMessage("/SQL set <player> <amount> §7| §aSet points to the player");
            }
            else
            {
              p.sendMessage(this.prefix + "§cUse §f/SQL help §cfor more information.");
            }
          }
          if ((args.length == 2) &&
            (args[0].equalsIgnoreCase("get")))
          {
            Player target = p.getServer().getPlayer(args[1]);
            p.sendMessage(this.prefix + "§a" + target.getName() + " has §a" + VersusAPI.getPoints(target) + " points.");
          }
          if (args.length == 3)
          {
            if (args[0].equalsIgnoreCase("add"))
            {
              int c = Integer.parseInt(args[2]);
              Player target = p.getServer().getPlayer(args[1]);
              VersusAPI.addPoints(target, c);
              p.sendMessage(this.prefix + "§aYou have added " + c + " points to " + target.getName());
            }
            if (args[0].equalsIgnoreCase("set"))
            {
              int c = Integer.parseInt(args[2]);
              Player target = p.getServer().getPlayer(args[1]);
              VersusAPI.setPoints(target, c);
              p.sendMessage(this.prefix + "§aYou have set " + c + " points to " + target.getName());
            }
            if ((!args[0].equalsIgnoreCase("add")) && (!args[0].equalsIgnoreCase("set"))) {
              p.sendMessage(this.prefix + "§cUse §f/SQL help §cfor more information.");
            }
          }
          if (args.length > 3) {
            p.sendMessage(this.prefix + "§cUse §f/SQL help §cfor more information.");
          }
        }
        else
        {
          p.sendMessage(this.prefix + "§cYou don't have permission to use this command !");
        }
      }
      else
      {
        p.sendMessage(this.prefix + "§cThe commands are not enable.");
        return false;
      }
    }
    return false;
  }
}







//CLASS 2

package fr.ronnay57.VersusSQL.API;

import fr.ronnay57.VersusSQL.Main;
import java.io.PrintStream;
import java.sql.ResultSet;
import org.bukkit.entity.Player;

public class VersusAPI
{
  public static int getPoints(Player p)
  {
    int c = 0;
    try
    {
      ResultSet rs = Main.Query("SELECT `points` FROM `players` WHERE `name`='" + p.getName() + "'");
      while (rs.next()) {
        c = rs.getInt(1);
      }
    }
    catch (Exception err)
    {
      System.err.println(err);
      err.printStackTrace();
    }
    return c;
  }

  public static void addPoints(Player p, int points)
  {
    int c = getPoints(p);
    c += points;
    Main.Update("UPDATE `players` SET `points`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static void removePoints(Player p, int points)
  {
    int c = getPoints(p);
    c -= points;
    Main.Update("UPDATE `players` SET `points`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static void setPoints(Player p, int points)
  {
    int c = getPoints(p);
    int a = 0;
    c = a + points;
    Main.Update("UPDATE `players` SET `points`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static int getRang(Player p)
  {
    int c = 0;
    try
    {
      ResultSet rs = Main.Query("SELECT `rang` FROM `players` WHERE `name`='" + p.getName() + "'");
      while (rs.next()) {
        c = rs.getInt(1);
      }
    }
    catch (Exception err)
    {
      System.err.println(err);
      err.printStackTrace();
    }
    return c;
  }

  public static void addRang(Player p, int rang)
  {
    int c = getRang(p);
    c += rang;
    Main.Update("UPDATE `players` SET `rang`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static void removeRang(Player p, int rang)
  {
    int c = getRang(p);
    c -= rang;
    Main.Update("UPDATE `players` SET `rang`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static void setRang(Player p, int rang)
  {
    int c = getRang(p);
    int a = 0;
    c = a + rang;
    Main.Update("UPDATE `players` SET `rang`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static int getGrade(Player p)
  {
    int c = 0;
    try
    {
      ResultSet rs = Main.Query("SELECT `grade` FROM `players` WHERE `name`='" + p.getName() + "'");
      while (rs.next()) {
        c = rs.getInt(1);
      }
    }
    catch (Exception err)
    {
      System.err.println(err);
      err.printStackTrace();
    }
    return c;
  }

  public static void addGrade(Player p, int grade)
  {
    int c = getGrade(p);
    c += grade;
    Main.Update("UPDATE `players` SET `grade`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static void removeGrade(Player p, int grade)
  {
    int c = getGrade(p);
    c -= grade;
    Main.Update("UPDATE `players` SET `grade`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static void setGrade(Player p, int grade)
  {
    int c = getGrade(p);
    int a = 0;
    c = a + grade;
    Main.Update("UPDATE `players` SET `grade`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static int getKills(Player p)
  {
    int c = 0;
    try
    {
      ResultSet rs = Main.Query("SELECT `kill` FROM `players` WHERE `name`='" + p.getName() + "'");
      while (rs.next()) {
        c = rs.getInt(1);
      }
    }
    catch (Exception err)
    {
      System.err.println(err);
      err.printStackTrace();
    }
    return c;
  }

  public static void addKills(Player p, int kill)
  {
    int c = getKills(p);
    c += kill;
    Main.Update("UPDATE `players` SET `kill`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static void removeKills(Player p, int kill)
  {
    int c = getKills(p);
    c -= kill;
    Main.Update("UPDATE `players` SET `kill`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static void setKills(Player p, int kill)
  {
    int c = getKills(p);
    int a = 0;
    c = a + kill;
    Main.Update("UPDATE `players` SET `kill`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static int getDeaths(Player p)
  {
    int c = 0;
    try
    {
      ResultSet rs = Main.Query("SELECT `death` FROM `players` WHERE `name`='" + p.getName() + "'");
      while (rs.next()) {
        c = rs.getInt(1);
      }
    }
    catch (Exception err)
    {
      System.err.println(err);
      err.printStackTrace();
    }
    return c;
  }

  public static void addDeaths(Player p, int Death)
  {
    int c = getDeaths(p);
    c += Death;
    Main.Update("UPDATE `players` SET `death`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static void removeDeaths(Player p, int Death)
  {
    int c = getDeaths(p);
    c -= Death;
    Main.Update("UPDATE `players` SET `death`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static void setDeaths(Player p, int Death)
  {
    int c = getDeaths(p);
    int a = 0;
    c = a + Death;
    Main.Update("UPDATE `players` SET `death`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static int getTime(Player p)
  {
    int c = 0;
    try
    {
      ResultSet rs = Main.Query("SELECT `Time_in_secs` FROM `players` WHERE `name`='" + p.getName() + "'");
      while (rs.next()) {
        c = rs.getInt(1);
      }
    }
    catch (Exception err)
    {
      System.err.println(err);
      err.printStackTrace();
    }
    return c;
  }

  public static void addTime(Player p, int Time_in_secs)
  {
    int c = getTime(p);
    c += Time_in_secs;
    Main.Update("UPDATE `players` SET `Time_in_secs`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static void removeTime(Player p, int Time_in_secs)
  {
    int c = getTime(p);
    c -= Time_in_secs;
    Main.Update("UPDATE `players` SET `Time_in_secs`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }

  public static void setTime(Player p, int Time_in_secs)
  {
    int c = getTime(p);
    int a = 0;
    c = a + Time_in_secs;
    Main.Update("UPDATE `players` SET `Time_in_secs`='" + c + "' WHERE `name`='" + p.getName() + "'");
  }
}