package de.squatic.coinsapi.utils;

import de.squatic.coinsapi.CoinsAPI;
import java.io.PrintStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class API_MySQL
{
  private String HOST = CoinsAPI.host;
  private String DATABASE = CoinsAPI.Database;
  private String USER = CoinsAPI.user;
  private String PASSWORD = CoinsAPI.password;
  private Connection connection;

  public API_MySQL(String host, String database, String user, String password)
  {
    this.HOST = host;
    this.DATABASE = database;
    this.USER = user;
    this.PASSWORD = password;

    connect();
  }

  public void connect()
  {
    try
    {
      this.connection = DriverManager.getConnection("jdbc:mysql://" + this.HOST + ":3306/" + this.DATABASE + "?autoReconnect=true", this.USER, this.PASSWORD);
      System.out.println("[MySQL] Die Verbindung zur MySQL wurde hergestellt!");
    }
    catch (SQLException e)
    {
      System.out.println("[MySQL] Die Verbindung zur MySQL ist fehlgeschlagen! Fehler: " + e.getMessage());
    }
  }

  public void close()
  {
    try
    {
      if (this.connection != null)
      {
        this.connection.close();
        System.out.println("[MySQL] Die Verbindung zur MySQL wurde Erfolgreich beendet!");
      }
    }
    catch (SQLException e)
    {
      System.out.println("[MySQL] Fehler beim beenden der Verbindung zur MySQL! Fehler: " + e.getMessage());
    }
  }

  public void update(String qry)
  {
    try
    {
      if (this.connection.isClosed()) {
        connect();
      }
      Statement st = this.connection.createStatement();
      st.executeUpdate(qry);
      st.close();
    }
    catch (SQLException e)
    {
      System.err.println(e);
    }
  }

  public ResultSet query(String qry)
  {
    ResultSet rs = null;
    try
    {
      if (this.connection.isClosed()) {
        connect();
      }
      Statement st = this.connection.createStatement();
      st.executeQuery(qry);
      return st.getResultSet();
    }
    catch (SQLException e)
    {
      System.err.println(e);
    }
    return rs;
  }
}