diff --git a/src/main/java/de/uniluebeck/mi/projmi6/db/DBHandler.java b/src/main/java/de/uniluebeck/mi/projmi6/db/DBHandler.java index 2163e13..55862d6 100644 --- a/src/main/java/de/uniluebeck/mi/projmi6/db/DBHandler.java +++ b/src/main/java/de/uniluebeck/mi/projmi6/db/DBHandler.java @@ -26,6 +26,7 @@ public class DBHandler { private static final String SELECT_ALL_OPSCODES = "SELECT * FROM `stammops`"; private static final String SELECT_ICD10CODE_BY_ID = "SELECT * FROM `stammicd10` WHERE `icd10code` = '?' AND `version` = ?"; private static final String SELECT_OPSCODE_BY_ID = "SELECT * FROM `stammops` WHERE `opscode` = '?' AND `version` = ?"; + private static final String SELECT_ALL_MITARBEITER = "SELECT * FROM `mitarbeiter`"; public static List getAllPatients() throws SQLException { Statement statement = MySqlConnFactory.getConnection().createStatement(); @@ -218,4 +219,24 @@ public class DBHandler { return new OpsCode(code, text, version); } + public static List getAllMitarbeiter() throws SQLException { + Statement statement = MySqlConnFactory.getConnection().createStatement(); + ResultSet rs = statement.executeQuery(SELECT_ALL_MITARBEITER); + + List mitarbeiters = new ArrayList<>(); + while (rs.next()) { + mitarbeiters.add(getMitarbeiter(rs)); + } + + return mitarbeiters; + } + + private static Mitarbeiter getMitarbeiter(ResultSet rs) throws SQLException { + Mitarbeiter mitarbeiter = new Mitarbeiter(rs.getInt("mitarbid")); + mitarbeiter.setTitel(rs.getString("titel")); + mitarbeiter.setVorname(rs.getString("vorname")); + mitarbeiter.setNachname(rs.getString("nachname")); + mitarbeiter.setEinweisenderArzt(rs.getString("einweisenderarzt")); + return mitarbeiter; + } }