dive4elements/river: flys-backend/src/main/java/de/intevation/flys/importer/ImportRiver.java annotate

annotate flys-backend/src/main/java/de/intevation/flys/importer/ImportRiver.java @ 4781:e77b461fa360

ImportRiver: Bail out if skip* parameters were given.

author	Felix Wolfsteller <felix.wolfsteller@intevation.de>
date	Tue, 08 Jan 2013 12:26:29 +0100
parents	18908a3cbb3a
children	696285cef182

rev	line source
177 31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	1 package de.intevation.flys.importer;
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	2
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	3 import java.io.File;
184 4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	4 import java.io.IOException;
2809 f283212966e8 Finished work on MINFO bed heights (single). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2806 diff changeset	5 import java.sql.SQLException;
3320 8f905390c10d Removed superfluous imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2860 diff changeset	6 import java.util.ArrayList;
8f905390c10d Removed superfluous imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2860 diff changeset	7 import java.util.Calendar;
8f905390c10d Removed superfluous imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2860 diff changeset	8 import java.util.Date;
8f905390c10d Removed superfluous imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2860 diff changeset	9 import java.util.HashSet;
8f905390c10d Removed superfluous imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2860 diff changeset	10 import java.util.List;
8f905390c10d Removed superfluous imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2860 diff changeset	11 import java.util.Map;
8f905390c10d Removed superfluous imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2860 diff changeset	12 import java.util.Set;
8f905390c10d Removed superfluous imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2860 diff changeset	13
184 4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	14 import org.apache.log4j.Logger;
3320 8f905390c10d Removed superfluous imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2860 diff changeset	15 import org.hibernate.Query;
8f905390c10d Removed superfluous imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 2860 diff changeset	16 import org.hibernate.Session;
4193 f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	17 import org.hibernate.exception.ConstraintViolationException;
177 31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	18
4193 f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	19 import de.intevation.artifacts.common.utils.FileTools;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	20 import de.intevation.artifacts.common.utils.FileTools.HashedFile;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	21 import de.intevation.flys.importer.parsers.AnnotationClassifier;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	22 import de.intevation.flys.importer.parsers.AnnotationsParser;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	23 import de.intevation.flys.importer.parsers.BedHeightEpochParser;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	24 import de.intevation.flys.importer.parsers.BedHeightSingleParser;
4716 6016b9aa827a Adjust callbacks after Parsers new interface implementation, re-enable file hashing for da66s. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4712 diff changeset	25 import de.intevation.flys.importer.parsers.CrossSectionParser;
4706 e7b238247c4e Documentation added. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4678 diff changeset	26 import de.intevation.flys.importer.parsers.DA66Parser;
4193 f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	27 import de.intevation.flys.importer.parsers.FlowVelocityMeasurementParser;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	28 import de.intevation.flys.importer.parsers.FlowVelocityModelParser;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	29 import de.intevation.flys.importer.parsers.HYKParser;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	30 import de.intevation.flys.importer.parsers.MeasurementStationsParser;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	31 import de.intevation.flys.importer.parsers.MorphologicalWidthParser;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	32 import de.intevation.flys.importer.parsers.PRFParser;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	33 import de.intevation.flys.importer.parsers.PegelGltParser;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	34 import de.intevation.flys.importer.parsers.SQRelationParser;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	35 import de.intevation.flys.importer.parsers.SedimentDensityParser;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	36 import de.intevation.flys.importer.parsers.SedimentYieldParser;
4767 03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	37 import de.intevation.flys.importer.parsers.W80Parser;
4193 f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	38 import de.intevation.flys.importer.parsers.WaterlevelDifferencesParser;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	39 import de.intevation.flys.importer.parsers.WaterlevelParser;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	40 import de.intevation.flys.importer.parsers.WstParser;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	41 import de.intevation.flys.model.River;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	42 import de.intevation.flys.model.Unit;
188 003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	43
4706 e7b238247c4e Documentation added. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4678 diff changeset	44
e7b238247c4e Documentation added. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4678 diff changeset	45 /** Import all river-related data (files) that can be found. */
177 31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	46 public class ImportRiver
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	47 {
184 4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	48 private static Logger log = Logger.getLogger(ImportRiver.class);
4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	49
4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	50 public static final String PEGEL_GLT = "PEGEL.GLT";
4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	51
483 f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	52 public static final String FIXATIONS = "Fixierungen";
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	53
482 3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	54 public static final String EXTRA_LONGITUDINALS =
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	55 "Zus.L\u00e4ngsschnitte";
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	56
484 a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	57 public static final String [] OFFICIAL_LINES_FOLDERS = {
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	58 "Basisdaten",
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	59 "Fixierungen" };
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	60
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	61 public static final String OFFICIAL_LINES =
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	62 "Amtl_Linien.wst";
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	63
490 13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	64 public static final String FLOOD_WATER = "HW-Marken";
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	65
494 88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	66 public static final String FLOOD_PROTECTION =
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	67 "HW-Schutzanlagen";
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	68
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	69 public static final String MINFO_DIR = "Morphologie";
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	70
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	71 public static final String BED_HEIGHT_DIR = "Sohlhoehen";
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	72
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	73 public static final String BED_HEIGHT_SINGLE_DIR = "Einzeljahre";
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	74
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	75 public static final String BED_HEIGHT_EPOCH_DIR = "Epochen";
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	76
2815 3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	77 public static final String SEDIMENT_DENSITY_DIR = "Sedimentdichte";
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	78
2821 0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	79 public static final String MORPHOLOGICAL_WIDTH_DIR = "morphologische_Breite";
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	80
2826 c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	81 public static final String FLOW_VELOCITY_DIR = "Geschwindigkeit_Schubspannung";
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	82
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	83 public static final String FLOW_VELOCITY_MODEL = "Modellrechnungen";
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	84
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	85 public static final String FLOW_VELOCITY_MEASUREMENTS = "v-Messungen";
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	86
2839 163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	87 public static final String SEDIMENT_YIELD_DIR = "Fracht";
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	88
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	89 public static final String SEDIMENT_YIELD_SINGLE_DIR = "Einzeljahre";
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	90
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	91 public static final String SEDIMENT_YIELD_EPOCH_DIR = "Epochen";
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	92
2844 c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	93 public static final String MINFO_FIXATIONS_DIR = "Fixierungsanalyse";
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	94
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	95 public static final String MINFO_WATERLEVELS_DIR = "Wasserspiegellagen";
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	96
2851 acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	97 public static final String MINFO_WATERLEVEL_DIFF_DIR = "Wasserspiegeldifferenzen";
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	98
4193 f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	99 public static final String MINFO_BASE_DIR = "Basisdaten";
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	100
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	101 public static final String MINFO_CORE_DATA_FILE = "Stammdaten_Messstellen.csv";
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	102
3328 a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	103 public static final String MINFO_SQ_DIR = "Feststofftransport-Abfluss-Beziehung";
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	104
177 31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	105 protected String name;
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	106
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	107 protected File wstFile;
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	108
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	109 protected File bbInfoFile;
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	110
184 4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	111 protected List<ImportGauge> gauges;
4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	112
186 cf8cbcb6a10d Added parser to read .KM files. Sascha L. Teichmann <sascha.teichmann@intevation.de>* parents: 184 diff changeset	113 protected List<ImportAnnotation> annotations;
cf8cbcb6a10d Added parser to read .KM files. Sascha L. Teichmann <sascha.teichmann@intevation.de>* parents: 184 diff changeset	114
1220 3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	115 protected List<ImportHYK> hyks;
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	116
1204 22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	117 protected List<ImportCrossSection> crossSections;
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	118
482 3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	119 protected List<ImportWst> extraWsts;
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	120
483 f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	121 protected List<ImportWst> fixations;
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	122
484 a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	123 protected List<ImportWst> officialLines;
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	124
490 13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	125 protected List<ImportWst> floodWater;
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	126
494 88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	127 protected List<ImportWst> floodProtection;
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	128
2811 8926571e47fb Finished importing MINFO bed heights (single and epoch). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2810 diff changeset	129 protected List<ImportBedHeight> bedHeightSingles;
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	130
2811 8926571e47fb Finished importing MINFO bed heights (single and epoch). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2810 diff changeset	131 protected List<ImportBedHeight> bedHeightEpochs;
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	132
2815 3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	133 protected List<ImportSedimentDensity> sedimentDensities;
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	134
2821 0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	135 protected List<ImportMorphWidth> morphologicalWidths;
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	136
2827 85b25e74594f Added temp classes used during the import process of flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2826 diff changeset	137 protected List<ImportFlowVelocityModel> flowVelocityModels;
85b25e74594f Added temp classes used during the import process of flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2826 diff changeset	138
2832 ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	139 protected List<ImportFlowVelocityMeasurement> flowVelocityMeasurements;
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	140
2839 163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	141 protected List<ImportSedimentYield> sedimentYields;
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	142
2844 c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	143 protected List<ImportWaterlevel> waterlevels;
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	144
2851 acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	145 protected List<ImportWaterlevelDifference> waterlevelDiffs;
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	146
4193 f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	147 protected List<ImportMeasurementStation> measurementStations;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	148
3328 a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	149 protected List<ImportSQRelation> sqRelations;
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	150
201 3169b559ca3c Build models for wsts, wst columns and q ranges and store them in the backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 197 diff changeset	151 protected ImportWst wst;
3169b559ca3c Build models for wsts, wst columns and q ranges and store them in the backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 197 diff changeset	152
2347 0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	153 protected ImportUnit wstUnit;
0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	154
765 763c4137d6e1 Added classification of annotation types. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 503 diff changeset	155 protected AnnotationClassifier annotationClassifier;
763c4137d6e1 Added classification of annotation types. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 503 diff changeset	156
188 003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	157 protected River peer;
003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	158
4778 a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	159
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	160 /** Callback-implementation for CrossSectionParsers. */
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	161 class ImportRiverCrossSectionParserCallback implements CrossSectionParser.Callback {
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	162 Set<HashedFile> files = new HashSet<HashedFile>();
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	163 String type;
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	164
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	165
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	166 /**
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	167 * Create new Callback, given type which is used for logging
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	168 * purposes only.
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	169 */
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	170 public ImportRiverCrossSectionParserCallback (String type) {
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	171 this.type = type;
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	172 }
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	173
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	174
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	175 /** Accept file if not duplicate. */
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	176 public boolean accept(File file) {
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	177 HashedFile hf = new HashedFile(file);
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	178 boolean success = files.add(hf);
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	179 if (!success) {
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	180 log.warn(type + " file '" + file + "' seems to be a duplicate.");
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	181 }
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	182 return success;
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	183 }
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	184
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	185
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	186 /** Add crosssection. */
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	187 public void parsed(CrossSectionParser parser) {
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	188 log.debug("callback from " + type + " parser");
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	189
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	190 addCrossSections(parser);
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	191 }
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	192 }
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	193
a70de5298248 ImportRiver: Add helper implementation of a CrossSectionParserCallback. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4767 diff changeset	194
177 31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	195 public ImportRiver() {
2832 ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	196 hyks = new ArrayList<ImportHYK>();
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	197 crossSections = new ArrayList<ImportCrossSection>();
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	198 extraWsts = new ArrayList<ImportWst>();
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	199 fixations = new ArrayList<ImportWst>();
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	200 officialLines = new ArrayList<ImportWst>();
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	201 floodWater = new ArrayList<ImportWst>();
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	202 floodProtection = new ArrayList<ImportWst>();
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	203 sedimentDensities = new ArrayList<ImportSedimentDensity>();
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	204 morphologicalWidths = new ArrayList<ImportMorphWidth>();
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	205 flowVelocityModels = new ArrayList<ImportFlowVelocityModel>();
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	206 flowVelocityMeasurements = new ArrayList<ImportFlowVelocityMeasurement>();
2839 163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	207 sedimentYields = new ArrayList<ImportSedimentYield>();
2844 c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	208 waterlevels = new ArrayList<ImportWaterlevel>();
2851 acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	209 waterlevelDiffs = new ArrayList<ImportWaterlevelDifference>();
4193 f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	210 measurementStations = new ArrayList<ImportMeasurementStation>();
3328 a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	211 sqRelations = new ArrayList<ImportSQRelation>();
177 31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	212 }
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	213
766 aa9e3da95c31 Importer: Fix import of annotation type classification. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 765 diff changeset	214 public ImportRiver(
aa9e3da95c31 Importer: Fix import of annotation type classification. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 765 diff changeset	215 String name,
aa9e3da95c31 Importer: Fix import of annotation type classification. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 765 diff changeset	216 File wstFile,
aa9e3da95c31 Importer: Fix import of annotation type classification. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 765 diff changeset	217 File bbInfoFile,
aa9e3da95c31 Importer: Fix import of annotation type classification. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 765 diff changeset	218 AnnotationClassifier annotationClassifier
aa9e3da95c31 Importer: Fix import of annotation type classification. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 765 diff changeset	219 ) {
482 3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	220 this();
766 aa9e3da95c31 Importer: Fix import of annotation type classification. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 765 diff changeset	221 this.name = name;
aa9e3da95c31 Importer: Fix import of annotation type classification. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 765 diff changeset	222 this.wstFile = wstFile;
aa9e3da95c31 Importer: Fix import of annotation type classification. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 765 diff changeset	223 this.bbInfoFile = bbInfoFile;
aa9e3da95c31 Importer: Fix import of annotation type classification. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 765 diff changeset	224 this.annotationClassifier = annotationClassifier;
177 31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	225 }
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	226
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	227 public String getName() {
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	228 return name;
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	229 }
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	230
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	231 public void setName(String name) {
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	232 this.name = name;
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	233 }
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	234
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	235 public File getWstFile() {
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	236 return wstFile;
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	237 }
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	238
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	239 public void setWstFile(File wstFile) {
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	240 this.wstFile = wstFile;
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	241 }
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	242
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	243 public File getBBInfo() {
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	244 return bbInfoFile;
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	245 }
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	246
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	247 public void setBBInfo(File bbInfoFile) {
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	248 this.bbInfoFile = bbInfoFile;
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	249 }
184 4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	250
201 3169b559ca3c Build models for wsts, wst columns and q ranges and store them in the backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 197 diff changeset	251 public ImportWst getWst() {
3169b559ca3c Build models for wsts, wst columns and q ranges and store them in the backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 197 diff changeset	252 return wst;
3169b559ca3c Build models for wsts, wst columns and q ranges and store them in the backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 197 diff changeset	253 }
3169b559ca3c Build models for wsts, wst columns and q ranges and store them in the backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 197 diff changeset	254
3169b559ca3c Build models for wsts, wst columns and q ranges and store them in the backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 197 diff changeset	255 public void setWst(ImportWst wst) {
3169b559ca3c Build models for wsts, wst columns and q ranges and store them in the backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 197 diff changeset	256 this.wst = wst;
3169b559ca3c Build models for wsts, wst columns and q ranges and store them in the backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 197 diff changeset	257 }
3169b559ca3c Build models for wsts, wst columns and q ranges and store them in the backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 197 diff changeset	258
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	259 public File getMinfoDir() {
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	260 File riverDir = wstFile.getParentFile().getParentFile().getParentFile();
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	261 return new File(riverDir, MINFO_DIR);
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	262 }
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	263
186 cf8cbcb6a10d Added parser to read .KM files. Sascha L. Teichmann <sascha.teichmann@intevation.de>* parents: 184 diff changeset	264 public void parseDependencies() throws IOException {
cf8cbcb6a10d Added parser to read .KM files. Sascha L. Teichmann <sascha.teichmann@intevation.de>* parents: 184 diff changeset	265 parseGauges();
cf8cbcb6a10d Added parser to read .KM files. Sascha L. Teichmann <sascha.teichmann@intevation.de>* parents: 184 diff changeset	266 parseAnnotations();
1204 22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	267 parsePRFs();
4712 70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	268 parseDA66s();
4767 03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	269 parseDA50s();
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	270 parseW80s();
1220 3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	271 parseHYKs();
197 c0dcc2357106 Added stub for WST parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 194 diff changeset	272 parseWst();
482 3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	273 parseExtraWsts();
483 f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	274 parseFixations();
484 a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	275 parseOfficialLines();
490 13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	276 parseFloodWater();
494 88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	277 parseFloodProtection();
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	278 parseBedHeight();
2815 3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	279 parseSedimentDensity();
2821 0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	280 parseMorphologicalWidth();
2826 c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	281 parseFlowVelocity();
2839 163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	282 parseSedimentYield();
2844 c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	283 parseWaterlevels();
2851 acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	284 parseWaterlevelDifferences();
4193 f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	285 parseMeasurementStations();
3328 a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	286 parseSQRelation();
494 88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	287 }
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	288
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	289 public void parseFloodProtection() throws IOException {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	290 if (Config.INSTANCE.skipFloodProtection()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	291 log.info("skip parsing flood protection");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	292 return;
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	293 }
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	294
494 88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	295 log.info("Parse flood protection wst file");
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	296
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	297 File riverDir = wstFile.getParentFile().getParentFile();
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	298
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	299 File dir = FileTools.repair(new File(riverDir, FLOOD_PROTECTION));
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	300
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	301 if (!dir.isDirectory() \|\| !dir.canRead()) {
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	302 log.info("no directory '" + dir + "' found");
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	303 return;
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	304 }
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	305
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	306 File [] files = dir.listFiles();
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	307
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	308 if (files == null) {
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	309 log.warn("cannot read '" + dir + "'");
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	310 return;
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	311 }
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	312
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	313 for (File file: files) {
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	314 if (!file.isFile() \|\| !file.canRead()) {
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	315 continue;
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	316 }
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	317 String name = file.getName().toLowerCase();
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	318 if (!(name.endsWith(".zus") \|\| name.endsWith(".wst"))) {
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	319 continue;
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	320 }
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	321 log.info("found file '" + file.getName() + "'");
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	322 WstParser wstParser = new WstParser();
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	323 wstParser.parse(file);
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	324 ImportWst iw = wstParser.getWst();
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	325 iw.setKind(5);
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	326 iw.setDescription(FLOOD_PROTECTION + "/" + iw.getDescription());
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	327 floodProtection.add(iw);
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	328 }
490 13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	329 }
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	330
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	331
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	332 public void parseBedHeight() throws IOException {
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	333 File minfoDir = getMinfoDir();
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	334 File bedHeightDir = new File(minfoDir, BED_HEIGHT_DIR);
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	335 File singlesDir = new File(bedHeightDir, BED_HEIGHT_SINGLE_DIR);
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	336 File epochDir = new File(bedHeightDir, BED_HEIGHT_EPOCH_DIR);
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	337
2810 04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	338 if (Config.INSTANCE.skipBedHeightSingle()) {
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	339 log.info("skip parsing bed height single.");
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	340 }
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	341 else {
2844 c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	342 log.info("Parse bed height single.");
2810 04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	343 parseBedHeightSingles(singlesDir);
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	344 }
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	345
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	346 if (Config.INSTANCE.skipBedHeightEpoch()) {
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	347 log.info("skip parsing bed height epochs.");
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	348 }
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	349 else {
2844 c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	350 log.info("Parse bed height epochs.");
2810 04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	351 parseBedHeightEpochs(epochDir);
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	352 }
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	353 }
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	354
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	355
2815 3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	356 protected void parseSedimentDensity() throws IOException {
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	357 if (Config.INSTANCE.skipSedimentDensity()) {
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	358 log.info("skip parsing sediment density.");
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	359 return;
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	360 }
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	361
3327 bf8d9a4f4cd4 Cleared some irritating debug messages. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3320 diff changeset	362 log.debug("Parse sediment density");
bf8d9a4f4cd4 Cleared some irritating debug messages. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3320 diff changeset	363
2815 3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	364 File minfoDir = getMinfoDir();
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	365 File sediment = new File(minfoDir, SEDIMENT_DENSITY_DIR);
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	366
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	367 File[] files = sediment.listFiles();
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	368
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	369 if (files == null) {
3660 976ead36192d backend: Mention backend warnings in importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3659 diff changeset	370 log.warn("Cannot read directory '" + sediment + "'");
2815 3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	371 return;
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	372 }
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	373
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	374 SedimentDensityParser parser = new SedimentDensityParser();
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	375
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	376 for (File file: files) {
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	377 parser.parse(file);
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	378 }
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	379
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	380 sedimentDensities = parser.getSedimentDensities();
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	381
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	382 log.info("Parsed " + sedimentDensities.size() + " sediment densities.");
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	383 }
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	384
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	385
2821 0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	386 protected void parseMorphologicalWidth() throws IOException {
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	387 if (Config.INSTANCE.skipMorphologicalWidth()) {
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	388 log.info("skip parsing morphological width.");
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	389 return;
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	390 }
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	391
3327 bf8d9a4f4cd4 Cleared some irritating debug messages. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3320 diff changeset	392 log.debug("Parse morphological width");
bf8d9a4f4cd4 Cleared some irritating debug messages. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3320 diff changeset	393
2821 0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	394 File minfoDir = getMinfoDir();
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	395 File morphDir = new File(minfoDir, MORPHOLOGICAL_WIDTH_DIR);
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	396
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	397 File[] files = morphDir.listFiles();
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	398
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	399 if (files == null) {
3660 976ead36192d backend: Mention backend warnings in importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3659 diff changeset	400 log.warn("Cannot read directory '" + morphDir + "'");
2821 0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	401 return;
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	402 }
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	403
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	404 MorphologicalWidthParser parser = new MorphologicalWidthParser();
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	405
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	406 for (File file: files) {
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	407 parser.parse(file);
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	408 }
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	409
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	410 morphologicalWidths = parser.getMorphologicalWidths();
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	411
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	412 log.info("Parsed " + morphologicalWidths.size() + " morph. widths files.");
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	413 }
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	414
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	415
2826 c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	416 protected void parseFlowVelocity() throws IOException {
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	417 if (Config.INSTANCE.skipFlowVelocity()) {
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	418 log.info("skip parsing flow velocity");
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	419 return;
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	420 }
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	421
3328 a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	422 log.debug("Parse flow velocity");
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	423
2826 c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	424 File minfoDir = getMinfoDir();
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	425 File flowDir = new File(minfoDir, FLOW_VELOCITY_DIR);
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	426 File modelDir = new File(flowDir, FLOW_VELOCITY_MODEL);
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	427 File measureDir = new File(flowDir, FLOW_VELOCITY_MEASUREMENTS);
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	428
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	429 File[] modelFiles = modelDir.listFiles();
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	430 File[] measureFiles = measureDir.listFiles();
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	431
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	432 if (modelFiles == null) {
3660 976ead36192d backend: Mention backend warnings in importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3659 diff changeset	433 log.warn("Cannot read directory '" + modelDir + "'");
2826 c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	434 }
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	435 else {
2828 ac13e466a55e Added a parser for flow velocity model data and adjusted the db relation schema (missing q column). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2827 diff changeset	436 FlowVelocityModelParser parser = new FlowVelocityModelParser();
ac13e466a55e Added a parser for flow velocity model data and adjusted the db relation schema (missing q column). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2827 diff changeset	437
2826 c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	438 for (File model: modelFiles) {
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	439 log.debug("Parse file '" + model + "'");
2828 ac13e466a55e Added a parser for flow velocity model data and adjusted the db relation schema (missing q column). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2827 diff changeset	440 parser.parse(model);
2826 c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	441 }
2828 ac13e466a55e Added a parser for flow velocity model data and adjusted the db relation schema (missing q column). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2827 diff changeset	442
ac13e466a55e Added a parser for flow velocity model data and adjusted the db relation schema (missing q column). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2827 diff changeset	443 flowVelocityModels = parser.getModels();
2826 c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	444 }
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	445
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	446 if (measureFiles == null) {
3660 976ead36192d backend: Mention backend warnings in importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3659 diff changeset	447 log.warn("Cannot read directory '" + measureDir + "'");
2826 c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	448 }
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	449 else {
2832 ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	450 FlowVelocityMeasurementParser parser =
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	451 new FlowVelocityMeasurementParser();
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	452
2826 c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	453 for (File measurement: measureFiles) {
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	454 log.debug("Parse file '" + measurement + "'");
2832 ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	455 parser.parse(measurement);
2826 c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	456 }
2832 ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	457
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	458 flowVelocityMeasurements = parser.getMeasurements();
2826 c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	459 }
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	460 }
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	461
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	462
2839 163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	463 protected void parseSedimentYield() throws IOException {
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	464 if (Config.INSTANCE.skipSedimentYield()) {
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	465 log.info("skip parsing sediment yield data");
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	466 return;
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	467 }
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	468
3327 bf8d9a4f4cd4 Cleared some irritating debug messages. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3320 diff changeset	469 log.debug("Parse sediment yield data");
bf8d9a4f4cd4 Cleared some irritating debug messages. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3320 diff changeset	470
2839 163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	471 File minfoDir = getMinfoDir();
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	472 File sedimentYieldDir = new File(minfoDir, SEDIMENT_YIELD_DIR);
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	473
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	474 File singleDir = new File(sedimentYieldDir, SEDIMENT_YIELD_SINGLE_DIR);
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	475 File epochDir = new File(sedimentYieldDir, SEDIMENT_YIELD_EPOCH_DIR);
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	476
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	477 File[] singles = singleDir.listFiles();
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	478 File[] epochs = epochDir.listFiles();
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	479
2840 71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	480 SedimentYieldParser parser = new SedimentYieldParser();
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	481
2839 163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	482 if (singles == null \|\| singles.length == 0) {
3660 976ead36192d backend: Mention backend warnings in importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3659 diff changeset	483 log.warn("Cannot read directory '" + singleDir + "'");
2839 163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	484 }
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	485 else {
2840 71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	486 for (File file: singles) {
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	487 if (file.isDirectory()) {
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	488 for (File child: file.listFiles()) {
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	489 parser.parse(child);
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	490 }
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	491 }
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	492 else {
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	493 parser.parse(file);
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	494 }
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	495 }
2839 163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	496 }
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	497
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	498 if (epochs == null \|\| epochs.length == 0) {
3660 976ead36192d backend: Mention backend warnings in importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3659 diff changeset	499 log.warn("Cannot read directory '" + epochDir + "'");
2839 163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	500 }
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	501 else {
2840 71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	502 for (File file: epochs) {
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	503 if (file.isDirectory()) {
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	504 for (File child: file.listFiles()) {
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	505 parser.parse(child);
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	506 }
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	507 }
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	508 else {
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	509 parser.parse(file);
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	510 }
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	511 }
2839 163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	512 }
2840 71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	513
71175502d868 Added a parser for sediment yield files; started parsing and store values in db. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2839 diff changeset	514 sedimentYields = parser.getSedimentYields();
2839 163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	515 }
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	516
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	517
2844 c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	518 protected void parseWaterlevels() throws IOException {
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	519 if (Config.INSTANCE.skipWaterlevels()) {
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	520 log.info("skip parsing waterlevels");
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	521 return;
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	522 }
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	523
2851 acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	524 log.info("Parse waterlevels");
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	525
2844 c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	526 File minfo = getMinfoDir();
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	527 File fixDir = new File(minfo, MINFO_FIXATIONS_DIR);
2845 a65b5b0ade6f Completed the MINFO waterlevel import. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2844 diff changeset	528 File wspDir = new File(fixDir, MINFO_WATERLEVELS_DIR);
2844 c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	529
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	530 File[] files = wspDir.listFiles();
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	531
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	532 if (files == null) {
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	533 log.warn("Cannot read directory '" + wspDir + "'");
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	534 return;
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	535 }
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	536
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	537 WaterlevelParser parser = new WaterlevelParser();
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	538
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	539 for (File file: files) {
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	540 parser.parse(file);
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	541 }
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	542
2851 acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	543 waterlevels = parser.getWaterlevels();
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	544 }
2844 c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	545
4193 f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	546 protected void parseMeasurementStations() throws IOException {
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	547 if (Config.INSTANCE.skipMeasurementStations()) {
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	548 log.info("skip parsing measurement stations");
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	549 return;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	550 }
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	551
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	552 log.info("Parse measurement stations");
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	553
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	554 File minfo = getMinfoDir();
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	555 File minfoBaseDir = new File(minfo, MINFO_BASE_DIR);
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	556 File coredataFile = new File(minfoBaseDir, MINFO_CORE_DATA_FILE);
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	557
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	558 if (coredataFile == null \|\| !coredataFile.exists()) {
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	559 log.warn("No core data file '" + MINFO_CORE_DATA_FILE + "' found");
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	560 return;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	561 }
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	562
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	563 MeasurementStationsParser parser = new MeasurementStationsParser();
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	564 try {
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	565 parser.parse(coredataFile);
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	566 measurementStations = parser.getMeasurementStations();
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	567
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	568 log.info("Successfully parsed " + measurementStations.size() + " measurement stations.");
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	569 }
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	570 catch (IOException ioe) {
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	571 log.error("unable to parse file '" + coredataFile.getName() +
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	572 ": " + ioe.getMessage());
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	573 }
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	574 }
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	575
2851 acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	576
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	577 protected void parseWaterlevelDifferences() throws IOException {
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	578 if (Config.INSTANCE.skipWaterlevelDifferences()) {
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	579 log.info("skip parsing waterlevel differences");
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	580 return;
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	581 }
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	582
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	583 log.info("Parse waterlevel differences");
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	584
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	585 File minfo = getMinfoDir();
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	586 File fixDir = new File(minfo, MINFO_FIXATIONS_DIR);
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	587 File diffDir = new File(fixDir, MINFO_WATERLEVEL_DIFF_DIR);
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	588
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	589 File[] files = diffDir.listFiles();
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	590
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	591 if (files == null) {
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	592 log.warn("Cannot read directory '" + diffDir + "'");
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	593 return;
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	594 }
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	595
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	596 WaterlevelDifferencesParser parser = new WaterlevelDifferencesParser();
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	597
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	598 for (File file: files) {
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	599 parser.parse(file);
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	600 }
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	601
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	602 waterlevelDiffs = parser.getDifferences();
2844 c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	603 }
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	604
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	605
3328 a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	606 protected void parseSQRelation() throws IOException {
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	607 if (Config.INSTANCE.skipSQRelation()) {
3329 cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	608 log.info("skip parsing sq relation");
3328 a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	609 return;
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	610 }
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	611
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	612 log.info("Parse sq relations");
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	613
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	614 File minfo = getMinfoDir();
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	615 File sqDir = new File(minfo, MINFO_SQ_DIR);
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	616
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	617 File[] files = sqDir.listFiles();
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	618
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	619 if (files == null) {
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	620 log.warn("Cannot read directory '" + sqDir + "'");
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	621 return;
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	622 }
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	623
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	624 SQRelationParser parser = new SQRelationParser();
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	625
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	626 for (File file: files) {
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	627 parser.parse(file);
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	628 }
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	629
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	630 sqRelations = parser.getSQRelations();
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	631
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	632 log.debug("Parsed " + sqRelations.size() + " SQ relations.");
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	633 }
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	634
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	635
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	636 protected void parseBedHeightSingles(File dir) throws IOException {
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	637 log.debug("Parse bed height singles");
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	638
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	639 File[] files = dir.listFiles();
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	640
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	641 if (files == null) {
3660 976ead36192d backend: Mention backend warnings in importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3659 diff changeset	642 log.warn("Cannot read directory '" + dir + "'");
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	643 return;
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	644 }
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	645
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	646 BedHeightSingleParser parser = new BedHeightSingleParser();
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	647
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	648 for (File file: files) {
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	649 parser.parse(file);
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	650 }
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	651
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	652 bedHeightSingles = parser.getBedHeights();
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	653 }
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	654
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	655
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	656 protected void parseBedHeightEpochs(File dir) throws IOException {
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	657 log.debug("Parse bed height epochs");
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	658
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	659 File[] files = dir.listFiles();
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	660
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	661 if (files == null) {
3660 976ead36192d backend: Mention backend warnings in importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3659 diff changeset	662 log.warn("Cannot read directory '" + dir + "'");
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	663 return;
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	664 }
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	665
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	666 BedHeightEpochParser parser = new BedHeightEpochParser();
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	667
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	668 for (File file: files) {
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	669 parser.parse(file);
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	670 }
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	671
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	672 bedHeightEpochs = parser.getBedHeights();
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	673 }
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	674
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	675
490 13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	676 public void parseFloodWater() throws IOException {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	677 if (Config.INSTANCE.skipFloodWater()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	678 log.info("skip parsing flod water");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	679 return;
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	680 }
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	681
490 13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	682 log.info("Parse flood water wst file");
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	683
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	684 File riverDir = wstFile.getParentFile().getParentFile();
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	685
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	686 File dir = FileTools.repair(new File(riverDir, FLOOD_WATER));
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	687
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	688 if (!dir.isDirectory() \|\| !dir.canRead()) {
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	689 log.info("no directory '" + dir + "' found");
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	690 return;
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	691 }
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	692
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	693 File [] files = dir.listFiles();
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	694
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	695 if (files == null) {
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	696 log.warn("cannot read '" + dir + "'");
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	697 return;
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	698 }
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	699
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	700 for (File file: files) {
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	701 if (!file.isFile() \|\| !file.canRead()) {
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	702 continue;
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	703 }
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	704 String name = file.getName().toLowerCase();
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	705 if (!(name.endsWith(".zus") \|\| name.endsWith(".wst"))) {
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	706 continue;
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	707 }
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	708 log.info("found file '" + file.getName() + "'");
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	709 WstParser wstParser = new WstParser();
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	710 wstParser.parse(file);
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	711 ImportWst iw = wstParser.getWst();
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	712 iw.setKind(4);
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	713 iw.setDescription(FLOOD_WATER + "/" + iw.getDescription());
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	714 floodWater.add(iw);
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	715 }
484 a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	716 }
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	717
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	718 public void parseOfficialLines() throws IOException {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	719 if (Config.INSTANCE.skipOfficialLines()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	720 log.info("skip parsing official lines");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	721 return;
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	722 }
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	723
484 a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	724 log.info("Parse official wst files");
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	725
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	726 File riverDir = wstFile.getParentFile().getParentFile();
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	727
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	728 for (String folder: OFFICIAL_LINES_FOLDERS) {
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	729 File dir = FileTools.repair(new File(riverDir, folder));
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	730
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	731 if (!dir.isDirectory() \|\| !dir.canRead()) {
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	732 log.info("no directory '" + folder + "' found");
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	733 continue;
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	734 }
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	735
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	736 File file = FileTools.repair(new File(dir, OFFICIAL_LINES));
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	737 if (!file.isFile() \|\| !file.canRead()) {
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	738 log.warn("no official lines wst file found");
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	739 continue;
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	740 }
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	741 log.debug("Found WST file: " + file);
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	742
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	743 WstParser wstParser = new WstParser();
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	744 wstParser.parse(file);
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	745 ImportWst iw = wstParser.getWst();
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	746 iw.setKind(3);
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	747 iw.setDescription(folder + "/" + iw.getDescription());
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	748 officialLines.add(iw);
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	749 } // for all folders
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	750
483 f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	751 }
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	752
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	753 public void parseFixations() throws IOException {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	754 if (Config.INSTANCE.skipFixations()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	755 log.info("skip parsing fixations");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	756 return;
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	757 }
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	758
483 f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	759 log.info("Parse fixation wst files");
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	760
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	761 File riverDir = wstFile.getParentFile().getParentFile();
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	762
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	763 File fixDir = FileTools.repair(
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	764 new File(riverDir, FIXATIONS));
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	765
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	766 if (!fixDir.isDirectory() \|\| !fixDir.canRead()) {
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	767 log.info("no fixation wst file directory found");
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	768 return;
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	769 }
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	770
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	771 File [] files = fixDir.listFiles();
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	772
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	773 if (files == null) {
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	774 log.warn("cannot read fixations wst file directory");
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	775 return;
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	776 }
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	777
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	778 for (File file: files) {
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	779 if (!file.isFile() \|\| !file.canRead()) {
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	780 continue;
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	781 }
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	782 String name = file.getName().toLowerCase();
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	783 if (!name.endsWith(".wst")) {
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	784 continue;
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	785 }
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	786 log.debug("Found WST file: " + file);
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	787
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	788 WstParser wstParser = new WstParser();
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	789 wstParser.parse(file);
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	790 ImportWst iw = wstParser.getWst();
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	791 iw.setKind(2);
490 13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	792 iw.setDescription(FIXATIONS+ "/" + iw.getDescription());
483 f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	793 fixations.add(iw);
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	794 }
482 3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	795 }
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	796
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	797 public void parseExtraWsts() throws IOException {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	798 if (Config.INSTANCE.skipExtraWsts()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	799 log.info("skip parsing extra WST files");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	800 return;
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	801 }
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	802
482 3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	803 log.info("Parse extra longitudinal wst files");
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	804
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	805 File riverDir = wstFile.getParentFile().getParentFile();
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	806
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	807 File extraDir = FileTools.repair(
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	808 new File(riverDir, EXTRA_LONGITUDINALS));
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	809
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	810 if (!extraDir.isDirectory() \|\| !extraDir.canRead()) {
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	811 log.info("no extra longitudinal wst file directory found");
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	812 return;
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	813 }
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	814
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	815 File [] files = extraDir.listFiles();
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	816
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	817 if (files == null) {
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	818 log.warn("cannot read extra longitudinal wst file directory");
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	819 return;
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	820 }
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	821
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	822 for (File file: files) {
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	823 if (!file.isFile() \|\| !file.canRead()) {
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	824 continue;
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	825 }
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	826 String name = file.getName().toLowerCase();
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	827 if (!(name.endsWith(".zus") \|\| name.endsWith(".wst"))) {
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	828 continue;
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	829 }
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	830 log.debug("Found WST file: " + file);
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	831
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	832 WstParser wstParser = new WstParser();
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	833 wstParser.parse(file);
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	834 ImportWst iw = wstParser.getWst();
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	835 iw.setKind(1);
491 738140fe56fe Importer: Prefix "Zusätzliche Längsschnitte" with "Zus.Längsschnitte" in description. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 490 diff changeset	836 iw.setDescription(EXTRA_LONGITUDINALS + "/" + iw.getDescription());
482 3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	837 extraWsts.add(iw);
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	838 }
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	839
197 c0dcc2357106 Added stub for WST parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 194 diff changeset	840 }
c0dcc2357106 Added stub for WST parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 194 diff changeset	841
c0dcc2357106 Added stub for WST parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 194 diff changeset	842 public void parseWst() throws IOException {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	843 if (Config.INSTANCE.skipWst()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	844 log.info("skip parsing WST file");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	845 return;
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	846 }
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	847
197 c0dcc2357106 Added stub for WST parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 194 diff changeset	848 WstParser wstParser = new WstParser();
c0dcc2357106 Added stub for WST parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 194 diff changeset	849 wstParser.parse(wstFile);
201 3169b559ca3c Build models for wsts, wst columns and q ranges and store them in the backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 197 diff changeset	850 wst = wstParser.getWst();
186 cf8cbcb6a10d Added parser to read .KM files. Sascha L. Teichmann <sascha.teichmann@intevation.de>* parents: 184 diff changeset	851 }
cf8cbcb6a10d Added parser to read .KM files. Sascha L. Teichmann <sascha.teichmann@intevation.de>* parents: 184 diff changeset	852
184 4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	853 public void parseGauges() throws IOException {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	854 if (Config.INSTANCE.skipGauges()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	855 log.info("skip parsing gauges");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	856 return;
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	857 }
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	858
184 4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	859 File gltFile = new File(wstFile.getParentFile(), PEGEL_GLT);
4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	860 gltFile = FileTools.repair(gltFile);
4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	861
4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	862 if (!gltFile.isFile() \|\| !gltFile.canRead()) {
4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	863 log.warn("cannot read gauges from '" + gltFile + "'");
4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	864 return;
4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	865 }
4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	866
4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	867 PegelGltParser pgltp = new PegelGltParser();
4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	868 pgltp.parse(gltFile);
4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	869
4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	870 gauges = pgltp.getGauges();
189 bc3747a371cc First part of parsing main values. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 188 diff changeset	871
bc3747a371cc First part of parsing main values. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 188 diff changeset	872 for (ImportGauge gauge: gauges) {
bc3747a371cc First part of parsing main values. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 188 diff changeset	873 gauge.parseDependencies();
bc3747a371cc First part of parsing main values. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 188 diff changeset	874 }
184 4ab2c3bd474c Added parsing of PEGEL.GLT files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 177 diff changeset	875 }
186 cf8cbcb6a10d Added parser to read .KM files. Sascha L. Teichmann <sascha.teichmann@intevation.de>* parents: 184 diff changeset	876
cf8cbcb6a10d Added parser to read .KM files. Sascha L. Teichmann <sascha.teichmann@intevation.de>* parents: 184 diff changeset	877 public void parseAnnotations() throws IOException {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	878 if (Config.INSTANCE.skipAnnotations()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	879 log.info("skip parsing annotations");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	880 return;
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	881 }
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	882
186 cf8cbcb6a10d Added parser to read .KM files. Sascha L. Teichmann <sascha.teichmann@intevation.de>* parents: 184 diff changeset	883 File riverDir = wstFile.getParentFile().getParentFile();
765 763c4137d6e1 Added classification of annotation types. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 503 diff changeset	884 AnnotationsParser aparser =
763c4137d6e1 Added classification of annotation types. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 503 diff changeset	885 new AnnotationsParser(annotationClassifier);
186 cf8cbcb6a10d Added parser to read .KM files. Sascha L. Teichmann <sascha.teichmann@intevation.de>* parents: 184 diff changeset	886 aparser.parse(riverDir);
cf8cbcb6a10d Added parser to read .KM files. Sascha L. Teichmann <sascha.teichmann@intevation.de>* parents: 184 diff changeset	887
cf8cbcb6a10d Added parser to read .KM files. Sascha L. Teichmann <sascha.teichmann@intevation.de>* parents: 184 diff changeset	888 annotations = aparser.getAnnotations();
cf8cbcb6a10d Added parser to read .KM files. Sascha L. Teichmann <sascha.teichmann@intevation.de>* parents: 184 diff changeset	889 }
188 003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	890
1220 3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	891 public void parseHYKs() {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	892 if (Config.INSTANCE.skipHYKs()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	893 log.info("skip parsing HYK files");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	894 return;
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	895 }
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	896
1220 3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	897 log.info("looking for HYK files");
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	898 HYKParser parser = new HYKParser();
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	899 File riverDir = wstFile
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	900 .getParentFile() // Basisdaten
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	901 .getParentFile() // Hydrologie
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	902 .getParentFile(); // <river>
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	903
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	904 parser.parseHYKs(riverDir, new HYKParser.Callback() {
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	905
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	906 Set<HashedFile> hfs = new HashSet<HashedFile>();
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	907
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	908 @Override
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	909 public boolean hykAccept(File file) {
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	910 HashedFile hf = new HashedFile(file);
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	911 boolean success = hfs.add(hf);
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	912 if (!success) {
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	913 log.warn("HYK file '" + file + "' seems to be a duplicate.");
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	914 }
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	915 return success;
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	916 }
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	917
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	918 @Override
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	919 public void hykParsed(HYKParser parser) {
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	920 log.debug("callback from HYK parser");
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	921 ImportHYK hyk = parser.getHYK();
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	922 hyk.setRiver(ImportRiver.this);
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	923 hyks.add(hyk);
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	924 }
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	925 });
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	926 }
3c860d3e79d9 Importer: Parse HYKs from importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1211 diff changeset	927
4712 70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	928
4724 c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	929 /** Add cross sections with description, years and lines to
c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	930 * store. */
c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	931 private void addCrossSections(CrossSectionParser parser) {
c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	932 String description = parser.getDescription();
c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	933 Integer year = parser.getYear();
c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	934 ImportTimeInterval ti = year != null
c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	935 ? new ImportTimeInterval(yearToDate(year))
c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	936 : null;
c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	937
4735 94b39073f0f7 Moved EpsilonComparator to utils package becaus its not only useful for TIM parsing. Used EpsilonComparator in DA60 and DA66 case. Maybe TODO: Use in PRF, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4725 diff changeset	938 Map<Double, List<XY>> data = parser.getData();
94b39073f0f7 Moved EpsilonComparator to utils package becaus its not only useful for TIM parsing. Used EpsilonComparator in DA60 and DA66 case. Maybe TODO: Use in PRF, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4725 diff changeset	939
4724 c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	940 List<ImportCrossSectionLine> lines =
4735 94b39073f0f7 Moved EpsilonComparator to utils package becaus its not only useful for TIM parsing. Used EpsilonComparator in DA60 and DA66 case. Maybe TODO: Use in PRF, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4725 diff changeset	941 new ArrayList<ImportCrossSectionLine>(data.size());
4724 c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	942
4735 94b39073f0f7 Moved EpsilonComparator to utils package becaus its not only useful for TIM parsing. Used EpsilonComparator in DA60 and DA66 case. Maybe TODO: Use in PRF, too. Sascha L. Teichmann <teichmann@intevation.de> parents: 4725 diff changeset	943 for (Map.Entry<Double, List<XY>> entry: data.entrySet()) {
4724 c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	944 Double km = entry.getKey();
c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	945 List<XY> points = entry.getValue();
c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	946 lines.add(new ImportCrossSectionLine(km, points));
c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	947 }
c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	948
c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	949 crossSections.add(new ImportCrossSection(
c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	950 ImportRiver.this, description, ti, lines));
c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	951 }
c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	952
4767 03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	953 /** Create a W80 Parser and parse w80 files found. */
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	954 public void parseW80s() {
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	955 if (Config.INSTANCE.skipW80s()) {
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	956 log.info("skip parsing W80s");
4781 e77b461fa360 ImportRiver: Bail out if skip* parameters were given. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4779 diff changeset	957 return;
4767 03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	958 }
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	959 W80Parser parser = new W80Parser();
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	960 File riverDir = wstFile
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	961 .getParentFile() // Basisdaten
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	962 .getParentFile() // Hydrologie
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	963 .getParentFile(); // <river>
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	964
4779 18908a3cbb3a ImportRiver: Use callback (refactoring), resolving TODOs. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4778 diff changeset	965 ImportRiverCrossSectionParserCallback w80Callback =
18908a3cbb3a ImportRiver: Use callback (refactoring), resolving TODOs. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4778 diff changeset	966 new ImportRiverCrossSectionParserCallback("w80");
18908a3cbb3a ImportRiver: Use callback (refactoring), resolving TODOs. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4778 diff changeset	967 parser.parseW80s(riverDir, w80Callback);
4767 03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	968 }
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	969
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	970 public void parseDA50s() {
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	971 if (Config.INSTANCE.skipDA50s()) {
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	972 log.info("skip parsing DA50s");
4781 e77b461fa360 ImportRiver: Bail out if skip* parameters were given. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4779 diff changeset	973 return;
4767 03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	974 }
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	975 else log.warn("DA50 parsing not yet implemented");
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	976 }
03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	977
4724 c30152f77f77 ImportRiver: Refactoring, use description and year of da66parser. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4716 diff changeset	978
4712 70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	979 /** Create a DA66 Parser and parse the da66 files found. */
70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	980 // TODO this is a copy of parsePRFs, extract interfaces (e.g. CrossSectionParser).
70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	981 public void parseDA66s() {
70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	982 if (Config.INSTANCE.skipDA66s()) {
70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	983 log.info("skip parsing DA66s");
70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	984 return;
70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	985 }
70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	986
70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	987 log.info("looking for DA66 files");
70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	988 DA66Parser parser = new DA66Parser();
70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	989 File riverDir = wstFile
70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	990 .getParentFile() // Basisdaten
70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	991 .getParentFile() // Hydrologie
70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	992 .getParentFile(); // <river>
70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	993
4779 18908a3cbb3a ImportRiver: Use callback (refactoring), resolving TODOs. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4778 diff changeset	994 ImportRiverCrossSectionParserCallback da66Callback =
18908a3cbb3a ImportRiver: Use callback (refactoring), resolving TODOs. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4778 diff changeset	995 new ImportRiverCrossSectionParserCallback("da66");
18908a3cbb3a ImportRiver: Use callback (refactoring), resolving TODOs. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4778 diff changeset	996 parser.parseDA66s(riverDir, da66Callback);
4712 70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	997 }
70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	998
70842db72ee4 Include improved DA66Parser into importer. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4706 diff changeset	999 /** Create a PRFParser and let it parse the prf files found. */
1204 22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1000 public void parsePRFs() {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1001 if (Config.INSTANCE.skipPRFs()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1002 log.info("skip parsing PRFs");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1003 return;
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1004 }
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1005
1204 22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1006 log.info("looking for PRF files");
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1007 PRFParser parser = new PRFParser();
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1008 File riverDir = wstFile
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1009 .getParentFile() // Basisdaten
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1010 .getParentFile() // Hydrologie
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1011 .getParentFile(); // <river>
1206 c7370734b872 Prevent parsing and storing PRF duplicates. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1204 diff changeset	1012
4779 18908a3cbb3a ImportRiver: Use callback (refactoring), resolving TODOs. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4778 diff changeset	1013 ImportRiverCrossSectionParserCallback prfCallback =
18908a3cbb3a ImportRiver: Use callback (refactoring), resolving TODOs. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4778 diff changeset	1014 new ImportRiverCrossSectionParserCallback("prf");
18908a3cbb3a ImportRiver: Use callback (refactoring), resolving TODOs. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4778 diff changeset	1015 parser.parsePRFs(riverDir, prfCallback);
1204 22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1016 }
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1017
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1018 public static Date yearToDate(int year) {
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1019 Calendar cal = Calendar.getInstance();
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1020 cal.set(year, 5, 15, 12, 0, 0);
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1021 long ms = cal.getTimeInMillis();
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1022 cal.setTimeInMillis(ms - ms%1000);
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1023 return cal.getTime();
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1024 }
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1025
190 d40da430d2fe Added stub code to write gauges Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 189 diff changeset	1026 public void storeDependencies() {
2347 0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	1027 storeWstUnit();
190 d40da430d2fe Added stub code to write gauges Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 189 diff changeset	1028 storeAnnotations();
1221 979ff070e368 Store HYK data structures to database. Needs testing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1220 diff changeset	1029 storeHYKs();
1204 22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1030 storeCrossSections();
190 d40da430d2fe Added stub code to write gauges Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 189 diff changeset	1031 storeGauges();
201 3169b559ca3c Build models for wsts, wst columns and q ranges and store them in the backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 197 diff changeset	1032 storeWst();
482 3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	1033 storeExtraWsts();
483 f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	1034 storeFixations();
484 a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	1035 storeOfficialLines();
490 13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	1036 storeFloodWater();
494 88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	1037 storeFloodProtection();
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	1038 storeBedHeight();
2815 3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	1039 storeSedimentDensity();
2821 0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1040 storeMorphologicalWidth();
2826 c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	1041 storeFlowVelocity();
2839 163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1042 storeSedimentYield();
2844 c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	1043 storeWaterlevels();
2851 acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1044 storeWaterlevelDifferences();
4193 f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1045 storeMeasurementStations();
3328 a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	1046 storeSQRelations();
201 3169b559ca3c Build models for wsts, wst columns and q ranges and store them in the backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 197 diff changeset	1047 }
3169b559ca3c Build models for wsts, wst columns and q ranges and store them in the backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 197 diff changeset	1048
2347 0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	1049 public void storeWstUnit() {
0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	1050 if (wst == null) {
0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	1051 wstUnit = new ImportUnit("NN + m");
0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	1052 }
0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	1053 else {
0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	1054 wstUnit = wst.getUnit();
0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	1055 }
0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	1056 }
0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	1057
1221 979ff070e368 Store HYK data structures to database. Needs testing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1220 diff changeset	1058 public void storeHYKs() {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1059 if (!Config.INSTANCE.skipHYKs()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1060 log.info("store HYKs");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1061 getPeer();
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1062 for (ImportHYK hyk: hyks) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1063 hyk.storeDependencies();
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1064 }
1221 979ff070e368 Store HYK data structures to database. Needs testing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1220 diff changeset	1065 }
979ff070e368 Store HYK data structures to database. Needs testing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1220 diff changeset	1066 }
979ff070e368 Store HYK data structures to database. Needs testing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1220 diff changeset	1067
1204 22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1068 public void storeCrossSections() {
4767 03246a8b3869 ImportRiver: Added w80 and hook for da50 parsing (not implemented). Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4735 diff changeset	1069 if (!Config.INSTANCE.skipPRFs() \|\| !Config.INSTANCE.skipDA66s() \|\| !Config.INSTANCE.skipDA50s() \|\| !Config.INSTANCE.skipW80s()) {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1070 log.info("store cross sections");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1071 getPeer();
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1072 for (ImportCrossSection crossSection: crossSections) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1073 crossSection.storeDependencies();
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1074 }
1204 22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1075 }
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1076 }
22858e7cca79 Integrated PRF parsing into importer. Needs testing! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 766 diff changeset	1077
201 3169b559ca3c Build models for wsts, wst columns and q ranges and store them in the backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 197 diff changeset	1078 public void storeWst() {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1079 if (!Config.INSTANCE.skipWst()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1080 River river = getPeer();
483 f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	1081 wst.storeDependencies(river);
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	1082 }
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	1083 }
f1fd9cab6a07 Importer: parse and store fixation wst files as well Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 482 diff changeset	1084
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1085 public void storeFixations() {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1086 if (!Config.INSTANCE.skipFixations()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1087 log.info("store fixation wsts");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1088 River river = getPeer();
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1089 for (ImportWst wst: fixations) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1090 log.debug("name: " + wst.getDescription());
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1091 wst.storeDependencies(river);
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1092 }
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1093 }
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1094 }
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1095
482 3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	1096 public void storeExtraWsts() {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1097 if (!Config.INSTANCE.skipExtraWsts()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1098 log.info("store extra wsts");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1099 River river = getPeer();
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1100 for (ImportWst wst: extraWsts) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1101 log.debug("name: " + wst.getDescription());
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1102 wst.storeDependencies(river);
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1103 }
482 3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	1104 }
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	1105 }
3a99d0295006 Importer: Support parsing "zusaetzliche Laengsschnitte". Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 201 diff changeset	1106
484 a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	1107 public void storeOfficialLines() {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1108 if (!Config.INSTANCE.skipOfficialLines()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1109 log.info("store official lines wsts");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1110 River river = getPeer();
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1111 for (ImportWst wst: officialLines) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1112 log.debug("name: " + wst.getDescription());
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1113 wst.storeDependencies(river);
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1114 }
484 a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	1115 }
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	1116 }
a9e9a8a44d19 Parse and store "amtliche Linien" wst files. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 483 diff changeset	1117
490 13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	1118 public void storeFloodWater() {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1119 if (!Config.INSTANCE.skipFloodWater()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1120 log.info("store flood water wsts");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1121 River river = getPeer();
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1122 for (ImportWst wst: floodWater) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1123 log.debug("name: " + wst.getDescription());
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1124 wst.storeDependencies(river);
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1125 }
490 13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	1126 }
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	1127 }
13af9318a4a2 Import "Hochwasser-Marken", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 484 diff changeset	1128
494 88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	1129 public void storeFloodProtection() {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1130 if (!Config.INSTANCE.skipFloodProtection()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1131 log.info("store flood protection wsts");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1132 River river = getPeer();
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1133 for (ImportWst wst: floodProtection) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1134 log.debug("name: " + wst.getDescription());
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1135 wst.storeDependencies(river);
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1136 }
494 88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	1137 }
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	1138 }
88d5b02ff0c1 Importer: Import the "HW-Schutzanlagen", too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 491 diff changeset	1139
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	1140
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	1141 public void storeBedHeight() {
2810 04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1142 if (!Config.INSTANCE.skipBedHeightSingle()) {
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1143 log.info("store bed heights single");
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1144 storeBedHeightSingle();
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1145 }
2809 f283212966e8 Finished work on MINFO bed heights (single). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2806 diff changeset	1146
2810 04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1147 if (!Config.INSTANCE.skipBedHeightEpoch()) {
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1148 log.info("store bed height epoch.");
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1149 storeBedHeightEpoch();
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1150 }
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1151 }
2809 f283212966e8 Finished work on MINFO bed heights (single). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2806 diff changeset	1152
2810 04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1153
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1154 private void storeBedHeightSingle() {
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1155 River river = getPeer();
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1156
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1157 if (bedHeightSingles != null) {
2811 8926571e47fb Finished importing MINFO bed heights (single and epoch). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2810 diff changeset	1158 for (ImportBedHeight tmp: bedHeightSingles) {
8926571e47fb Finished importing MINFO bed heights (single and epoch). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2810 diff changeset	1159 ImportBedHeightSingle single = (ImportBedHeightSingle) tmp;
8926571e47fb Finished importing MINFO bed heights (single and epoch). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2810 diff changeset	1160
2810 04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1161 String desc = single.getDescription();
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1162
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1163 log.debug("name: " + desc);
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1164
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1165 try {
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1166 single.storeDependencies(river);
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1167 }
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1168 catch (SQLException sqle) {
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1169 log.error("File '" + desc + "' is broken!");
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1170 }
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1171 catch (ConstraintViolationException cve) {
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1172 log.error("File '" + desc + "' is broken!");
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	1173 }
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	1174 }
2810 04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1175 }
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1176 else {
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1177 log.info("No single bed heights to store.");
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1178 }
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1179 }
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	1180
2810 04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1181
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1182 private void storeBedHeightEpoch() {
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1183 River river = getPeer();
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1184
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1185 if (bedHeightEpochs != null) {
2811 8926571e47fb Finished importing MINFO bed heights (single and epoch). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2810 diff changeset	1186 for (ImportBedHeight tmp: bedHeightEpochs) {
8926571e47fb Finished importing MINFO bed heights (single and epoch). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2810 diff changeset	1187 ImportBedHeightEpoch epoch = (ImportBedHeightEpoch) tmp;
8926571e47fb Finished importing MINFO bed heights (single and epoch). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2810 diff changeset	1188
2810 04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1189 String desc = epoch.getDescription();
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1190
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1191 log.debug("name: " + desc);
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1192
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1193 try {
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	1194 epoch.storeDependencies(river);
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	1195 }
2810 04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1196 catch (SQLException sqle) {
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1197 log.error("File '" + desc + "' is broken!");
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1198 }
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1199 catch (ConstraintViolationException cve) {
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1200 log.error("File '" + desc + "' is broken!");
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1201 }
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	1202 }
2810 04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1203 }
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1204 else {
04eeb45df27b Implemented model classes and importer classes for bed height epochs. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2809 diff changeset	1205 log.info("No epoch bed heights to store.");
2806 33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	1206 }
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	1207 }
33f40b23edd8 Initial checkin for parsing MINFO bed heights. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2347 diff changeset	1208
2815 3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	1209 public void storeSedimentDensity() {
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	1210 if (!Config.INSTANCE.skipSedimentDensity()) {
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	1211 log.info("store sediment density");
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	1212
2817 8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1213 River river = getPeer();
8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1214
8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1215 for (ImportSedimentDensity density: sedimentDensities) {
8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1216 String desc = density.getDescription();
8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1217
8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1218 log.debug("name: " + desc);
8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1219
8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1220 try {
8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1221 density.storeDependencies(river);
8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1222 }
8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1223 catch (SQLException sqle) {
8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1224 log.error("File '" + desc + "' is broken!");
8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1225 }
8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1226 catch (ConstraintViolationException cve) {
8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1227 log.error("File '" + desc + "' is broken!");
8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1228 }
8979f2294af9 Finished parsing MINFO specific sediment density. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2815 diff changeset	1229 }
2815 3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	1230 }
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	1231 }
3febaed762b8 Added new parser (stub) to read MINFO sediment density files; prepared import process to handle those files. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2811 diff changeset	1232
2821 0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1233 public void storeMorphologicalWidth() {
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1234 if (!Config.INSTANCE.skipMorphologicalWidth()) {
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1235 log.info("store morphological width");
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1236
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1237 River river = getPeer();
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1238
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1239 for (ImportMorphWidth width: morphologicalWidths) {
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1240 try {
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1241 width.storeDependencies(river);
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1242 }
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1243 catch (SQLException sqle) {
3659 36edf9a71cbd backend: Mention backend errors in importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3329 diff changeset	1244 log.error("Error while parsing file for morph. width.", sqle);
2821 0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1245 }
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1246 catch (ConstraintViolationException cve) {
3659 36edf9a71cbd backend: Mention backend errors in importer. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 3329 diff changeset	1247 log.error("Error while parsing file for morph. width.", cve);
2821 0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1248 }
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1249 }
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1250 }
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1251 }
0a536eb5d668 Added parser for parsing morphological widths. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2817 diff changeset	1252
2826 c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	1253 public void storeFlowVelocity() {
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	1254 if (!Config.INSTANCE.skipFlowVelocity()) {
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	1255 log.info("store flow velocity");
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	1256
2827 85b25e74594f Added temp classes used during the import process of flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2826 diff changeset	1257 River river = getPeer();
85b25e74594f Added temp classes used during the import process of flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2826 diff changeset	1258
85b25e74594f Added temp classes used during the import process of flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2826 diff changeset	1259 for (ImportFlowVelocityModel flowVelocityModel: flowVelocityModels){
85b25e74594f Added temp classes used during the import process of flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2826 diff changeset	1260 try {
85b25e74594f Added temp classes used during the import process of flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2826 diff changeset	1261 flowVelocityModel.storeDependencies(river);
85b25e74594f Added temp classes used during the import process of flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2826 diff changeset	1262 }
85b25e74594f Added temp classes used during the import process of flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2826 diff changeset	1263 catch (SQLException sqle) {
85b25e74594f Added temp classes used during the import process of flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2826 diff changeset	1264 log.error("Error while storing flow velocity model.", sqle);
85b25e74594f Added temp classes used during the import process of flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2826 diff changeset	1265 }
85b25e74594f Added temp classes used during the import process of flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2826 diff changeset	1266 catch (ConstraintViolationException cve) {
85b25e74594f Added temp classes used during the import process of flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2826 diff changeset	1267 log.error("Error while storing flow velocity model.", cve);
85b25e74594f Added temp classes used during the import process of flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2826 diff changeset	1268 }
85b25e74594f Added temp classes used during the import process of flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2826 diff changeset	1269 }
2832 ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	1270
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	1271 for (ImportFlowVelocityMeasurement m: flowVelocityMeasurements) {
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	1272 try {
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	1273 m.storeDependencies(river);
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	1274 }
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	1275 catch (SQLException sqle) {
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	1276 log.error("Error while storing flow velocity measurement.", sqle);
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	1277 }
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	1278 catch (ConstraintViolationException cve) {
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	1279 log.error("Error while storing flow velocity measurement.", cve);
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	1280 }
ac5bd90697c1 Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2828 diff changeset	1281 }
2826 c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	1282 }
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	1283 }
c3f8cf0cdf69 Prepared the importer to parse flow velocity files and added a config option to skip that process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2821 diff changeset	1284
2839 163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1285
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1286 public void storeSedimentYield() {
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1287 if (!Config.INSTANCE.skipSedimentYield()) {
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1288 log.info("store sediment yield data");
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1289
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1290 River river = getPeer();
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1291
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1292 for (ImportSedimentYield sedimentYield: sedimentYields) {
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1293 try {
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1294 sedimentYield.storeDependencies(river);
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1295 }
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1296 catch (SQLException sqle) {
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1297 log.error("Error while storing sediment yield.", sqle);
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1298 }
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1299 catch (ConstraintViolationException cve) {
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1300 log.error("Error while storing sediment yield.", cve);
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1301 }
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1302 }
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1303 }
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1304 }
163c037f2c7e Added config option to skip parsing sediment yield data and prepared the importer to read/store those data. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2832 diff changeset	1305
2844 c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	1306
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	1307 public void storeWaterlevels() {
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	1308 if (!Config.INSTANCE.skipWaterlevels()) {
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	1309 log.info("store waterlevels");
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	1310
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	1311 River river = getPeer();
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	1312
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	1313 for (ImportWaterlevel waterlevel: waterlevels) {
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	1314 waterlevel.storeDependencies(river);
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	1315 }
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	1316 }
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	1317 }
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	1318
c4db0f75a94a Prepared the importer to import MINFO specific waterlevel values and added a stub for a parser. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2840 diff changeset	1319
2851 acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1320 public void storeWaterlevelDifferences() {
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1321 if (!Config.INSTANCE.skipWaterlevelDifferences()) {
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1322 log.info("store waterlevel differences");
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1323
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1324 River river = getPeer();
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1325
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1326 for (ImportWaterlevelDifference diff: waterlevelDiffs) {
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1327 try {
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1328 diff.storeDependencies(river);
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1329 }
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1330 catch (SQLException sqle) {
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1331 log.error("Error while storing waterlevel diff.", sqle);
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1332 }
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1333 catch (ConstraintViolationException cve) {
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1334 log.error("Error while storing waterlevel diff.", cve);
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1335 }
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1336 }
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1337 }
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1338 }
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1339
acb8d08f59a2 Parse and store MINFO waterlevel differences; added config option to skip this process. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 2845 diff changeset	1340
4193 f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1341 public void storeMeasurementStations() {
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1342 if (!Config.INSTANCE.skipMeasurementStations()) {
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1343 log.info("store measurement stations");
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1344
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1345 River river = getPeer();
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1346
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1347 int count = 0;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1348
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1349 for (ImportMeasurementStation station: measurementStations) {
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1350 try {
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1351 boolean success = station.storeDependencies(river);
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1352 if (success) {
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1353 count++;
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1354 }
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1355 }
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1356 catch (SQLException sqle) {
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1357 log.error("Error while storing measurement station.", sqle);
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1358 }
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1359 catch (ConstraintViolationException cve) {
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1360 log.error("Error while storing measurement station.", cve);
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1361 }
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1362 }
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1363
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1364 log.info("stored " + count + " measurement stations.");
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1365 }
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1366 }
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1367
f63b39799d2d Adapted DB schema (added relation measurement_station); improved importer to read files from filesystem with measurement stations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3660 diff changeset	1368
3328 a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	1369 public void storeSQRelations() {
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	1370 if (!Config.INSTANCE.skipSQRelation()) {
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	1371 log.info("store sq relations");
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	1372
3329 cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1373 River river = getPeer();
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1374
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1375 int count = 0;
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1376
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1377 for (ImportSQRelation sqRelation: sqRelations) {
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1378 try {
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1379 sqRelation.storeDependencies(river);
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1380 count++;
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1381 }
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1382 catch (SQLException sqle) {
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1383 log.error("Error while storing sq relation.", sqle);
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1384 }
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1385 catch (ConstraintViolationException cve) {
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1386 log.error("Error while storing sq relation.", cve);
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1387 }
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1388 }
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1389
cc8fc6b29649 Store sq relations into database after parsing. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3328 diff changeset	1390 log.info("stored " + count + " sq relations.");
3328 a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	1391 }
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	1392 }
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	1393
a41f279a66e2 Added parser and import classes to import MINFO sq relations. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 3327 diff changeset	1394
188 003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1395 public void storeAnnotations() {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1396 if (!Config.INSTANCE.skipAnnotations()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1397 River river = getPeer();
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1398 for (ImportAnnotation annotation: annotations) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1399 annotation.getPeer(river);
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1400 }
188 003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1401 }
003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1402 }
003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1403
190 d40da430d2fe Added stub code to write gauges Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 189 diff changeset	1404 public void storeGauges() {
1223 268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1405 if (!Config.INSTANCE.skipGauges()) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1406 log.info("store gauges:");
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1407 River river = getPeer();
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1408 Session session = ImporterSession.getInstance()
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1409 .getDatabaseSession();
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1410 for (ImportGauge gauge: gauges) {
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1411 log.info("\tgauge: " + gauge.getName());
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1412 gauge.storeDependencies(river);
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1413 ImporterSession.getInstance().getDatabaseSession();
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1414 session.flush();
268f8da412e3 Importer: Added a central configuration to allow skipping of parsing/storing individual sub systems. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1221 diff changeset	1415 }
191 c4fb5141ce11 Propagate river into storing of gauges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 190 diff changeset	1416 }
190 d40da430d2fe Added stub code to write gauges Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 189 diff changeset	1417 }
d40da430d2fe Added stub code to write gauges Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 189 diff changeset	1418
188 003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1419 public River getPeer() {
003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1420 if (peer == null) {
497 67fd63e4ef66 Importer: centralized caching Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 494 diff changeset	1421 Session session = ImporterSession.getInstance().getDatabaseSession();
188 003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1422 Query query = session.createQuery("from River where name=:name");
2347 0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	1423
0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	1424 Unit u = wstUnit.getPeer();
0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	1425
188 003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1426 query.setString("name", name);
003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1427 List<River> rivers = query.list();
003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1428 if (rivers.isEmpty()) {
2347 0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	1429 log.info("Store new river '" + name + "'");
0acf28a3d28a Removed the Unit from Wsts - added a WstUnit column to rivers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 1234 diff changeset	1430 peer = new River(name, u);
188 003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1431 session.save(peer);
003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1432 }
003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1433 else {
003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1434 peer = rivers.get(0);
003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1435 }
003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1436 }
003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1437 return peer;
003ac16812dd Store annotations in backend. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 186 diff changeset	1438 }
177 31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	1439 }
31895d24387e Importer: Added info gew parser. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	1440 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :

Mercurial > dive4elements > river

annotate flys-backend/src/main/java/de/intevation/flys/importer/ImportRiver.java @ 4781:e77b461fa360