package util;

import de.mint.asyncmysqlpoolhandler.configservice.ConfigBuilder;
import de.mint.asyncmysqlpoolhandler.enumservice.EnumPoolFramework;
import de.mint.asyncmysqlpoolhandler.mainservice.AsyncMySQLPoolHandler;
import java.util.concurrent.CompletableFuture;
import org.intellij.lang.annotations.Language;

public class DatabaseUtil {

  private static final AsyncMySQLPoolHandler asyncMySQLPoolHandler =
      new AsyncMySQLPoolHandler(
          "localhost",
          3306,
          "root",
          "",
          "test",
          EnumPoolFramework.HIKARICP,
          ConfigBuilder.getConfigBuilder().build());

  public static void connect() {
    DatabaseUtil.asyncMySQLPoolHandler.openPool();
  }

  public static CompletableFuture<Void> update(@Language("MySQL") final String sql) {
    return DatabaseUtil.asyncMySQLPoolHandler.executeUpdateAsync(sql);
  }

  public static void disconnect() {
    DatabaseUtil.asyncMySQLPoolHandler.closePool();
  }

  public static void setup() {
    DatabaseUtil.update("CREATE TABLE IF NOT EXISTS `temp` (`first` INT, `second` VARCHAR(16));")
        .join(); // so the connection only closes if the query got executed
  }

  public static void main(final String[] args) {
    DatabaseUtil.connect();
    DatabaseUtil.setup();
    DatabaseUtil.disconnect();
  }
}