X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=org.argeo.slc.hibernate%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fhibernate%2Fstructure%2Ftree%2FTreeSRegistryDaoHibernate.java;fp=org.argeo.slc.hibernate%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fhibernate%2Fstructure%2Ftree%2FTreeSRegistryDaoHibernate.java;h=fab18a19d6c17efe4b12db1ca75b038a4d3e2499;hb=12b475b97f9d3897ecb685f6ead364c8fda0cb6d;hp=0000000000000000000000000000000000000000;hpb=a32208c9fd354f253afbb8fd5cd48a455a335d6a;p=gpl%2Fargeo-slc.git

diff --git a/org.argeo.slc.hibernate/src/main/java/org/argeo/slc/hibernate/structure/tree/TreeSRegistryDaoHibernate.java b/org.argeo.slc.hibernate/src/main/java/org/argeo/slc/hibernate/structure/tree/TreeSRegistryDaoHibernate.java
new file mode 100644
index 000000000..fab18a19d
--- /dev/null
+++ b/org.argeo.slc.hibernate/src/main/java/org/argeo/slc/hibernate/structure/tree/TreeSRegistryDaoHibernate.java
@@ -0,0 +1,133 @@
+package org.argeo.slc.hibernate.structure.tree;
+
+import java.util.List;
+
+import org.springframework.orm.hibernate3.support.HibernateDaoSupport;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+import org.argeo.slc.core.structure.SimpleSElement;
+import org.argeo.slc.core.structure.StructureElement;
+import org.argeo.slc.core.structure.StructureRegistry;
+import org.argeo.slc.core.structure.tree.TreeSPath;
+import org.argeo.slc.core.structure.tree.TreeSRegistry;
+import org.argeo.slc.dao.structure.tree.TreeSPathDao;
+import org.argeo.slc.dao.structure.tree.TreeSRegistryDao;
+import org.hibernate.Session;
+
+/**
+ * The Hibernate implementation for tree-based structure registry.
+ * 
+ * @see TreeSRegistry
+ */
+public class TreeSRegistryDaoHibernate extends HibernateDaoSupport implements
+		TreeSRegistryDao {
+
+	private TreeSPathDao treeSPathDao;
+
+	private static Log log = LogFactory.getLog(TreeSRegistryDaoHibernate.class);
+
+	public void create(TreeSRegistry registry) {
+		getHibernateTemplate().save(registry);
+	}
+
+	public void update(TreeSRegistry registryArg) {
+		Session session = getSession();
+		session.beginTransaction();
+		TreeSRegistry registry = (TreeSRegistry)session.merge(registryArg);
+		session.update(registry);
+		session.getTransaction().commit();
+	}
+
+	public TreeSRegistry getActiveTreeSRegistry() {
+		List<?> list = getHibernateTemplate().find(
+				"from TreeSRegistry where status=?",
+				TreeSRegistry.STATUS_ACTIVE);
+		if (list.size() == 0) {
+			return null;
+		} else {
+			return (TreeSRegistry) list.get(0);
+		}
+	}
+
+	public void syncPath(TreeSRegistry registryArg,
+			StructureRegistry<TreeSPath> localRegistry, TreeSPath pathArg) {
+		Session session = getSession();
+		session.beginTransaction();
+		TreeSRegistry registry = (TreeSRegistry)session.merge(registryArg);
+		TreeSPath path = (TreeSPath)session.merge(pathArg);
+		if (log.isTraceEnabled())
+			log.trace("Session#" + session.hashCode() + " " + session);
+		syncPathImpl(registry, localRegistry, path, session);
+		session.update(registry);
+		session.getTransaction().commit();
+	}
+
+	private void syncPathImpl(TreeSRegistry registry,
+			StructureRegistry<TreeSPath> localRegistry, TreeSPath path,
+			Session session) {
+		if (path.getParent() != null) {
+			TreeSPath parent = treeSPathDao.getOrCreate(path.getParent());
+			syncPathImpl(registry, localRegistry, parent, session);
+		}
+
+		if (log.isTraceEnabled())
+			log.trace("Synchronize path " + path);
+
+		if (registry.getElement(path) == null) {
+			final StructureElement element = getElement(registry,
+					localRegistry, path, session);
+			StructureElement elementPersisted = (StructureElement) session
+					.merge(element);
+			registry.register(path, elementPersisted);
+			// update(registry);
+
+			if (log.isTraceEnabled())
+				log.trace("No element in persisted structure for " + path
+						+ ", merged to " + elementPersisted);
+		} else {
+			if (localRegistry != null) {
+				StructureElement element = getElement(registry, localRegistry,
+						path, session);
+
+				if (element != null) {
+					StructureElement elementPersisted = (StructureElement) session
+							.merge(element);
+					registry.register(path, elementPersisted);
+					// update(registry);
+					if (log.isTraceEnabled())
+						log
+								.trace("Update existing element in persisted structure for "
+										+ path
+										+ ", merged to "
+										+ elementPersisted);
+				}
+			}
+		}
+
+	}
+
+	public void setTreeSPathDao(TreeSPathDao treeSPathDao) {
+		this.treeSPathDao = treeSPathDao;
+	}
+
+	protected StructureElement getElement(TreeSRegistry registry,
+			StructureRegistry<TreeSPath> localRegistry, TreeSPath path,
+			Session session) {
+		StructureElement element;
+		if (localRegistry != null) {
+			element = localRegistry.getElement(path);
+			if (session.getSessionFactory()
+					.getClassMetadata(element.getClass()) == null) {
+				if (log.isTraceEnabled())
+					log.trace("Replace non-hibernate element " + element
+							+ " by a simple element.");
+				element = new SimpleSElement(element.getLabel());
+			}
+		} else {
+			element = new SimpleSElement(path.getName());
+		}
+		return element;
+	}
+}