import de.teamnecross.teamspeakbot.TeamspeakBot;

import java.sql.*;

public class MySQL {

  private static String HOST = "";
  private static String PORT = "";
  private static String DATABASE = "";
  private static String USER = "";
  private static String PASSWORD = "";
  private static Connection con;

  public MySQL(String host, String port, String database, String user, String password) {
    HOST = host;
    PORT = port;
    DATABASE = database;
    USER = user;
    PASSWORD = password;

    connect();
  }

  public static void connect() {
    if (!isConnected()) {
      try {
        con = DriverManager.getConnection("jdbc:mysql://" + HOST + ":" + PORT + "/" + DATABASE + "?autoReconnect=true", USER, PASSWORD);
        TeamspeakBot.log.send("Connection to Database successfully!");
      } catch (SQLException e) {
        TeamspeakBot.log.send("Connection to Database failed!");
        e.printStackTrace();
      }
    }
  }

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

  public static void disconnect() {
    if (isConnected()) {
      try {
        con.close();
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
  }

  public static Connection getConnection() {
    return con;
  }

  public static void update(String qry) {
    if (isConnected()) {
      try {
        Statement st = con.createStatement();
        st.executeUpdate(qry);
      } catch (SQLException e) {
        connect();
        System.err.println(e);
      }
    }
  }

  public static ResultSet getResult(String qry) {
    if (isConnected()) {
      try {
        return con.createStatement().executeQuery(qry);
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
    return null;
  }


}