diff --git a/src/main/java/io/ebeaninternal/api/LoadManyRequest.java b/src/main/java/io/ebeaninternal/api/LoadManyRequest.java index 0e234536f..043f51e58 100644 --- a/src/main/java/io/ebeaninternal/api/LoadManyRequest.java +++ b/src/main/java/io/ebeaninternal/api/LoadManyRequest.java @@ -169,7 +169,7 @@ public class LoadManyRequest extends LoadRequest { Object parentId = desc.getId(ownerBean); logger.debug("BeanCollection after lazy load was empty. type:" + ownerBean.getClass().getName() + " id:" + parentId + " owner:" + ownerBean); } - } else if (isLoadCache()) { + } else if (isLoadCache() && many.isUseCache()) { Object parentId = desc.getId(bc.getOwnerBean()); desc.cacheManyPropPut(many, bc, parentId); } diff --git a/src/main/java/io/ebeaninternal/server/cache/CacheChangeSet.java b/src/main/java/io/ebeaninternal/server/cache/CacheChangeSet.java index b25ba9ce5..20cd7329c 100644 --- a/src/main/java/io/ebeaninternal/server/cache/CacheChangeSet.java +++ b/src/main/java/io/ebeaninternal/server/cache/CacheChangeSet.java @@ -177,7 +177,7 @@ public class CacheChangeSet { final ManyKey key; - final List removes = new ArrayList<>(); + final Set removes = new HashSet<>(); final Map puts = new LinkedHashMap<>(); diff --git a/src/main/java/io/ebeaninternal/server/core/DefaultBeanLoader.java b/src/main/java/io/ebeaninternal/server/core/DefaultBeanLoader.java index fc8d42027..faef445a6 100644 --- a/src/main/java/io/ebeaninternal/server/core/DefaultBeanLoader.java +++ b/src/main/java/io/ebeaninternal/server/core/DefaultBeanLoader.java @@ -82,7 +82,7 @@ class DefaultBeanLoader { parentDesc.contextPut(pc, parentId, parentBean); } - boolean useManyIdCache = beanCollection != null && parentDesc.isManyPropCaching(); + boolean useManyIdCache = beanCollection != null && parentDesc.isManyPropCaching() && many.isUseCache(); if (useManyIdCache) { Boolean readOnly = null; if (ebi.isReadOnly()) { diff --git a/src/main/java/io/ebeaninternal/server/deploy/BeanPropertyAssocMany.java b/src/main/java/io/ebeaninternal/server/deploy/BeanPropertyAssocMany.java index 969777472..f884bb900 100644 --- a/src/main/java/io/ebeaninternal/server/deploy/BeanPropertyAssocMany.java +++ b/src/main/java/io/ebeaninternal/server/deploy/BeanPropertyAssocMany.java @@ -226,6 +226,7 @@ public class BeanPropertyAssocMany extends BeanPropertyAssoc implements ST desc.registerTable(targetDescriptor.getBaseTable(), this); } } + /** * Return the underlying collection of beans. */ @@ -345,7 +346,7 @@ public class BeanPropertyAssocMany extends BeanPropertyAssoc implements ST /** * Add the loaded current bean to its associated parent. - * + *

* Helper method used by Elastic integration when loading with a persistence context. */ @Override @@ -967,6 +968,13 @@ public class BeanPropertyAssocMany extends BeanPropertyAssoc implements ST elementDescriptor.jsonWriteElement(ctx, element); } + /** + * Only cache Many Ids if the target bean is also cached. + */ + public boolean isUseCache() { + return targetDescriptor.isBeanCaching(); + } + /** * A Many (element collection) property in bean cache to held as JSON. */ diff --git a/src/main/java/io/ebeaninternal/server/loadcontext/DLoadManyContext.java b/src/main/java/io/ebeaninternal/server/loadcontext/DLoadManyContext.java index a1cdb0fb6..d58bcdcf0 100644 --- a/src/main/java/io/ebeaninternal/server/loadcontext/DLoadManyContext.java +++ b/src/main/java/io/ebeaninternal/server/loadcontext/DLoadManyContext.java @@ -209,7 +209,7 @@ class DLoadManyContext extends DLoadBaseContext implements LoadManyContext { public void loadMany(BeanCollection bc, boolean onlyIds) { synchronized (this) { - boolean useCache = context.hitCache && !onlyIds; + boolean useCache = !onlyIds && context.hitCache && context.property.isUseCache(); if (useCache) { EntityBean ownerBean = bc.getOwnerBean(); BeanDescriptor parentDesc = context.desc.getBeanDescriptor(ownerBean.getClass()); diff --git a/src/test/java/org/tests/cache/TestCacheCollectionIds.java b/src/test/java/org/tests/cache/TestCacheCollectionIds.java index a57908242..c57811889 100644 --- a/src/test/java/org/tests/cache/TestCacheCollectionIds.java +++ b/src/test/java/org/tests/cache/TestCacheCollectionIds.java @@ -141,11 +141,11 @@ public class TestCacheCollectionIds extends BaseTestCase { } @Test - public void testChangingCollectionByEditingConnectedBean() { + public void testChangingCollectionByEditingConnectedCachedBean() { ResetBasicData.reset(); OCachedBean cachedBean = new OCachedBean(); - cachedBean.setName("hello"); + cachedBean.setName("hello1"); Ebean.save(cachedBean); awaitL2Cache(); @@ -180,6 +180,46 @@ public class TestCacheCollectionIds extends BaseTestCase { Ebean.delete(cachedBean); } + @Test + public void testChangingCollectionByEditingConnectedNotCachedBean() { + ResetBasicData.reset(); + + OCachedBean cachedBean = new OCachedBean(); + cachedBean.setName("hello2"); + + Ebean.save(cachedBean); + awaitL2Cache(); + + OCachedBean dummyToLoad = Ebean.find(OCachedBean.class, cachedBean.getId()); + assertEquals(0, dummyToLoad.getNotCachedChildren().size()); + + OBeanChild child1=new OBeanChild(); + child1.setCachedBean(cachedBean); + Ebean.insert(child1); + awaitL2Cache(); + dummyToLoad = Ebean.find(OCachedBean.class, cachedBean.getId()); + assertEquals(1, dummyToLoad.getNotCachedChildren().size()); + + OBeanChild child2=new OBeanChild(); + child2.setCachedBean(cachedBean); + Ebean.insert(child2); + awaitL2Cache(); + dummyToLoad = Ebean.find(OCachedBean.class, cachedBean.getId()); + assertEquals(2, dummyToLoad.getNotCachedChildren().size()); + + Ebean.delete(child2); + awaitL2Cache(); + dummyToLoad = Ebean.find(OCachedBean.class, cachedBean.getId()); + assertEquals(1, dummyToLoad.getNotCachedChildren().size()); + + Ebean.delete(child1); + awaitL2Cache(); + dummyToLoad = Ebean.find(OCachedBean.class, cachedBean.getId()); + assertEquals(0, dummyToLoad.getNotCachedChildren().size()); + + Ebean.delete(cachedBean); + } + /** * When updating a ManyToMany relations also the collection cache must be updated. diff --git a/src/test/java/org/tests/model/basic/OBeanChild.java b/src/test/java/org/tests/model/basic/OBeanChild.java new file mode 100644 index 000000000..a4d8d65ee --- /dev/null +++ b/src/test/java/org/tests/model/basic/OBeanChild.java @@ -0,0 +1,38 @@ +package org.tests.model.basic; + +import io.ebean.annotation.Cache; + +import javax.persistence.Entity; +import javax.persistence.Id; +import javax.persistence.ManyToOne; +import javax.persistence.Table; + +/** + * Not cached bean (copy of {@link OCachedBeanChild}} without {@link Cache} annotation + * for testing caching implementation for relations {@link Cache} and not {@link Cache}. + */ +@Entity +@Table(name = "o_bean_child") +public class OBeanChild { + @Id + Long id; + + @ManyToOne + OCachedBean cachedBean; + + public Long getId() { + return id; + } + + public void setId(Long id) { + this.id = id; + } + + public OCachedBean getCachedBean() { + return cachedBean; + } + + public void setCachedBean(OCachedBean cachedBean) { + this.cachedBean = cachedBean; + } +} diff --git a/src/test/java/org/tests/model/basic/OCachedBean.java b/src/test/java/org/tests/model/basic/OCachedBean.java index 8e8d2a976..7879b5251 100644 --- a/src/test/java/org/tests/model/basic/OCachedBean.java +++ b/src/test/java/org/tests/model/basic/OCachedBean.java @@ -30,6 +30,9 @@ public class OCachedBean { @OneToMany(mappedBy = "cachedBean", cascade = CascadeType.ALL) List children = new ArrayList<>(); + @OneToMany(mappedBy = "cachedBean", cascade = CascadeType.ALL) + List notCachedChildren = new ArrayList<>(); + public Long getId() { return id; } @@ -61,4 +64,12 @@ public class OCachedBean { public void setChildren(List children) { this.children = children; } + + public List getNotCachedChildren() { + return notCachedChildren; + } + + public void setNotCachedChildren(List notCachedChildren) { + this.notCachedChildren = notCachedChildren; + } }