Mercurial > dive4elements > river
view flys-backend/src/main/java/de/intevation/flys/importer/Importer.java @ 3337:69f06b83b3ec
Set correct connection provider class which package had changed in the last commit.
flys-backend/trunk@4857 c6561f87-3c4e-4783-a992-168aeb5c3f6f
author | Ingo Weinzierl <ingo.weinzierl@intevation.de> |
---|---|
date | Tue, 03 Jul 2012 10:02:14 +0000 |
parents | 33f40b23edd8 |
children | 36edf9a71cbd |
line wrap: on
line source
package de.intevation.flys.importer; import de.intevation.artifacts.common.utils.XMLUtils; import de.intevation.flys.importer.parsers.InfoGewParser; import de.intevation.flys.importer.parsers.AnnotationClassifier; import java.io.File; import java.io.IOException; import java.util.List; import java.sql.SQLException; import org.apache.log4j.Logger; import org.hibernate.Transaction; import org.hibernate.HibernateException; import org.w3c.dom.Document; public class Importer { private static Logger log = Logger.getLogger(Importer.class); protected List<ImportRiver> rivers; 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() { log.debug("write rivers started"); for (ImportRiver river: rivers) { log.debug("writing river '" + river.getName() + "'"); river.storeDependencies(); ImporterSession.getInstance().getDatabaseSession().flush(); } log.debug("write rivers finished"); } public void writeToDatabase() { Transaction tx = null; try { tx = ImporterSession.getInstance() .getDatabaseSession().beginTransaction(); try { writeRivers(); } catch (HibernateException he) { Throwable t = he.getCause(); while (t instanceof SQLException) { SQLException sqle = (SQLException)t; log.error("SQL exeception chain:", sqle); t = sqle.getNextException(); } throw he; } tx.commit(); } catch (RuntimeException re) { if (tx != null) { tx.rollback(); } throw re; } } public static AnnotationClassifier getAnnotationClassifier() { String annotationTypes = Config.INSTANCE.getAnnotationTypes(); if (annotationTypes == null) { log.info("no annotation types file configured."); return null; } File file = new File(annotationTypes); log.info("use annotation types file '" + file + "'"); if (!(file.isFile() && file.canRead())) { log.warn("annotation type file '" + file + "' is not readable."); return null; } Document rules = XMLUtils.parseDocument(file); if (rules == null) { log.warn("cannot parse annotation types file."); return null; } return new AnnotationClassifier(rules); } public static void main(String [] args) { InfoGewParser infoGewParser = new InfoGewParser( getAnnotationClassifier()); log.info("Start parsing rivers..."); for (String gew: args) { log.info("parsing info gew file: " + gew); try { infoGewParser.parse(new File(gew)); } catch (IOException ioe) { log.error("cannot while parsing: " + gew); } } String gew = Config.INSTANCE.getInfoGewFile(); if (gew != null && gew.length() > 0) { log.info("parsing info gew file: " + gew); try { infoGewParser.parse(new File(gew)); } catch (IOException ioe) { log.error("cannot parse file: " + gew); } } if (!Config.INSTANCE.dryRun()) { new Importer(infoGewParser.getRivers()).writeToDatabase(); } } } // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :