1 files changed, 73 insertions, 0 deletions
diff --git a/eaaf_core/src/main/java/at/gv/egiz/eaaf/core/impl/idp/process/dao/ProcessInstanceStoreDAOImpl.java b/eaaf_core/src/main/java/at/gv/egiz/eaaf/core/impl/idp/process/dao/ProcessInstanceStoreDAOImpl.java
new file mode 100644
index 00000000..be80a629
--- /dev/null
+++ b/eaaf_core/src/main/java/at/gv/egiz/eaaf/core/impl/idp/process/dao/ProcessInstanceStoreDAOImpl.java
@@ -0,0 +1,73 @@
+/*******************************************************************************
+ *******************************************************************************/
+package at.gv.egiz.eaaf.core.impl.idp.process.dao;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import at.gv.egiz.eaaf.core.api.idp.process.ProcessInstanceStoreDAO;
+import at.gv.egiz.eaaf.core.api.storage.ITransactionStorage;
+import at.gv.egiz.eaaf.core.exceptions.EAAFException;
+
+/**
+ * Database backed implementation of the {@link ProcessInstanceStoreDAO}
+ * interface.
+ */
+@Service("ProcessInstanceStoreage")
+public class ProcessInstanceStoreDAOImpl implements ProcessInstanceStoreDAO {
+
+	private Logger log = LoggerFactory.getLogger(getClass());
+
+	@Autowired ITransactionStorage transactionStorage;
+	
+	@Override
+	public void saveOrUpdate(ProcessInstanceStore pIStore) throws EAAFException {
+		try {
+			transactionStorage.put(pIStore.getProcessInstanceId(), pIStore, -1);
+			log.debug("Store process instance with='{}' in the database.", pIStore.getProcessInstanceId());
+			
+		} catch (EAAFException e) {
+			log.warn("ProcessInstanceStore could not be persisted to the database.");
+			throw e;
+		}
+	}
+
+	@Override
+	public ProcessInstanceStore load(String processInstanceId) throws EAAFException {
+		log.debug("Retrieve the ProcessInstanceStore for id='{}' from the database.", processInstanceId);
+		ProcessInstanceStore result = null;
+		try {
+			result = transactionStorage.get(processInstanceId, ProcessInstanceStore.class);
+
+		} catch (Exception e) {
+			log.error("There are multiple persisted processes with the same process instance id '{}'",
+				processInstanceId);
+
+			throw e;
+		}
+			
+		if (result != null) {
+			log.debug("Found process instance store for instance '{}'.", processInstanceId);
+			
+		} else {
+			log.debug("Unable to find process instance store for instance '{}'.", processInstanceId);
+			
+		}
+		
+		return result;
+	}
+
+	@Override
+	public void remove(String processInstanceId) throws EAAFException {
+
+		log.debug("Delete the ProcessInstanceStore for id='{}' from the database.", processInstanceId);		
+				
+		if (transactionStorage.containsKey(processInstanceId))
+			transactionStorage.remove(processInstanceId);
+		else 
+			log.trace("ProcessInstanceStore for id='{}' was not found and could therefore not be deleted.", processInstanceId);
+	}
+
+}