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

annotate flys-aft/src/main/java/de/intevation/aft/River.java @ 4097:83c72bc07591

Load all discharge tables from AFT and FLYS of a gauge which needs updating. flys-aft/trunk@3618 c6561f87-3c4e-4783-a992-168aeb5c3f6f

author	Sascha L. Teichmann <sascha.teichmann@intevation.de>
date	Fri, 06 Jan 2012 18:32:08 +0000
parents	b20b710aa86f
children	9215253ad0be

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;
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	10 import java.sql.Types;
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	11
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	12 import org.apache.log4j.Logger;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	13
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	14 import de.intevation.db.ConnectedStatements;
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	15 import de.intevation.db.SymbolicStatement;
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	16
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	17 public class River
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	18 extends IdPair
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	19 {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	20 private static Logger log = Logger.getLogger(River.class);
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	21
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	22 protected String name;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	23
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	24 public River() {
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
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	27 public River(int id1, int id2, String name) {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	28 super(id1, id2);
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	29 this.name = name;
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
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	32 public String getName() {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	33 return name;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	34 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	35
4078 0944cdd2ee90 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4077 diff changeset	36
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	37 public boolean sync(SyncContext context) throws SQLException {
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	38 log.info("sync river: " + this);
4077 97de7a552b79 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4076 diff changeset	39
4084 9178beeb7b05 Moved DIPS gauge number -> DIPS gauge index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4083 diff changeset	40 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	41
4077 97de7a552b79 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4076 diff changeset	42 ConnectedStatements flysStatements = context.getFlysStatements();
97de7a552b79 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4076 diff changeset	43 ConnectedStatements aftStatements = context.getAftStatements();
97de7a552b79 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4076 diff changeset	44
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	45 ResultSet messstellenRs = aftStatements
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	46 .getStatement("select.messstelle")
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	47 .clearParameters()
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	48 .setInt("GEWAESSER_NR", id2).executeQuery();
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	49
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	50 String riverName = getName();
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	51
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	52 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	53
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	54 while (messstellenRs.next()) {
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	55 String name = messstellenRs.getString("NAME");
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	56 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	57 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	58 if (number == null) {
7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	59 log.warn("Invalid MESSSTELLE_NR for MESSSTELLE '"+name+"'");
7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	60 continue;
7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	61 }
7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	62 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	63 if (dipsGauge == null) {
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	64 log.warn(
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	65 "MESSSTELLE '" + name + "' not found in DIPS. " +
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	66 "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	67 continue;
7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	68 }
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	69 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	70 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	71 log.warn(
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	72 "MESSSTELLE '" + name +
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	73 "' 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	74 "'. 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	75 continue;
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	76 }
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	77 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	78 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	79 aftDIPSGauges.put(number, dipsGauge);
4076 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
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	82 messstellenRs.close();
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	83
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	84 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	85
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	86 ResultSet gaugesRs = flysStatements
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	87 .getStatement("select.gauges")
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	88 .clearParameters()
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	89 .setInt("river_id", id1).executeQuery();
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	90
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	91 while (gaugesRs.next()) {
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	92 int gaugeId = gaugesRs.getInt("id");
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	93 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	94 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	95 if (gaugesRs.wasNull()) {
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	96 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	97 "' 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	98 continue;
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	99 }
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	100 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	101 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	102 if (aftDIPSGauge == null) {
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	103 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	104 " 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	105 continue;
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	106 }
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	107 aftDIPSGauge.setFlysId(gaugeId);
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	108 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	109 "' 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	110 updateGauges.add(aftDIPSGauge);
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	111 }
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	112 gaugesRs.close();
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	113
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	114 boolean modified = createGauges(context, aftDIPSGauges);
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	115
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	116 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	117
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 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	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
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 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	122 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	123 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	124 )
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 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	126 {
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 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	128
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 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	130 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	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
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 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	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
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 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	137 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	138 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	139 )
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 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	141 {
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
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	147 List<DischargeTable> flysDTs =
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	148 DischargeTable.loadFlysDischargeTables(
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	149 context, gauge.getFlysId());
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	150
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	151 List<DischargeTable> aftDTs =
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	152 DischargeTable.loadAftDischargeTables(
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	153 context, gauge.getOfficialNumber());
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	154
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	155 // TODO: Do pairing
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	156
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	157 return modified;
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	158 }
4079 42094f01afa6 Added model for DIPS gauges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4078 diff changeset	159
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	160 protected boolean createGauges(
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	161 SyncContext context,
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	162 Map<Long, DIPSGauge> gauges
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	163 )
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	164 throws SQLException
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	165 {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	166 ConnectedStatements flysStatements = context.getFlysStatements();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	167
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	168 SymbolicStatement.Instance nextId =
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	169 flysStatements.getStatement("next.gauge.id");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	170
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	171 SymbolicStatement.Instance insertStmnt =
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	172 flysStatements.getStatement("insert.gauge");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	173
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	174 boolean modified = false;
b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	175
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	176 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	177 Long officialNumber = entry.getKey();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	178 DIPSGauge gauge = entry.getValue();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	179
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	180 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	181 "' 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	182
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	183 if (!gauge.hasDatums()) {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	184 log.warn("FLYS: Gauge '" +
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	185 gauge.getAftName() + "' has no datum. Ignored.");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	186 continue;
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	187 }
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	188
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	189 ResultSet rs = null;
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	190 flysStatements.beginTransaction();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	191 try {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	192 (rs = nextId.executeQuery()).next();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	193 int gaugeId = rs.getInt("gauge_id");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	194 rs.close(); rs = null;
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	195
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	196 insertStmnt
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	197 .clearParameters()
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	198 .setInt("id", gaugeId)
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	199 .setString("name", gauge.getAftName())
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	200 .setInt("river_id", id1)
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	201 .setDouble("station", gauge.getStation())
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	202 .setDouble("aeo", gauge.getAeo())
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	203 .setDouble("official_number", officialNumber)
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	204 .setDouble("datum", gauge.getLatestDatum().getValue());
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	205
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	206 insertStmnt.execute();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	207
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	208 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	209 "' with id " + gaugeId + ".");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	210
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	211 gauge.setFlysId(gaugeId);
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	212 createDischargeTables(context, officialNumber, gauge);
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	213 flysStatements.commitTransaction();
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	214 modified = true;
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	215 }
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	216 catch (SQLException sqle) {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	217 flysStatements.rollbackTransaction();
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	218 log.error(sqle, sqle);
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	219 }
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	220 finally {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	221 if (rs != null) {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	222 rs.close();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	223 }
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	224 }
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	225 }
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	226
b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	227 return modified;
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	228 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	229
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	230 protected void createDischargeTables(
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	231 SyncContext context,
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	232 Long officialNumber,
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	233 DIPSGauge gauge
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	234 )
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	235 throws SQLException
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	236 {
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	237 log.info("create discharge tables");
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	238
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	239 // 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	240 List<DischargeTable> dts = 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	241 context, officialNumber, gauge);
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	242
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	243 // 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	244 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	245
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	246 // Persist the discharge tables
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	247 int [] flysDTIds = persistFlysDischargeTables(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	248
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	249 // 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	250 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	251 }
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	252
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	253 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	254 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	255 Long officialNumber,
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	256 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	257 )
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	258 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	259 {
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	260 return DischargeTable.loadAftDischargeTables(
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	261 context, officialNumber, 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	262 }
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	263
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	264 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	265 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	266 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	267 )
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	268 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	269 {
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	270 for (DischargeTable dt: dts) {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	271 TimeInterval timeInterval = dt.getTimeInterval();
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	272 if (timeInterval != null) {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	273 dt.setTimeInterval(
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	274 context.fetchOrCreateFLYSTimeInterval(timeInterval));
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	275 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	276 }
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	277 }
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	278
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	279 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	280 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	281 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	282 )
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	283 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	284 {
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	285 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	286
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	287 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	288
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	289 ResultSet rs = null;
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	290 try {
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	291 ConnectedStatements flysStatements =
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	292 context.getFlysStatements();
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	293
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	294 SymbolicStatement.Instance nextId =
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	295 flysStatements.getStatement("next.discharge.id");
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	296
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	297 SymbolicStatement.Instance insertDT =
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	298 flysStatements.getStatement("insert.dischargetable");
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	299
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	300 for (int i = 0; i < flysDTIds.length; ++i) {
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	301 rs = nextId.executeQuery();
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	302 rs.next();
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	303 int id = rs.getInt("discharge_table_id");
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	304 flysDTIds[i] = id;
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	305 rs.close(); rs = null;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	306
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	307 DischargeTable dt = dts.get(i);
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	308 insertDT.clearParameters()
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	309 .setInt("id", id)
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	310 .setInt("gauge_id", dt.getGaugeId())
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	311 .setString("description", dt.getDescription());
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	312
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	313 TimeInterval timeInterval = dt.getTimeInterval();
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	314 if (timeInterval != null) {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	315 insertDT.setInt("time_interval_id", timeInterval.getId());
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	316 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	317 else {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	318 insertDT.setNull("time_interval_id", Types.INTEGER);
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	319 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	320
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	321 insertDT.execute();
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	322 if (debug) {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	323 log.debug("FLYS: Created discharge table id: " + id);
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	324 }
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	325 }
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	326 }
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	327 finally {
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	328 if (rs != null) {
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	329 rs.close();
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	330 rs = null;
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	331 }
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	332 }
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	333
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	334 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	335 }
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 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	338 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	339 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	340 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	341 )
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 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	343 {
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 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	345 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	346 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	347 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	348 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	349 }
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	350 }
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	351
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	352 public String toString() {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	353 return "[River: name=" + name + ", " + super.toString() + "]";
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	354 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	355
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	356 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	357 // 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 @ 4097:83c72bc07591