package play.elygames.fr;

import java.io.PrintStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.UUID;
import org.bukkit.entity.Player;
import play.elygames.fr.ranks.RanksManager;

public class SQLConnection
{
  private Connection connection;
  private String urlbase;
  private String host;
  private String database;
  private String user;
  private String pass;

  public SQLConnection(String urlbase, String host, String database, String user, String pass)
  {
    this.urlbase = urlbase;
    this.host = host;
    this.database = database;
    this.user = user;
    this.pass = pass;
  }

  public boolean isConnected()
  {
    return this.connection != null;
  }

  public void connection()
  {
    if (!isConnected()) {
      try
      {
        this.connection = DriverManager.getConnection(this.urlbase + this.host + "/" + this.database, this.user, this.pass);
        System.out.println("connection reussite !");
      }
      catch (SQLException e)
      {
        e.printStackTrace();
      }
    }
  }

  public void disconnect()
  {
    if (isConnected()) {
      try
      {
        this.connection.close();
        System.out.println("connection impossible");
      }
      catch (SQLException e)
      {
        e.printStackTrace();
      }
    }
  }

  public boolean hasAccount(Player player)
  {
    connection();
    try
    {
      PreparedStatement q = this.connection.prepareStatement("SELECT uuid FROM players WHERE uuid = ?");
      q.setString(1, player.getUniqueId().toString());
      ResultSet resultat = q.executeQuery();
      boolean hasAccount = resultat.next();
      q.close();
      return hasAccount;
    }
    catch (SQLException e)
    {
      e.printStackTrace();
    }
    return false;
  }

  public void createAccount(Player player)
  {
    connection();
    if (!hasAccount(player)) {
      try
      {
        PreparedStatement q = this.connection.prepareStatement("INSERT INTO players(uuid,ranks) VALUES (?,?)");
        q.setString(1, player.getUniqueId().toString());
        q.setInt(2, RanksManager.Default.getPower().intValue());
        q.execute();
        q.close();
      }
      catch (SQLException e)
      {
        e.printStackTrace();
      }
    }
  }

  public void setRank(Player player, RanksManager rank)
  {
    connection();
    if (hasAccount(player)) {
      try
      {
        PreparedStatement rs = this.connection.prepareStatement("UPDATE players SET ranks = ? WHERE uuid = ?");
        rs.setInt(1, rank.getPower().intValue());
        rs.setString(2, player.getUniqueId().toString());
        rs.executeUpdate();
        rs.close();
      }
      catch (SQLException e)
      {
        e.printStackTrace();
      }
    }
  }

  public RanksManager getRank(Player player)
  {
    connection();
    if (hasAccount(player)) {
      try
      {
        PreparedStatement q = this.connection.prepareStatement("SELECT ranks FROM players WHERE uuid = ?");
        q.setString(1, player.getUniqueId().toString());

        int power = 0;
        ResultSet rs = q.executeQuery();
        while (rs.next()) {
          power = rs.getInt("ranks");
        }
        q.close();
        return RanksManager.PowerToRanks(power);
      }
      catch (SQLException e)
      {
        e.printStackTrace();
      }
    }
    return RanksManager.Default;
  }
}