dive4elements/river: flys-artifacts/src/main/java/de/intevation/flys/artifacts/datacage/Datacage.java annotate

annotate flys-artifacts/src/main/java/de/intevation/flys/artifacts/datacage/Datacage.java @ 999:b0218f21c664

Wire datacage with backend of artifact database. flys-artifacts/trunk@2438 c6561f87-3c4e-4783-a992-168aeb5c3f6f

author	Sascha L. Teichmann <sascha.teichmann@intevation.de>
date	Mon, 01 Aug 2011 14:58:15 +0000
parents	f61fe8b561d2
children	db86c665ab6e

rev	line source
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	1 package de.intevation.flys.artifacts.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	2
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	3 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	4 import java.util.List;
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	5
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	6 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	7 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	8 import java.sql.Types;
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	9
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 import de.intevation.artifacts.GlobalContext;
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	11 import de.intevation.artifacts.ArtifactCollection;
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	12 import de.intevation.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	13
983 4ea5f5a2284e Ajusted datacage to use the SQL infrastructure from the artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 982 diff changeset	14 import de.intevation.artifactdatabase.db.SQL;
4ea5f5a2284e Ajusted datacage to use the SQL infrastructure from the artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 982 diff changeset	15 import de.intevation.artifactdatabase.db.SQLExecutor;
4ea5f5a2284e Ajusted datacage to use the SQL infrastructure from the artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 982 diff changeset	16
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	17 import de.intevation.artifactdatabase.LifetimeListener;
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	18 import de.intevation.artifactdatabase.BackendListener;
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	19 import de.intevation.artifactdatabase.Backend;
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	20
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	21 import de.intevation.artifactdatabase.data.StateData;
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	22
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	23 import de.intevation.artifactdatabase.state.Output;
992 5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	24 import de.intevation.artifactdatabase.state.Facet;
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	25
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	26 import de.intevation.artifacts.Artifact;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	27 import de.intevation.artifacts.ArtifactDatabase;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	28 import de.intevation.artifacts.ArtifactDatabaseException;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	29
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	30 import de.intevation.flys.artifacts.FLYSArtifact;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	31
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	32 import de.intevation.artifacts.common.utils.LRUCache;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	33
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	34 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	35
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	36 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	37
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	38 public class Datacage
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	39 implements LifetimeListener, BackendListener
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	40 {
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	41 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	42
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	43 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	44 "global.datacage.instance";
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	45
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	46 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	47 "global.artifact.database";
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	48
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	49 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	50 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	51 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	52 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	53 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	54 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	55 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	56 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	57 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	58 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	59 "collection.item.id.nextval";
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	60 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	61 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	62 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	63 private String SQL_ARTIFACT_DATA_ID_NEXTVAL = "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	64 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	65 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	66 private String SQL_INSERT_OUT = "insert.out";
992 5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	67 private String SQL_FACET_ID_NEXTVAL = "facet.id.nextval";
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	68 private String SQL_INSERT_FACET = "insert.facet";
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	69
983 4ea5f5a2284e Ajusted datacage to use the SQL infrastructure from the artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 982 diff changeset	70 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	71
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	72 public class InitialScan
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	73 implements ArtifactDatabase.ArtifactLoadedCallback
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	74 {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	75 protected LRUCache<String, Integer> users;
986 70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	76 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	77 protected LRUCache<String, Integer> artifacts;
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	78
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	79 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	80
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	81 public InitialScan() {
986 70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	82 users = new LRUCache<String, Integer>();
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	83 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	84 artifacts = new LRUCache<String, Integer>();
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	85 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	86
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	87 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	88 this();
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	89 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	90 }
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	91
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	92 @Override
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	93 public void artifactLoaded(
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	94 String userId,
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	95 String collectionId,
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	96 String artifactId,
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	97 Artifact artifact
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 if (!(artifact instanceof FLYSArtifact)) {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	100 log.warn("ignoring none FLYS artifacts");
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	101 return;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	102 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	103
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	104 FLYSArtifact flysArtifact = (FLYSArtifact)artifact;
986 70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	105
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	106 Integer uId = getUserId(userId);
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	107 // TODO: We need the name of the collection
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	108 Integer cId = getCollectionId(collectionId, uId, "XXX");
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	109
988 dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	110 storeArtifact(artifactId, cId, flysArtifact);
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	111 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	112
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	113 protected Integer getId(
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	114 LRUCache<String, Integer> cache,
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	115 final String idString,
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	116 final String selectById
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	117 ) {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	118 Integer id = cache.get(idString);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	119 if (id != null) {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	120 return id;
986 70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	121 }
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	122
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	123 final Integer [] res = new Integer[1];
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	124
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	125 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	126 @Override
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	127 public boolean doIt() throws SQLException {
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	128 prepareStatement(selectById);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	129 stmnt.setString(1, idString);
986 70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	130 result = stmnt.executeQuery();
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	131 if (!result.next()) {
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	132 return false;
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	133 }
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	134 res[0] = result.getInt(1);
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	135 return true;
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	136 }
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	137 };
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	138
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	139 if (exec.runRead()) {
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	140 cache.put(idString, res[0]);
986 70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	141 return res[0];
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	142 }
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	143
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	144 return null;
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	145 }
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	146
988 dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	147 protected void storeArtifact(
989 f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	148 final String artifactId,
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	149 Integer collectionId,
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	150 final FLYSArtifact artifact
988 dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	151 ) {
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	152 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	153
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	154 if (aId != null) {
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	155 // 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	156 storeCollectionItem(collectionId, aId);
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	157 return;
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	158 }
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	159 // 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	160
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	161 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	162
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	163 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	164 @Override
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	165 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	166 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	167 result = stmnt.executeQuery();
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	168 if (!result.next()) {
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	169 return false;
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	170 }
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	171 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	172 reset();
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	173 prepareStatement(SQL_INSERT_ARTIFACT);
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	174 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	175 stmnt.setString(2, artifactId);
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	176 stmnt.setString(3, artifact.getCurrentStateId());
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	177 stmnt.execute();
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	178 conn.commit();
989 f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	179 return true;
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	180 }
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	181 };
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	182
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	183 if (!exec.runWrite()) {
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	184 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	185 return;
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	186 }
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	187
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	188 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	189
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	190 storeCollectionItem(collectionId, aId);
f3be883325ce Add artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 988 diff changeset	191
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	192 storeData(aId, artifact);
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	193
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	194 storeOuts(aId, artifact);
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	195 }
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	196
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	197 protected void storeOuts(
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	198 final int artifactId,
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	199 final FLYSArtifact artifact
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	200 ) {
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	201 final List<Output> outs = artifact.getCurrentOutputs(context);
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	202
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	203 if (outs.isEmpty()) {
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	204 return;
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	205 }
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	206
992 5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	207 final int [] outIds = new int[outs.size()];
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	208
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	209 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	210 @Override
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	211 public boolean doIt() throws SQLException {
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	212 prepareStatement(SQL_OUT_ID_NEXTVALUE);
992 5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	213 for (int i = 0; i < outIds.length; ++i) {
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	214 result = stmnt.executeQuery();
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	215 if (!result.next()) {
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	216 log.error("generation of out ids failed");
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	217 return false;
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	218 }
992 5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	219 outIds[i] = result.getInt(1);
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	220 result.close(); result = null;
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	221 }
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	222 reset();
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	223 prepareStatement(SQL_INSERT_OUT);
992 5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	224 for (int i = 0; i < outIds.length; ++i) {
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	225 Output out = outs.get(i);
992 5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	226 stmnt.setInt(1, outIds[i]);
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	227 stmnt.setInt(2, artifactId);
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	228 stmnt.setString(3, out.getName());
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	229 setString(stmnt, 4, out.getDescription());
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	230 setString(stmnt, 5, out.getType());
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	231 stmnt.execute();
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	232 }
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	233 conn.commit();
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	234 return true;
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	235 }
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	236 };
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	237
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	238 if (!exec.runWrite()) {
992 5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	239 log.error("storing artifact outs failed");
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	240 return;
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	241 }
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	242
992 5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	243 final int FACETS = numFacets(outs);
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	244
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	245 if (FACETS == 0) {
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	246 return;
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	247 }
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	248
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	249 exec = sqlExecutor.new Instance() {
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	250 @Override
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	251 public boolean doIt() throws SQLException {
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	252 int [] facetIds = new int[FACETS];
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	253 prepareStatement(SQL_FACET_ID_NEXTVAL);
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	254 for (int i = 0; i < facetIds.length; ++i) {
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	255 result = stmnt.executeQuery();
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	256 if (!result.next()) {
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	257 log.error("generation of facet ids failed");
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	258 return false;
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	259 }
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	260 facetIds[i] = result.getInt(1);
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	261 result.close(); result = null;
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	262 }
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	263 reset();
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	264 prepareStatement(SQL_INSERT_FACET);
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	265 int index = 0;
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	266 for (int i = 0, N = outs.size(); i < N; ++i) {
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	267 Output out = outs.get(i);
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	268 int outId = outIds[i];
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	269 for (Facet facet: out.getFacets()) {
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	270 stmnt.setInt(1, facetIds[index]);
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	271 stmnt.setInt(2, outId);
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	272 stmnt.setString(3, facet.getName());
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	273 stmnt.setInt(4, facet.getIndex());
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	274 stmnt.setString(5, "XXX"); // TODO: handle states
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	275 setString(stmnt, 6, facet.getDescription());
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	276 stmnt.execute();
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	277 ++index;
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	278 }
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	279 }
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	280 conn.commit();
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	281 return true;
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	282 }
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	283 };
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	284
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	285 if (!exec.runWrite()) {
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	286 log.error("storing facets failed");
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	287 }
988 dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	288 }
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	289
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	290 protected void storeData(
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	291 final int artifactId,
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	292 FLYSArtifact artifact
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	293 ) {
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	294 final Collection<StateData> data = artifact.getAllData();
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	295
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	296 if (data.isEmpty()) {
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	297 return;
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	298 }
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	299
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	300 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	301 @Override
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	302 public boolean doIt() throws SQLException {
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	303 int [] ids = new int[data.size()];
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	304 prepareStatement(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	305
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	306 for (int i = 0; i < ids.length; ++i) {
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	307 result = stmnt.executeQuery();
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	308 if (!result.next()) {
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	309 log.error("generating id for artifact data failed");
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	310 return false;
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	311 }
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	312 ids[i] = result.getInt(1);
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	313 result.close(); result = null;
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	314 }
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	315 reset();
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	316 prepareStatement(SQL_INSERT_ARTIFACT_DATA);
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	317
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	318 int i = 0;
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	319 for (StateData sd: data) {
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	320 int id = ids[i++];
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	321 stmnt.setInt(1, id);
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	322 stmnt.setInt(2, artifactId);
995 e0df86bc6d31 Added kludge for the null type information of artifact data. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 993 diff changeset	323 // XXX: Where come the nulls from?
e0df86bc6d31 Added kludge for the null type information of artifact data. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 993 diff changeset	324 String type = sd.getType();
e0df86bc6d31 Added kludge for the null type information of artifact data. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 993 diff changeset	325 if (type == null) type = "String";
e0df86bc6d31 Added kludge for the null type information of artifact data. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 993 diff changeset	326 stmnt.setString(3, type);
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	327 stmnt.setString(4, sd.getName());
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	328 setString(stmnt, 5, sd.getValue());
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	329 stmnt.execute();
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	330 }
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	331
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	332 conn.commit();
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	333 return true;
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	334 }
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	335 };
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	336
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	337 if (!exec.runWrite()) {
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	338 log.error("storing artifact data failed");
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	339 }
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	340 }
e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	341
988 dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	342 protected void storeCollectionItem(
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	343 final Integer collectionId,
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	344 final Integer artifactId
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	345 ) {
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	346 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	347 @Override
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	348 public boolean doIt() throws SQLException {
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	349 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	350 result = stmnt.executeQuery();
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	351 if (!result.next()) {
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	352 return false;
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	353 }
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	354 int ciId = result.getInt(1);
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	355 reset();
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	356 prepareStatement(SQL_INSERT_COLLECTION_ITEM);
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	357 stmnt.setInt(1, ciId);
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	358 stmnt.setInt(2, collectionId);
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	359 stmnt.setInt(3, artifactId);
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	360 stmnt.execute();
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	361 conn.commit();
988 dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	362 return true;
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	363 }
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	364 };
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	365
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	366 if (!exec.runWrite()) {
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	367 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	368 }
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	369 }
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	370
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	371 protected Integer getCollectionId(
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	372 final String collectionId,
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	373 final Integer ownerId,
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	374 final String collectionName
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	375 ) {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	376 Integer c = getId(collections, collectionId, SQL_COLLECTION_BY_GID);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	377
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	378 if (c != null) {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	379 return c;
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	380 }
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	381
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	382 final Integer [] res = new Integer[1];
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	383
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	384 SQLExecutor.Instance exec = sqlExecutor.new Instance() {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	385 @Override
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	386 public boolean doIt() throws SQLException {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	387 prepareStatement(SQL_COLLECTION_ID_NEXTVAL);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	388 result = stmnt.executeQuery();
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	389 if (!result.next()) {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	390 return false;
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	391 }
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	392 res[0] = result.getInt(1);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	393 reset();
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	394 prepareStatement(SQL_INSERT_COLLECTION);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	395 stmnt.setInt (1, res[0]);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	396 stmnt.setString(2, collectionId);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	397 stmnt.setInt (3, ownerId);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	398 stmnt.setString(4, collectionName);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	399 stmnt.execute();
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	400 conn.commit();
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	401 return true;
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	402 }
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	403 };
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	404
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	405 if (exec.runWrite()) {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	406 collections.put(collectionId, res[0]);
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	407 return res[0];
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	408 }
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	409
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	410 return null;
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	411 }
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	412
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	413 protected Integer getUserId(final String userId) {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	414
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	415 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	416
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	417 if (u != null) {
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	418 return u;
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	419 }
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	420
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	421 final Integer [] res = new Integer[1];
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	422
82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	423 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	424 @Override
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	425 public boolean doIt() throws SQLException {
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	426 prepareStatement(SQL_USER_ID_NEXTVAL);
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	427 result = stmnt.executeQuery();
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	428 if (!result.next()) {
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	429 return false;
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	430 }
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	431 res[0] = result.getInt(1);
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	432 reset();
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	433 prepareStatement(SQL_INSERT_USER);
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	434 stmnt.setInt (1, res[0]);
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	435 stmnt.setString(2, userId);
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	436 stmnt.execute();
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	437 conn.commit();
986 70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	438 return true;
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	439 }
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	440 };
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	441
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	442 if (exec.runWrite()) {
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	443 users.put(userId, res[0]);
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	444 return res[0];
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	445 }
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	446
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	447 return null;
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	448 }
70545233f8ee Datacage: Add users at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 984 diff changeset	449
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	450 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	451 log.debug("scan");
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	452 try {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	453 adb.loadAllArtifacts(this);
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	454 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	455 catch (ArtifactDatabaseException ade) {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	456 log.error(ade);
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	457 return false;
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 return true;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	460 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	461 } // class InitialScan
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
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	464 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	465 }
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	466
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	467 @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	468 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	469 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	470 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	471 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	472 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	473 }
4ea5f5a2284e Ajusted datacage to use the SQL infrastructure from the artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 982 diff changeset	474
4ea5f5a2284e Ajusted datacage to use the SQL infrastructure from the artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 982 diff changeset	475 protected void setupSQL(SQL sql) {
987 82ef338fee91 Datacage: Add collections at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 986 diff changeset	476 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	477 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	478 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	479 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	480 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	481 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	482 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	483 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	484 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	485 SQL_COLLECTION_ITEM_ID_NEXTVAL =
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	486 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	487 SQL_INSERT_COLLECTION_ITEM =
dbe39e1fb5e7 Datacage: Add collection items at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 987 diff changeset	488 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	489 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	490 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	491 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	492 SQL_INSERT_ARTIFACT_DATA = sql.get(SQL_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	493 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	494 SQL_INSERT_OUT = sql.get(SQL_INSERT_OUT);
992 5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	495 SQL_FACET_ID_NEXTVAL = sql.get(SQL_FACET_ID_NEXTVAL);
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	496 SQL_INSERT_FACET = sql.get(SQL_INSERT_FACET);
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	497 }
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	498
992 5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	499 protected static final int numFacets(List<Output> outs) {
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	500 int sum = 0;
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	501 for (Output out: outs) {
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	502 sum += out.getFacets().size();
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	503 }
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	504 return sum;
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	505 }
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	506
5b467bc27eda Datacage: Store Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 991 diff changeset	507 protected static final void setString(
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	508 PreparedStatement stmnt,
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	509 int index,
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	510 Object value
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	511 )
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	512 throws SQLException
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	513 {
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	514 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	515 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	516 }
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	517 else {
c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	518 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	519 }
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	520 }
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	521
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	522 @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	523 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	524 log.debug("systemUp entered");
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	525 initialScan(context);
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	526 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	527 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	528 }
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	529
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	530 protected void initialScan(GlobalContext context) {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	531 log.debug("initialScan");
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	532
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	533 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	534
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	535 if (!(adbObject instanceof ArtifactDatabase)) {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	536 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	537 return;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	538 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	539
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	540 ArtifactDatabase adb = (ArtifactDatabase)adbObject;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	541
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	542 if (!cleanDatabase()) {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	543 log.error("cleaning database failed");
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	544 return;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	545 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	546
991 c675b4a87201 Store outs of artifacts into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 990 diff changeset	547 InitialScan is = new InitialScan(context);
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	548
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	549 if (!is.scan(adb)) {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	550 log.error("initial scan failed");
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	551 return;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	552 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	553
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	554 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	555
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	556 protected boolean cleanDatabase() {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	557
993 aabcca7aeb6c Fixed datacage db scheme. add some debug output. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 992 diff changeset	558 log.debug("cleanDatabase");
aabcca7aeb6c Fixed datacage db scheme. add some debug output. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 992 diff changeset	559
aabcca7aeb6c Fixed datacage db scheme. add some debug output. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 992 diff changeset	560 boolean success = sqlExecutor.new Instance() {
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	561 @Override
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	562 public boolean doIt() throws SQLException {
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	563 prepareStatement(SQL_DELETE_ALL_USERS);
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	564 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	565 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	566 stmnt.execute();
990 e573c4715d81 Add artifacts data into datacage db at initial scan. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 989 diff changeset	567 conn.commit();
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	568 return true;
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	569 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	570 }.runWrite();
993 aabcca7aeb6c Fixed datacage db scheme. add some debug output. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 992 diff changeset	571
aabcca7aeb6c Fixed datacage db scheme. add some debug output. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 992 diff changeset	572 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	573
aabcca7aeb6c Fixed datacage db scheme. add some debug output. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 992 diff changeset	574 return success;
984 2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	575 }
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	576
2b05c4a0c6fd Datacage: clear database before initial scan Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 983 diff changeset	577
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	578 @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	579 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	580 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	581 }
999 b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	582
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	583 @Override
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	584 public void setup(GlobalContext globalContext) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	585 log.debug("setup");
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	586 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	587
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	588 @Override
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	589 public void createdArtifact(Artifact artifact, Backend backend) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	590 log.debug("createdArtifact");
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	591 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	592
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	593 @Override
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	594 public void storedArtifact(Artifact artifact, Backend backend) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	595 log.debug("storedArtifact");
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	596 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	597
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	598 @Override
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	599 public void createdUser(User user, Backend backend) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	600 log.debug("createdUser");
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	601 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	602
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	603 @Override
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	604 public void deletedUser(String identifier, Backend backend) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	605 log.debug("deletedUser");
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	606 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	607
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	608 @Override
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	609 public void createdCollection(
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	610 ArtifactCollection collection,
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	611 Backend backend
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	612 ) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	613 log.debug("createdCollection");
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	614 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	615
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	616 @Override
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	617 public void deletedCollection(String identifier, Backend backend) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	618 log.debug("deletedCollection");
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
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	621 @Override
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	622 public void changedCollectionAttribute(
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	623 String identifier,
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	624 Document document,
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	625 Backend backend
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	626 ) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	627 log.debug("changedCollectionAttribute");
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	628 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	629
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	630 @Override
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	631 public void changedCollectionItemAttribute(
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	632 String collectionId,
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	633 String artifactId,
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	634 Document document,
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	635 Backend backend
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	636 ) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	637 log.debug("changedCollectionItemAttribute");
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	638 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	639
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	640 @Override
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	641 public void addedArtifactToCollection(
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	642 String artifactId,
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	643 String collectionId,
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	644 Backend backend
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	645 ) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	646 log.debug("addedArtifactToCollection");
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	647 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	648
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	649 @Override
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	650 public void removedArtifactFromCollection(
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	651 String artifactId,
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	652 String collectionId,
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	653 Backend backend
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	654 ) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	655 log.debug("removedArtifactFromCollection");
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	656 }
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	657
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	658 @Override
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	659 public void setCollectionName(
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	660 String collectionId,
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	661 String name
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	662 ) {
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	663 log.debug("setCollectionName");
b0218f21c664 Wire datacage with backend of artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 996 diff changeset	664 }
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	665 }
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	666 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :

Mercurial > dive4elements > river

annotate flys-artifacts/src/main/java/de/intevation/flys/artifacts/datacage/Datacage.java @ 999:b0218f21c664