Mitarbeiter aus DB ausgelesen

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<Patient> getAllPatients() throws SQLException {
         Statement statement = MySqlConnFactory.getConnection().createStatement();
@@ -218,4 +219,24 @@ public class DBHandler {
         return new OpsCode(code, text, version);
     }
 
+    public static List<Mitarbeiter> getAllMitarbeiter() throws SQLException {
+        Statement statement = MySqlConnFactory.getConnection().createStatement();
+        ResultSet rs = statement.executeQuery(SELECT_ALL_MITARBEITER);
+
+        List<Mitarbeiter> 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;
+    }
 }