import java.sql.SQLException;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.ResultSet;
import java.sql.DriverManager;
import java.util.List;
import java.util.ArrayList;

class Mariadb {
	String host = "localhost";
	String port = "3306";
	String db = "surubt";
	String user = "surubt";
	String pass = "titok";    
        Connection conn;
    
        public Mariadb() {
            this.conn = null;
        }
    
	public void connectDb() {		
		try {
			tryConnectDb();
		}catch(SQLException ex) {
			System.err.println("Hiba! A kapcsolódás sikertelen!");
		}
	}
    
	public void tryConnectDb() throws SQLException {
		String url = "jdbc:mariadb://" + host + ":" + port + "/"+ db;
		this.conn = DriverManager.getConnection(url, user, pass);		
	}
    
	public void closeDb() {
		try {
			tryCloseDb();
		}catch(SQLException ex) {
			System.err.println("Hiba! Az adatbázis bezárása sikertelen!");
		}
	}
    
	public void tryCloseDb() throws SQLException {
		this.conn.close();
	}
    
	public List<Dolgozo> getWorkmen() {
		List<Dolgozo> dolgozok = null;
		try {
			dolgozok = tryGetWorkmen();
		}catch(SQLException ex) {
			System.err.println("Hiba! A lekérdezés sikertelen");
		}
		return dolgozok;
	}
    
	public List<Dolgozo> tryGetWorkmen() throws SQLException {
        connectDb();
        String sql = "select az, nev, telepules, fizetes from dolgozok";		
		Statement stmt = this.conn.createStatement();		
		ResultSet rs = stmt.executeQuery(sql);
        List<Dolgozo> dolgozok = new ArrayList<>();
        while(rs.next()) {            
            Dolgozo dolgozo = new Dolgozo();
            dolgozo.az = rs.getInt("az");
            dolgozo.nev = rs.getString("nev");
            dolgozo.fizetes = rs.getDouble("fizetes");            
            dolgozok.add(dolgozo);
        }
        closeDb();
        return dolgozok;
	}
    
}