src/Dr.NO/src/drno/server/database/broker/TidsreservationBroker.java

   1 /*
   2  * Created on 2005-04-25
   3
   4  */
   5 package drno.server.database.broker;
   6
   7 import java.sql.Timestamp;
   8 import java.util.GregorianCalendar;
   9 import java.util.HashMap;
  10 import java.util.Iterator;
  11 import java.util.Vector;
  12
  13 import drno.exception.ConsistanceException;
  14 import drno.exception.DatabaseDisconnectedException;
  15 import drno.exception.MappingException;
  16 import drno.exception.ObjectLockException;
  17 import drno.exception.UnkErrException;
  18 import drno.server.database.persistence.LockObject;
  19 import drno.server.database.persistence.repository.MapperFacade;
  20 import drno.server.database.persistence.repository.ObjectMapper;
  21 import drno.server.model.EmployeeImpl;
  22 import drno.server.model.Patient;
  23 import drno.server.model.Tidsreservation;
  24
  25
  26
  27 /**
  28  * @author tobibobi
  29  *
  30  * Vedligeholder alle mappings for de enkelte Tidsreservation objekter og dets felter.
  31  * Når den bliver instantieret, forsøger den at oprette en ny tabel til at indeholde
  32  * klassens felter.
  33  */
  34 public class TidsreservationBroker {
  35
  36         TidsreservationBroker() {
  37                 ObjectMapper mp = new ObjectMapper("Tidsreservation",Tidsreservation.class);
  38                 try {
  39                         mp.map("Emne","Emne");
  40                         mp.map("Doctor","Employee").setClass(EmployeeImpl.class);
  41                         mp.map("Patient","Patient").setClass(Patient.class);
  42                         mp.map("Reel_start","ReelTidStart");
  43                         mp.map("Reel_slut","ReelTidSlut");
  44                         mp.map("Slut","TidSlut");
  45             mp.map("Start","TidStart");
  46                         mp.map("Type","Type");
  47
  48                 } catch (MappingException e) {
  49                         e.printStackTrace();
  50             System.exit(-1);
  51                 }
  52         try {
  53             MapperFacade.instance().addMapper(mp);
  54                         MapperFacade.instance().CreateTable(mp);
  55                 } catch (Exception ex) {
  56             ex.printStackTrace();
  57                 }
  58         }
  59
  60         public Vector getAll() throws UnkErrException {
  61                 MapperFacade mf = MapperFacade.instance();
  62                 return mf.find(Tidsreservation.class,"");
  63         }
  64
  65         public Vector getFromDate(Timestamp ts) throws UnkErrException {
  66                 Vector all = new Vector();
  67
  68         Vector span = getBeginAndEndOfDateVector(ts);
  69
  70
  71                 MapperFacade mf = MapperFacade.instance();
  72                 return mf.find(Tidsreservation.class,"Start between \"" + span.get(0) +
  73                 "\" and \"" + span.get(1) + "\";");
  74         }
  75
  76     /**
  77      * @param ts
  78      * @return
  79      */
  80     private Vector getBeginAndEndOfDateVector(Timestamp ts)
  81     {
  82         GregorianCalendar cal = new GregorianCalendar();
  83         Vector span = new Vector(2);
  84         cal.setTime(ts);
  85         System.out.println(cal);
  86         ts.setHours(0);
  87         ts.setMinutes(0);
  88         ts.setSeconds(0);
  89
  90         System.out.println(ts);
  91         span.add(ts.clone());
  92         ts.setHours(23);
  93         ts.setMinutes(59);
  94         ts.setSeconds(59);
  95         span.add(ts.clone());
  96         return span;
  97     }
  98
  99         public Vector getTRsFromDateAndDoctor(Timestamp ts,EmployeeImpl e) throws UnkErrException {
 100                 Vector all = new Vector();
 101         Vector span = getBeginAndEndOfDateVector(ts);
 102
 103                 MapperFacade mf = MapperFacade.instance();
 104                 return mf.find(Tidsreservation.class,"Start between \"" + span.get(0) + "\" and \""
 105                 + span.get(1)  + "\" and Doctor=" + e.getOId() + ";");
 106         }
 107
 108         /**
 109          * @param patient
 110          * @return
 111          * @throws UnkErrException
 112          */
 113         public Vector getTRsFromPatient(Patient patient) throws UnkErrException{
 114         MapperFacade mf = MapperFacade.instance();
 115                 return mf.find(Tidsreservation.class,"Patient=" + patient.getOId());
 116      }
 117
 118     public void deletePatientsReservationer(Patient pat) throws UnkErrException, ObjectLockException
 119     {
 120         Vector pats = new Vector();
 121         HashMap keys = new HashMap();
 122         Vector LockedTid = new Vector();
 123         MapperFacade mf = MapperFacade.instance();
 124         pats = mf.find(Tidsreservation.class,"Patient=" + pat.getOId());
 125         Iterator it = pats.iterator();
 126         try {
 127             while(it.hasNext()) {
 128                 Tidsreservation tid = (Tidsreservation)it.next();
 129                 keys.put(tid,tid.save());
 130                 LockedTid.add(tid);
 131             }
 132         } catch(ObjectLockException ex) {
 133             it = LockedTid.iterator();
 134             while(it.hasNext()) {
 135                 Tidsreservation tid = (Tidsreservation)it.next();
 136                 tid.rollback((LockObject)keys.get(pat));
 137             }
 138             throw ex;
 139         }
 140
 141         it = pats.iterator();
 142
 143         // in transaction...
 144
 145         while(it.hasNext()) {
 146             Tidsreservation tid = (Tidsreservation)it.next();
 147             tid.delete((LockObject)keys.get(tid));
 148             try { tid.commit((LockObject)keys.get(tid)); }
 149             catch (ConsistanceException newer_happens) {  }
 150
 151         }
 152     }
 153 }