dive4elements/river: flys-aft/src/main/java/de/intevation/aft/River.java annotate

annotate flys-aft/src/main/java/de/intevation/aft/River.java @ 4197:810db532803a

Removed superfluous imports.

author	Sascha L. Teichmann <teichmann@intevation.de>
date	Mon, 22 Oct 2012 11:48:01 +0200
parents	06891562e633
children	79bb64f66c74

rev	line source
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	1 package de.intevation.aft;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	2
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	3 import java.util.List;
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	4 import java.util.ArrayList;
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	5 import java.util.HashMap;
4078 0944cdd2ee90 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4077 diff changeset	6 import java.util.Map;
0944cdd2ee90 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4077 diff changeset	7
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	8 import java.sql.ResultSet;
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	9 import java.sql.SQLException;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	10
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	11 import org.apache.log4j.Logger;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	12
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	13 import de.intevation.db.ConnectedStatements;
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	14 import de.intevation.db.SymbolicStatement;
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	15
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	16 public class River
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	17 extends IdPair
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	18 {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	19 private static Logger log = Logger.getLogger(River.class);
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	20
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	21 protected String name;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	22
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	23 public River() {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	24 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	25
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	26 public River(int id1, int id2, String name) {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	27 super(id1, id2);
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	28 this.name = name;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	29 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	30
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	31 public String getName() {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	32 return name;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	33 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	34
4078 0944cdd2ee90 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4077 diff changeset	35
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	36 public boolean sync(SyncContext context) throws SQLException {
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	37 log.info("sync river: " + this);
4077 97de7a552b79 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4076 diff changeset	38
4084 9178beeb7b05 Moved DIPS gauge number -> DIPS gauge index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4083 diff changeset	39 Map<Long, DIPSGauge> dipsGauges = context.getDIPSGauges();
4081 7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	40
4077 97de7a552b79 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4076 diff changeset	41 ConnectedStatements flysStatements = context.getFlysStatements();
97de7a552b79 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4076 diff changeset	42 ConnectedStatements aftStatements = context.getAftStatements();
97de7a552b79 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4076 diff changeset	43
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	44 ResultSet messstellenRs = aftStatements
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	45 .getStatement("select.messstelle")
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	46 .clearParameters()
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	47 .setInt("GEWAESSER_NR", id2).executeQuery();
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	48
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	49 String riverName = getName();
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	50
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	51 Map<Long, DIPSGauge> aftDIPSGauges = new HashMap<Long, DIPSGauge>();
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	52
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	53 while (messstellenRs.next()) {
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	54 String name = messstellenRs.getString("NAME");
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	55 String num = messstellenRs.getString("MESSSTELLE_NR");
4084 9178beeb7b05 Moved DIPS gauge number -> DIPS gauge index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4083 diff changeset	56 Long number = SyncContext.numberToLong(num);
4081 7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	57 if (number == null) {
4110 06891562e633 Extracted and documented the error messages of the process. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4104 diff changeset	58 log.warn("AFT: Invalid MESSSTELLE_NR for MESSSTELLE '"+name+"'");
4081 7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	59 continue;
7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	60 }
7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	61 DIPSGauge dipsGauge = dipsGauges.get(number);
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	62 if (dipsGauge == null) {
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	63 log.warn(
4110 06891562e633 Extracted and documented the error messages of the process. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4104 diff changeset	64 "DIPS: MESSSTELLE '" + name + "' not found in DIPS. " +
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	65 "Gauge number used for lookup: " + number);
4081 7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	66 continue;
7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	67 }
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	68 String gaugeRiver = dipsGauge.getRiverName();
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	69 if (!gaugeRiver.equalsIgnoreCase(riverName)) {
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	70 log.warn(
4110 06891562e633 Extracted and documented the error messages of the process. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4104 diff changeset	71 "DIPS: MESSSTELLE '" + name +
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	72 "' is assigned to river '" + gaugeRiver +
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	73 "'. Needs to be on '" + riverName + "'.");
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	74 continue;
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	75 }
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	76 dipsGauge.setAftName(name);
4097 83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	77 dipsGauge.setOfficialNumber(number);
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	78 aftDIPSGauges.put(number, dipsGauge);
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	79 }
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	80
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	81 messstellenRs.close();
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	82
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	83 List<DIPSGauge> updateGauges = new ArrayList<DIPSGauge>();
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	84
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	85 ResultSet gaugesRs = flysStatements
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	86 .getStatement("select.gauges")
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	87 .clearParameters()
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	88 .setInt("river_id", id1).executeQuery();
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	89
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	90 while (gaugesRs.next()) {
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	91 int gaugeId = gaugesRs.getInt("id");
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	92 String name = gaugesRs.getString("name");
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	93 long number = gaugesRs.getLong("official_number");
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	94 if (gaugesRs.wasNull()) {
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	95 log.warn("FLYS: Gauge '" + name +
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	96 "' has no official number. Ignored.");
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	97 continue;
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	98 }
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	99 Long key = Long.valueOf(number);
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	100 DIPSGauge aftDIPSGauge = aftDIPSGauges.remove(key);
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	101 if (aftDIPSGauge == null) {
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	102 log.warn("FLYS: Gauge '" + name + "' number " + number +
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	103 " is not found in AFT/DIPS.");
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	104 continue;
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	105 }
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	106 aftDIPSGauge.setFlysId(gaugeId);
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	107 log.info("Gauge '" + name +
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	108 "' found in FLYS, AFT and DIPS. -> Update");
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	109 updateGauges.add(aftDIPSGauge);
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	110 }
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	111 gaugesRs.close();
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	112
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	113 boolean modified = createGauges(context, aftDIPSGauges);
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	114
4097 83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	115 modified \|= updateGauges(context, updateGauges);
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	116
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	117 return modified;
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	118 }
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	119
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	120 protected boolean updateGauges(
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	121 SyncContext context,
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	122 List<DIPSGauge> gauges
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	123 )
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	124 throws SQLException
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	125 {
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	126 boolean modified = false;
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	127
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	128 for (DIPSGauge gauge: gauges) {
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	129 modified \|= updateGauge(context, gauge);
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	130 }
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	131
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	132 return modified;
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	133 }
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	134
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	135 protected boolean updateGauge(
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	136 SyncContext context,
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	137 DIPSGauge gauge
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	138 )
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	139 throws SQLException
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	140 {
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	141 log.info("FLYS: Updating gauge '" + gauge.getAftName() + "'.");
4097 83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	142 // We need to load all discharge tables from both database
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	143 // of the gauge and do some pairing based on their descriptions.
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	144
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	145 boolean modified = false;
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	146
4104 cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	147 ConnectedStatements flysStatements = context.getFlysStatements();
4098 9215253ad0be Do the FLYS/AFT description pairing of discharge tables in case a gauge needs updates. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	148
4104 cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	149 flysStatements.beginTransaction();
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	150 try {
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	151 List<DischargeTable> flysDTs =
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	152 DischargeTable.loadFlysDischargeTables(
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	153 context, gauge.getFlysId());
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	154
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	155 List<DischargeTable> aftDTs =
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	156 DischargeTable.loadAftDischargeTables(
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	157 context, gauge.getOfficialNumber());
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	158
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	159 Map<String, DischargeTable> desc2FlysDT =
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	160 new HashMap<String, DischargeTable>();
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	161
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	162 for (DischargeTable dt: flysDTs) {
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	163 String description = dt.getDescription();
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	164 if (description == null) {
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	165 log.warn("FLYS: discharge table " + dt.getId()
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	166 + " has no description. Ignored.");
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	167 continue;
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	168 }
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	169 desc2FlysDT.put(description, dt);
4098 9215253ad0be Do the FLYS/AFT description pairing of discharge tables in case a gauge needs updates. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	170 }
4104 cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	171
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	172 List<DischargeTable> createDTs = new ArrayList<DischargeTable>();
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	173
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	174 for (DischargeTable aftDT: aftDTs) {
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	175 String description = aftDT.getDescription();
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	176 DischargeTable flysDT = desc2FlysDT.remove(description);
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	177 if (flysDT != null) {
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	178 // Found in AFT and FLYS.
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	179 log.info("FLYS: Discharge table '" + description
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	180 + "' found in AFT and FLYS. -> update");
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	181 // Create the W/Q diff.
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	182 modified \|= writeWQChanges(context, flysDT, aftDT);
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	183 }
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	184 else {
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	185 log.info("FLYS: Discharge table '" + description
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	186 + "' not found in FLYS. -> create");
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	187 createDTs.add(aftDT);
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	188 }
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	189 }
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	190
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	191 for (String description: desc2FlysDT.keySet()) {
4098 9215253ad0be Do the FLYS/AFT description pairing of discharge tables in case a gauge needs updates. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	192 log.info("FLYS: Discharge table '" + description
4104 cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	193 + "' found in FLYS but not in AFT. -> ignore");
4098 9215253ad0be Do the FLYS/AFT description pairing of discharge tables in case a gauge needs updates. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	194 }
9215253ad0be Do the FLYS/AFT description pairing of discharge tables in case a gauge needs updates. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	195
4104 cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	196 log.info("FLYS: Copy " + createDTs.size() +
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	197 " discharge tables over from AFT.");
4098 9215253ad0be Do the FLYS/AFT description pairing of discharge tables in case a gauge needs updates. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	198
4104 cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	199 // Create the new discharge tables.
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	200 for (DischargeTable aftDT: createDTs) {
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	201 createDischargeTable(context, aftDT, gauge.getFlysId());
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	202 modified = true;
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	203 }
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	204
4104 cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	205 flysStatements.commitTransaction();
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	206 }
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	207 catch (SQLException sqle) {
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	208 flysStatements.rollbackTransaction();
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	209 log.error(sqle, sqle);
cdcf98245e36 Commit/rollback changes if a gauge is only updated. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	210 modified = false;
4100 981de0b77c6b If gauges exist in FLYS and AFT store the discharge tables in FLYS that are only in AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4099 diff changeset	211 }
4097 83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	212
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	213 return modified;
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	214 }
4079 42094f01afa6 Added model for DIPS gauges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4078 diff changeset	215
4099 006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	216 protected boolean writeWQChanges(
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	217 SyncContext context,
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	218 DischargeTable flysDT,
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	219 DischargeTable aftDT
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	220 )
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	221 throws SQLException
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	222 {
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	223 flysDT.loadFlysValues(context);
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	224 aftDT.loadAftValues(context);
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	225 WQDiff diff = new WQDiff(flysDT.getValues(), aftDT.getValues());
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	226 if (diff.hasChanges()) {
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	227 diff.writeChanges(context, flysDT.getId());
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	228 return true;
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	229 }
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	230 return false;
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	231 }
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4098 diff changeset	232
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	233 protected boolean createGauges(
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	234 SyncContext context,
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	235 Map<Long, DIPSGauge> gauges
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	236 )
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	237 throws SQLException
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	238 {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	239 ConnectedStatements flysStatements = context.getFlysStatements();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	240
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	241 SymbolicStatement.Instance nextId =
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	242 flysStatements.getStatement("next.gauge.id");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	243
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	244 SymbolicStatement.Instance insertStmnt =
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	245 flysStatements.getStatement("insert.gauge");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	246
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	247 boolean modified = false;
b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	248
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	249 for (Map.Entry<Long, DIPSGauge> entry: gauges.entrySet()) {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	250 Long officialNumber = entry.getKey();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	251 DIPSGauge gauge = entry.getValue();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	252
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	253 log.info("Gauge '" + gauge.getAftName() +
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	254 "' not in FLYS but in AFT/DIPS. -> Create");
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	255
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	256 if (!gauge.hasDatums()) {
4110 06891562e633 Extracted and documented the error messages of the process. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4104 diff changeset	257 log.warn("DIPS: Gauge '" +
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	258 gauge.getAftName() + "' has no datum. Ignored.");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	259 continue;
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	260 }
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	261
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	262 ResultSet rs = null;
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	263 flysStatements.beginTransaction();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	264 try {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	265 (rs = nextId.executeQuery()).next();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	266 int gaugeId = rs.getInt("gauge_id");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	267 rs.close(); rs = null;
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	268
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	269 insertStmnt
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	270 .clearParameters()
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	271 .setInt("id", gaugeId)
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	272 .setString("name", gauge.getAftName())
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	273 .setInt("river_id", id1)
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	274 .setDouble("station", gauge.getStation())
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	275 .setDouble("aeo", gauge.getAeo())
4100 981de0b77c6b If gauges exist in FLYS and AFT store the discharge tables in FLYS that are only in AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4099 diff changeset	276 .setLong("official_number", officialNumber)
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	277 .setDouble("datum", gauge.getLatestDatum().getValue());
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	278
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	279 insertStmnt.execute();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	280
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	281 log.info("FLYS: Created gauge '" + gauge.getAftName() +
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	282 "' with id " + gaugeId + ".");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	283
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	284 gauge.setFlysId(gaugeId);
4100 981de0b77c6b If gauges exist in FLYS and AFT store the discharge tables in FLYS that are only in AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4099 diff changeset	285 createDischargeTables(context, gauge);
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	286 flysStatements.commitTransaction();
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	287 modified = true;
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	288 }
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	289 catch (SQLException sqle) {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	290 flysStatements.rollbackTransaction();
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	291 log.error(sqle, sqle);
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	292 }
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	293 finally {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	294 if (rs != null) {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	295 rs.close();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	296 }
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	297 }
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	298 }
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	299
b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	300 return modified;
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	301 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	302
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	303 protected void createDischargeTable(
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	304 SyncContext context,
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	305 DischargeTable aftDT,
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	306 int flysGaugeId
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	307 )
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	308 throws SQLException
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	309 {
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	310 aftDT.persistFlysTimeInterval(context);
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	311 int flysId = aftDT.persistFlysDischargeTable(context, flysGaugeId);
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	312
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	313 aftDT.loadAftValues(context);
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	314 aftDT.storeFlysValues(context, flysId);
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	315 }
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	316
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	317 protected void createDischargeTables(
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	318 SyncContext context,
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	319 DIPSGauge gauge
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	320 )
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	321 throws SQLException
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	322 {
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	323 log.info("FLYS: Create discharge tables for '" +
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	324 gauge.getAftName() + "'.");
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	325
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	326 // Load the discharge tables from AFT.
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	327 List<DischargeTable> dts = loadAftDischargeTables(
4100 981de0b77c6b If gauges exist in FLYS and AFT store the discharge tables in FLYS that are only in AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4099 diff changeset	328 context, gauge);
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	329
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	330 // Persist the time intervals.
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	331 persistFlysTimeIntervals(context, dts);
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	332
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	333 // Persist the discharge tables
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	334 int [] flysDTIds = persistFlysDischargeTables(
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	335 context, dts, gauge.getFlysId());
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	336
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	337 // Copy over the W/Q values
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	338 copyWQsFromAftToFlys(context, dts, flysDTIds);
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	339 }
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	340
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	341 protected List<DischargeTable> loadAftDischargeTables(
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	342 SyncContext context,
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	343 DIPSGauge gauge
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	344 )
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	345 throws SQLException
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	346 {
4097 83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4094 diff changeset	347 return DischargeTable.loadAftDischargeTables(
4100 981de0b77c6b If gauges exist in FLYS and AFT store the discharge tables in FLYS that are only in AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4099 diff changeset	348 context, gauge.getOfficialNumber(), gauge.getFlysId());
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	349 }
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	350
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	351 protected void persistFlysTimeIntervals(
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	352 SyncContext context,
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	353 List<DischargeTable> dts
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	354 )
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	355 throws SQLException
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	356 {
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	357 for (DischargeTable dt: dts) {
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	358 dt.persistFlysTimeInterval(context);
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	359 }
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	360 }
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	361
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	362 protected int [] persistFlysDischargeTables(
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	363 SyncContext context,
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	364 List<DischargeTable> dts,
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	365 int flysGaugeId
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	366 )
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	367 throws SQLException
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	368 {
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	369 boolean debug = log.isDebugEnabled();
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	370
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	371 int [] flysDTIds = new int[dts.size()];
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	372
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	373 for (int i = 0; i < flysDTIds.length; ++i) {
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	374 flysDTIds[i] = dts.get(i)
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4100 diff changeset	375 .persistFlysDischargeTable(context, flysGaugeId);
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	376 }
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	377
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	378 return flysDTIds;
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	379 }
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	380
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	381 protected void copyWQsFromAftToFlys(
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	382 SyncContext context,
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	383 List<DischargeTable> dts,
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	384 int [] flysDTIds
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	385 )
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	386 throws SQLException
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	387 {
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	388 for (int i = 0; i < flysDTIds.length; ++i) {
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	389 DischargeTable dt = dts.get(i);
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	390 dt.loadAftValues(context);
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	391 dt.storeFlysValues(context, flysDTIds[i]);
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	392 dt.clearValues(); // To save memory.
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	393 }
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	394 }
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	395
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	396 public String toString() {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	397 return "[River: name=" + name + ", " + super.toString() + "]";
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	398 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	399 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	400 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :

Mercurial > dive4elements > river

annotate flys-aft/src/main/java/de/intevation/aft/River.java @ 4197:810db532803a