Mercurial > dive4elements > river

comparison flys-backend/src/main/java/de/intevation/flys/importer/ImportRiver.java @ 2809:f283212966e8

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Finished work on MINFO bed heights (single). flys-backend/trunk@4221 c6561f87-3c4e-4783-a992-168aeb5c3f6f
author Ingo Weinzierl <ingo.weinzierl@intevation.de>
date Thu, 12 Apr 2012 10:42:46 +0000
parents 33f40b23edd8
children 04eeb45df27b
comparison
equal deleted inserted replaced
2808:b57c95094b68 2809:f283212966e8
10 import java.util.Date; 10 import java.util.Date;
11 import java.util.Calendar; 11 import java.util.Calendar;
12 12
13 import java.io.File; 13 import java.io.File;
14 import java.io.IOException; 14 import java.io.IOException;
15
16 import java.sql.SQLException;
15 17
16 import org.apache.log4j.Logger; 18 import org.apache.log4j.Logger;
17 19
18 import de.intevation.artifacts.common.utils.FileTools; 20 import de.intevation.artifacts.common.utils.FileTools;
19 import de.intevation.artifacts.common.utils.FileTools.HashedFile; 21 import de.intevation.artifacts.common.utils.FileTools.HashedFile;
30 import de.intevation.flys.importer.parsers.PegelGltParser; 32 import de.intevation.flys.importer.parsers.PegelGltParser;
31 import de.intevation.flys.importer.parsers.WstParser; 33 import de.intevation.flys.importer.parsers.WstParser;
32 34
33 import org.hibernate.Session; 35 import org.hibernate.Session;
34 import org.hibernate.Query; 36 import org.hibernate.Query;
37 import org.hibernate.exception.ConstraintViolationException;
35 38
36 public class ImportRiver 39 public class ImportRiver
37 { 40 {
38 private static Logger log = Logger.getLogger(ImportRiver.class); 41 private static Logger log = Logger.getLogger(ImportRiver.class);
39 42
230 File bedHeightDir = new File(minfoDir, BED_HEIGHT_DIR); 233 File bedHeightDir = new File(minfoDir, BED_HEIGHT_DIR);
231 File singlesDir = new File(bedHeightDir, BED_HEIGHT_SINGLE_DIR); 234 File singlesDir = new File(bedHeightDir, BED_HEIGHT_SINGLE_DIR);
232 File epochDir = new File(bedHeightDir, BED_HEIGHT_EPOCH_DIR); 235 File epochDir = new File(bedHeightDir, BED_HEIGHT_EPOCH_DIR);
233 236
234 parseBedHeightSingles(singlesDir); 237 parseBedHeightSingles(singlesDir);
235 parseBedHeightEpochs(epochDir); 238 //parseBedHeightEpochs(epochDir);
239
240 log.info("Finished parsing bed heights.");
236 } 241 }
237 242
238 243
239 protected void parseBedHeightSingles(File dir) throws IOException { 244 protected void parseBedHeightSingles(File dir) throws IOException {
240 log.debug("Parse bed height singles"); 245 log.debug("Parse bed height singles");
700 log.info("store bed heights"); 705 log.info("store bed heights");
701 River river = getPeer(); 706 River river = getPeer();
702 707
703 if (bedHeightSingles != null) { 708 if (bedHeightSingles != null) {
704 for (ImportBedHeightSingle single: bedHeightSingles) { 709 for (ImportBedHeightSingle single: bedHeightSingles) {
705 log.debug("name: " + single.getDescription()); 710 String desc = single.getDescription();
706 single.storeDependencies(river); 711
712 log.debug("name: " + desc);
713
714 try {
715 single.storeDependencies(river);
716 }
717 catch (SQLException sqle) {
718 log.error("File '" + desc + "' is broken!");
719 }
720 catch (ConstraintViolationException cve) {
721 log.error("File '" + desc + "' is broken!");
722 }
707 } 723 }
724 }
725 else {
726 log.info("No single bed heights to store.");
708 } 727 }
709 728
710 if (bedHeightEpochs != null) { 729 if (bedHeightEpochs != null) {
711 for (ImportBedHeightEpoch epoch: bedHeightEpochs) { 730 for (ImportBedHeightEpoch epoch: bedHeightEpochs) {
712 log.debug("name: " + epoch.getDescription()); 731 log.debug("name: " + epoch.getDescription());
713 epoch.storeDependencies(river); 732 epoch.storeDependencies(river);
714 } 733 }
734 }
735 else {
736 log.info("No epoch bed heights to store.");
715 } 737 }
716 } 738 }
717 } 739 }
718 740
719 public void storeAnnotations() { 741 public void storeAnnotations() {
http://dive4elements.wald.intevation.org