package ru.autodonate;

import com.mysql.jdbc.Statement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import org.bukkit.command.ConsoleCommandSender;

public class Mysql
{
  static Connection conn;
  static Statement statmt;
  static PreparedStatement preparedStatement = null;

  public static void connect(String url, String name, String user, String pass)
  {
    try
    {
      Class.forName("com.mysql.jdbc.Driver");
      conn = DriverManager.getConnection("jdbc:mysql://" + url + "/" + name + "?useUnicode=true&characterEncoding=utf8&autoReconnect=true", user, pass);
      statmt = (Statement)conn.createStatement();

      statmt.execute("CREATE TABLE if not exists commands (player VARCHAR(16),  command VARCHAR(256))");

      Core.clogger.sendMessage(Core.prefix + "Соединение с базой данных прошло успешно!");
    }
    catch (Exception e)
    {
      e.printStackTrace();
    }
  }

  public static ArrayList<String> select(String p)
  {
    try
    {
      preparedStatement = conn.prepareStatement("SELECT * FROM commands WHERE player = ?");
      preparedStatement.setString(1, p);
      ResultSet rs = preparedStatement.executeQuery();
      List<String> command = new ArrayList();
      while (rs.next()) {
        command.add(rs.getString("command"));
      }
      return (ArrayList)command;
    }
    catch (Exception e)
    {
      Core.clogger.sendMessage(Core.prefix + "Ошибка подключения!");
      e.printStackTrace();
    }
    return null;
  }

  public static void delete(String p)
  {
    try
    {
      preparedStatement = conn.prepareStatement("DELETE FROM commands WHERE player = ?");
      preparedStatement.setString(1, p);
      preparedStatement.execute();
    }
    catch (Exception e)
    {
      Core.clogger.sendMessage(Core.prefix + "Ошибка подключения!");
      e.printStackTrace();
    }
  }
}