--- a/flys-backend/src/main/java/de/intevation/flys/importer/ImportRiver.java	Thu Mar 17 18:07:13 2011 +0000
+++ b/flys-backend/src/main/java/de/intevation/flys/importer/ImportRiver.java	Fri Mar 18 12:10:33 2011 +0000
@@ -7,8 +7,13 @@
 
 import org.apache.log4j.Logger;
 
+import de.intevation.flys.model.River;
+
 import de.intevation.flys.utils.FileTools;
 
+import org.hibernate.Session;
+import org.hibernate.Query;
+
 public class ImportRiver
 {
     private static Logger log = Logger.getLogger(ImportRiver.class);
@@ -25,6 +30,8 @@
 
     protected List<ImportAnnotation> annotations;
 
+    protected River peer;
+
     public ImportRiver() {
     }
 
@@ -85,5 +92,29 @@
 
         annotations = aparser.getAnnotations();
     }
+
+    public void storeAnnotations() {
+        River river = getPeer();
+        for (ImportAnnotation annotation: annotations) {
+            annotation.getPeer(river);
+        }
+    }
+
+    public River getPeer() {
+        if (peer == null) {
+            Session session = Importer.sessionHolder.get();
+            Query query = session.createQuery("from River where name=:name");
+            query.setString("name", name);
+            List<River> rivers = query.list();
+            if (rivers.isEmpty()) {
+                peer = new River(name);
+                session.save(peer);
+            }
+            else {
+                peer = rivers.get(0);
+            }
+        }
+        return peer;
+    }
 }
 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :