lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2017-01-10 20:01:09 +08:00
parent 8bab9ad22b
commit c590d45ce0
3 changed files with 13 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/org/redkale/source/EntityInfo.java
View File

@@ -108,7 +108,7 @@ public final class EntityInfo<T> {
final BiFunction<DataSource, Class, List> fullloader;
//------------------------------------------------------------
public static <T> EntityInfo<T> load(Class<T> clazz, final int nodeid, final boolean cacheForbidden, final Properties conf,
static <T> EntityInfo<T> load(Class<T> clazz, final int nodeid, final boolean cacheForbidden, final Properties conf,
DataSource source, BiFunction<DataSource, Class, List> fullloader) {
EntityInfo rs = entityInfos.get(clazz);
if (rs != null) return rs;
@@ -127,7 +127,7 @@ public final class EntityInfo<T> {
}
}
public static <T> EntityInfo<T> get(Class<T> clazz) {
static <T> EntityInfo<T> get(Class<T> clazz) {
return entityInfos.get(clazz);
}

7
test/org/redkale/test/source/CacheTestBean.java
View File

@@ -5,6 +5,7 @@
*/
package org.redkale.test.source;
import java.lang.reflect.Method;
import java.util.*;
import java.util.function.BiFunction;
import javax.persistence.Id;
@@ -35,7 +36,11 @@ public class CacheTestBean {
Attribute nameattr = Attribute.create(CacheTestBean.class, "name");
Attribute priceattr = Attribute.create(CacheTestBean.class, "price");
BiFunction<DataSource, Class, List> fullloader = (s, z) -> list;
EntityCache<CacheTestBean> cache = new EntityCache(EntityInfo.load(CacheTestBean.class, 0, true, new Properties(), null, fullloader));
Method method = EntityInfo.class.getDeclaredMethod("load", Class.class, int.class, boolean.class, Properties.class,
DataSource.class, BiFunction.class);
method.setAccessible(true);
final EntityInfo<CacheTestBean> info = (EntityInfo<CacheTestBean>) method.invoke(null, CacheTestBean.class, 0, true, new Properties(), null, fullloader);
EntityCache<CacheTestBean> cache = new EntityCache(info);
cache.fullLoad();
System.out.println(cache.queryColumnMap("pkgid", FilterFunc.COUNT, "name", null));

7
test/org/redkale/test/source/TestSourceCache.java
View File

@@ -5,6 +5,7 @@
*/
package org.redkale.test.source;
import java.lang.reflect.Method;
import java.util.*;
import org.redkale.source.VirtualEntity;
import org.redkale.source.FilterNodeBean;
@@ -43,8 +44,10 @@ public class TestSourceCache {
public static void main(String[] args) throws Exception {
final BiFunction<DataSource, Class, List> fullloader = (DataSource t, Class u) -> null;
final EntityInfo<TestEntity> info = EntityInfo.load(TestEntity.class, 0, false, new Properties(), null, fullloader);
Method method = EntityInfo.class.getDeclaredMethod("load", Class.class, int.class, boolean.class, Properties.class,
DataSource.class, BiFunction.class);
method.setAccessible(true);
final EntityInfo<TestEntity> info = (EntityInfo<TestEntity>) method.invoke(null, TestEntity.class, 0, false, new Properties(), null, fullloader);
TestEntity[] entitys = new TestEntity[10_0000];
for (int i = 0; i < entitys.length; i++) {
entitys[i] = new TestEntity(i + 1, "用户_" + (i + 1));