--- a/flys-backend/ChangeLog	Wed Mar 16 17:28:16 2011 +0000
+++ b/flys-backend/ChangeLog	Wed Mar 16 18:23:45 2011 +0000
@@ -1,3 +1,11 @@
+2011-03-16	Sascha L. Teichmann	<sascha.teichmann@intevation.de>
+
+	* src/main/java/de/intevation/flys/importer/InfoGewParser.java:
+	  Expose imported rivers.
+
+	* src/main/java/de/intevation/flys/importer/InfoGewParser.java:
+	  Store imported rivers into database. Needs testing!
+
 2011-03-16	Sascha L. Teichmann	<sascha.teichmann@intevation.de>
 
 	* src/main/java/de/intevation/flys/backend/SessionFactoryProvider.java:

--- a/flys-backend/src/main/java/de/intevation/flys/importer/Importer.java	Wed Mar 16 17:28:16 2011 +0000
+++ b/flys-backend/src/main/java/de/intevation/flys/importer/Importer.java	Wed Mar 16 18:23:45 2011 +0000
@@ -3,12 +3,82 @@
 import java.io.File;
 import java.io.IOException;
 
+import java.util.List;
+
 import org.apache.log4j.Logger;
 
+import org.hibernate.SessionFactory;
+import org.hibernate.Session;
+import org.hibernate.Transaction;
+import org.hibernate.Query;
+
+import de.intevation.flys.backend.SessionFactoryProvider;
+
+import de.intevation.flys.model.River;
+
 public class Importer
 {
     private static Logger log = Logger.getLogger(Importer.class);
 
+    protected List<ImportRiver> rivers;
+
+    protected Session session;
+
+    public Importer() {
+    }
+
+    public Importer(List<ImportRiver> rivers) {
+        this.rivers = rivers;
+    }
+
+    public List<ImportRiver> getRivers() {
+        return rivers;
+    }
+
+    public void setRivers(List<ImportRiver> rivers) {
+        this.rivers = rivers;
+    }
+
+    public void writeRivers() {
+        Query query = session.createQuery("select River where name=:name");
+        for (ImportRiver iriver: rivers) {
+            query.setString("name", iriver.getName());
+            List<River> dbrivers = (List<River>)query.list();
+            if (dbrivers.isEmpty()) {
+                River dbriver = new River(iriver.getName());
+                session.save(dbriver);
+            }
+        }
+    }
+
+    public void writeToDatabase() {
+        SessionFactory sessionFactory =
+            SessionFactoryProvider.createSessionFactory();
+
+        session = sessionFactory.openSession();
+        Transaction tx = null;
+
+        try {
+            tx = session.beginTransaction();
+
+            writeRivers();
+
+            tx.commit();
+        }
+        catch (RuntimeException re) {
+            if (tx != null) {
+                tx.rollback();
+            }
+            throw re;
+        }
+        finally {
+            if (session != null) {
+                session.close();
+                session = null;
+            }
+        }
+    }
+
     public static void main(String [] args) {
 
         InfoGewParser infoGewParser = new InfoGewParser();
@@ -21,8 +91,9 @@
             catch (IOException ioe) {
                 log.error("cannot while parsing: " + gew);
             }
-            
         }
+
+        new Importer(infoGewParser.getRivers()).writeToDatabase();
     }
 }
 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :

--- a/flys-backend/src/main/java/de/intevation/flys/importer/InfoGewParser.java	Wed Mar 16 17:28:16 2011 +0000
+++ b/flys-backend/src/main/java/de/intevation/flys/importer/InfoGewParser.java	Wed Mar 16 18:23:45 2011 +0000
@@ -38,6 +38,10 @@
         rivers = new ArrayList<ImportRiver>();
     }
 
+    public List<ImportRiver> getRivers() {
+        return rivers;
+    }
+
     public static final String normalize(String f) {
         return f.replace("\\", "/").replace("/", File.separator);
     }