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

annotate flys-aft/src/main/java/de/intevation/aft/River.java @ 4094:b20b710aa86f

Bubble up modifications up to main(). flys-aft/trunk@3605 c6561f87-3c4e-4783-a992-168aeb5c3f6f

author	Sascha L. Teichmann <sascha.teichmann@intevation.de>
date	Thu, 05 Jan 2012 18:58:49 +0000
parents	7bddd4601707
children	83c72bc07591

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;
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	7 import java.util.Date;
4078 0944cdd2ee90 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4077 diff changeset	8
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	9 import java.sql.ResultSet;
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	10 import java.sql.SQLException;
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	11 import java.sql.Types;
4075 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 org.apache.log4j.Logger;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	14
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	15 import de.intevation.db.ConnectedStatements;
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	16 import de.intevation.db.SymbolicStatement;
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	17
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	18 public class River
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	19 extends IdPair
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 private static Logger log = Logger.getLogger(River.class);
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 protected String name;
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 public River() {
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
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	28 public River(int id1, int id2, String name) {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	29 super(id1, id2);
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	30 this.name = name;
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
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	33 public String getName() {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	34 return name;
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	35 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	36
4078 0944cdd2ee90 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4077 diff changeset	37
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	38 public boolean sync(SyncContext context) throws SQLException {
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	39 log.info("sync river: " + this);
4077 97de7a552b79 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4076 diff changeset	40
4084 9178beeb7b05 Moved DIPS gauge number -> DIPS gauge index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4083 diff changeset	41 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	42
4077 97de7a552b79 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4076 diff changeset	43 ConnectedStatements flysStatements = context.getFlysStatements();
97de7a552b79 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4076 diff changeset	44 ConnectedStatements aftStatements = context.getAftStatements();
97de7a552b79 Load DIPS XML Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4076 diff changeset	45
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	46 ResultSet messstellenRs = aftStatements
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	47 .getStatement("select.messstelle")
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	48 .clearParameters()
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	49 .setInt("GEWAESSER_NR", id2).executeQuery();
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	50
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	51 String riverName = getName();
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	52
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	53 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	54
4076 039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	55 while (messstellenRs.next()) {
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	56 String name = messstellenRs.getString("NAME");
039413d7e394 Load gauges from both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4075 diff changeset	57 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	58 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	59 if (number == null) {
7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	60 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	61 continue;
7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	62 }
7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	63 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	64 if (dipsGauge == null) {
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	65 log.warn(
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	66 "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	67 "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	68 continue;
7a7b0f0cb653 Check if AFT gauges are in DIPS, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4079 diff changeset	69 }
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	70 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	71 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	72 log.warn(
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	73 "MESSSTELLE '" + name +
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	74 "' 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	75 "'. 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	76 continue;
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	77 }
067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	78 dipsGauge.setAftName(name);
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
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	116 return modified;
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	117 }
4079 42094f01afa6 Added model for DIPS gauges. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4078 diff changeset	118
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	119 protected boolean createGauges(
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	120 SyncContext context,
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	121 Map<Long, DIPSGauge> gauges
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	122 )
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	123 throws SQLException
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	124 {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	125 ConnectedStatements flysStatements = context.getFlysStatements();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	126
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	127 SymbolicStatement.Instance nextId =
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	128 flysStatements.getStatement("next.gauge.id");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	129
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	130 SymbolicStatement.Instance insertStmnt =
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	131 flysStatements.getStatement("insert.gauge");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	132
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	133 boolean modified = false;
b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	134
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	135 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	136 Long officialNumber = entry.getKey();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	137 DIPSGauge gauge = entry.getValue();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	138
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	139 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	140 "' 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	141
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	142 if (!gauge.hasDatums()) {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	143 log.warn("FLYS: Gauge '" +
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	144 gauge.getAftName() + "' has no datum. Ignored.");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	145 continue;
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	146 }
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	147
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	148 ResultSet rs = null;
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	149 flysStatements.beginTransaction();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	150 try {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	151 (rs = nextId.executeQuery()).next();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	152 int gaugeId = rs.getInt("gauge_id");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	153 rs.close(); rs = null;
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	154
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	155 insertStmnt
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	156 .clearParameters()
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	157 .setInt("id", gaugeId)
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	158 .setString("name", gauge.getAftName())
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	159 .setInt("river_id", id1)
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	160 .setDouble("station", gauge.getStation())
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	161 .setDouble("aeo", gauge.getAeo())
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	162 .setDouble("official_number", officialNumber)
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	163 .setDouble("datum", gauge.getLatestDatum().getValue());
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	164
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	165 insertStmnt.execute();
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	166
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	167 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	168 "' with id " + gaugeId + ".");
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	169
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	170 gauge.setFlysId(gaugeId);
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	171 createDischargeTables(context, officialNumber, gauge);
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	172 flysStatements.commitTransaction();
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	173 modified = true;
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	174 }
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	175 catch (SQLException sqle) {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	176 flysStatements.rollbackTransaction();
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	177 log.error(sqle, sqle);
4087 aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	178 }
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	179 finally {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	180 if (rs != null) {
aad1886ea226 Store new gauges in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4085 diff changeset	181 rs.close();
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 }
4085 067341e86375 Separate FLYS gauges to be updated or to create. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4084 diff changeset	184 }
4094 b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	185
b20b710aa86f Bubble up modifications up to main(). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	186 return modified;
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	187 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	188
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	189 protected void createDischargeTables(
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	190 SyncContext context,
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	191 Long officialNumber,
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	192 DIPSGauge gauge
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	193 )
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	194 throws SQLException
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	195 {
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	196 log.info("create discharge tables");
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	197
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	198 // 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	199 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	200 context, officialNumber, gauge);
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	201
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	202 // 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	203 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	204
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	205 // 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	206 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	207
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	208 // 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	209 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	210 }
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	211
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	212 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	213 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	214 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	215 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	216 )
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	217 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	218 {
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	219 boolean debug = log.isDebugEnabled();
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	220
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	221 List<DischargeTable> dts = new ArrayList<DischargeTable>();
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	222
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	223 ResultSet rs = null;
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	224 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	225 rs = 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	226 .getAftStatements()
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	227 .getStatement("select.abflusstafel")
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	228 .clearParameters()
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	229 .setString("number", "%" + officialNumber).
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	230 executeQuery();
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	231
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	232 while (rs.next()) {
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	233 int dtId = rs.getInt("ABFLUSSTAFEL_NR");
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	234 Date from = rs.getDate("GUELTIG_VON");
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	235 Date to = rs.getDate("GUELTIG_BIS");
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	236 String description = rs.getString("ABFLUSSTAFEL_BEZ");
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	237 if (description == null) {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	238 description = String.valueOf(officialNumber);
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	239 }
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	240
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	241 double datumValue = rs.getDouble("PEGELNULLPUNKT");
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	242 Double datum = rs.wasNull() ? null : datumValue;
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	243
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	244 if (debug) {
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	245 log.debug("id: " + dtId);
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	246 log.debug("valid from: " + from);
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	247 log.debug("valid to: " + to);
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	248 log.debug("datum: " + datum);
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	249 log.debug("description: " + description);
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	250 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	251
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	252 TimeInterval timeInterval = from == null
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	253 ? null
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	254 : new TimeInterval(from, to);
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	255
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	256 DischargeTable dt = new DischargeTable(
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	257 dtId,
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	258 gauge.getFlysId(),
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	259 timeInterval,
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	260 description);
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	261 dts.add(dt);
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	262 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	263 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	264 finally {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	265 if (rs != null) {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	266 rs.close();
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	267 rs = null;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	268 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	269 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	270
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	271 return 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	272 }
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	273
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	274 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	275 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	276 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	277 )
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	278 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	279 {
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	280 for (DischargeTable dt: dts) {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	281 TimeInterval timeInterval = dt.getTimeInterval();
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	282 if (timeInterval != null) {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	283 dt.setTimeInterval(
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	284 context.fetchOrCreateFLYSTimeInterval(timeInterval));
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	285 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	286 }
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	287 }
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	288
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	289 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	290 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	291 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	292 )
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 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	294 {
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	295 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	296
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	297 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	298
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	299 ResultSet rs = null;
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	300 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	301 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	302 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	303
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	304 SymbolicStatement.Instance nextId =
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	305 flysStatements.getStatement("next.discharge.id");
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	306
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	307 SymbolicStatement.Instance insertDT =
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	308 flysStatements.getStatement("insert.dischargetable");
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	309
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	310 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	311 rs = nextId.executeQuery();
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	312 rs.next();
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	313 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	314 flysDTIds[i] = id;
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	315 rs.close(); rs = null;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	316
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	317 DischargeTable dt = dts.get(i);
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	318 insertDT.clearParameters()
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	319 .setInt("id", id)
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	320 .setInt("gauge_id", dt.getGaugeId())
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	321 .setString("description", dt.getDescription());
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	322
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	323 TimeInterval timeInterval = dt.getTimeInterval();
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	324 if (timeInterval != null) {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	325 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	326 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	327 else {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	328 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	329 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	330
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	331 insertDT.execute();
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	332 if (debug) {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	333 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	334 }
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	335 }
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	336 }
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	337 finally {
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	338 if (rs != null) {
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	339 rs.close();
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4088 diff changeset	340 rs = null;
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	341 }
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	342 }
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	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 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	345 }
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
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 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	348 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	349 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	350 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	351 )
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 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	353 {
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 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	355 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	356 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	357 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	358 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	359 }
4088 52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	360 }
52cde7fe742a Fetch discharge table infos from AFT. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4087 diff changeset	361
4075 dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	362 public String toString() {
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	363 return "[River: name=" + name + ", " + super.toString() + "]";
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	364 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	365
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	366 }
dbd0b3b1b8b8 Sync each river. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	367 // 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 @ 4094:b20b710aa86f