Merge branch 'master' of https://xp-dev.com/git/RRRRHHHH_Code
[RRRRHHHH_Code] / ruralHouses / src / dataAccess / DB4oManager.java
index 7275ba2..eb80b86 100644 (file)
@@ -3,20 +3,27 @@ package dataAccess;
 import java.io.File;
 //import java.util.Enumeration;
 //import java.util.Vector;
-
 import java.rmi.RemoteException;
+
+
 import java.util.Date;
-import java.util.HashSet;
+import java.util.LinkedList;
+import java.util.List;
 import java.util.ListIterator;
 import java.util.Vector;
 
-import com.db4o.*;
+
+import com.db4o.Db4oEmbedded;
+import com.db4o.ObjectContainer;
+import com.db4o.ObjectSet;
 import com.db4o.config.EmbeddedConfiguration;
 import com.db4o.cs.Db4oClientServer;
 import com.db4o.cs.config.ClientConfiguration;
+import com.db4o.query.Predicate;
 
 import configuration.ConfigXML;
 import domain.Account;
+import domain.Administrator;
 import domain.Booking;
 import domain.HouseFeatures;
 import domain.Offer;
@@ -112,25 +119,30 @@ public class DB4oManager {
                try {
                        Owner jon = new Owner("Jon");
                        Owner alfredo = new Owner("Alfredo");
-                       jon.addRuralHouse("Ezkioko", "Ezkioko etxea", "Beatriz", 3, 3, 3, 3,
-                                       3);
-                       jon.addRuralHouse("Eskiatze", "Eskiatzeko etxea", "Guazate", 4, 4, 4,
-                                       4, 4);
+                       jon.addRuralHouse("Ezkioko", "Ezkioko etxea", "Beatriz", 3, 3, 3,
+                                       3, 3);
+                       jon.addRuralHouse("Eskiatze", "Eskiatzeko etxea", "Guazate", 4, 4,
+                                       4, 4, 4);
                        jon.setBankAccount("1349 5677 21 2133567777");
-                       alfredo.addRuralHouse("Aitonako", "Casa del abuelo", "Vegas", 5,
-                                       5, 5, 5, 5);
+                       alfredo.addRuralHouse("Aitonako", "Casa del abuelo", "Vegas", 5, 5,
+                                       5, 5, 5);
+                       
                        alfredo.addRuralHouse("Murgoitz", "", "Cedro", 6, 6, 6, 6, 6);
                        alfredo.setBankAccount("4144 0087 23 9700002133");
                        Account jonAcc = new Account("userJon", "passJon", jon);
                        Account alfredoAcc = new Account("userAlfredo", "passAlfredo",
                                        alfredo);
+
+                       Account admin = new Account("admin","admin", true);
+                       db.store(Administrator.giveAdmin());
                        db.store(jon);
                        db.store(alfredo);
                        db.store(jonAcc);
                        db.store(alfredoAcc);
+                       db.store(admin);
                        db.commit();
                } finally {
-                       db.close();
+                       db.close();     
                }
        }
 
@@ -156,7 +168,6 @@ public class DB4oManager {
                }
        }
 
