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

annotate flys-aft/src/main/java/de/intevation/aft/WQDiff.java @ 4241:49cb65d5932d

Improved the historical discharge calculation. The calculation now creates new HistoricalWQKms (new subclass of WQKms). Those WQKms are used to create new facets from (new) type 'HistoricalDischargeCurveFacet'. The chart generator is improved to support those facets.

author	Ingo Weinzierl <ingo.weinzierl@intevation.de>
date	Wed, 24 Oct 2012 14:34:35 +0200
parents	82f5266f881b
children	b195fede1c3b

rev	line source
4096 82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	1 package de.intevation.aft;
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	2
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	3 import java.util.Collection;
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	4 import java.util.Set;
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	5 import java.util.TreeSet;
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	6 import java.util.Iterator;
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	7
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	8 import java.sql.ResultSet;
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	9 import java.sql.SQLException;
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	10
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	11 import de.intevation.db.ConnectedStatements;
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	12 import de.intevation.db.SymbolicStatement;
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	13
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	14 public class WQDiff
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	15 {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	16 protected Set<WQ> toAdd;
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	17 protected Set<WQ> toDelete;
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	18
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	19 public WQDiff() {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	20 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	21
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	22 public WQDiff(Collection<WQ> a, Collection<WQ> b) {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	23 toAdd = new TreeSet<WQ>(WQ.EPS_CMP);
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	24 toDelete = new TreeSet<WQ>(WQ.EPS_CMP);
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	25 build(a, b);
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	26 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	27
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	28 public void build(Collection<WQ> a, Collection<WQ> b) {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	29 toAdd.addAll(b);
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	30 toAdd.removeAll(a);
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	31
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	32 toDelete.addAll(a);
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	33 toDelete.removeAll(b);
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	34 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	35
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	36 public void clear() {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	37 toAdd.clear();
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	38 toDelete.clear();
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	39 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	40
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	41 public Set<WQ> getToAdd() {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	42 return toAdd;
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	43 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	44
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	45 public void setToAdd(Set<WQ> toAdd) {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	46 this.toAdd = toAdd;
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	47 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	48
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	49 public Set<WQ> getToDelete() {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	50 return toDelete;
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	51 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	52
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	53 public void setToDelete(Set<WQ> toDelete) {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	54 this.toDelete = toDelete;
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	55 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	56
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	57 public boolean hasChanges() {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	58 return !(toAdd.isEmpty() && toDelete.isEmpty());
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	59 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	60
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	61 public void writeChanges(
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	62 SyncContext context,
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	63 int tableId
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	64 )
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	65 throws SQLException
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	66 {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	67 ConnectedStatements flysStatements = context.getFlysStatements();
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	68
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	69 // Delete the old entries
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	70 if (!toDelete.isEmpty()) {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	71 SymbolicStatement.Instance deleteDTV =
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	72 flysStatements.getStatement("delete.discharge.table.value");
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	73 for (WQ wq: toDelete) {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	74 deleteDTV
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	75 .clearParameters()
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	76 .setInt("id", wq.getId())
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	77 .execute();
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	78 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	79 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	80
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	81 // Add the new entries.
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	82 if (!toAdd.isEmpty()) {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	83 SymbolicStatement.Instance nextId =
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	84 flysStatements.getStatement("next.discharge.table.values.id");
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	85
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	86 SymbolicStatement.Instance insertDTV =
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	87 flysStatements.getStatement("insert.discharge.table.value");
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	88
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	89 // Recycle old ids as much as possible.
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	90 Iterator<WQ> oldIds = toDelete.iterator();
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	91
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	92 // Create ids for new entries.
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	93 for (WQ wq: toAdd) {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	94 if (oldIds.hasNext()) {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	95 wq.setId(oldIds.next().getId());
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	96 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	97 else {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	98 ResultSet rs = nextId.executeQuery();
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	99 rs.next();
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	100 wq.setId(rs.getInt("discharge_table_values_id"));
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	101 rs.close();
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	102 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	103 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	104
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	105 // Write the new entries.
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	106 for (WQ wq: toAdd) {
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	107 insertDTV
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	108 .clearParameters()
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	109 .setInt("id", wq.getId())
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	110 .setInt("table_id", tableId)
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	111 .setDouble("w", wq.getW())
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	112 .setDouble("q", wq.getQ())
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	113 .execute();
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	114 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	115 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	116 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	117 }
82f5266f881b Add code to build the difference of the W/Q values of two discharge tables. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	118 // 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/WQDiff.java @ 4241:49cb65d5932d