package ru.yooxa.ultrawipe;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import org.bukkit.configuration.file.FileConfiguration;

public class SqlConnect
{
  String url;
  Log log;
  FileConfiguration config;
  String host;
  String port;
  String dbauthme;
  String dbpermissions;
  String username;
  String password;
  List<String> list;
  String group;
  String authmetable;
  String pextable;

  public SqlConnect(Main main)
  {
    this.log = new Log();
    this.config = main.getConfig();
    this.host = this.config.getString("Mysql.host");
    this.port = this.config.getString("Mysql.port");
    this.username = this.config.getString("Mysql.username");
    this.password = this.config.getString("Mysql.password");
    this.dbauthme = this.config.getString("Mysql.database.authme");
    this.dbpermissions = this.config.getString("Mysql.database.permissions");
    this.group = this.config.getString("deletegroup");
    this.list = new ArrayList();
    this.authmetable = this.config.getString("Mysql.tables.authme");
    this.pextable = this.config.getString("Mysql.tables.permissions");
  }

  public void waip()
  {
    Start();
  }

  private void Start()
  {
    new Thread(new Runnable()
    {
      public void run()
      {
        Connection connection;
        try
        {
          connection = DriverManager.getConnection("jdbc:mysql://" + SqlConnect.this.host + ":" + SqlConnect.this.port + "/" + SqlConnect.this.dbauthme, SqlConnect.this.username, SqlConnect.this.password);
          ResultSet resultSet = connection.createStatement().executeQuery("SELECT * FROM " + SqlConnect.this.authmetable);
          while (resultSet.next()) {
            SqlConnect.this.list.add(resultSet.getString("name"));
          }
          SqlConnect.this.log.info("Добавил игроков из таблицы AuthMe");
          resultSet.close();
          connection.close();
        }
        catch (Exception e)
        {
          SqlConnect.this.log.info("[Error] Ошибка при запросе AuthMe! Ошибка - " + e.getMessage());
          e.printStackTrace();
        }
        try
        {
          connection = DriverManager.getConnection("jdbc:mysql://" + SqlConnect.this.host + ":" + SqlConnect.this.port + "/" + SqlConnect.this.dbpermissions, SqlConnect.this.username, SqlConnect.this.password);
          ResultSet resultSet = connection.createStatement().executeQuery("SELECT * FROM " + SqlConnect.this.pextable);
          while (resultSet.next()) {
            if ((resultSet.getInt("type") == 1) && (!resultSet.getString("parent").equals(SqlConnect.this.group)))
            {
              SqlConnect.this.list.remove(resultSet.getString("child").toLowerCase());
              SqlConnect.this.log.info("Удалил из списка игрока " + resultSet.getString("child"));
            }
          }
          SqlConnect.this.log.info("Удалил донатеров");
          resultSet.close();
          connection.close();
        }
        catch (Exception e)
        {
          SqlConnect.this.log.info("[Error] Ошибка при запросе PermissionEx! Ошибка - " + e.getMessage());
          e.printStackTrace();
        }
        try
        {
          connection = DriverManager.getConnection("jdbc:mysql://" + SqlConnect.this.host + ":" + SqlConnect.this.port + "/" + SqlConnect.this.dbauthme, SqlConnect.this.username, SqlConnect.this.password);
          Statement state = connection.createStatement();
          for (String name : SqlConnect.this.list) {
            state.executeUpdate("DELETE FROM " + SqlConnect.this.authmetable + " WHERE name = '" + name + "'");
          }
          state.close();
          connection.close();
        }
        catch (Exception e)
        {
          SqlConnect.this.log.info("[Error] Ошибка при соединении с базой данных! Ошибка - " + e.getMessage());
          e.printStackTrace();
        }
        SqlConnect.this.log.info("Вайп завершен");
      }
    }).start();
  }
}