Mercurial > dive4elements > river
annotate flys-backend/src/main/java/de/intevation/flys/importer/ImportFlowVelocityMeasurement.java @ 5433:df32d7518f55
Expose function dc:has-result to Function Resolver.
author | Sascha L. Teichmann <teichmann@intevation.de> |
---|---|
date | Tue, 26 Mar 2013 16:29:12 +0100 |
parents | 4ee97d914501 |
children | 3bd786772798 |
rev | line source |
---|---|
2831
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
1 package de.intevation.flys.importer; |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
2 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
3 import java.sql.SQLException; |
2832
ac5bd90697c1
Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2831
diff
changeset
|
4 import java.util.ArrayList; |
2831
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
5 import java.util.List; |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
6 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
7 import org.apache.log4j.Logger; |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
8 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
9 import org.hibernate.Session; |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
10 import org.hibernate.Query; |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
11 import org.hibernate.exception.ConstraintViolationException; |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
12 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
13 import de.intevation.flys.model.FlowVelocityMeasurement; |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
14 import de.intevation.flys.model.River; |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
15 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
16 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
17 public class ImportFlowVelocityMeasurement { |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
18 |
3943
a5b003595d6c
Store minfo values into database only if their peer has been successfully stored.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2832
diff
changeset
|
19 private static final Logger log = Logger |
a5b003595d6c
Store minfo values into database only if their peer has been successfully stored.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2832
diff
changeset
|
20 .getLogger(ImportFlowVelocityMeasurement.class); |
2831
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
21 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
22 private String description; |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
23 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
24 private List<ImportFlowVelocityMeasurementValue> values; |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
25 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
26 private FlowVelocityMeasurement peer; |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
27 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
28 public ImportFlowVelocityMeasurement() { |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
29 this(null); |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
30 } |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
31 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
32 public ImportFlowVelocityMeasurement(String description) { |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
33 this.description = description; |
3943
a5b003595d6c
Store minfo values into database only if their peer has been successfully stored.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2832
diff
changeset
|
34 this.values = new ArrayList<ImportFlowVelocityMeasurementValue>(); |
2832
ac5bd90697c1
Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2831
diff
changeset
|
35 } |
ac5bd90697c1
Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2831
diff
changeset
|
36 |
ac5bd90697c1
Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2831
diff
changeset
|
37 public void setDescription(String description) { |
ac5bd90697c1
Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2831
diff
changeset
|
38 this.description = description; |
ac5bd90697c1
Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2831
diff
changeset
|
39 } |
ac5bd90697c1
Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2831
diff
changeset
|
40 |
ac5bd90697c1
Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2831
diff
changeset
|
41 public void addValue(ImportFlowVelocityMeasurementValue value) { |
ac5bd90697c1
Added new parser for flow velocity measurements and fixed some smaller bugs while importing flow velocity data.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2831
diff
changeset
|
42 this.values.add(value); |
2831
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
43 } |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
44 |
5416
4ee97d914501
Morpho-Importer: Do not mask database exceptions as broken files
Tom Gottfried <tom.gottfried@intevation.de>
parents:
3943
diff
changeset
|
45 public void storeDependencies(River river) { |
2831
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
46 log.debug("store dependencies"); |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
47 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
48 FlowVelocityMeasurement peer = getPeer(river); |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
49 |
3943
a5b003595d6c
Store minfo values into database only if their peer has been successfully stored.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2832
diff
changeset
|
50 if (peer != null) { |
a5b003595d6c
Store minfo values into database only if their peer has been successfully stored.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2832
diff
changeset
|
51 for (ImportFlowVelocityMeasurementValue value : values) { |
a5b003595d6c
Store minfo values into database only if their peer has been successfully stored.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2832
diff
changeset
|
52 value.storeDependencies(peer); |
a5b003595d6c
Store minfo values into database only if their peer has been successfully stored.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2832
diff
changeset
|
53 } |
2831
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
54 } |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
55 } |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
56 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
57 public FlowVelocityMeasurement getPeer(River river) { |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
58 if (peer == null) { |
3943
a5b003595d6c
Store minfo values into database only if their peer has been successfully stored.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2832
diff
changeset
|
59 Session session = ImporterSession.getInstance() |
a5b003595d6c
Store minfo values into database only if their peer has been successfully stored.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2832
diff
changeset
|
60 .getDatabaseSession(); |
2831
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
61 |
3943
a5b003595d6c
Store minfo values into database only if their peer has been successfully stored.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2832
diff
changeset
|
62 Query query = session |
a5b003595d6c
Store minfo values into database only if their peer has been successfully stored.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2832
diff
changeset
|
63 .createQuery("from FlowVelocityMeasurement where " |
a5b003595d6c
Store minfo values into database only if their peer has been successfully stored.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
2832
diff
changeset
|
64 + " river=:river and " + " description=:description"); |
2831
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
65 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
66 query.setParameter("river", river); |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
67 query.setParameter("description", description); |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
68 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
69 List<FlowVelocityMeasurement> measurement = query.list(); |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
70 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
71 if (measurement.isEmpty()) { |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
72 peer = new FlowVelocityMeasurement(river, description); |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
73 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
74 session.save(peer); |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
75 } |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
76 else { |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
77 peer = measurement.get(0); |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
78 } |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
79 } |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
80 |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
81 return peer; |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
82 } |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
83 } |
8fe9c6584b93
Added importer classes used during the import process of flow velocity measurements.
Ingo Weinzierl <ingo.weinzierl@intevation.de>
parents:
diff
changeset
|
84 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 : |