/eu.etaxonomy.taxeditor.cdmlib/src/main/java/eu/etaxonomy/taxeditor/remoting/cache/CacheLoader.java - Diff - EDIT - EDIT Project Management

« Previous | Next »

Revision ba0d4c2f

Added by Cherian Mathew about 9 years ago

ID ba0d4c2faae1f477febf98e247678497f0b4d877
Parent 348d552a
Child 07cebe78

httpInvokerServiceClients.xml : set 'CdmServiceRequestExecutor' class as default for all services
ICdmEntitySession, CdmEntitySession, MockCdmEntitySession : added method to update session
ICdmEntitySessionManager, CdmEntitySessionManager, MockCdmEntitySessionManager : added methods to set active session, dispose and update sessions
ProxyUtils : added utility method
EntityCacherDebugResult : corrected method to determine cache corresponding to entity
CdmTransientEntityCacher : corrected put method
CacheLoader : optimised recursive call
CdmServiceCacher : corrected methods to get from cache and load
CdmServiceRequestExecutor : added update result return calls to load

     import java.util.Map;
     import java.util.Set;
     import javassist.util.proxy.ProxyFactory;
     import net.sf.ehcache.Cache;
     import net.sf.ehcache.Element;
     import org.apache.log4j.Logger;
     import org.hibernate.collection.spi.PersistentCollection;
     import org.hibernate.proxy.HibernateProxy;
     import org.hibernate.proxy.LazyInitializer;
     import org.springframework.util.ReflectionUtils;
-...
         private static boolean isRecursiveEnabled = true;
         private final ICdmCacher cdmCacher;
         protected final ICdmCacher cdmCacher;
         private final Cache cdmlibModelCache;
         private final ICdmCacher cdmServiceCacher;
         public CacheLoader(ICdmCacher cdmCacher) {
             this(cdmCacher, null);
+        }
         public CacheLoader(ICdmCacher cdmCacher, ICdmCacher cdmServiceCacher) {
             this.cdmCacher = cdmCacher;
             this.cdmlibModelCache = CdmRemoteCacheManager.getInstance().getCdmModelGetMethodsCache();
             this.cdmServiceCacher = cdmServiceCacher;
+        }
-...
                 return null;
+            }
             // start by looking up the cdm entity in the cache
             CdmBase cachedCdmEntity = cdmCacher.getFromCache(cdmEntity);
-...
                 if(cachedCdmEntity == cdmEntity) {
                     return cachedCdmEntity;
+                }
+            }
             CdmBase loadedCdmBase;
-...
+        }
         private CdmBase load(CdmBase cdmEntity) {
         protected CdmBase load(CdmBase cdmEntity) {
             logger.info("loading object of type " + cdmEntity.getClass().getName() + " with id " + cdmEntity.getId());
             cdmEntity = (CdmBase)ProxyUtils.deproxy(cdmEntity);
             // start by looking up the cdm entity in the cache
             CdmBase cachedCdmEntity = cdmCacher.getFromCache(cdmEntity);
             cdmCacher.put(cdmEntity);
             return cdmCacher.getFromCache(cdmEntity);
             if(cachedCdmEntity != null) {
                 // if cdm entity was found in cache then return ...
                 logger.info(" - object of type " + cdmEntity.getClass().getName() + " with id " + cdmEntity.getId() + " already exists");
                 return cachedCdmEntity;
             } else {
                 // ... else save the entity in the cache
                 cdmCacher.put(cdmEntity);
                 logger.info(" - object of type " + cdmEntity.getClass().getName() + " with id " + cdmEntity.getId() + " put in cache");
                 return cdmEntity;
+            }
+        }
         private CdmBase loadRecursive(CdmBase cdmEntity,  Set<Object> alreadyVisitedEntities, boolean update) {
             CdmBase cachedCdmEntity = load(cdmEntity);
             if(cdmServiceCacher != null && cdmServiceCacher.exists(cachedCdmEntity)) {
                 return cachedCdmEntity;
+            }
             // we want to recursive through the cdmEntity (and not the cachedCdmEntity)
             // since there could be new or deleted objects in the cdmEntity sub-graph
-...
                         } else {
                             logger.info("object of type " + cdmEntityInSubGraph.getClass().getName() + " with id " + cdmEntityInSubGraph.getId() + " already visited");
+                        }
+                    }
+                }
             } else {
                 throw new CdmClientCacheException("CdmEntity with class " + cdmEntity.getClass().getName() + " is not found in the cdmlib model cache. " +
                         "The cache may be corrupted or not in sync with the latest model version" );
+            }
             return cachedCdmEntity;
