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

comparison artifact-database/src/main/java/de/intevation/artifactdatabase/Backend.java @ 311:1d517e051e95

Made backend listeners loadable at boot time. artifacts/trunk@2436 c6561f87-3c4e-4783-a992-168aeb5c3f6f

author	Sascha L. Teichmann <sascha.teichmann@intevation.de>
date	Mon, 01 Aug 2011 14:17:09 +0000
parents	63122b9dee1d
children	fa056f9c8a0c

comparison

equal deleted inserted replaced

-:63122b9dee1d
+:1d517e051e95
 public void addListener(BackendListener listener) {
 listeners.add(listener);
 }
+public void addAllListeners(List<BackendListener> others) {
+listeners.addAll(others);
+}
 /**
 * Sets the factory lookup mechanism to decouple ArtifactDatabase
 * and Backend.
 * @param factoryLookup
 */
 if (!exec.runWrite()) {
 throw new RuntimeException("failed insert artifact into database");
 }
-fireArtifactStored(artifact);
+fireCreatedArtifact(artifact);
 return id[0];
 }
-protected void fireArtifactStored(Artifact artifact) {
+protected void fireCreatedArtifact(Artifact artifact) {
 for (BackendListener listener: listeners) {
-listener.artifactStored(artifact, this);
+listener.createdArtifact(artifact, this);
 }
 }
 /**
 * Touches the access timestamp of a given artifact to prevent
 return true;
 }
 }.runWrite();
 if (success) {
-fireArtifactStored(artifact.getArtifact());
+fireStoredArtifact(artifact.getArtifact());
 }
 }
+protected void fireStoredArtifact(Artifact artifact) {
+for (BackendListener listener: listeners) {
+listener.storedArtifact(artifact, this);
+}
+}
 public User createUser(
 final String      name,
 final Document    role,
 final UserFactory factory,
 identifier, name, role, context);
 return true;
 }
 };
-return exec.runWrite() ? user[0] : null;
+boolean success = exec.runWrite();
+if (success) {
+fireCreatedUser(user[0]);
+return user[0];
+}
+return null;
+}
+protected void fireCreatedUser(User user) {
+for (BackendListener listener: listeners) {
+listener.createdUser(user, this);
+}
 }
 public boolean deleteUser(final String identifier) {
 if (!isValidIdentifier(identifier)) {
 conn.commit();
 return true;
 }
 };
-return exec.runWrite();
+boolean success = exec.runWrite();
+if (success) {
+fireDeletedUser(identifier);
+}
+return success;
+}
+protected void fireDeletedUser(String identifier) {
+for (BackendListener listener: listeners) {
+listener.deletedUser(identifier, this);
+}
 }
 public User getUser(
 final String      identifier,
 final UserFactory factory,
 return true;
 }
 };
-return exec.runWrite() ? collection[0]: null;
+boolean success = exec.runWrite();
+if (success) {
+fireCreatedCollection(collection[0]);
+return collection[0];
+}
+return null;
+}
+protected void fireCreatedCollection(ArtifactCollection collection) {
+for (BackendListener listener: listeners) {
+listener.createdCollection(collection, this);
+}
 }
 public ArtifactCollection getCollection(
 final String                    collectionId,
 final ArtifactCollectionFactory collectionFactory,
 stmnt.execute();
 conn.commit();
 return true;
 }
 };
-return exec.runWrite();
+boolean success = exec.runWrite();
+if (success) {
+fireDeletedCollection(collectionId);
+}
+return success;
+}
+protected void fireDeletedCollection(String identifier) {
+for (BackendListener listener: listeners) {
+listener.deletedCollection(identifier, this);
+}
 }
 public Document getCollectionAttribute(final String collectionId) {
 if (!isValidIdentifier(collectionId)) {
 logger.debug("collection id is not valid: " + collectionId);
 return false;
 }
 final byte [] data = XMLUtils.toByteArray(attribute, true);
-return sqlExecutor.new Instance() {
+boolean success = sqlExecutor.new Instance() {
 public boolean doIt() throws SQLException {
 // set the column in collection items
 prepareStatement(SQL_COLLECTION_SET_ATTRIBUTE);
 if (data == null) {
 conn.commit();
 return true;
 }
 }.runWrite();
+if (success) {
+fireChangedCollectionAttribute(collectionId, attribute);
+}
+return success;
+}
+protected void fireChangedCollectionAttribute(
+String   collectionId,
+Document document
+) {
+for (BackendListener listener: listeners) {
+listener.changedCollectionAttribute(collectionId, document, this);
+}
 }
 public Document getCollectionItemAttribute(
 final String collectionId,
 final String artifactId
 return false;
 }
 final byte [] data = XMLUtils.toByteArray(attribute, true);
-return sqlExecutor.new Instance() {
+boolean success = sqlExecutor.new Instance() {
 public boolean doIt() throws SQLException {
 // set the column in collection items
 prepareStatement(SQL_COLLECTION_ITEM_SET_ATTRIBUTE);
 if (data == null) {
 conn.commit();
 return true;
 }
 }.runWrite();
+if (success) {
+fireChangedCollectionItemAttribute(
+collectionId, artifactId, attribute);
+}
+return success;
+}
+protected void fireChangedCollectionItemAttribute(
+String collectionId,
+String artifactId,
+Document document
+) {
+for (BackendListener listener: listeners) {
+listener.changedCollectionItemAttribute(
+collectionId, artifactId, document, this);
+}
 }
 public boolean addCollectionArtifact(
 final String   collectionId,
 final String   artifactId,
 conn.commit();
 return true;
 }
 };
-return exec.runWrite();
+boolean success = exec.runWrite();
+if (success) {
+fireAddedArtifactToCollection(artifactId, collectionId);
+}
+return success;
+}
+protected void fireAddedArtifactToCollection(
+String artifactId,
+String collectionId
+) {
+for (BackendListener listener: listeners) {
+listener.addedArtifactToCollection(
+artifactId, collectionId, this);
+}
 }
 public boolean removeCollectionArtifact(
 final String collectionId,
 final String artifactId
 ) {
 if (!isValidIdentifier(collectionId)) {
 logger.debug("Invalid collection id: '" + collectionId + "'");
 return false;
 }
-return sqlExecutor.new Instance() {
+boolean success = sqlExecutor.new Instance() {
 public boolean doIt() throws SQLException {
 // fetch id, collection id and artitfact id
 prepareStatement(SQL_COLLECTION_ITEM_ID_CID_AID);
 stmnt.setString(1, collectionId);
 conn.commit();
 return true;
 }
 }.runWrite();
+if (success) {
+fireRemovedArtifactFromCollection(artifactId, collectionId);
+}
+return success;
+}
+protected void fireRemovedArtifactFromCollection(
+String artifactId,
+String collectionId
+) {
+for (BackendListener listener: listeners) {
+listener.removedArtifactFromCollection(
+artifactId, collectionId, this);
+}
 }
 public CollectionItem [] listCollectionArtifacts(
 final String collectionId
 ) {
 if (!isValidIdentifier(uuid)) {
 logger.debug("Invalid collection id: '" + uuid + "'");
 return false;
 }
-return sqlExecutor.new Instance() {
+boolean success = sqlExecutor.new Instance() {
 public boolean doIt() throws SQLException {
 prepareStatement(SQL_UPDATE_COLLECTION_NAME);
 stmnt.setString(1, name);
 stmnt.setString(2, uuid);
 stmnt.execute();
 conn.commit();
 return true;
 }
 }.runWrite();
+if (success) {
+fireSetCollectionName(uuid, name);
+}
+return success;
+}
+protected void fireSetCollectionName(String identifier, String name) {
+for (BackendListener listener: listeners) {
+listener.setCollectionName(identifier, name);
+}
 }
 public boolean loadAllArtifacts(final ArtifactLoadedCallback alc) {
 logger.debug("loadAllArtifacts");

Mercurial > dive4elements > framework

comparison artifact-database/src/main/java/de/intevation/artifactdatabase/Backend.java @ 311:1d517e051e95