dive4elements/framework: artifact-database/src/main/java/de/intevation/artifactdatabase/Backend.java annotate

annotate artifact-database/src/main/java/de/intevation/artifactdatabase/Backend.java @ 138:b90e831d3dfe

Call database to create a new user. artifacts/trunk@1363 c6561f87-3c4e-4783-a992-168aeb5c3f6f

author	Sascha L. Teichmann <sascha.teichmann@intevation.de>
date	Wed, 02 Mar 2011 11:24:03 +0000
parents	2950c6011afa
children	5369582d4fbf

rev	line source
100 933bbc9fc11f Added license file and license headers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 93 diff changeset	1 /*
933bbc9fc11f Added license file and license headers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 93 diff changeset	2 * Copyright (c) 2010 by Intevation GmbH
933bbc9fc11f Added license file and license headers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 93 diff changeset	3 *
933bbc9fc11f Added license file and license headers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 93 diff changeset	4 * This program is free software under the LGPL (>=v2.1)
933bbc9fc11f Added license file and license headers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 93 diff changeset	5 * Read the file LGPL.txt coming with the software for details
933bbc9fc11f Added license file and license headers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 93 diff changeset	6 * or visit http://www.gnu.org/licenses/ if it does not exist.
933bbc9fc11f Added license file and license headers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 93 diff changeset	7 */
933bbc9fc11f Added license file and license headers. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 93 diff changeset	8
13 0d6badf6af42 Added not yet working backend to artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	9 package de.intevation.artifactdatabase;
0d6badf6af42 Added not yet working backend to artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	10
0d6badf6af42 Added not yet working backend to artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	11 import de.intevation.artifacts.Artifact;
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	12 import de.intevation.artifacts.ArtifactFactory;
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	13 import de.intevation.artifacts.ArtifactSerializer;
133 2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	14 import de.intevation.artifacts.User;
13 0d6badf6af42 Added not yet working backend to artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	15
138 b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	16 import de.intevation.artifacts.common.utils.XMLUtils;
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	17
93 e27cf9c84eb8 Unified imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 90 diff changeset	18 import java.sql.Connection;
e27cf9c84eb8 Unified imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 90 diff changeset	19 import java.sql.PreparedStatement;
e27cf9c84eb8 Unified imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 90 diff changeset	20 import java.sql.ResultSet;
e27cf9c84eb8 Unified imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 90 diff changeset	21 import java.sql.SQLException;
e27cf9c84eb8 Unified imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 90 diff changeset	22 import java.sql.Types;
e27cf9c84eb8 Unified imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 90 diff changeset	23
e27cf9c84eb8 Unified imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 90 diff changeset	24 import javax.sql.DataSource;
e27cf9c84eb8 Unified imports. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 90 diff changeset	25
17 5a6b6a3debc7 Integrated logging into artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 15 diff changeset	26 import org.apache.log4j.Logger;
5a6b6a3debc7 Integrated logging into artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 15 diff changeset	27
133 2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	28 import org.w3c.dom.Document;
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	29
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	30
13 0d6badf6af42 Added not yet working backend to artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	31 /**
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	32 * The backend implements the low level layer used to store artifacts
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	33 * in a SQL database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	34 *
79 f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	35 * @author <a href="mailto:sascha.teichmann@intevation.de">Sascha L. Teichmann</a>
13 0d6badf6af42 Added not yet working backend to artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	36 */
0d6badf6af42 Added not yet working backend to artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	37 public class Backend
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	38 implements DatabaseCleaner.ArtifactReviver
13 0d6badf6af42 Added not yet working backend to artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	39 {
17 5a6b6a3debc7 Integrated logging into artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 15 diff changeset	40 private static Logger logger = Logger.getLogger(Backend.class);
5a6b6a3debc7 Integrated logging into artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 15 diff changeset	41
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	42 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	43 * The SQL statement to create new artifact id inside the database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	44 */
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	45 public static final String SQL_NEXT_ID =
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	46 SQL.get("artifacts.id.nextval");
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	47
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	48 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	49 * The SQL statement to insert an artifact into the database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	50 */
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	51 public static final String SQL_INSERT =
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	52 SQL.get("artifacts.insert");
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	53
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	54 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	55 * The SQL statement to update some columns of an existing
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	56 * artifact in the database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	57 */
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	58 public static final String SQL_UPDATE =
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	59 SQL.get("artifacts.update");
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	60
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	61 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	62 * The SQL statement to touch the access time of an
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	63 * artifact inside the database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	64 */
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	65 public static final String SQL_TOUCH =
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	66 SQL.get("artifacts.touch");
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	67
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	68 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	69 * The SQL statement to load an artifact by a given
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	70 * identifier from the database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	71 */
15 9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	72 public static final String SQL_LOAD_BY_GID =
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	73 SQL.get("artifacts.select.gid");
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	74
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	75 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	76 * The SQL statement to get the database id of an artifact
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	77 * identified by the identifier.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	78 */
80 8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	79 public static final String SQL_GET_ID =
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	80 SQL.get("artifacts.get.id");
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	81
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	82 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	83 * The SQL statement to replace the content of an
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	84 * existing artifact inside the database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	85 */
80 8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	86 public static final String SQL_REPLACE =
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	87 SQL.get("artifacts.replace");
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	88
133 2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	89 // USER SQL
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	90
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	91 public static final String SQL_USERS_NEXT_ID =
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	92 SQL.get("users.id.nextval");
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	93
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	94 public static final String SQL_USERS_INSERT =
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	95 SQL.get("users.insert");
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	96
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	97 public static final String SQL_USERS_SELECT_GID =
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	98 SQL.get("users.select.gid");
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	99
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	100 public static final String SQL_USERS_DELETE_ID =
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	101 SQL.get("users.delete.id");
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	102
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	103 public static final String SQL_USERS_DELETE_COLLECTIONS =
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	104 SQL.get("users.delete.collections");
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	105
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	106 public static final String SQL_USER_SELECT_ALL =
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	107 SQL.get("users.select.all");
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	108
128 bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	109 /** The singleton.*/
bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	110 protected static Backend instance;
bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	111
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	112 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	113 * The database cleaner. Reference is stored here because
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	114 * the cleaner is woken up if the backend finds an outdated
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	115 * artifact. This artifact should be removed as soon as
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	116 * possible.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	117 */
30 88972c6daa4f Added a cleanup thread which periodically removes Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 27 diff changeset	118 protected DatabaseCleaner cleaner;
88972c6daa4f Added a cleanup thread which periodically removes Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 27 diff changeset	119
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	120 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	121 * To revive an artifact from the bytes coming from the database
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	122 * we need the artifact factory which references the artifact
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	123 * serializer which is able to do the reviving job.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	124 */
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	125 protected FactoryLookup factoryLookup;
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	126
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	127 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	128 * Little helper interface to decouple the ArtifactDatabase
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	129 * from the Backend. A ArtifactDatabase should depend on a
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	130 * Backend but a Backend not from an ArtifactDatabase.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	131 */
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	132 public interface FactoryLookup {
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	133
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	134 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	135 * Returns an ArtifactFactory which is bound to a given name.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	136 * @param factoryName The name of the artifact factory.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	137 * @return The ArtifactFactory bound to the factory name or
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	138 * null if not matching factory is found.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	139 */
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	140 ArtifactFactory getArtifactFactory(String factoryName);
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	141
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	142 } // interface FactoryLookup
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	143
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	144 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	145 * Inner class that brigdes between the persisten form of the
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	146 * artifact and the living one inside the artifact database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	147 * After the describe(), feed(), advance() and out() operations
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	148 * of the artifact it must be possible to write to modified artifact
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	149 * back into the database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	150 */
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	151 public final class PersistentArtifact
c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	152 extends Id
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	153 {
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	154 private Artifact artifact;
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	155 private ArtifactSerializer serializer;
84 72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	156 private Long ttl;
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	157
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	158 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	159 * Cronstructor to create a persistent artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	160 * @param artifact The living artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	161 * @param serializer The serializer to store the artifact
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	162 * after the operations.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	163 * @param ttl The time to life of the artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	164 * @param id The database id of the artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	165 */
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	166 public PersistentArtifact(
47 4ae4dc99127d Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 46 diff changeset	167 Artifact artifact,
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	168 ArtifactSerializer serializer,
84 72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	169 Long ttl,
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	170 int id
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	171 ) {
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	172 super(id);
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	173 this.artifact = artifact;
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	174 this.serializer = serializer;
84 72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	175 this.ttl = ttl;
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	176 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	177
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	178 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	179 * Returns the wrapped living artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	180 * @return the living artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	181 */
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	182 public Artifact getArtifact() {
c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	183 return artifact;
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	184 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	185
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	186 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	187 * Returns the serialized which is able to write a
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	188 * modified artifact back into the database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	189 * @return The serializer.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	190 */
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	191 public ArtifactSerializer getSerializer() {
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	192 return serializer;
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	193 }
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	194
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	195 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	196 * The time to life of the artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	197 * @return The time to live.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	198 */
84 72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	199 public Long getTTL() {
72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	200 return ttl;
72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	201 }
72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	202
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	203 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	204 * Stores the living artifact back into the database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	205 */
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	206 public void store() {
38 93edc04f3a10 Added postgresql support. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 34 diff changeset	207 if (logger.isDebugEnabled()) {
93edc04f3a10 Added postgresql support. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 34 diff changeset	208 logger.debug("storing artifact id = " + getId());
93edc04f3a10 Added postgresql support. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 34 diff changeset	209 }
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	210 Backend.this.store(this);
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	211 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	212
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	213 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	214 * Only touches the access time of the artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	215 */
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	216 public void touch() {
38 93edc04f3a10 Added postgresql support. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 34 diff changeset	217 if (logger.isDebugEnabled()) {
93edc04f3a10 Added postgresql support. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 34 diff changeset	218 logger.debug("touching artifact id = " + getId());
93edc04f3a10 Added postgresql support. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 34 diff changeset	219 }
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	220 Backend.this.touch(this);
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	221 }
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	222 } // class ArtifactWithId
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	223
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	224 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	225 * Default constructor
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	226 */
13 0d6badf6af42 Added not yet working backend to artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	227 public Backend() {
0d6badf6af42 Added not yet working backend to artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	228 }
0d6badf6af42 Added not yet working backend to artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	229
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	230 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	231 * Constructor to create a backend with a link to the database cleaner.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	232 * @param cleaner The clean which periodically removes outdated
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	233 * artifacts from the database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	234 */
30 88972c6daa4f Added a cleanup thread which periodically removes Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 27 diff changeset	235 public Backend(DatabaseCleaner cleaner) {
88972c6daa4f Added a cleanup thread which periodically removes Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 27 diff changeset	236 this.cleaner = cleaner;
88972c6daa4f Added a cleanup thread which periodically removes Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 27 diff changeset	237 }
88972c6daa4f Added a cleanup thread which periodically removes Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 27 diff changeset	238
128 bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	239
bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	240 /**
bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	241 * Returns the singleton of this Backend.
bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	242 *
bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	243 * @return the backend.
bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	244 */
bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	245 public static synchronized Backend getInstance() {
bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	246 if (instance == null) {
bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	247 instance = new Backend();
bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	248 }
bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	249
bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	250 return instance;
bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	251 }
bfa65a812c7a Made the backend singleton. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 100 diff changeset	252
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	253 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	254 * Sets the factory lookup mechanism to decouple ArtifactDatabase
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	255 * and Backend.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	256 * @param factoryLookup
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	257 */
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	258 public void setFactoryLookup(FactoryLookup factoryLookup) {
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	259 this.factoryLookup = factoryLookup;
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	260 }
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	261
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	262 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	263 * Sets the database cleaner explicitly.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	264 * @param cleaner The database cleaner
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	265 */
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	266 public void setCleaner(DatabaseCleaner cleaner) {
c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	267 this.cleaner = cleaner;
c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	268 }
c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	269
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	270 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	271 * Returns a new unique identifier to external identify
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	272 * the artifact across the system. This implementation
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	273 * uses random UUIDs v4 to achieve this target.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	274 * @return the new identifier
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	275 */
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	276 public String newIdentifier() {
c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	277 // TODO: check database for collisions.
79 f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	278 return StringUtils.newUUID();
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	279 }
c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	280
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	281 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	282 * Stores a new artifact into the database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	283 * @param artifact The artifact to be stored
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	284 * @param factory The factory which build the artifact
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	285 * @param ttl The initial time to life of the artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	286 * @return A persistent wrapper around the living
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	287 * artifact to be able to write modification later.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	288 * @throws Exception Thrown if something went wrong with the
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	289 * storage process.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	290 */
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	291 public PersistentArtifact storeInitially(
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	292 Artifact artifact,
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	293 ArtifactFactory factory,
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	294 Long ttl
47 4ae4dc99127d Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 46 diff changeset	295 )
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	296 throws Exception
c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	297 {
c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	298 return new PersistentArtifact(
c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	299 artifact,
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	300 factory.getSerializer(),
84 72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	301 ttl,
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	302 insertDatabase(artifact, factory, ttl));
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	303 }
47 4ae4dc99127d Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 46 diff changeset	304
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	305 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	306 * Stores an artifact into database if it does not exist there.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	307 * If it exists there it is only updated.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	308 * @param artifact The artifact to store/update.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	309 * @param factory The factory which created the artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	310 * @param ttl The initial time to live of the artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	311 * @return A persistent version of the artifact to be able
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	312 * to store a modification later.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	313 * @throws Exception Thrown if something went wrong during
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	314 * storing/updating.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	315 */
80 8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	316 public PersistentArtifact storeOrReplace(
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	317 Artifact artifact,
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	318 ArtifactFactory factory,
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	319 Long ttl
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	320 )
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	321 throws Exception
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	322 {
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	323 return new PersistentArtifact(
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	324 artifact,
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	325 factory.getSerializer(),
84 72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	326 ttl,
80 8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	327 storeOrReplaceDatabase(artifact, factory, ttl));
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	328 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	329
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	330 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	331 * Implementors of this interface are able to process the raw
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	332 * artifact data from the database for loading.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	333 */
79 f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	334 public interface ArtifactLoader {
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	335
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	336 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	337 * Creates a custom object from the raw artifact database data.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	338 * @param factory The factory that created this artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	339 * @param ttl The current time to life of the artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	340 * @param bytes The raw artifact bytes from the database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	341 * @param id The database id of the artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	342 * @return The custom object created by the implementation.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	343 */
84 72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	344 Object load(ArtifactFactory factory, Long ttl, byte [] bytes, int id);
79 f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	345
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	346 } // interface ArtifactLoader
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	347
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	348 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	349 * Fetches an artifact from the database identified by the
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	350 * given identifier.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	351 * @param identifer The identifier of the artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	352 * @return A persistent wrapper around the found artifact
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	353 * to be able to write back a modifaction later or null
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	354 * if no artifact is found for this identifier.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	355 */
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	356 public PersistentArtifact getArtifact(String identifer) {
15 9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	357
79 f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	358 return (PersistentArtifact)loadArtifact(
86 b2e0cb83631c Removed trailing whitespace Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 84 diff changeset	359 identifer,
79 f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	360 new ArtifactLoader() {
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	361
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	362 public Object load(
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	363 ArtifactFactory factory,
84 72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	364 Long ttl,
79 f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	365 byte [] bytes,
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	366 int id
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	367 ) {
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	368 ArtifactSerializer serializer = factory.getSerializer();
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	369
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	370 Artifact artifact = serializer.fromBytes(bytes);
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	371
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	372 return artifact == null
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	373 ? null
84 72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	374 : new PersistentArtifact(artifact, serializer, ttl, id);
79 f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	375 }
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	376 });
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	377 }
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	378
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	379 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	380 * More general loading mechanism for artifacts. The concrete
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	381 * load processing is delegated to the given loader.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	382 * @param identifer The identifier of the artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	383 * @param loader The loader which processes the raw database data.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	384 * @return The object created by the loader.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	385 */
79 f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	386 public Object loadArtifact(String identifer, ArtifactLoader loader) {
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	387
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	388 if (!StringUtils.checkUUID(identifer)) {
15 9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	389 return null;
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	390 }
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	391
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	392 Connection connection = null;
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	393 PreparedStatement stmnt_load = null;
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	394 ResultSet load_result = null;
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	395
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	396 DataSource dataSource = DBConnection.getDataSource();
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	397 try {
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	398 connection = dataSource.getConnection();
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	399 stmnt_load = connection.prepareStatement(SQL_LOAD_BY_GID);
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	400 stmnt_load.setString(1, identifer);
15 9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	401
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	402 load_result = stmnt_load.executeQuery();
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	403
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	404 if (!load_result.next()) {
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	405 return null;
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	406 }
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	407
84 72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	408 int id = load_result.getInt(1);
72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	409 long ttlX = load_result.getLong(3);
15 9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	410
84 72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	411 Long ttl = load_result.wasNull() ? null : Long.valueOf(ttlX);
72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	412
72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	413 if (ttl != null) { // real time to life
15 9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	414 long last_access = load_result.getTimestamp(2).getTime();
84 72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	415 if (last_access + ttlX < System.currentTimeMillis()) {
15 9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	416 artifactOutdated(id);
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	417 return null;
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	418 }
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	419 }
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	420
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	421 String factoryName = load_result.getString(4);
15 9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	422
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	423 if (factoryLookup == null) {
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	424 logger.error("factory lookup == null");
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	425 return null;
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	426 }
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	427
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	428 ArtifactFactory factory = factoryLookup
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	429 .getArtifactFactory(factoryName);
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	430
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	431 if (factory == null) {
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	432 logger.error("factory '" + factoryName + "' not found");
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	433 return null;
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	434 }
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	435
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	436 byte [] bytes = load_result.getBytes(5);
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	437
84 72e2dd4feb31 Added the time to live of an artifact to the CallContext. Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 80 diff changeset	438 return loader.load(factory, ttl, bytes, id);
15 9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	439 }
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	440 catch (SQLException sqle) {
17 5a6b6a3debc7 Integrated logging into artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 15 diff changeset	441 logger.error(sqle.getLocalizedMessage(), sqle);
15 9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	442 }
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	443 finally {
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	444 if (load_result != null) {
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	445 try { load_result.close(); }
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	446 catch (SQLException sqle) {}
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	447 }
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	448 if (stmnt_load != null) {
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	449 try { load_result.close(); }
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	450 catch (SQLException sqle) {}
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	451 }
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	452 if (connection != null) {
47 4ae4dc99127d Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 46 diff changeset	453 try { connection.close(); }
15 9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	454 catch (SQLException sqle) {}
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	455 }
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	456 }
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	457 return null;
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	458 }
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	459
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	460 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	461 * Called if the load mechanism found an outdated artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	462 * It wakes up the database cleaner.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	463 * @param id The id of the outdated artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	464 */
15 9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	465 protected void artifactOutdated(int id) {
79 f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	466 if (logger.isDebugEnabled()) {
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	467 logger.info("artifactOutdated: id = " + id);
f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	468 }
30 88972c6daa4f Added a cleanup thread which periodically removes Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 27 diff changeset	469 if (cleaner != null) {
88972c6daa4f Added a cleanup thread which periodically removes Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 27 diff changeset	470 cleaner.wakeup();
88972c6daa4f Added a cleanup thread which periodically removes Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 27 diff changeset	471 }
15 9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	472 }
9ad6ec2d09c3 Implemented restoring artifacts from database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 14 diff changeset	473
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	474 public Artifact reviveArtifact(String factoryName, byte [] bytes) {
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	475 if (factoryLookup == null) {
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	476 logger.error("reviveArtifact: factory lookup == null");
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	477 return null;
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	478 }
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	479 ArtifactFactory factory = factoryLookup
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	480 .getArtifactFactory(factoryName);
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	481
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	482 if (factory == null) {
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	483 logger.error(
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	484 "reviveArtifact: no factory '" + factoryName + "' found");
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	485 return null;
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	486 }
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	487
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	488 ArtifactSerializer serializer = factory.getSerializer();
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	489
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	490 return serializer.fromBytes(bytes);
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	491 }
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	492
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	493 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	494 * Internal method to store/replace an artifact inside the database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	495 * If an artifact with the given identifier does not exists it is
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	496 * created else only the content data is updated.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	497 * @param artifact The artifact to be store/update inside the database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	498 * @param factory The factory that created the artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	499 * @param ttl The initial time to life of the artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	500 * @return The database id of the stored/updated artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	501 */
80 8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	502 protected int storeOrReplaceDatabase(
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	503 Artifact artifact,
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	504 ArtifactFactory factory,
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	505 Long ttl
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	506 ) {
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	507 String uuid = artifact.identifier();
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	508
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	509 if (!StringUtils.checkUUID(uuid)) {
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	510 throw new RuntimeException("No valid UUID");
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	511 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	512
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	513 Connection connection = null;
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	514 PreparedStatement stmnt = null;
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	515 ResultSet result = null;
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	516
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	517 DataSource dataSource = DBConnection.getDataSource();
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	518 try {
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	519 connection = dataSource.getConnection();
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	520 try {
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	521 connection.setAutoCommit(false);
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	522
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	523 stmnt = connection.prepareStatement(SQL_GET_ID);
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	524
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	525 stmnt.setString(1, uuid);
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	526 result = stmnt.executeQuery();
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	527
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	528 Integer ID = result.next()
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	529 ? Integer.valueOf(result.getInt(1))
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	530 : null;
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	531
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	532 result.close(); result = null;
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	533 stmnt.close(); stmnt = null;
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	534
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	535 if (ID != null) { // already in database
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	536 int id = ID.intValue();
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	537
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	538 stmnt = connection.prepareStatement(SQL_REPLACE);
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	539
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	540 if (ttl == null) {
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	541 stmnt.setNull(1, Types.BIGINT);
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	542 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	543 else {
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	544 stmnt.setLong(1, ttl.longValue());
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	545 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	546
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	547 stmnt.setString(2, factory.getName());
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	548 stmnt.setBytes(
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	549 3,
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	550 factory.getSerializer().toBytes(artifact));
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	551 stmnt.setInt(4, id);
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	552
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	553 stmnt.execute();
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	554 connection.commit();
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	555 return id;
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	556 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	557
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	558 stmnt = connection.prepareStatement(SQL_NEXT_ID);
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	559 result = stmnt.executeQuery();
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	560
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	561 if (!result.next()) {
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	562 throw new RuntimeException("No id generated");
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	563 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	564
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	565 int id = result.getInt(1);
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	566
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	567 result.close(); result = null;
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	568 stmnt.close(); stmnt = null;
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	569
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	570 stmnt = connection.prepareStatement(SQL_INSERT);
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	571
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	572 stmnt.setInt(1, id);
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	573 stmnt.setString(2, uuid);
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	574 if (ttl == null) {
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	575 stmnt.setNull(3, Types.BIGINT);
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	576 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	577 else {
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	578 stmnt.setLong(3, ttl.longValue());
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	579 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	580
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	581 stmnt.setString(4, factory.getName());
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	582
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	583 stmnt.setBytes(
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	584 5,
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	585 factory.getSerializer().toBytes(artifact));
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	586
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	587 stmnt.execute();
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	588 connection.commit();
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	589 return id;
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	590 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	591 catch (SQLException sqle) {
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	592 connection.rollback();
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	593 throw sqle;
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	594 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	595 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	596 catch (SQLException sqle) {
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	597 logger.error(sqle.getLocalizedMessage(), sqle);
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	598 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	599 finally {
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	600 if (result != null) {
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	601 try { result.close(); }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	602 catch (SQLException sqle) {}
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	603 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	604 if (stmnt != null) {
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	605 try { stmnt.close(); }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	606 catch (SQLException sqle) {}
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	607 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	608 if (connection != null) {
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	609 try { connection.close(); }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	610 catch (SQLException sqle) {}
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	611 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	612 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	613 throw new RuntimeException("failed insert artifact into database");
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	614 }
8447467cef86 Implementation to import artifacts from incoming xml documents (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 79 diff changeset	615
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	616 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	617 * Internal method to store an artifact inside the database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	618 * @param artifact The artifact to be stored.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	619 * @param factory The factory which created the artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	620 * @param ttl The initial time to live of the artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	621 * @return The database id of the stored artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	622 */
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	623 protected int insertDatabase(
47 4ae4dc99127d Removed trailing whitespace. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 46 diff changeset	624 Artifact artifact,
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	625 ArtifactFactory factory,
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	626 Long ttl
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	627 ) {
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	628 String uuid = artifact.identifier();
c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	629
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	630 Connection connection = null;
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	631 PreparedStatement stmnt_next_id = null;
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	632 PreparedStatement stmnt_insert = null;
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	633 ResultSet res_id = null;
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	634
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	635 DataSource dataSource = DBConnection.getDataSource();
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	636 try {
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	637 connection = dataSource.getConnection();
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	638 try {
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	639 connection.setAutoCommit(false);
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	640
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	641 stmnt_next_id = connection.prepareStatement(SQL_NEXT_ID);
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	642 stmnt_insert = connection.prepareStatement(SQL_INSERT);
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	643
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	644 res_id = stmnt_next_id.executeQuery();
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	645
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	646 if (!res_id.next()) {
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	647 throw new RuntimeException("No id generated");
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	648 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	649
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	650 int id = res_id.getInt(1);
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	651
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	652 stmnt_insert.setInt(1, id);
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	653 stmnt_insert.setString(2, uuid);
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	654 if (ttl == null) {
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	655 stmnt_insert.setNull(3, Types.BIGINT);
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	656 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	657 else {
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	658 stmnt_insert.setLong(3, ttl.longValue());
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	659 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	660
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	661 stmnt_insert.setString(4, factory.getName());
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	662
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	663 stmnt_insert.setBytes(
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	664 5,
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	665 factory.getSerializer().toBytes(artifact));
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	666
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	667 stmnt_insert.execute();
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	668
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	669 connection.commit();
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	670
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	671 return id;
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	672 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	673 catch (SQLException sqle) {
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	674 connection.rollback();
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	675 throw sqle;
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	676 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	677 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	678 catch (SQLException sqle) {
17 5a6b6a3debc7 Integrated logging into artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 15 diff changeset	679 logger.error(sqle.getLocalizedMessage(), sqle);
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	680 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	681 finally {
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	682 if (res_id != null) {
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	683 try { res_id.close(); }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	684 catch (SQLException sqle) {}
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	685 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	686 if (stmnt_insert != null) {
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	687 try { stmnt_insert.close(); }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	688 catch (SQLException sqle) {}
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	689 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	690 if (stmnt_next_id != null) {
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	691 try { stmnt_next_id.close(); }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	692 catch (SQLException sqle) {}
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	693 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	694 if (connection != null) {
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	695 try { connection.close(); }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	696 catch (SQLException sqle) {}
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	697 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	698 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	699 throw new RuntimeException("failed insert artifact into database");
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	700 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	701
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	702 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	703 * Touches the access timestamp of a given artifact to prevent
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	704 * that it will be removed from the database by the database cleaner.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	705 * @param artifact The persistent wrapper around the living artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	706 */
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	707 public void touch(PersistentArtifact artifact) {
26 83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	708
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	709 try {
26 83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	710 Connection connection = null;
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	711 PreparedStatement stmnt_touch = null;
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	712 DataSource dataSource = DBConnection.getDataSource();
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	713 try {
26 83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	714 connection = dataSource.getConnection();
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	715 try {
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	716 connection.setAutoCommit(false);
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	717 stmnt_touch = connection.prepareStatement(SQL_TOUCH);
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	718 stmnt_touch.setInt(1, artifact.getId());
26 83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	719 stmnt_touch.execute();
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	720 connection.commit();
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	721 }
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	722 catch (SQLException sqle) {
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	723 connection.rollback();
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	724 }
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	725 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	726 catch (SQLException sqle) {
26 83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	727 logger.error(sqle.getLocalizedMessage(), sqle);
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	728 }
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	729 finally {
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	730 if (stmnt_touch != null) {
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	731 try { stmnt_touch.close(); }
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	732 catch (SQLException sqle) {}
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	733 }
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	734 if (connection != null) {
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	735 try { connection.close(); }
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	736 catch (SQLException sqle) {}
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	737 }
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	738 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	739 }
26 83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	740 catch (Exception e) {
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	741 logger.error(e.getLocalizedMessage(), e);
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	742 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	743 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	744
90 68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	745 /**
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	746 * Writes modification of an artifact back to the database.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	747 * @param artifact The persistent wrapper around a living
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	748 * artifact.
68285f7bc476 More javadoc. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 86 diff changeset	749 */
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	750 public void store(PersistentArtifact artifact) {
26 83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	751
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	752 try {
26 83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	753 Connection connection = null;
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	754 PreparedStatement stmnt_update = null;
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	755 DataSource dataSource = DBConnection.getDataSource();
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	756 try {
26 83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	757 connection = dataSource.getConnection();
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	758 try {
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	759 connection.setAutoCommit(false);
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	760 stmnt_update = connection.prepareStatement(SQL_UPDATE);
32 c2d53bd30ab8 Re-factored artifact API for better integration of background processing. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 31 diff changeset	761 stmnt_update.setInt(2, artifact.getId());
26 83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	762
41 5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	763 byte [] bytes = artifact
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	764 .getSerializer()
5e4bc24ea438 Made serilization more flexible. DB update required!!! Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 38 diff changeset	765 .toBytes(artifact.getArtifact());
26 83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	766
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	767 stmnt_update.setBytes(1, bytes);
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	768 stmnt_update.execute();
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	769 connection.commit();
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	770 }
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	771 catch (SQLException sqle) {
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	772 connection.rollback();
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	773 }
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	774 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	775 catch (SQLException sqle) {
26 83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	776 logger.error(sqle.getLocalizedMessage(), sqle);
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	777 }
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	778 finally {
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	779 if (stmnt_update != null) {
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	780 try { stmnt_update.close(); }
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	781 catch (SQLException sqle) {}
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	782 }
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	783 if (connection != null) {
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	784 try { connection.close(); }
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	785 catch (SQLException sqle) {}
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	786 }
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	787 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	788 }
26 83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	789 catch (Exception e) {
83a059c204f8 Connected /create with artifact db. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 24 diff changeset	790 logger.error(e.getLocalizedMessage(), e);
14 0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	791 }
0d16d1bb2df0 Initial checkin of artigact persistents back by database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 13 diff changeset	792 }
133 2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	793
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	794 public User createUser(
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	795 String name,
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	796 Document role
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	797 ) {
138 b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	798 Connection connection = null;
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	799 PreparedStatement stmnt_next_id = null;
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	800 PreparedStatement stmnt_insert = null;
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	801 ResultSet res_id = null;
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	802
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	803 String identifier = newIdentifier();
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	804
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	805 DataSource dataSource = DBConnection.getDataSource();
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	806 try {
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	807 connection = dataSource.getConnection();
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	808 try {
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	809 connection.setAutoCommit(false);
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	810
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	811 stmnt_next_id = connection.prepareStatement(SQL_USERS_NEXT_ID);
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	812 stmnt_insert = connection.prepareStatement(SQL_USERS_INSERT);
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	813
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	814 res_id = stmnt_next_id.executeQuery();
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	815
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	816 if (!res_id.next()) {
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	817 throw new RuntimeException("No id generated");
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	818 }
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	819
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	820 int id = res_id.getInt(1);
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	821
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	822 stmnt_insert.setInt(1, id);
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	823 stmnt_insert.setString(2, identifier);
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	824 stmnt_insert.setString(3, name);
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	825
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	826 byte [] roleData = role == null
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	827 ? null
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	828 : XMLUtils.toByteArray(role);
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	829
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	830 if (roleData == null) {
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	831 stmnt_insert.setNull(4, Types.BIGINT);
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	832 }
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	833 else {
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	834 stmnt_insert.setBytes(4, roleData);
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	835 }
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	836
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	837 stmnt_insert.execute();
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	838
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	839 connection.commit();
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	840
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	841 return new DefaultUser(identifier, name, role);
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	842 }
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	843 catch (SQLException sqle) {
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	844 connection.rollback();
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	845 throw sqle;
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	846 }
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	847 }
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	848 catch (SQLException sqle) {
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	849 logger.error(sqle.getLocalizedMessage(), sqle);
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	850 }
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	851 finally {
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	852 if (res_id != null) {
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	853 try { res_id.close(); }
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	854 catch (SQLException sqle) {}
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	855 }
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	856 if (stmnt_insert != null) {
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	857 try { stmnt_insert.close(); }
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	858 catch (SQLException sqle) {}
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	859 }
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	860 if (stmnt_next_id != null) {
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	861 try { stmnt_next_id.close(); }
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	862 catch (SQLException sqle) {}
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	863 }
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	864 if (connection != null) {
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	865 try { connection.close(); }
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	866 catch (SQLException sqle) {}
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	867 }
b90e831d3dfe Call database to create a new user. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 133 diff changeset	868 }
133 2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	869 return null;
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	870 }
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	871
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	872 public void deleteUser(User user) {
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	873 // TODO: implement me!
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	874 }
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	875
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	876 public User getUser(String identifier) {
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	877 // TODO: implement me!
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	878 return null;
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	879 }
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	880
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	881 public User [] getUsers() {
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	882 // TODO: implement me!
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	883 return null;
2950c6011afa Fixed typo in keys. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 128 diff changeset	884 }
13 0d6badf6af42 Added not yet working backend to artifact database. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	885 }
79 f69e5b87f05f Implementation to export artifacts as xml (applied patch from issue208 by SLT). Ingo Weinzierl <ingo.weinzierl@intevation.de> parents: 47 diff changeset	886 // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :

Mercurial > dive4elements > framework

annotate artifact-database/src/main/java/de/intevation/artifactdatabase/Backend.java @ 138:b90e831d3dfe