dive4elements/river: artifacts/src/main/java/org/dive4elements/river/artifacts/datacage/Datacage.java annotate

annotate artifacts/src/main/java/org/dive4elements/river/artifacts/datacage/Datacage.java @ 8856:5e38e2924c07 3.2.x

Fix code style.

author	Tom Gottfried <tom@intevation.de>
date	Thu, 18 Jan 2018 20:12:01 +0100
parents	5077fc1ace1c
children	0a5239a1e46e

rev	line source
5863 4897a58c8746 River artifacts: Added new copyright headers. Sascha L. Teichmann <teichmann@intevation.de> parents: 5838 diff changeset	1 /* Copyright (C) 2011, 2012, 2013 by Bundesanstalt für Gewässerkunde
4897a58c8746 River artifacts: Added new copyright headers. Sascha L. Teichmann <teichmann@intevation.de> parents: 5838 diff changeset	2 * Software engineering by Intevation GmbH
4897a58c8746 River artifacts: Added new copyright headers. Sascha L. Teichmann <teichmann@intevation.de> parents: 5838 diff changeset	3 *
5994 af13ceeba52a Removed trailing whitespace. Sascha L. Teichmann <teichmann@intevation.de> parents: 5867 diff changeset	4 * This file is Free Software under the GNU AGPL (>=v3)
5863 4897a58c8746 River artifacts: Added new copyright headers. Sascha L. Teichmann <teichmann@intevation.de> parents: 5838 diff changeset	5 * and comes with ABSOLUTELY NO WARRANTY! Check out the
5994 af13ceeba52a Removed trailing whitespace. Sascha L. Teichmann <teichmann@intevation.de> parents: 5867 diff changeset	6 * documentation coming with Dive4Elements River for details.
5863 4897a58c8746 River artifacts: Added new copyright headers. Sascha L. Teichmann <teichmann@intevation.de> parents: 5838 diff changeset	7 */
4897a58c8746 River artifacts: Added new copyright headers. Sascha L. Teichmann <teichmann@intevation.de> parents: 5838 diff changeset	8
5831 bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	9 package org.dive4elements.river.artifacts.datacage;
982 66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	10
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	11 import java.util.Collection;
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	12 import java.util.List;
1024 ba88157c6aa3 Make it compilable again (BackendListener interface changed). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1010 diff changeset	13 import java.util.Date;
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	14
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	15 import java.sql.SQLException;
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	16 import java.sql.PreparedStatement;
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	17 import java.sql.Types;
1025 02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	18 import java.sql.Timestamp;
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	19
5831 bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	20 import org.dive4elements.artifacts.GlobalContext;
bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	21 import org.dive4elements.artifacts.ArtifactCollection;
bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	22 import org.dive4elements.artifacts.User;
982 66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	23
5831 bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	24 import org.dive4elements.artifactdatabase.db.SQL;
bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	25 import org.dive4elements.artifactdatabase.db.SQLExecutor;
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	26
5831 bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	27 import org.dive4elements.artifactdatabase.LifetimeListener;
bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	28 import org.dive4elements.artifactdatabase.Backend;
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	29
5831 bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	30 import org.dive4elements.artifactdatabase.data.StateData;
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	31
5831 bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	32 import org.dive4elements.artifactdatabase.state.Output;
bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	33 import org.dive4elements.artifactdatabase.state.Facet;
bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	34
bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	35 import org.dive4elements.artifacts.Artifact;
bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	36 import org.dive4elements.artifacts.ArtifactDatabase;
bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	37 import org.dive4elements.artifacts.ArtifactDatabaseException;
bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	38
5867 59ff03ff48f1 River artifacts: Renamed FLYSArtifact(Collection) to D4EArtifact(Collection). Sascha L. Teichmann <teichmann@intevation.de> parents: 5863 diff changeset	39 import org.dive4elements.river.artifacts.D4EArtifact;
5831 bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	40
bd047b71ab37 Repaired internal references Sascha L. Teichmann <teichmann@intevation.de> parents: 3650 diff changeset	41 import org.dive4elements.artifacts.common.utils.LRUCache;
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	42
982 66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	43 import org.apache.log4j.Logger;
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	44
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	45 import org.w3c.dom.Document;
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	46
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	47 public class Datacage
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	48 implements LifetimeListener
982 66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	49 {
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	50 private static Logger log = Logger.getLogger(Datacage.class);
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	51
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	52 public static final String DATACAGE_KEY =
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	53 "global.datacage.instance";
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	54
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	55 public static final String ARTEFACT_DATABASE_KEY =
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	56 "global.artifact.database";
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	57
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	58 private String SQL_DELETE_ALL_USERS = "delete.all.users";
996 f61fe8b561d2 Datacage: delete artifacts at initial scan, too. Fixed problem with writing content of state data. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 995 diff changeset	59 private String SQL_DELETE_ALL_ARTIFACTS = "delete.all.artifacts";
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	60 private String SQL_USER_ID_NEXTVAL = "user.id.nextval";
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	61 private String SQL_USER_BY_GID = "user.by.gid";
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	62 private String SQL_INSERT_USER = "insert.user";
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	63 private String SQL_COLLECTION_BY_GID = "collection.by.gid";
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	64 private String SQL_COLLECTION_ID_NEXTVAL = "collection.id.nextval";
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	65 private String SQL_INSERT_COLLECTION = "insert.collection";
988 dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	66 private String SQL_ARTIFACT_BY_GID = "artifact.by.gid";
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	67 private String SQL_COLLECTION_ITEM_ID_NEXTVAL =
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	68 "collection.item.id.nextval";
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	69 private String SQL_INSERT_COLLECTION_ITEM = "insert.collection.item";
989 f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	70 private String SQL_ARTIFACT_ID_NEXTVAL = "artifact.id.nextval";
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	71 private String SQL_INSERT_ARTIFACT = "insert.artifact";
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	72 private String SQL_ARTIFACT_DATA_ID_NEXTVAL = "artifact.data.id.nextval";
6661 05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	73 private String SQL_UPDATE_ARTIFACT_STATE = "update.artifact.state";
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	74 private String SQL_INSERT_ARTIFACT_DATA = "insert.artifact.data";
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	75 private String SQL_OUT_ID_NEXTVALUE = "out.id.nextval";
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	76 private String SQL_INSERT_OUT = "insert.out";
992 5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	77 private String SQL_FACET_ID_NEXTVAL = "facet.id.nextval";
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	78 private String SQL_INSERT_FACET = "insert.facet";
1003 c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	79 private String SQL_UPDATE_COLLECTION_NAME = "update.collection.name";
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	80 private String SQL_DELETE_ARTIFACT_FROM_COLLECTION =
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	81 "delete.artifact.from.collection";
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	82 private String SQL_DELETE_COLLECTION_BY_GID =
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	83 "delete.collection.by.gid";
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	84 private String SQL_DELETE_USER_BY_GID = "delete.user.by.gid";
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	85 private String SQL_DELETE_ARTIFACT_DATA_BY_ARTIFACT_ID =
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	86 "delete.artifact.data.by.artifact.id";
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	87 private String SQL_DELETE_OUTS_BY_ARTIFACT_ID =
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	88 "delete.outs.by.artifact.id";
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	89 private String SQL_DELETE_FACETS_BY_ARTIFACT_ID =
1008 6268009e177d Datacage: fixed wrong SQL references Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1007 diff changeset	90 "delete.facets.by.artifact.id";
1006 1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	91 private String SQL_DELETE_ARTIFACT_BY_GID =
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	92 "delete.artifact.by.gid";
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	93
983 4ea5f5a2284e Ajusted datacage to use the SQL infrastructure from the artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 982 diff changeset	94 protected SQLExecutor sqlExecutor;
4ea5f5a2284e Ajusted datacage to use the SQL infrastructure from the artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 982 diff changeset	95
3076 5642a83420f2 FLYS artifacts: Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1624 diff changeset	96 public class InitialScan
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	97 implements ArtifactDatabase.ArtifactLoadedCallback
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	98 {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	99 protected LRUCache<String, Integer> users;
986 70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	100 protected LRUCache<String, Integer> collections;
988 dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	101 protected LRUCache<String, Integer> artifacts;
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	102
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	103 protected GlobalContext context;
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	104
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	105 public InitialScan() {
986 70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	106 users = new LRUCache<String, Integer>();
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	107 collections = new LRUCache<String, Integer>();
988 dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	108 artifacts = new LRUCache<String, Integer>();
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	109 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	110
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	111 public InitialScan(GlobalContext context) {
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	112 this();
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	113 this.context = context;
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	114 }
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	115
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	116 @Override
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	117 public void artifactLoaded(
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	118 String userId,
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	119 String collectionId,
1009 fc5fca0c33b3 Datacage: Set the name of the collections at initial scan, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1008 diff changeset	120 String collectionName,
1024 ba88157c6aa3 Make it compilable again (BackendListener interface changed). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1010 diff changeset	121 Date collectionCreated,
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	122 String artifactId,
1024 ba88157c6aa3 Make it compilable again (BackendListener interface changed). Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1010 diff changeset	123 Date artifactCreated,
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	124 Artifact artifact
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	125 ) {
5867 59ff03ff48f1 River artifacts: Renamed FLYSArtifact(Collection) to D4EArtifact(Collection). Sascha L. Teichmann <teichmann@intevation.de> parents: 5863 diff changeset	126 if (!(artifact instanceof D4EArtifact)) {
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	127 log.warn("ignoring none FLYS artifacts");
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	128 return;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	129 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	130
5867 59ff03ff48f1 River artifacts: Renamed FLYSArtifact(Collection) to D4EArtifact(Collection). Sascha L. Teichmann <teichmann@intevation.de> parents: 5863 diff changeset	131 D4EArtifact flysArtifact = (D4EArtifact)artifact;
986 70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	132
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	133 Integer uId = getUserId(userId);
1025 02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	134 Integer cId = getCollectionId(
02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	135 collectionId, uId, collectionName, collectionCreated);
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	136
1025 02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	137 storeArtifact(artifactId, cId, flysArtifact, artifactCreated);
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	138 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	139
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	140 protected Integer getId(
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	141 LRUCache<String, Integer> cache,
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	142 final String idString,
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	143 final String selectById
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	144 ) {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	145 Integer id = cache.get(idString);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	146 if (id != null) {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	147 return id;
986 70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	148 }
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	149
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	150 final Integer [] res = new Integer[1];
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	151
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	152 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	153 @Override
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	154 public boolean doIt() throws SQLException {
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	155 prepareStatement(selectById);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	156 stmnt.setString(1, idString);
986 70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	157 result = stmnt.executeQuery();
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	158 if (!result.next()) {
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	159 return false;
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	160 }
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	161 res[0] = result.getInt(1);
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	162 return true;
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	163 }
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	164 };
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	165
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	166 if (exec.runRead()) {
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	167 cache.put(idString, res[0]);
986 70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	168 return res[0];
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	169 }
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	170
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	171 return null;
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	172 }
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	173
988 dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	174 protected void storeArtifact(
989 f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	175 final String artifactId,
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	176 Integer collectionId,
5867 59ff03ff48f1 River artifacts: Renamed FLYSArtifact(Collection) to D4EArtifact(Collection). Sascha L. Teichmann <teichmann@intevation.de> parents: 5863 diff changeset	177 final D4EArtifact artifact,
1025 02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	178 final Date artifactCreated
988 dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	179 ) {
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	180 Integer aId = getId(artifacts, artifactId, SQL_ARTIFACT_BY_GID);
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	181
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	182 if (aId != null) {
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	183 // We've already stored it. Just create the collection item.
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	184 storeCollectionItem(collectionId, aId);
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	185 return;
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	186 }
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	187 // We need to write it to database
989 f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	188
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	189 final Integer [] res = new Integer[1];
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	190
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	191 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	192 @Override
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	193 public boolean doIt() throws SQLException {
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	194 prepareStatement(SQL_ARTIFACT_ID_NEXTVAL);
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	195 result = stmnt.executeQuery();
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	196 if (!result.next()) {
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	197 return false;
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	198 }
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	199 res[0] = result.getInt(1);
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	200 reset();
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	201 prepareStatement(SQL_INSERT_ARTIFACT);
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	202 stmnt.setInt (1, res[0]);
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	203 stmnt.setString(2, artifactId);
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	204 stmnt.setString(3, artifact.getCurrentStateId());
1025 02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	205 Timestamp timestamp = new Timestamp(artifactCreated != null
02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	206 ? artifactCreated.getTime()
02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	207 : System.currentTimeMillis());
02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	208 stmnt.setTimestamp(4, timestamp);
989 f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	209 stmnt.execute();
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	210 conn.commit();
989 f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	211 return true;
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	212 }
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	213 };
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	214
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	215 if (!exec.runWrite()) {
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	216 log.error("storing of artifact failed.");
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	217 return;
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	218 }
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	219
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	220 artifacts.put(artifactId, aId = res[0]);
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	221
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	222 storeCollectionItem(collectionId, aId);
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	223
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	224 storeData(aId, artifact);
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	225
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	226 storeOuts(aId, artifact, context);
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	227 }
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	228
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	229
988 dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	230 protected void storeCollectionItem(
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	231 final Integer collectionId,
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	232 final Integer artifactId
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	233 ) {
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	234 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	235 @Override
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	236 public boolean doIt() throws SQLException {
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	237 prepareStatement(SQL_COLLECTION_ITEM_ID_NEXTVAL);
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	238 result = stmnt.executeQuery();
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	239 if (!result.next()) {
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	240 return false;
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	241 }
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	242 int ciId = result.getInt(1);
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	243 reset();
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	244 prepareStatement(SQL_INSERT_COLLECTION_ITEM);
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	245 stmnt.setInt(1, ciId);
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	246 stmnt.setInt(2, collectionId);
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	247 stmnt.setInt(3, artifactId);
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	248 stmnt.execute();
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	249 conn.commit();
988 dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	250 return true;
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	251 }
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	252 };
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	253
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	254 if (!exec.runWrite()) {
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	255 log.error("storing of collection item failed.");
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	256 }
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	257 }
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	258
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	259 protected Integer getCollectionId(
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	260 final String collectionId,
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	261 final Integer ownerId,
1025 02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	262 final String collectionName,
02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	263 final Date collectionCreated
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	264 ) {
8856 5e38e2924c07 Fix code style. Tom Gottfried <tom@intevation.de> parents: 6775 diff changeset	265 Integer c = getId(
5e38e2924c07 Fix code style. Tom Gottfried <tom@intevation.de> parents: 6775 diff changeset	266 collections, collectionId, SQL_COLLECTION_BY_GID);
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	267
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	268 if (c != null) {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	269 return c;
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	270 }
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	271
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	272 final Integer [] res = new Integer[1];
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	273
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	274 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	275 @Override
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	276 public boolean doIt() throws SQLException {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	277 prepareStatement(SQL_COLLECTION_ID_NEXTVAL);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	278 result = stmnt.executeQuery();
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	279 if (!result.next()) {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	280 return false;
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	281 }
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	282 res[0] = result.getInt(1);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	283 reset();
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	284 prepareStatement(SQL_INSERT_COLLECTION);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	285 stmnt.setInt (1, res[0]);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	286 stmnt.setString(2, collectionId);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	287 stmnt.setInt (3, ownerId);
1009 fc5fca0c33b3 Datacage: Set the name of the collections at initial scan, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1008 diff changeset	288 setString(stmnt, 4, collectionName);
8856 5e38e2924c07 Fix code style. Tom Gottfried <tom@intevation.de> parents: 6775 diff changeset	289 Timestamp timestamp =
5e38e2924c07 Fix code style. Tom Gottfried <tom@intevation.de> parents: 6775 diff changeset	290 new Timestamp(collectionCreated != null
5e38e2924c07 Fix code style. Tom Gottfried <tom@intevation.de> parents: 6775 diff changeset	291 ? collectionCreated.getTime()
5e38e2924c07 Fix code style. Tom Gottfried <tom@intevation.de> parents: 6775 diff changeset	292 : System.currentTimeMillis());
1025 02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	293 stmnt.setTimestamp(5, timestamp);
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	294 stmnt.execute();
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	295 conn.commit();
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	296 return true;
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	297 }
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	298 };
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	299
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	300 if (exec.runWrite()) {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	301 collections.put(collectionId, res[0]);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	302 return res[0];
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	303 }
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	304
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	305 return null;
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	306 }
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	307
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	308 protected Integer getUserId(final String userId) {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	309
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	310 Integer u = getId(users, userId, SQL_USER_BY_GID);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	311
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	312 if (u != null) {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	313 return u;
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	314 }
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	315
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	316 final Integer [] res = new Integer[1];
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	317
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	318 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
986 70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	319 @Override
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	320 public boolean doIt() throws SQLException {
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	321 prepareStatement(SQL_USER_ID_NEXTVAL);
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	322 result = stmnt.executeQuery();
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	323 if (!result.next()) {
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	324 return false;
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	325 }
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	326 res[0] = result.getInt(1);
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	327 reset();
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	328 prepareStatement(SQL_INSERT_USER);
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	329 stmnt.setInt (1, res[0]);
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	330 stmnt.setString(2, userId);
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	331 stmnt.execute();
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	332 conn.commit();
986 70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	333 return true;
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	334 }
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	335 };
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	336
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	337 if (exec.runWrite()) {
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	338 users.put(userId, res[0]);
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	339 return res[0];
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	340 }
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	341
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	342 return null;
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	343 }
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	344
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	345 public boolean scan(ArtifactDatabase adb) {
993 aabcca7aeb6c Fixed datacage db scheme. add some debug output. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 992 diff changeset	346 log.debug("scan");
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	347 try {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	348 adb.loadAllArtifacts(this);
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	349 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	350 catch (ArtifactDatabaseException ade) {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	351 log.error(ade);
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	352 return false;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	353 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	354 return true;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	355 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	356 } // class InitialScan
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	357
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	358
982 66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	359 public Datacage() {
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	360 }
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	361
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	362 @Override
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	363 public void setup(Document document) {
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	364 log.debug("setup");
983 4ea5f5a2284e Ajusted datacage to use the SQL infrastructure from the artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 982 diff changeset	365 DBConfig config = DBConfig.getInstance();
4ea5f5a2284e Ajusted datacage to use the SQL infrastructure from the artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 982 diff changeset	366 setupSQL(config.getSQL());
4ea5f5a2284e Ajusted datacage to use the SQL infrastructure from the artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 982 diff changeset	367 sqlExecutor = new SQLExecutor(config.getDBConnection());
4ea5f5a2284e Ajusted datacage to use the SQL infrastructure from the artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 982 diff changeset	368 }
4ea5f5a2284e Ajusted datacage to use the SQL infrastructure from the artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 982 diff changeset	369
4ea5f5a2284e Ajusted datacage to use the SQL infrastructure from the artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 982 diff changeset	370 protected void setupSQL(SQL sql) {
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	371 SQL_DELETE_ALL_USERS = sql.get(SQL_DELETE_ALL_USERS);
996 f61fe8b561d2 Datacage: delete artifacts at initial scan, too. Fixed problem with writing content of state data. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 995 diff changeset	372 SQL_DELETE_ALL_ARTIFACTS = sql.get(SQL_DELETE_ALL_ARTIFACTS);
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	373 SQL_USER_ID_NEXTVAL = sql.get(SQL_USER_ID_NEXTVAL);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	374 SQL_USER_BY_GID = sql.get(SQL_USER_BY_GID);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	375 SQL_INSERT_USER = sql.get(SQL_INSERT_USER);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	376 SQL_COLLECTION_BY_GID = sql.get(SQL_COLLECTION_BY_GID);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	377 SQL_COLLECTION_ID_NEXTVAL = sql.get(SQL_COLLECTION_ID_NEXTVAL);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	378 SQL_INSERT_COLLECTION = sql.get(SQL_INSERT_COLLECTION);
988 dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	379 SQL_ARTIFACT_BY_GID = sql.get(SQL_ARTIFACT_BY_GID);
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	380 SQL_COLLECTION_ITEM_ID_NEXTVAL =
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	381 sql.get(SQL_COLLECTION_ITEM_ID_NEXTVAL);
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	382 SQL_INSERT_COLLECTION_ITEM =
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	383 sql.get(SQL_INSERT_COLLECTION_ITEM);
989 f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	384 SQL_ARTIFACT_ID_NEXTVAL = sql.get(SQL_ARTIFACT_ID_NEXTVAL);
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	385 SQL_INSERT_ARTIFACT = sql.get(SQL_INSERT_ARTIFACT);
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	386 SQL_ARTIFACT_DATA_ID_NEXTVAL = sql.get(SQL_ARTIFACT_DATA_ID_NEXTVAL);
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	387 SQL_INSERT_ARTIFACT_DATA = sql.get(SQL_INSERT_ARTIFACT_DATA);
6661 05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	388 SQL_UPDATE_ARTIFACT_STATE = sql.get(SQL_UPDATE_ARTIFACT_STATE);
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	389 SQL_OUT_ID_NEXTVALUE = sql.get(SQL_OUT_ID_NEXTVALUE);
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	390 SQL_INSERT_OUT = sql.get(SQL_INSERT_OUT);
992 5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	391 SQL_FACET_ID_NEXTVAL = sql.get(SQL_FACET_ID_NEXTVAL);
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	392 SQL_INSERT_FACET = sql.get(SQL_INSERT_FACET);
1003 c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	393 SQL_UPDATE_COLLECTION_NAME = sql.get(SQL_UPDATE_COLLECTION_NAME);
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	394 SQL_DELETE_ARTIFACT_FROM_COLLECTION =
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	395 sql.get(SQL_DELETE_ARTIFACT_FROM_COLLECTION);
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	396 SQL_DELETE_COLLECTION_BY_GID = sql.get(SQL_DELETE_COLLECTION_BY_GID);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	397 SQL_DELETE_USER_BY_GID = sql.get(SQL_DELETE_USER_BY_GID);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	398 SQL_DELETE_ARTIFACT_DATA_BY_ARTIFACT_ID =
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	399 sql.get(SQL_DELETE_ARTIFACT_DATA_BY_ARTIFACT_ID);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	400 SQL_DELETE_OUTS_BY_ARTIFACT_ID =
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	401 sql.get(SQL_DELETE_OUTS_BY_ARTIFACT_ID);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	402 SQL_DELETE_FACETS_BY_ARTIFACT_ID =
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	403 sql.get(SQL_DELETE_FACETS_BY_ARTIFACT_ID);
1010 d419c9904825 Datacage: Forgot to fetch dialect dependent SQL statement for deleting artifacts by uuid. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1009 diff changeset	404 SQL_DELETE_ARTIFACT_BY_GID =
d419c9904825 Datacage: Forgot to fetch dialect dependent SQL statement for deleting artifacts by uuid. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1009 diff changeset	405 sql.get(SQL_DELETE_ARTIFACT_BY_GID);
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	406 }
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	407
6719 7b2b81974018 Cosmetics. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 6661 diff changeset	408 /** Sum over facets in outs. */
992 5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	409 protected static final int numFacets(List<Output> outs) {
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	410 int sum = 0;
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	411 for (Output out: outs) {
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	412 sum += out.getFacets().size();
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	413 }
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	414 return sum;
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	415 }
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	416
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	417 protected static final void setString(
3076 5642a83420f2 FLYS artifacts: Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1624 diff changeset	418 PreparedStatement stmnt,
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	419 int index,
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	420 Object value
3076 5642a83420f2 FLYS artifacts: Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1624 diff changeset	421 )
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	422 throws SQLException
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	423 {
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	424 if (value == null) {
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	425 stmnt.setNull(index, Types.VARCHAR);
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	426 }
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	427 else {
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	428 stmnt.setString(index, value.toString());
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	429 }
982 66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	430 }
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	431
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	432 @Override
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	433 public void systemUp(GlobalContext context) {
993 aabcca7aeb6c Fixed datacage db scheme. add some debug output. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 992 diff changeset	434 log.debug("systemUp entered");
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	435 initialScan(context);
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	436 context.put(DATACAGE_KEY, this);
993 aabcca7aeb6c Fixed datacage db scheme. add some debug output. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 992 diff changeset	437 log.debug("systemUp leaved");
982 66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	438 }
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	439
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	440 protected void initialScan(GlobalContext context) {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	441 log.debug("initialScan");
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	442
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	443 Object adbObject = context.get(ARTEFACT_DATABASE_KEY);
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	444
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	445 if (!(adbObject instanceof ArtifactDatabase)) {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	446 log.error("missing artefact database. Cannot scan");
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	447 return;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	448 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	449
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	450 ArtifactDatabase adb = (ArtifactDatabase)adbObject;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	451
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	452 if (!cleanDatabase()) {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	453 log.error("cleaning database failed");
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	454 return;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	455 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	456
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	457 InitialScan is = new InitialScan(context);
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	458
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	459 if (!is.scan(adb)) {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	460 log.error("initial scan failed");
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	461 return;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	462 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	463
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	464 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	465
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	466 protected boolean cleanDatabase() {
993 aabcca7aeb6c Fixed datacage db scheme. add some debug output. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 992 diff changeset	467 log.debug("cleanDatabase");
aabcca7aeb6c Fixed datacage db scheme. add some debug output. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 992 diff changeset	468
aabcca7aeb6c Fixed datacage db scheme. add some debug output. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 992 diff changeset	469 boolean success = sqlExecutor.new Instance() {
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	470 @Override
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	471 public boolean doIt() throws SQLException {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	472 prepareStatement(SQL_DELETE_ALL_USERS);
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	473 stmnt.execute();
996 f61fe8b561d2 Datacage: delete artifacts at initial scan, too. Fixed problem with writing content of state data. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 995 diff changeset	474 prepareStatement(SQL_DELETE_ALL_ARTIFACTS);
f61fe8b561d2 Datacage: delete artifacts at initial scan, too. Fixed problem with writing content of state data. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 995 diff changeset	475 stmnt.execute();
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	476 conn.commit();
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	477 return true;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	478 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	479 }.runWrite();
993 aabcca7aeb6c Fixed datacage db scheme. add some debug output. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 992 diff changeset	480
aabcca7aeb6c Fixed datacage db scheme. add some debug output. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 992 diff changeset	481 log.debug("after runWrite(): " + success);
aabcca7aeb6c Fixed datacage db scheme. add some debug output. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 992 diff changeset	482
aabcca7aeb6c Fixed datacage db scheme. add some debug output. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 992 diff changeset	483 return success;
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	484 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	485
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	486
982 66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	487 @Override
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	488 public void systemDown(GlobalContext context) {
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	489 log.debug("systemDown");
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	490 }
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	491
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	492 public void setup(GlobalContext globalContext) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	493 log.debug("setup");
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	494 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	495
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	496 public void createdArtifact(
3076 5642a83420f2 FLYS artifacts: Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1624 diff changeset	497 Artifact artifact,
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	498 Backend backend,
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	499 GlobalContext context
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	500 ) {
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	501 log.debug("createdArtifact");
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	502
1624 238145ef67da Cosmetics. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 1050 diff changeset	503 if (artifact == null) {
238145ef67da Cosmetics. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 1050 diff changeset	504 log.warn("artifact to create is null");
238145ef67da Cosmetics. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 1050 diff changeset	505 return;
238145ef67da Cosmetics. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 1050 diff changeset	506 }
238145ef67da Cosmetics. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 1050 diff changeset	507
5867 59ff03ff48f1 River artifacts: Renamed FLYSArtifact(Collection) to D4EArtifact(Collection). Sascha L. Teichmann <teichmann@intevation.de> parents: 5863 diff changeset	508 if (!(artifact instanceof D4EArtifact)) {
8856 5e38e2924c07 Fix code style. Tom Gottfried <tom@intevation.de> parents: 6775 diff changeset	509 log.warn("need D4EArtifact here (have "
5e38e2924c07 Fix code style. Tom Gottfried <tom@intevation.de> parents: 6775 diff changeset	510 + artifact.getClass() + ")");
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	511 return;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	512 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	513
5867 59ff03ff48f1 River artifacts: Renamed FLYSArtifact(Collection) to D4EArtifact(Collection). Sascha L. Teichmann <teichmann@intevation.de> parents: 5863 diff changeset	514 final D4EArtifact flys = (D4EArtifact)artifact;
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	515
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	516 final int [] res = new int[1];
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	517
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	518 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	519 @Override
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	520 public boolean doIt() throws SQLException {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	521 prepareStatement(SQL_ARTIFACT_ID_NEXTVAL);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	522 result = stmnt.executeQuery();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	523 if (!result.next()) {
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	524 log.error("id generation for artifact failed");
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	525 return false;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	526 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	527 res[0] = result.getInt(1);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	528 reset();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	529 prepareStatement(SQL_INSERT_ARTIFACT);
1025 02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	530 stmnt.setInt (1, res[0]);
02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	531 stmnt.setString (2, flys.identifier());
02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	532 stmnt.setString (3, flys.getCurrentStateId());
02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	533 stmnt.setTimestamp(4,
02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	534 new Timestamp(System.currentTimeMillis()));
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	535 stmnt.execute();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	536 conn.commit();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	537 return true;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	538 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	539 };
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	540
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	541 if (!exec.runWrite()) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	542 log.error("storing of artifact failed.");
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	543 return;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	544 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	545
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	546 storeData(res[0], flys);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	547 storeOuts(res[0], flys, context);
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	548 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	549
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	550 public void storedArtifact(
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	551 Artifact artifact,
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	552 Backend backend,
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	553 GlobalContext context
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	554 ) {
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	555 log.debug("storedArtifact");
5867 59ff03ff48f1 River artifacts: Renamed FLYSArtifact(Collection) to D4EArtifact(Collection). Sascha L. Teichmann <teichmann@intevation.de> parents: 5863 diff changeset	556 if (!(artifact instanceof D4EArtifact)) {
8856 5e38e2924c07 Fix code style. Tom Gottfried <tom@intevation.de> parents: 6775 diff changeset	557 log.warn("need D4EArtifact here but have a "
5e38e2924c07 Fix code style. Tom Gottfried <tom@intevation.de> parents: 6775 diff changeset	558 + artifact.getClass());
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	559 return;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	560 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	561
5867 59ff03ff48f1 River artifacts: Renamed FLYSArtifact(Collection) to D4EArtifact(Collection). Sascha L. Teichmann <teichmann@intevation.de> parents: 5863 diff changeset	562 final D4EArtifact flys = (D4EArtifact)artifact;
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	563
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	564 final Integer [] res = new Integer[1];
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	565
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	566 // check first if artifact already exists
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	567 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	568 @Override
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	569 public boolean doIt() throws SQLException {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	570 prepareStatement(SQL_ARTIFACT_BY_GID);
1007 ed918497873b Datacage: Fixed two NPEs Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1006 diff changeset	571 stmnt.setString(1, flys.identifier());
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	572 result = stmnt.executeQuery();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	573 if (!result.next()) {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	574 // new artifact
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	575 return true;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	576 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	577 res[0] = result.getInt(1);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	578 return true;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	579 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	580 };
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	581
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	582 if (!exec.runRead()) {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	583 log.error("querying artifact failed");
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	584 return;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	585 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	586
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	587 if (res[0] == null) { // new artifact
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	588 createdArtifact(artifact, backend, context);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	589 return;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	590 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	591
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	592 // artifact already exists -> delete old data
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	593 exec = sqlExecutor.new Instance() {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	594 @Override
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	595 public boolean doIt() throws SQLException {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	596 prepareStatement(SQL_DELETE_ARTIFACT_DATA_BY_ARTIFACT_ID);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	597 stmnt.setInt(1, res[0]);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	598 stmnt.execute();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	599 prepareStatement(SQL_DELETE_FACETS_BY_ARTIFACT_ID);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	600 stmnt.setInt(1, res[0]);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	601 stmnt.execute();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	602 prepareStatement(SQL_DELETE_OUTS_BY_ARTIFACT_ID);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	603 stmnt.setInt(1, res[0]);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	604 stmnt.execute();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	605 conn.commit();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	606 return true;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	607 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	608 };
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	609
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	610 if (!exec.runWrite()) {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	611 log.error("deleting old artifact data failed");
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	612 return;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	613 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	614
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	615 // write new data
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	616 storeData(res[0], flys);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	617 storeOuts(res[0], flys, context);
6661 05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	618 storeState(res[0], flys);
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	619 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	620
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	621 public void createdUser(
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	622 final User user,
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	623 Backend backend,
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	624 GlobalContext context
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	625 ) {
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	626 log.debug("createdUser");
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	627 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	628 @Override
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	629 public boolean doIt() throws SQLException {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	630 prepareStatement(SQL_USER_ID_NEXTVAL);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	631 result = stmnt.executeQuery();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	632 if (!result.next()) {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	633 log.error("id generation for user failed");
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	634 return false;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	635 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	636 int uId = result.getInt(1);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	637 reset();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	638 prepareStatement(SQL_INSERT_USER);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	639 stmnt.setInt(1, uId);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	640 stmnt.setString(2, user.identifier());
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	641 stmnt.execute();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	642 conn.commit();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	643 return true;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	644 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	645 };
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	646
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	647 if (!exec.runWrite()) {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	648 log.error("create user failed");
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	649 }
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	650 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	651
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	652 public void deletedUser(
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	653 final String identifier,
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	654 Backend backend,
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	655 GlobalContext context
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	656 ) {
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	657 log.debug("deletedUser");
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	658 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	659 @Override
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	660 public boolean doIt() throws SQLException {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	661 prepareStatement(SQL_DELETE_USER_BY_GID);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	662 stmnt.setString(1, identifier);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	663 stmnt.execute();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	664 conn.commit();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	665 return true;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	666 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	667 };
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	668
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	669 if (!exec.runWrite()) {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	670 log.error("delete user failed");
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	671 }
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	672 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	673
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	674 public void createdCollection(
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	675 final ArtifactCollection collection,
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	676 Backend backend,
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	677 GlobalContext context
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	678 ) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	679 log.debug("createdCollection");
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	680 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	681 @Override
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	682 public boolean doIt() throws SQLException {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	683 String userId = collection.getUser().identifier();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	684 prepareStatement(SQL_USER_BY_GID);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	685 stmnt.setString(1, userId);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	686 result = stmnt.executeQuery();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	687 int uId;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	688 if (result.next()) {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	689 uId = result.getInt(1);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	690 reset();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	691 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	692 else {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	693 // need to create user first
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	694 reset();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	695 prepareStatement(SQL_USER_ID_NEXTVAL);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	696 result = stmnt.executeQuery();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	697 if (!result.next()) {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	698 log.error("id generation for user failed");
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	699 return false;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	700 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	701 uId = result.getInt(1);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	702 reset();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	703 prepareStatement(SQL_INSERT_USER);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	704 stmnt.setInt(1, uId);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	705 stmnt.setString(2, userId);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	706 stmnt.execute();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	707 conn.commit();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	708 reset();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	709 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	710
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	711 prepareStatement(SQL_COLLECTION_ID_NEXTVAL);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	712 result = stmnt.executeQuery();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	713 if (!result.next()) {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	714 log.error("id generation for collection failed");
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	715 return false;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	716 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	717 int cId = result.getInt(1);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	718 reset();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	719
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	720 String identifier = collection.identifier();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	721 String name = collection.getName();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	722
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	723 prepareStatement(SQL_INSERT_COLLECTION);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	724 stmnt.setInt(1, cId);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	725 stmnt.setString(2, identifier);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	726 stmnt.setInt(3, uId);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	727 setString(stmnt, 4, name);
1025 02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	728 stmnt.setTimestamp(5,
02c327ffbad7 Datacage: Extended schema for artifacts and collections Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1024 diff changeset	729 new Timestamp(System.currentTimeMillis()));
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	730 stmnt.execute();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	731
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	732 conn.commit();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	733 return true;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	734 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	735 };
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	736
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	737 if (!exec.runWrite()) {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	738 log.error("create collection failed");
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	739 }
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	740 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	741
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	742 public void deletedCollection(
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	743 final String identifier,
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	744 Backend backend,
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	745 GlobalContext context
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	746 ) {
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	747 log.debug("deletedCollection");
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	748 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	749 @Override
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	750 public boolean doIt() throws SQLException {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	751 prepareStatement(SQL_DELETE_COLLECTION_BY_GID);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	752 stmnt.setString(1, identifier);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	753 stmnt.execute();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	754 conn.commit();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	755 return true;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	756 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	757 };
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	758
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	759 if (!exec.runWrite()) {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	760 log.error("delete collection failed");
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	761 }
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	762 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	763
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	764 public void changedCollectionAttribute(
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	765 String identifier,
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	766 Document document,
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	767 Backend backend,
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	768 GlobalContext context
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	769 ) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	770 log.debug("changedCollectionAttribute");
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	771 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	772
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	773 public void changedCollectionItemAttribute(
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	774 String collectionId,
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	775 String artifactId,
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	776 Document document,
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	777 Backend backend,
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	778 GlobalContext context
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	779 ) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	780 log.debug("changedCollectionItemAttribute");
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	781 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	782
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	783 public void addedArtifactToCollection(
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	784 final String artifactId,
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	785 final String collectionId,
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	786 Backend backend,
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	787 GlobalContext context
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	788 ) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	789 log.debug("addedArtifactToCollection");
1004 0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	790 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	791 @Override
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	792 public boolean doIt() throws SQLException {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	793 prepareStatement(SQL_ARTIFACT_BY_GID);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	794 stmnt.setString(1, artifactId);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	795 result = stmnt.executeQuery();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	796 if (!result.next()) {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	797 return false;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	798 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	799 int aId = result.getInt(1);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	800 reset();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	801
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	802 prepareStatement(SQL_COLLECTION_BY_GID);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	803 stmnt.setString(1, collectionId);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	804 result = stmnt.executeQuery();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	805 if (!result.next()) {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	806 return false;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	807 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	808 int cId = result.getInt(1);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	809 reset();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	810
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	811 prepareStatement(SQL_COLLECTION_ITEM_ID_NEXTVAL);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	812 result = stmnt.executeQuery();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	813 if (!result.next()) {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	814 return false;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	815 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	816 int ciId = result.getInt(1);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	817 reset();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	818
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	819 prepareStatement(SQL_INSERT_COLLECTION_ITEM);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	820 stmnt.setInt(1, ciId);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	821 stmnt.setInt(2, cId);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	822 stmnt.setInt(3, aId);
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	823 stmnt.execute();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	824
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	825 conn.commit();
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	826 return true;
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	827 }
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	828 };
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	829 if (!exec.runWrite()) {
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	830 log.error("added artifact to collection failed");
0e8c03b69627 Datacage: completed backend listener stuff. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1003 diff changeset	831 }
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	832 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	833
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	834 public void removedArtifactFromCollection(
1003 c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	835 final String artifactId,
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	836 final String collectionId,
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	837 Backend backend,
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	838 GlobalContext context
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	839 ) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	840 log.debug("removedArtifactFromCollection");
1003 c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	841 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	842 @Override
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	843 public boolean doIt() throws SQLException {
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	844 prepareStatement(SQL_ARTIFACT_BY_GID);
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	845 stmnt.setString(1, artifactId);
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	846 result = stmnt.executeQuery();
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	847 if (!result.next()) {
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	848 return false;
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	849 }
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	850 int aId = result.getInt(1);
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	851 reset();
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	852 prepareStatement(SQL_COLLECTION_BY_GID);
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	853 stmnt.setString(1, collectionId);
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	854 result = stmnt.executeQuery();
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	855 if (!result.next()) {
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	856 return false;
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	857 }
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	858 int cId = result.getInt(1);
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	859 reset();
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	860 prepareStatement(SQL_DELETE_ARTIFACT_FROM_COLLECTION);
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	861 stmnt.setInt(1, cId);
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	862 stmnt.setInt(2, aId);
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	863 stmnt.execute();
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	864 conn.commit();
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	865 return true;
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	866 }
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	867 };
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	868 if (!exec.runWrite()) {
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	869 log.error("removing artifact from collection failed");
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	870 }
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	871 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	872
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	873 public void setCollectionName(
1003 c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	874 final String collectionId,
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	875 final String name,
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	876 GlobalContext context
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	877 ) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	878 log.debug("setCollectionName");
1003 c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	879 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	880 @Override
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	881 public boolean doIt() throws SQLException {
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	882 prepareStatement(SQL_UPDATE_COLLECTION_NAME);
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	883 stmnt.setString(1, name);
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	884 stmnt.setString(2, collectionId);
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	885 stmnt.execute();
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	886 conn.commit();
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	887 return true;
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	888 }
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	889 };
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	890 if (!exec.runWrite()) {
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	891 log.error("changing name failed");
c58da6dd15ed Datacage: Update collection names on change. Remove artifacts from collections. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1002 diff changeset	892 }
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	893 }
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	894
6661 05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	895 /** Update state of artifact. */
05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	896 protected void storeState(
05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	897 final int artifactId,
05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	898 final D4EArtifact artifact) {
05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	899 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	900 @Override
05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	901 public boolean doIt() throws SQLException {
05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	902 prepareStatement(SQL_UPDATE_ARTIFACT_STATE);
6775 5077fc1ace1c issue1415: Corrected update query and parameter setting. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 6719 diff changeset	903 stmnt.setString(1, artifact.getCurrentStateId());
5077fc1ace1c issue1415: Corrected update query and parameter setting. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 6719 diff changeset	904 stmnt.setInt(2, artifactId);
6661 05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	905 stmnt.execute();
05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	906 conn.commit();
05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	907 return true;
05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	908 }
05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	909 };
05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	910
05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	911 if (!exec.runWrite()) {
8856 5e38e2924c07 Fix code style. Tom Gottfried <tom@intevation.de> parents: 6775 diff changeset	912 log.error("storing state of artifact failed ("
5e38e2924c07 Fix code style. Tom Gottfried <tom@intevation.de> parents: 6775 diff changeset	913 + artifactId + "," + artifact.getCurrentStateId() + ")");
6661 05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	914 }
05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	915 }
05395533fe82 fix issue1415: Update state of artifact when storing artifact. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 5994 diff changeset	916
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	917 protected void storeData(
6719 7b2b81974018 Cosmetics. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 6661 diff changeset	918 final int artifactId,
7b2b81974018 Cosmetics. Felix Wolfsteller <felix.wolfsteller@intevation.de> parents: 6661 diff changeset	919 D4EArtifact artifact
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	920 ) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	921 final Collection<StateData> data = artifact.getAllData();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	922
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	923 if (data.isEmpty()) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	924 return;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	925 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	926
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	927 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	928 @Override
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	929 public boolean doIt() throws SQLException {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	930 int [] ids = new int[data.size()];
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	931 prepareStatement(SQL_ARTIFACT_DATA_ID_NEXTVAL);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	932
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	933 for (int i = 0; i < ids.length; ++i) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	934 result = stmnt.executeQuery();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	935 if (!result.next()) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	936 log.error("generating id for artifact data failed");
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	937 return false;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	938 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	939 ids[i] = result.getInt(1);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	940 result.close(); result = null;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	941 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	942 reset();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	943 prepareStatement(SQL_INSERT_ARTIFACT_DATA);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	944
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	945 int i = 0;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	946 for (StateData sd: data) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	947 int id = ids[i++];
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	948 stmnt.setInt(1, id);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	949 stmnt.setInt(2, artifactId);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	950 // XXX: Where come the nulls from?
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	951 String type = sd.getType();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	952 if (type == null) type = "String";
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	953 stmnt.setString(3, type);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	954 stmnt.setString(4, sd.getName());
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	955 setString(stmnt, 5, sd.getValue());
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	956 stmnt.execute();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	957 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	958
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	959 conn.commit();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	960 return true;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	961 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	962 };
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	963
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	964 if (!exec.runWrite()) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	965 log.error("storing artifact data failed");
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	966 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	967 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	968
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	969 protected void storeOuts(
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	970 final int artifactId,
5867 59ff03ff48f1 River artifacts: Renamed FLYSArtifact(Collection) to D4EArtifact(Collection). Sascha L. Teichmann <teichmann@intevation.de> parents: 5863 diff changeset	971 final D4EArtifact artifact,
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	972 GlobalContext context
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	973 ) {
1050 eccf966fb677 State engine: Removed CallContext from state validation. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1025 diff changeset	974 final List<Output> outs = artifact.getOutputs(context);
1002 db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	975
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	976 if (outs.isEmpty()) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	977 return;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	978 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	979
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	980 final int [] outIds = new int[outs.size()];
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	981
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	982 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	983 @Override
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	984 public boolean doIt() throws SQLException {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	985 prepareStatement(SQL_OUT_ID_NEXTVALUE);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	986 for (int i = 0; i < outIds.length; ++i) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	987 result = stmnt.executeQuery();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	988 if (!result.next()) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	989 log.error("generation of out ids failed");
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	990 return false;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	991 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	992 outIds[i] = result.getInt(1);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	993 result.close(); result = null;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	994 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	995 reset();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	996 prepareStatement(SQL_INSERT_OUT);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	997 for (int i = 0; i < outIds.length; ++i) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	998 Output out = outs.get(i);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	999 stmnt.setInt(1, outIds[i]);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1000 stmnt.setInt(2, artifactId);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1001 stmnt.setString(3, out.getName());
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1002 setString(stmnt, 4, out.getDescription());
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1003 setString(stmnt, 5, out.getType());
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1004 stmnt.execute();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1005 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1006 conn.commit();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1007 return true;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1008 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1009 };
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1010
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1011 if (!exec.runWrite()) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1012 log.error("storing artifact outs failed");
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1013 return;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1014 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1015
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1016 final int FACETS = numFacets(outs);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1017
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1018 if (FACETS == 0) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1019 return;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1020 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1021
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1022 exec = sqlExecutor.new Instance() {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1023 @Override
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1024 public boolean doIt() throws SQLException {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1025 int [] facetIds = new int[FACETS];
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1026 prepareStatement(SQL_FACET_ID_NEXTVAL);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1027 for (int i = 0; i < facetIds.length; ++i) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1028 result = stmnt.executeQuery();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1029 if (!result.next()) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1030 log.error("generation of facet ids failed");
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1031 return false;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1032 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1033 facetIds[i] = result.getInt(1);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1034 result.close(); result = null;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1035 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1036 reset();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1037 prepareStatement(SQL_INSERT_FACET);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1038 int index = 0;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1039 for (int i = 0, N = outs.size(); i < N; ++i) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1040 Output out = outs.get(i);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1041 int outId = outIds[i];
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1042 for (Facet facet: out.getFacets()) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1043 stmnt.setInt(1, facetIds[index]);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1044 stmnt.setInt(2, outId);
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1045 stmnt.setString(3, facet.getName());
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1046 stmnt.setInt(4, facet.getIndex());
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1047 stmnt.setString(5, "XXX"); // TODO: handle states
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1048 setString(stmnt, 6, facet.getDescription());
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1049 stmnt.execute();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1050 ++index;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1051 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1052 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1053 conn.commit();
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1054 return true;
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1055 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1056 };
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1057
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1058 if (!exec.runWrite()) {
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1059 log.error("storing facets failed");
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1060 }
db86c665ab6e Datacage: Pass global context to datacage if calls come from backend listener. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 999 diff changeset	1061 }
1006 1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1062
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1063 public void killedCollections(
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1064 final List<String> identifiers,
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1065 GlobalContext context
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1066 ) {
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1067 log.debug("killedCollections");
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1068
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1069 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1070 @Override
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1071 public boolean doIt() throws SQLException {
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1072 prepareStatement(SQL_DELETE_COLLECTION_BY_GID);
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1073 for (String identifier: identifiers) {
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1074 stmnt.setString(1, identifier);
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1075 stmnt.execute();
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1076 }
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1077 conn.commit();
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1078 return true;
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1079 }
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1080 };
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1081
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1082 if (!exec.runWrite()) {
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1083 log.error("killing collections failed");
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1084 }
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1085 }
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1086
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1087 public void killedArtifacts(
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1088 final List<String> identifiers,
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1089 GlobalContext context
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1090 ) {
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1091 log.debug("killedArtifacts");
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1092
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1093 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1094 @Override
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1095 public boolean doIt() throws SQLException {
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1096 prepareStatement(SQL_DELETE_ARTIFACT_BY_GID);
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1097 for (String identifier: identifiers) {
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1098 stmnt.setString(1, identifier);
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1099 stmnt.execute();
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1100 }
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1101 conn.commit();
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1102 return true;
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1103 }
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1104 };
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1105
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1106 if (!exec.runWrite()) {
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1107 log.error("killing artifacts failed");
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1108 }
1917f32701dc Forwarded kill collections and artifacts events to datacage. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1004 diff changeset	1109 }
982 66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	1110 }
66b3f2f064de Added the datacage as lifetime listener to the artifact database to create the initial index. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	1111 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :

Mercurial > dive4elements > river

annotate artifacts/src/main/java/org/dive4elements/river/artifacts/datacage/Datacage.java @ 8856:5e38e2924c07 3.2.x