dive4elements/river: etl/src/main/java/org/dive4elements/river/etl/aft/DischargeTable.java annotate

annotate etl/src/main/java/org/dive4elements/river/etl/aft/DischargeTable.java @ 9726:0a5239a1e46e 3.2.x

Upgrade to Log4j 2

author	Tom Gottfried <tom@intevation.de>
date	Wed, 02 Mar 2022 10:26:50 +0100
parents	6f80d5f375fd
children

rev	line source
5841 8bd9b551456c Added header to Java files in ETL process. Sascha L. Teichmann <teichmann@intevation.de> parents: 5838 diff changeset	1 /* Copyright (C) 2011, 2012, 2013 by Bundesanstalt für Gewässerkunde
8bd9b551456c Added header to Java files in ETL process. Sascha L. Teichmann <teichmann@intevation.de> parents: 5838 diff changeset	2 * Software engineering by Intevation GmbH
8bd9b551456c Added header to Java files in ETL process. Sascha L. Teichmann <teichmann@intevation.de> parents: 5838 diff changeset	3 *
5991 6f80d5f375fd Removed trailing whitespace. Sascha L. Teichmann <teichmann@intevation.de> parents: 5917 diff changeset	4 * This file is Free Software under the GNU AGPL (>=v3)
5841 8bd9b551456c Added header to Java files in ETL process. Sascha L. Teichmann <teichmann@intevation.de> parents: 5838 diff changeset	5 * and comes with ABSOLUTELY NO WARRANTY! Check out the
5991 6f80d5f375fd Removed trailing whitespace. Sascha L. Teichmann <teichmann@intevation.de> parents: 5917 diff changeset	6 * documentation coming with Dive4Elements River for details.
5841 8bd9b551456c Added header to Java files in ETL process. Sascha L. Teichmann <teichmann@intevation.de> parents: 5838 diff changeset	7 */
8bd9b551456c Added header to Java files in ETL process. Sascha L. Teichmann <teichmann@intevation.de> parents: 5838 diff changeset	8
5826 9438e9259213 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 5825 diff changeset	9 package org.dive4elements.river.etl.aft;
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	10
5826 9438e9259213 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 5825 diff changeset	11 import org.dive4elements.river.etl.db.ConnectedStatements;
9438e9259213 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 5825 diff changeset	12 import org.dive4elements.river.etl.db.SymbolicStatement;
4091 a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	13
4772 f939e1e6cfa4 Sorted imports. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	14 import java.sql.ResultSet;
4091 a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	15 import java.sql.SQLException;
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	16 import java.sql.Types;
4091 a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	17
4772 f939e1e6cfa4 Sorted imports. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	18 import java.util.ArrayList;
f939e1e6cfa4 Sorted imports. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	19 import java.util.Date;
f939e1e6cfa4 Sorted imports. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	20 import java.util.List;
f939e1e6cfa4 Sorted imports. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	21 import java.util.Set;
f939e1e6cfa4 Sorted imports. Sascha L. Teichmann <teichmann@intevation.de> parents: 4736 diff changeset	22 import java.util.TreeSet;
4091 a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	23
9726 0a5239a1e46e Upgrade to Log4j 2 Tom Gottfried <tom@intevation.de> parents: 5991 diff changeset	24 import org.apache.logging.log4j.Logger;
0a5239a1e46e Upgrade to Log4j 2 Tom Gottfried <tom@intevation.de> parents: 5991 diff changeset	25 import org.apache.logging.log4j.LogManager;
4101 b6a18d706cbe Added debugging for AFT time intervals. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4099 diff changeset	26
5372 ae3625b89cfd Doc. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 4775 diff changeset	27 /** A Discharge Table. */
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	28 public class DischargeTable
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	29 {
9726 0a5239a1e46e Upgrade to Log4j 2 Tom Gottfried <tom@intevation.de> parents: 5991 diff changeset	30 private static Logger log = LogManager.getLogger(DischargeTable.class);
4101 b6a18d706cbe Added debugging for AFT time intervals. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4099 diff changeset	31
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	32 protected int id;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	33 protected int gaugeId;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	34 protected TimeInterval timeInterval;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	35 protected String description;
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	36 protected String bfgId;
4103 2305731f563c Store W/Q in sets to prevent value duplications. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	37 protected Set<WQ> values;
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	38
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	39 public DischargeTable() {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	40 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	41
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	42 public DischargeTable(
4736 b195fede1c3b Remove trailing whitespace. Sascha L. Teichmann <teichmann@intevation.de> parents: 4477 diff changeset	43 int gaugeId,
b195fede1c3b Remove trailing whitespace. Sascha L. Teichmann <teichmann@intevation.de> parents: 4477 diff changeset	44 TimeInterval timeInterval,
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	45 String description,
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	46 String bfgId
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	47 ) {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	48 this.gaugeId = gaugeId;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	49 this.timeInterval = timeInterval;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	50 this.description = description;
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	51 this.bfgId = bfgId;
4103 2305731f563c Store W/Q in sets to prevent value duplications. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	52 values = new TreeSet<WQ>(WQ.EPS_CMP);
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	53 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	54
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	55 public DischargeTable(
4736 b195fede1c3b Remove trailing whitespace. Sascha L. Teichmann <teichmann@intevation.de> parents: 4477 diff changeset	56 int id,
b195fede1c3b Remove trailing whitespace. Sascha L. Teichmann <teichmann@intevation.de> parents: 4477 diff changeset	57 int gaugeId,
b195fede1c3b Remove trailing whitespace. Sascha L. Teichmann <teichmann@intevation.de> parents: 4477 diff changeset	58 TimeInterval timeInterval,
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	59 String description,
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	60 String bfgId
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	61 ) {
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	62 this(gaugeId, timeInterval, description, bfgId);
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	63 this.id = id;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	64 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	65
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	66 public int getId() {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	67 return id;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	68 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	69
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	70 public void setId(int id) {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	71 this.id = id;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	72 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	73
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	74 public int getGaugeId() {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	75 return gaugeId;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	76 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	77
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	78 public void setGaugeId(int gaugeId) {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	79 this.gaugeId = gaugeId;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	80 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	81
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	82 public TimeInterval getTimeInterval() {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	83 return timeInterval;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	84 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	85
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	86 public void setTimeInterval(TimeInterval timeInterval) {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	87 this.timeInterval = timeInterval;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	88 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	89
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	90 public String getDescription() {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	91 return description;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	92 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	93
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	94 public void setDescription(String description) {
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	95 this.description = description;
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	96 }
4091 a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	97
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	98 public String getBfgId() {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	99 return bfgId;
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	100 }
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	101
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	102 public void setBfgId(String bfgId) {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	103 this.bfgId = bfgId;
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	104 }
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	105
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	106
4093 7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4092 diff changeset	107 public void clearValues() {
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4092 diff changeset	108 values.clear();
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4092 diff changeset	109 }
7bddd4601707 Copy over W/Q values from AFT to FLYS for new discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4092 diff changeset	110
4103 2305731f563c Store W/Q in sets to prevent value duplications. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	111 public Set<WQ> getValues() {
4099 006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	112 return values;
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	113 }
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	114
4103 2305731f563c Store W/Q in sets to prevent value duplications. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	115 public void setValues(Set<WQ> values) {
4099 006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	116 this.values = values;
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	117 }
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	118
006e99437fb9 Store the W/Q differences o existing discharge tables to FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4097 diff changeset	119
4736 b195fede1c3b Remove trailing whitespace. Sascha L. Teichmann <teichmann@intevation.de> parents: 4477 diff changeset	120 protected void loadValues(SymbolicStatement.Instance query)
4091 a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	121 throws SQLException
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	122 {
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	123 ResultSet rs = query.executeQuery();
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	124 while (rs.next()) {
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	125 int id = rs.getInt("id");
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	126 double w = rs.getDouble("w");
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	127 double q = rs.getDouble("q");
4103 2305731f563c Store W/Q in sets to prevent value duplications. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	128 if (!values.add(new WQ(id, w, q))) {
4110 06891562e633 Extracted and documented the error messages of the process. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4105 diff changeset	129 log.warn("FLYS/AFT: Value duplication w="+w+" q="+q+". -> ignore.");
4103 2305731f563c Store W/Q in sets to prevent value duplications. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	130 }
4091 a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	131 }
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	132 rs.close();
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	133 }
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	134
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	135 public void loadAftValues(SyncContext context) throws SQLException {
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	136 loadValues(context.getAftStatements()
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	137 .getStatement("select.tafelwert")
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	138 .clearParameters()
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	139 .setInt("number", getId()));
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	140 }
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	141
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	142 public void loadFlysValues(SyncContext context) throws SQLException {
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	143 loadValues(context.getFlysStatements()
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	144 .getStatement("select.discharge.table.values")
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	145 .clearParameters()
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	146 .setInt("table_id", getId()));
a91c7e982c32 Make W/Q values from AFT and FLYS loadable. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4090 diff changeset	147 }
4092 b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	148
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	149 public void storeFlysValues(
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	150 SyncContext context,
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	151 int dischargeTableId
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	152 )
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	153 throws SQLException
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	154 {
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	155 ConnectedStatements flysStatements = context.getFlysStatements();
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	156
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	157 // Create the ids.
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	158 SymbolicStatement.Instance nextId = flysStatements
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	159 .getStatement("next.discharge.table.values.id");
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	160
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	161 // Insert the values.
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	162 SymbolicStatement.Instance insertDTV = flysStatements
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	163 .getStatement("insert.discharge.table.value");
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	164
4103 2305731f563c Store W/Q in sets to prevent value duplications. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	165 for (WQ wq: values) {
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	166 int wqId;
4103 2305731f563c Store W/Q in sets to prevent value duplications. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	167 ResultSet rs = nextId.executeQuery();
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	168 try {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	169 rs.next();
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	170 wqId = rs.getInt("discharge_table_values_id");
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	171 }
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	172 finally {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	173 rs.close();
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	174 }
4103 2305731f563c Store W/Q in sets to prevent value duplications. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	175
4092 b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	176 insertDTV
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	177 .clearParameters()
4103 2305731f563c Store W/Q in sets to prevent value duplications. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4102 diff changeset	178 .setInt("id", wqId)
4092 b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	179 .setInt("table_id", dischargeTableId)
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	180 .setDouble("w", wq.getW())
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	181 .setDouble("q", wq.getQ())
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	182 .execute();
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	183 }
b3fc044f75ba Added code to store W/Q values into FLYS database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4091 diff changeset	184 }
4097 83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	185
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	186 public static List<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: 4093 diff changeset	187 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: 4093 diff changeset	188 int gaugeId
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	189 )
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	190 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: 4093 diff changeset	191 {
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	192 List<DischargeTable> dts = new ArrayList<DischargeTable>();
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	193
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	194 ResultSet rs = context
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	195 .getFlysStatements()
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	196 .getStatement("select.gauge.discharge.tables")
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	197 .clearParameters()
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	198 .setInt("gauge_id", gaugeId)
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	199 .executeQuery();
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	200 try {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	201 OUTER: while (rs.next()) {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	202 int id = rs.getInt("id");
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	203 String description = rs.getString("description");
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	204 String bfgId = rs.getString("bfg_id");
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	205 if (description == null) {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	206 description = "";
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	207 }
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	208 if (bfgId == null) {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	209 bfgId = "";
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	210 }
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	211 for (DischargeTable dt: dts) {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	212 if (dt.getBfgId().equals(bfgId)) {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	213 log.warn("FLYS: Found discharge table '" +
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	214 bfgId + "' with same bfg_id. -> ignore");
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	215 continue OUTER;
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	216 }
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	217 }
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	218 Date startTime = rs.getDate("start_time");
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	219 Date stopTime = rs.getDate("stop_time");
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	220 TimeInterval ti = startTime == null
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	221 ? null
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	222 : new TimeInterval(startTime, stopTime);
4097 83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	223
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	224 DischargeTable dt = new DischargeTable(
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	225 id, gaugeId, ti, description, bfgId);
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	226 dts.add(dt);
4105 309d4ca09816 Prevent redundant and ever growing discharge table lists in FLYS db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4103 diff changeset	227 }
4097 83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	228 }
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	229 finally {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	230 rs.close();
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	231 }
4097 83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	232
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	233 return dts;
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	234 }
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	235
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	236 public static List<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: 4093 diff changeset	237 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: 4093 diff changeset	238 Long officialNumber
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	239 )
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	240 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: 4093 diff changeset	241 {
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	242 return loadAftDischargeTables(context, officialNumber, 0);
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	243 }
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	244
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	245 public static List<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: 4093 diff changeset	246 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: 4093 diff changeset	247 Long officialNumber,
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	248 int flysGaugeId
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	249 )
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	250 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: 4093 diff changeset	251 {
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	252 List<DischargeTable> dts = new ArrayList<DischargeTable>();
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	253
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	254 ResultSet rs = context
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	255 .getAftStatements()
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	256 .getStatement("select.abflusstafel")
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	257 .clearParameters()
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	258 .setString("number", "%" + officialNumber)
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	259 .executeQuery();
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	260 try {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	261 OUTER: while (rs.next()) {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	262 int dtId = rs.getInt("ABFLUSSTAFEL_NR");
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	263 Date from = rs.getDate("GUELTIG_VON");
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	264 Date to = rs.getDate("GUELTIG_BIS");
4101 b6a18d706cbe Added debugging for AFT time intervals. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4099 diff changeset	265
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	266 if (from == null) {
4736 b195fede1c3b Remove trailing whitespace. Sascha L. Teichmann <teichmann@intevation.de> parents: 4477 diff changeset	267 log.warn("AFT: ABFLUSSTAFEL_NR = "
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	268 + dtId + ": GUELTIG_VON = NULL -> ignored.");
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	269 continue;
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	270 }
4097 83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	271
5917 c73977be1795 ETL: Do not ignore open ended discharge tables. Sascha L. Teichmann <teichmann@intevation.de> parents: 5841 diff changeset	272 if (to != null && from.after(to)) {
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	273 log.warn("AFT: ABFLUSSTAFEL_NR = "
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	274 + dtId + ": " + from + " > " + to + ". -> swap");
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	275 Date temp = from;
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	276 from = to;
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	277 to = temp;
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	278 }
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	279
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	280 String description = rs.getString("ABFLUSSTAFEL_BEZ");
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	281 if (description == null) {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	282 description = String.valueOf(officialNumber);
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	283 }
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	284
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	285 String bfgId = rs.getString("BFG_ID");
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	286 if (bfgId == null) {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	287 bfgId = "";
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	288 }
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	289
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	290 for (DischargeTable dt: dts) {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	291 if (dt.getBfgId().equals(bfgId)) {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	292 log.warn("AFT: Found discharge table '" +
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	293 bfgId + "' with same bfg_id. -> ignore.");
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	294 continue OUTER;
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	295 }
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	296 }
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	297
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	298 TimeInterval timeInterval = new TimeInterval(from, to);
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	299
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	300 DischargeTable dt = new DischargeTable(
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	301 dtId,
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	302 flysGaugeId,
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	303 timeInterval,
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	304 description,
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	305 bfgId);
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	306 dts.add(dt);
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	307 }
4097 83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	308 }
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	309 finally {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	310 rs.close();
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	311 }
4097 83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	312
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	313 return dts;
83c72bc07591 Load all discharge tables from AFT and FLYS of a gauge which needs updating. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4093 diff changeset	314 }
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	315
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	316 public void persistFlysTimeInterval(
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	317 SyncContext context
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	318 )
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	319 throws SQLException
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	320 {
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	321 if (timeInterval != null) {
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	322 timeInterval = context.fetchOrCreateFLYSTimeInterval(
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	323 timeInterval);
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	324 }
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	325 }
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	326
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	327 public int persistFlysDischargeTable(
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	328 SyncContext context,
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	329 int gaugeId
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	330 )
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	331 throws SQLException
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	332 {
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	333 ConnectedStatements flysStatements =
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	334 context.getFlysStatements();
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	335
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	336 int flysId;
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	337
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	338 ResultSet rs = flysStatements
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	339 .getStatement("next.discharge.id")
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	340 .executeQuery();
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	341 try {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	342 rs.next();
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	343 flysId = rs.getInt("discharge_table_id");
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	344 }
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	345 finally {
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	346 rs.close();
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	347 }
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	348
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	349 SymbolicStatement.Instance insertDT = flysStatements
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	350 .getStatement("insert.dischargetable")
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	351 .clearParameters()
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	352 .setInt("id", flysId)
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	353 .setInt("gauge_id", gaugeId)
4775 d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	354 .setString("description", description)
d9f1202cef78 Do the pairing of FLYS and AFT discharge tables by the field 'ABFLUSSTAFEL.BFG_ID' in Sascha L. Teichmann <teichmann@intevation.de> parents: 4772 diff changeset	355 .setString("bfg_id", bfgId);
4102 e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	356
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	357 if (timeInterval != null) {
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	358 insertDT.setInt("time_interval_id", timeInterval.getId());
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	359 }
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	360 else {
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	361 insertDT.setNull("time_interval_id", Types.INTEGER);
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	362 }
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	363
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	364 insertDT.execute();
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	365
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	366 if (log.isDebugEnabled()) {
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	367 log.debug("FLYS: Created discharge table id: " + id);
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	368 }
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	369
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	370 return flysId;
e8967ee1cb05 Fixed logic bug when writing discharge tables of an gauge existing in both dbs. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 4101 diff changeset	371 }
4090 d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	372 }
d556e29592f5 Create new discharge tables if needed. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	373 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :

Mercurial > dive4elements > river

annotate etl/src/main/java/org/dive4elements/river/etl/aft/DischargeTable.java @ 9726:0a5239a1e46e 3.2.x