+        }
-...
+                }
                 field.setAccessible(true);
                 Object o = field.get(cdmEntity);
                 if(o != null && o instanceof HibernateProxy) {
                     LazyInitializer hli = ((HibernateProxy)o).getHibernateLazyInitializer();
                     if(!hli.isUninitialized()) {
                         o = ((HibernateProxy) o).getHibernateLazyInitializer().getImplementation();
                         field.set(cdmEntity, o);
+                    }
+                }
                 if(o != null && o instanceof PersistentCollection) {
                     PersistentCollection pc = ((PersistentCollection)o);
                     if(pc.wasInitialized()) {
                         o = ProxyUtils.getObject(pc);
                         field.set(cdmEntity, o);
+                    }
+                }
                 o = ProxyUtils.deproxy(o);
                 field.set(cdmEntity, o);
                 CdmBase cdmEntityInSubGraph = null;
                 if(update) {
                     // making sure that the field in cached cdm entity is always
                     // up-to-date by setting to the value of the cdm entity being loaded
                     // the only exception to this is found below
                     field.set(cachedCdmEntity, o);
+                }
                 if(o != null
                         && !ProxyFactory.isProxyClass(o.getClass())
                         && !(o instanceof PersistentCollection) ) {
                         // if we are in update mode we have to make the field of the cached entity
                         // up-to-date by setting it to the value of the cdm entity being loaded
                         // NOTE : two exceptions to this are found below
                         field.set(cachedCdmEntity, o);
+                }
                 if(o != null && !ProxyUtils.isProxy(o)) {
                     if(CdmBase.class.isAssignableFrom(o.getClass())) {
                         logger.info("found initialised cdm entity '" + fieldName + "' in object of type " + clazz.getName() + " with id " + cdmEntity.getId());
                         cdmEntityInSubGraph  = (CdmBase)o;
                         CdmBase cachedCdmEntityInSubGraph = cdmCacher.getFromCache(cdmEntityInSubGraph);
                         // the only exception to updating the field to the latest value
                         // is the case where the field has been already initialised, cached and
                         // is not the same as the one in the cache, in which case we set the value
                         // of the field to the one found in the cache
                         Object oldCachedCdmEntityInSubGraph = field.get(cachedCdmEntity);
                         if(ProxyUtils.isProxy(oldCachedCdmEntityInSubGraph)) {
                             LazyInitializer hli =
                                     ((HibernateProxy)oldCachedCdmEntityInSubGraph).getHibernateLazyInitializer();
                             if(cdmEntityInSubGraph.getId() == ((Integer)hli.getIdentifier()).intValue()) {
                                 // exception 1 : is the case where
                                 // the earlier value of the field in the cached entity
                                 // was a proxy with the same id then we don't need to
                                 // update it here as it will be updated on demand,
                                 // so we reset it to the earlier proxy
                                 field.set(cachedCdmEntity, oldCachedCdmEntityInSubGraph);
                                 return null;
+                            }
+                        }
                         if(cachedCdmEntityInSubGraph != null) {
                             if(cachedCdmEntityInSubGraph != cdmEntityInSubGraph) {
                                 // exception 2 : is the case where
                                 // the field has been already initialised, cached and
                                 // is not the same as the one in the cache, in which case we set the value
                                 // of the field to the one found in the cache
                                 logger.info("setting cached + real value to '" + fieldName + "' in object of type " + clazz.getName() + " with id " + cdmEntity.getId());
                                 field.set(cachedCdmEntity, cachedCdmEntityInSubGraph);
                                 field.set(cdmEntity, cachedCdmEntityInSubGraph);
                             } else {
                                 // hack to stop the recursion, since the field value object in cdmEntity
                                 // since the field value object in cdmEntity
                                 // is the same as the field value object in cachedCdmEntity
                                 cdmEntityInSubGraph = null;
                                 // we are sure that the its subgraph is also correctly loaded,
                                 // so we can exit the recursion
                                 return null;
+                            }
+                        }
                     } else if(o instanceof Map && !alreadyVisitedEntities.contains(o)) {
                         loadRecursive((Map)o, alreadyVisitedEntities, update);
                     } else if(o instanceof Collection && !alreadyVisitedEntities.contains(o)) {

Also available in: Unified diff

Project

General

Profile

EDIT

Revision ba0d4c2f

Added by Cherian Mathew about 9 years ago