package me.phil.mw;

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.sql.Statement;

public class MySQL
{
	  public static String host = "";
	  public static String port = "3306";
	  public static String database = "";
	  public static String usrname = "";
	  public static String passwd = "";
  public static Connection con;

  public static void connect()
  {
    if (!connected()) {
      try
      {
        con = DriverManager.getConnection("jdbc:mysql://" + host + ":" + port + "/" + database + "?user=" + usrname + "&password=" + passwd + "&autoReconnect=true");

        System.out.println("[PSQL] MySQL Verbindung aufgebaut!");
      }
      catch (SQLException e)
      {
        System.out.println("[PSQL] " + e.getMessage());
      }
    }
  }




  public static void disconnect()
  {
    if (connected()) {
      try
      {
        con.close();
        System.out.println("[PSQL] MySQL Verbindung geschlossen!");
      }
      catch (SQLException e)
      {
        e.printStackTrace();
      }
    }
  }

public AsyncMySQL(Plugin owner, String host, int port, String user, String password, String database) {
      try {
         sql = new MySQL(host, port, user, password, database);
         executor = Executors.newCachedThreadPool();
         plugin = owner;
      } catch (Exception e) {
         e.printStackTrace();
      }
   }

  public static boolean connected()
  {
    return con != null;
  }

  public static void update(String qry)
  {
    try
    {
      PreparedStatement statement = con.prepareStatement(qry);
      statement.executeUpdate();
      statement.close();
    }
    catch (SQLException e)
    {
      e.printStackTrace();
    }
  }
  public static void Aupdate(String statement) {
      executor.execute(() -> sql.queryUpdate(statement));
   }

   public static void Aquery(PreparedStatement statement, Consumer<ResultSet> consumer) {
      executor.execute(() -> {
         ResultSet result = sql.query(statement);
         Bukkit.getScheduler().runTask(plugin, () -> consumer.accept(result));
      });
   }
   public static PreparedStatement Aprepare(String query) {
      try {
         return sql.getConnection().prepareStatement(query);
      } catch (Exception e) {
         e.printStackTrace();
      }
      return null;
   }
  public static ResultSet query(String qry)
  {
    ResultSet rs = null;
    try
    {
      Statement st = con.createStatement();
      rs = st.executeQuery(qry);
    }
    catch (SQLException e)
    {
      e.printStackTrace();
    }
    return rs;
  }
}