-       @SuppressWarnings("finally")
        public Offer createOffer(RuralHouse ruralHouse, Date firstDay,
                        Date lastDay, float price) throws RemoteException, Exception {
                Offer o = null;
@@ -170,7 +181,7 @@ public class DB4oManager {
 
                        RuralHouse proto = new RuralHouse(ruralHouse.getHouseName(), null,
                                        null, null, null);
-                       ObjectSet result = db.queryByExample(proto);
+                       ObjectSet<RuralHouse> result = db.queryByExample(proto);
                        RuralHouse rh = (RuralHouse) result.next();
                        o = rh.createOffer(theDB4oManagerAux.offerNumber++, firstDay,
                                        lastDay, price);
@@ -188,16 +199,19 @@ public class DB4oManager {
                return o;
        }
 
-       @SuppressWarnings("finally")
-       public Offer modifyOffer(Offer offer) throws RemoteException, Exception {
+       
+       public void deleteOffer(Offer offer) throws RemoteException,
+                       Exception {
                if (c.isDatabaseLocal() == false)
                        openSDB();
                else
                        openDB();
 
                try {
-
-                       db.store(offer);
+                       ObjectSet<Offer> of = db.queryByExample(offer);
+                       RuralHouse rh =of.get(0).getRuralHouse();
+                       System.out.println(rh.offers.remove(of.get(0)));
+                       db.store(rh);
                        db.commit();
 
                } catch (com.db4o.ext.ObjectNotStorableException e) {
@@ -206,31 +220,64 @@ public class DB4oManager {
                } finally {
                        db.close();
                }
-               return offer;
        }
 
-       @SuppressWarnings("finally")
-       public void deleteOffer(RuralHouse rh, Offer offer) throws RemoteException,
-                       Exception {
+       
+       public LinkedList<RuralHouse>[] getAdminData(){
                if (c.isDatabaseLocal() == false)
                        openSDB();
                else
                        openDB();
-
+               LinkedList<RuralHouse>[] ret =  new LinkedList[2];
+               
                try {
-
-                       db.store(rh);
-                       db.delete(offer);
+                       
+                       List<Administrator> admL = db.query(new Predicate<Administrator>(){
+                               public boolean match(Administrator admin){
+                                       return true;
+                               }
+                       });
+                       
+                       ret[0] = admL.get(0).getAddRequest();
+                       ret[1] = admL.get(0).getRemoveRequest();
+                       return ret;
+               }
+               finally {
+                       db.close();
+                       
+               }
+               
+       }
+       
+       public void storeAdmin() {
+               if (c.isDatabaseLocal() == false)
+                       openSDB();
+               else
+                       openDB();               
+               try {
+                       
+                       List<Administrator> admL = db.query(new Predicate<Administrator>(){
+                               public boolean match(Administrator admin){
+                                       return true;
+                               }
+                       });
+                       
+                       admL.get(0).setAddRequest(Administrator.getAddRequest());
+                       admL.get(0).setRemoveRequest(Administrator.getRemoveRequest());
                        db.commit();
-
-               } catch (com.db4o.ext.ObjectNotStorableException e) {
-                       System.out
-                                       .println("Error: com.db4o.ext.ObjectNotStorableException in createOffer");
-               } finally {
+                       
+               }
+               catch(Exception e){
+                       
+               }
+               finally {
                        db.close();
                }
+               
+               
        }
-
+       
+       
        /**
         * This method creates a book with a corresponding parameters
         * 
@@ -248,6 +295,7 @@ public class DB4oManager {
                        openDB();
 
                Booking bok = null;
+               
 
                try {
 
@@ -296,7 +344,7 @@ public class DB4oManager {
 
                try {
                        Owner proto = new Owner(null, null);
-                       ObjectSet result = db.queryByExample(proto);
+                       ObjectSet<Owner> result = db.queryByExample(proto);
                        Vector<Owner> owners = new Vector<Owner>();
                        while (result.hasNext())
                                owners.add((Owner) result.next());
@@ -377,7 +425,7 @@ public class DB4oManager {
                        openDB();
 
                try {
-                       Account proto = new Account(usr, pwd, new Owner(null, null));
+                       Account proto = new Account(usr, pwd, null);
                        ObjectSet<Account> result = db.queryByExample(proto);
                        Vector<Account> accounts = new Vector<Account>();
                        while (result.hasNext())
@@ -407,6 +455,11 @@ public class DB4oManager {
                                db.store(rh);
                                db.commit();
                                stored = true;
+                       } else {
+                               db.delete(result.get(0));
+                               db.store(rh);
+                               db.commit();
+                               stored = true;
                        }
                } finally {
                        db.close();
@@ -421,12 +474,12 @@ public class DB4oManager {
                else
                        openDB();
                try {
-                       ObjectSet<RuralHouse> result = db.queryByExample(rh);
-                       if (!result.isEmpty()) {
-                               RuralHouse found = (RuralHouse) result.get(0);
-                               // db.delete(found.getOwner());
-                               db.store(owner);
-                               db.delete(found);
+                       ObjectSet<Owner> result = db.queryByExample(owner);
+                       ObjectSet<RuralHouse> rhs = db.queryByExample(rh);
+                       if (!rhs.isEmpty()) {
+                               Owner found =  result.get(0);
+                               found.getRuralHouses().remove(rhs.get(0));
+                               db.store(found);
                                db.commit();
                        }
                } catch (Exception exc) {
@@ -437,54 +490,11 @@ public class DB4oManager {
 
        }
 
-       public Vector<RuralHouse> getRuralHousesByTown(String town) {
-               RuralHouse rh = new RuralHouse(null, null, null, town, null);
-
-               if (c.isDatabaseLocal() == false)
-                       openSDB();
-               else
-                       openDB();
-
-               try {
-                       ObjectSet<RuralHouse> result = db.queryByExample(rh);
-                       Vector<RuralHouse> ruralHouses = new Vector<RuralHouse>();
-                       while (result.hasNext())
-                               ruralHouses.add(result.next());
-                       return ruralHouses;
-               } finally {
-                       db.close();
-               }
-
-       }
-
-       public RuralHouse getRuralHouseByName(String name) {
-               RuralHouse rh = new RuralHouse(name, null, null, null, null);
-
-               if (c.isDatabaseLocal() == false)
-                       openSDB();
-               else
-                       openDB();
-
-               try {
-                       ObjectSet<RuralHouse> result = db.queryByExample(rh);
-                       Vector<RuralHouse> ruralHouses = new Vector<RuralHouse>();
-                       while (result.hasNext())
-                               ruralHouses.add(result.next());
-                       db.close();
-                       if (!ruralHouses.isEmpty())
-                               return ruralHouses.get(0);
-                       else
-                               return null;
-               } catch (NullPointerException e) {
-                       return null;
-               }
-
-       }
 
-       public Vector<RuralHouse> getRuralHouses(String town, int nBed, int nKit,
-                       int nBath, int nPark, int nLiv) {
+       public Vector<RuralHouse> getRuralHouses(String name, String town,
+                       int nBed, int nKit, int nBath, int nPark, int nLiv) {
                HouseFeatures fea = new HouseFeatures(nBed, nKit, nBath, nLiv, nPark);
-               RuralHouse rh = new RuralHouse(null, null, null, town, fea);
+               RuralHouse rh = new RuralHouse(name, null, null, town, fea);
                if (c.isDatabaseLocal() == false)
                        openSDB();
                else
@@ -502,4 +512,6 @@ public class DB4oManager {
                }
 
        }
+
+       
 }