/**
 * Created by matsf on 24.05.2017.
 */
public class MySQL {

    public String HOST;
    public String DATABASE;
    public String USERNAME;
    public String PASSWORD;
    public Connection con;

    public MySQL(String HOST, String DATABASE, String USERNAME, String PASSWORD) {
        this.HOST = HOST;
        this.DATABASE = DATABASE;
        this.USERNAME = USERNAME;
        this.PASSWORD = PASSWORD;
    }

    public void connect() {
        if(isConnected()) {
            try {
                con = DriverManager.getConnection("jdbc:mysql://" + HOST + ":3306/" + DATABASE + "?autoReconnect=true", USERNAME, PASSWORD);
                Bukkit.getConsoleSender().sendMessage("[MySQL] Erfolgreich zur MySQL-Datenbank verbunden");
            } catch(SQLException e) {
                Bukkit.getConsoleSender().sendMessage("[MySQL] Es konnte nicht zur MySQL-Datenbank verbunden werden, bitte überprüfe deine Einstellungen");
            }
        }
    }

    public void close() {
        if(isConnected()) {
            try {
                con.close();
                con = null;
                Bukkit.getConsoleSender().sendMessage("[MySQL] Die MySQL Verbindung wurde getrennt");
            } catch(SQLException e) {
                Bukkit.getConsoleSender().sendMessage("[MySQL] Die MySQL Verbindung konnte nicht geschlossen werden");
            }
        }
    }

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

    public void update(String qry) {
        if(isConnected()) {
            try {
                con.createStatement().executeUpdate(qry);
            } catch(SQLException e) {
                e.printStackTrace();
            }
        }
    }

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