| @@ -2,10 +2,7 @@ package de.uniluebeck.mi.projmi6.db; | |||||
| import de.uniluebeck.mi.projmi6.model.*; | import de.uniluebeck.mi.projmi6.model.*; | ||||
| import java.sql.PreparedStatement; | |||||
| import java.sql.ResultSet; | |||||
| import java.sql.SQLException; | |||||
| import java.sql.Statement; | |||||
| import java.sql.*; | |||||
| import java.util.ArrayList; | import java.util.ArrayList; | ||||
| import java.util.List; | import java.util.List; | ||||
| import java.util.StringJoiner; | import java.util.StringJoiner; | ||||
| @@ -20,12 +17,16 @@ public class DBHandler { | |||||
| private static final String UPDATE_PATIENT = "UPDATE `patient` SET `CAVE`=?, `Familienstand`=?, " + | private static final String UPDATE_PATIENT = "UPDATE `patient` SET `CAVE`=?, `Familienstand`=?, " + | ||||
| "`Geburtsdatum`=?, `Geburtsname`=?, `Geschlecht`=?, `KassenID`=?, `LetzterBearbeiter`=?, `Nachname`=?, " + | "`Geburtsdatum`=?, `Geburtsname`=?, `Geschlecht`=?, `KassenID`=?, `LetzterBearbeiter`=?, `Nachname`=?, " + | ||||
| "`Ort`=?, `PLZ`=?, `Strasse`=?, `Telefon`=?, `Versichertennummer`=?, `Vorname`=? WHERE `ID`=?"; | "`Ort`=?, `PLZ`=?, `Strasse`=?, `Telefon`=?, `Versichertennummer`=?, `Vorname`=? WHERE `ID`=?"; | ||||
| private static final String INSERT_PATIENT = "INSERT INTO `patient` (`CAVE`, `Ersteller`, `Familienstand`, " + | |||||
| "`Geburtdatum`, `Geburtsname`,`Geschlecht`, `Hausnummer`, `KassenID`, `LetzterBearbeiter`, `Nachname`, " + | |||||
| "`Ort`, `PLZ`, `Strasse`, `Telefon`,`Versichertennummer`, `Vorname`) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, " + | |||||
| "?, ?, ?, ?, ?, ?, ?, ?, ?)"; | |||||
| private static final String SELECT_ALL_STATIONEN = "SELECT * FROM `stammstation`"; | private static final String SELECT_ALL_STATIONEN = "SELECT * FROM `stammstation`"; | ||||
| private static final String SELECT_FAELLE_BY_PATID = "SELECT * FROM `fall` WHERE `patientid` = ?"; | private static final String SELECT_FAELLE_BY_PATID = "SELECT * FROM `fall` WHERE `patientid` = ?"; | ||||
| private static final String SELECT_DIAGNOSE_BY_ID = "SELECT * FROM `diagnose` WHERE `diagid` = ?"; | private static final String SELECT_DIAGNOSE_BY_ID = "SELECT * FROM `diagnose` WHERE `diagid` = ?"; | ||||
| private static final String SELECT_ALL_ICD10CODES = "SELECT * FROM `stammicd10`"; | private static final String SELECT_ALL_ICD10CODES = "SELECT * FROM `stammicd10`"; | ||||
| private static final String SELECT_ALL_OPSCODES = "SELECT * FROM `stammops`"; | 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_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_OPSCODE_BY_ID = "SELECT * FROM `stammops` WHERE `opscode` = ? AND `version` = ?"; | ||||
| private static final String SELECT_ALL_MITARBEITER = "SELECT * FROM `mitarbeiter`"; | private static final String SELECT_ALL_MITARBEITER = "SELECT * FROM `mitarbeiter`"; | ||||
| private static final String SELECT_UNTERS_BY_FALLID = "SELECT * FROM `untersuchung` WHERE `fallid` = ?"; | private static final String SELECT_UNTERS_BY_FALLID = "SELECT * FROM `untersuchung` WHERE `fallid` = ?"; | ||||
| @@ -73,6 +74,7 @@ public class DBHandler { | |||||
| return patient; | return patient; | ||||
| } | } | ||||
| // TODO: Defaultwerte entfernen und so. | |||||
| public static void updatePatient(Patient patient, int mitarbid) throws SQLException { | public static void updatePatient(Patient patient, int mitarbid) throws SQLException { | ||||
| PreparedStatement statement = MySqlConnFactory.getConnection().prepareStatement(UPDATE_PATIENT); | PreparedStatement statement = MySqlConnFactory.getConnection().prepareStatement(UPDATE_PATIENT); | ||||
| statement.setString(1, patient.getCave()); // CAVE | statement.setString(1, patient.getCave()); // CAVE | ||||
| @@ -80,13 +82,14 @@ public class DBHandler { | |||||
| statement.setString(2, patient.getFamilienstand().toString()); // Familienstand | statement.setString(2, patient.getFamilienstand().toString()); // Familienstand | ||||
| else | else | ||||
| statement.setString(2, "l"); | statement.setString(2, "l"); | ||||
| statement.setString(3, ""); // Geburtsdatum | |||||
| statement.setDate(3, Date.valueOf(patient.getGeburtsdatum())); // Geburtsdatum | |||||
| statement.setString(4, patient.getGeburtsname()); // Geburtsname | statement.setString(4, patient.getGeburtsname()); // Geburtsname | ||||
| if (patient.getGeschlecht() != null) | if (patient.getGeschlecht() != null) | ||||
| statement.setString(5, String.valueOf(patient.getGeschlecht().id())); // Geschlecht | statement.setString(5, String.valueOf(patient.getGeschlecht().id())); // Geschlecht | ||||
| else | else | ||||
| statement.setString(5, "o"); | statement.setString(5, "o"); | ||||
| statement.setInt(6, patient.getKassenID()); // KasseId | |||||
| // statement.setInt(6, patient.getKassenID()); // KasseId | |||||
| statement.setInt(6, 1); // KasseId | |||||
| statement.setInt(7, mitarbid); // Letzterbearbeiter | statement.setInt(7, mitarbid); // Letzterbearbeiter | ||||
| statement.setString(8, patient.getNachname()); // Nachname | statement.setString(8, patient.getNachname()); // Nachname | ||||
| statement.setString(9, patient.getOrt()); // Ort | statement.setString(9, patient.getOrt()); // Ort | ||||
| @@ -98,10 +101,13 @@ public class DBHandler { | |||||
| statement.setInt(15, patient.getPatID()); // patid | statement.setInt(15, patient.getPatID()); // patid | ||||
| System.out.println(statement.toString()); | System.out.println(statement.toString()); | ||||
| System.exit(0); | |||||
| statement.executeUpdate(); | statement.executeUpdate(); | ||||
| } | |||||
| public static void insertPatient(Patient patient, int mitarbid) throws SQLException { | |||||
| PreparedStatement statement = MySqlConnFactory.getConnection().prepareStatement(INSERT_PATIENT); | |||||
| // TODO | |||||
| } | } | ||||
| public static List<Station> getAllStationen() throws SQLException { | public static List<Station> getAllStationen() throws SQLException { | ||||
| @@ -162,6 +168,7 @@ public class DBHandler { | |||||
| private static Diagnose getDiagnose(int id) throws SQLException { | private static Diagnose getDiagnose(int id) throws SQLException { | ||||
| PreparedStatement statement = MySqlConnFactory.getConnection().prepareStatement(SELECT_DIAGNOSE_BY_ID); | PreparedStatement statement = MySqlConnFactory.getConnection().prepareStatement(SELECT_DIAGNOSE_BY_ID); | ||||
| statement.setInt(1, id); | |||||
| ResultSet rs = statement.executeQuery(); | ResultSet rs = statement.executeQuery(); | ||||
| rs.next(); // TODO | rs.next(); // TODO | ||||