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 8840e56..f21e4db 100644 --- a/src/main/java/de/uniluebeck/mi/projmi6/db/DBHandler.java +++ b/src/main/java/de/uniluebeck/mi/projmi6/db/DBHandler.java @@ -59,6 +59,7 @@ public class DBHandler { private static final String SELECT_UNTERS_BY_FALLID = "SELECT * FROM `untersuchung` WHERE `fallid` = ?"; private static final String SELECT_MITARBEITER_BY_ID = "SELECT * FROM `mitarbeiter` WHERE `mitarbid` = ?"; private static final String SELECT_DIAGNOSE_BY_FALLID = "SELECT * FROM `diagnose` WHERE `fallid` = ?"; + private static final String SELECT_ALL_KASSEN = "SELECT * FROM `kasse`"; public static List getAllPatients() throws SQLException { Statement statement = MySqlConnFactory.getConnection().createStatement(); @@ -378,4 +379,26 @@ public class DBHandler { return diagnosen; } + + public static List getAllKassen() throws SQLException { + Statement statement = MySqlConnFactory.getConnection().createStatement(); + ResultSet rs = statement.executeQuery(SELECT_ALL_KASSEN); + + List kassen = new ArrayList<>(); + while (rs.next()) { + kassen.add(getKasse(rs)); + } + + return kassen; + } + + private static Kasse getKasse(ResultSet rs) throws SQLException { + Kasse kasse = new Kasse(); + kasse.setKassenID(rs.getInt("kassenid")); + kasse.setName(rs.getString("name")); + kasse.setAdresse(rs.getString("adresse")); + kasse.setPrivat(rs.getBoolean("privat")); + setVersionInformation(kasse, rs); + return kasse; + } }