Browse Source

Patient Enums angepasst

hapi
Nils Dittberner 10 years ago
parent
commit
2329ae73b2
2 changed files with 43 additions and 6 deletions
  1. +35
    -6
      src/main/java/de/uniluebeck/mi/projmi6/db/DBHandler.java
  2. +8
    -0
      src/main/java/de/uniluebeck/mi/projmi6/model/Patient.java

+ 35
- 6
src/main/java/de/uniluebeck/mi/projmi6/db/DBHandler.java View File

@@ -8,6 +8,7 @@ import java.sql.SQLException;
import java.sql.Statement; import java.sql.Statement;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.StringJoiner;


/** /**
* Created by nils on 15.11.2015. * Created by nils on 15.11.2015.
@@ -29,6 +30,7 @@ public class DBHandler {
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` = ?";
private static final String SELECT_MITARBEITER_BY_ID = "SELECT * FROM `mitarbeiter` WHERE `mitarbid` = ?"; 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` = ?";


public static List<Patient> getAllPatients() throws SQLException { public static List<Patient> getAllPatients() throws SQLException {
Statement statement = MySqlConnFactory.getConnection().createStatement(); Statement statement = MySqlConnFactory.getConnection().createStatement();
@@ -71,11 +73,25 @@ public class DBHandler {
return patient; return patient;
} }


public static void updatePatient(Patient patient) 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());
statement.setString(2, patient.getFamilienstand().toString());
// TODO
statement.setString(1, patient.getCave()); // CAVE
statement.setString(2, patient.getFamilienstand().toString()); // Familienstand
statement.setString(3, ""); // Geburtsdatum
statement.setString(4, patient.getGeburtsname()); // Geburtsname
statement.setString(5, String.valueOf(patient.getGeschlecht().id())); // Geschlecht
statement.setInt(6, patient.getKassenID()); // KasseId
statement.setInt(7, mitarbid); // Letzterbearbeiter
statement.setString(8, patient.getNachname()); // Nachname
statement.setString(9, patient.getOrt()); // Ort
statement.setString(10, patient.getPlz()); // PLZ
statement.setString(11, patient.getStrasse()); // Strasse
statement.setString(12, patient.getTelefon()); // telefon
statement.setString(13, patient.getVersichertennummer()); // versichertennummer
statement.setString(14, patient.getVorname()); // vorname

statement.executeUpdate();

} }


public static List<Station> getAllStationen() throws SQLException { public static List<Station> getAllStationen() throws SQLException {
@@ -127,8 +143,8 @@ public class DBHandler {
return fall; return fall;
} }


private static Diagnose getDiagnose(int hauptdiagnose, Fall fall) throws SQLException {
Diagnose diagnose = getDiagnose(hauptdiagnose);
private static Diagnose getDiagnose(int diagid, Fall fall) throws SQLException {
Diagnose diagnose = getDiagnose(diagid);
diagnose.setFall(fall); diagnose.setFall(fall);


return diagnose; return diagnose;
@@ -274,4 +290,17 @@ public class DBHandler {
setVersionInformation(untersuchung, rs); setVersionInformation(untersuchung, rs);
return untersuchung; return untersuchung;
} }

public static List<Diagnose> getDiagnosenByFall(Fall fall) throws SQLException {
PreparedStatement statement = MySqlConnFactory.getConnection().prepareStatement(SELECT_DIAGNOSE_BY_FALLID);
statement.setInt(1, fall.getFallID());
ResultSet rs = statement.executeQuery();

List<Diagnose> diagnosen = new ArrayList<>();
while (rs.next()) {
diagnosen.add(getDiagnose(rs.getInt("diagid"), fall));
}

return diagnosen;
}
} }

+ 8
- 0
src/main/java/de/uniluebeck/mi/projmi6/model/Patient.java View File

@@ -238,6 +238,10 @@ public class Patient extends Version {
public String toString() { public String toString() {
return geschlecht; return geschlecht;
} }

public char id() {
return id;
}
} }


public enum Familienstand { public enum Familienstand {
@@ -270,6 +274,10 @@ public class Patient extends Version {
} }
} }


public char id() {
return id;
}

@Override @Override
public String toString() { public String toString() {
return familienstand; return familienstand;


Loading…
Cancel
Save