import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;

/**
 * Ez az osztály egy MySQL adatbázishoz való kapcsolódásért felelős.
 */
public class DatabaseConnection {
    private Connection dbConnection;
    private String mysqlVersion;

    /**
     * Kapcsolódik az adatbázishoz a megadott adatok felhasználásával.
     *
     * @param HostName A szerver címe
     * @param Username A felhasználónév
     * @param Password A felhasználónévhez tartozó jelszó
     * @param Database A használandó adatbázis
     * @throws SQLException Ha nem sikerült kapcsolódni a szerverhez
     */
    public DatabaseConnection(String HostName, String Username, String Password, String Database) throws SQLException {
        String ConnectionStr = String.format("jdbc:mysql://%s:3306/%s", HostName, Database);

        this.dbConnection = DriverManager.getConnection(ConnectionStr, Username, Password);
        this.dbConnection.setAutoCommit(true);

        try (ResultSet r = dbConnection.createStatement().executeQuery("SELECT VERSION()")) {
            r.next();
            this.mysqlVersion = r.getString(1);
        }
    }

    /**
     * Lezárja az adatbázis-kapcsolatot
     * @throws Throwable Ha valami misztikus hiba történik
     */
    @Override
    public void finalize() throws Throwable {
        this.dbConnection.close();
        super.finalize();
    }

    /**
     * Megadja a kapcsolatot, amivel piszkálhatjuk a szervert
     * @return A MySQL kapcsolat
     */
    public Connection getConnection() {
        return dbConnection;
    }

    /**
     * Megadja a MySQL szerver verziószámát.
     * @return A szerver verziószáma
     */
    public String getMysqlVersion() {
        return mysqlVersion;
    }
}