Changeset 2632 for molgenis4animaldb

Timestamp:

02/08/10 14:53:20 (2 years ago)

Author:

erikroos

Message:

Corresponding event types also updated/deleted when feature is updated/removed

File:

• molgenis4animaldb/handwritten/java/decorators/FeatureDecorator.java (modified) (8 diffs)

molgenis4animaldb/handwritten/java/decorators/FeatureDecorator.java

@@ -31 +31 @@
                 super(generatedMapper);
         }
-
-        public int add(List<Feature> entities) throws DatabaseException {
-                // add your pre-processing here
-
-                // here we call the standard 'add'
-                int count = super.add(entities);
-
-                // post-processing:
+        
+        private boolean makeCorrEventType(List<Feature> entities) {
                 String eventTypeName;
                 String featureName;
-                Database db = null;
-                db = this.getDatabase();
+                Database db = this.getDatabase();
 
                 for (animaldb.Feature e : entities) {
@@ -56 +49 @@
                         } catch (IOException e1) {
                                 e1.printStackTrace();
+                                return false;
+                        } catch (DatabaseException e1) {
+                                e1.printStackTrace();
+                                return false;
                         }
 
@@ -63 +60 @@
                         q.addRules(new QueryRule("name", Operator.EQUALS, eventTypeName));
                         try {
-                                List<EventType> eventTypeList = q.find();
+                                List<EventType> eventTypeList = q.find();               
                                 for (EventType et : eventTypeList) {
                                         etId = et.getId();
@@ -69 +66 @@
                         } catch (ParseException e1) {
                                 e1.printStackTrace();
+                                return false;
+                        } catch (DatabaseException e1) {
+                                e1.printStackTrace();
+                                return false;
                         }
                         int featId = -99;
@@ -80 +81 @@
                         } catch (ParseException e1) {
                                 e1.printStackTrace();
+                                return false;
+                        } catch (DatabaseException e1) {
+                                e1.printStackTrace();
+                                return false;
                         }
 
@@ -90 +95 @@
                         } catch (IOException e1) {
                                 e1.printStackTrace();
+                                return false;
+                        } catch (DatabaseException e1) {
+                                e1.printStackTrace();
+                                return false;
                         }
+                }
+                return true;
+        }
+        
+        private boolean remCorrEventType(List<Feature> entities) {
+                String eventTypeName;
+                String featureName;
+                Database db = this.getDatabase();
+        
+                for (animaldb.Feature e : entities) {
+                        featureName = e.getName();
+
+                        // Remove corresponding event type
+                        eventTypeName = "Set" + featureName;
+                        Query q = db.query(EventType.class);
+                        q.addRules(new QueryRule("name", Operator.EQUALS, eventTypeName));
+                        try {
+                                List<EventType> eventTypeList = q.find();
+                                for (EventType et : eventTypeList) {
+                                        db.remove(et);
+                                }
+                        } catch (DatabaseException e1) {
+                                e1.printStackTrace();
+                                return false;
+                        } catch (ParseException e1) {
+                                e1.printStackTrace();
+                                return false;
+                        } catch (IOException e1) {
+                                e1.printStackTrace();
+                                return false;
+                        }
+                }
+                return true;
+        }
+
+        public int add(List<Feature> entities) throws DatabaseException {
+                // add your pre-processing here
+
+                // here we call the standard 'add'
+                int count = super.add(entities);
+                
+                // post-processing:
+                if (!makeCorrEventType(entities)) {
+                        throw new DatabaseException("Could not make corresponding event type - feature not added");
                 }
 
@@ -96 +149 @@
         }
 
-        public int update(List<animaldb.Feature> entities) throws DatabaseException {
+        public int update(List<Feature> entities) throws DatabaseException {
 
-                // add your pre-processing here, e.g.
-                // for (animaldb.Feature e : entities)
-                // {
-                // e.setTriggeredField("Before update called!!!");
-                // }
+                // add your pre-processing here
+                if (!remCorrEventType(entities) || !makeCorrEventType(entities)) {
+                        throw new DatabaseException("Could not update corresponding event type - feature not updated");
+                }
 
                 // here we call the standard 'update'
                 int count = super.update(entities);
-
-                // add your post-processing here
-                // if you throw and exception the previous add will be rolled back
-
+                
+                // post-processing:
+                
                 return count;
         }
@@ -115 +166 @@
         public int remove(List<animaldb.Feature> entities) throws DatabaseException {
                 // add your pre-processing here
+                if (!remCorrEventType(entities)) {
+                        throw new DatabaseException("Could not remove corresponding event type - feature not removed");
+                }
 
                 // here we call the standard 'remove'
                 int count = super.remove(entities);
 
-                // add your post-processing here, e.g.
-                // if(true) throw new
-                // SQLException("Because of a post trigger the remove is cancelled.");
+                // post-processing:
 
                 return count;