tiennm99/zfoo
1
0
Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-05-20 20:25:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore[orm]: comment

Browse Source
This commit is contained in:
godotg
2024-06-25 12:55:11 +08:00
parent 82b8e6211b
commit facea30fb5
2 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
orm/src/main/java/com/zfoo/orm/cache/EntityCache.java
Vendored
+2
View File
@@ -242,6 +242,8 @@ public class EntityCache<PK extends Comparable<PK>, E extends IEntity<PK>> imple
}
// 游戏中80%都是执行更新的操作，这样做会极大的提高更新速度
// 没有并发问题的entity指的是内部没有使用集合或者使用的集合全部支持并发操作
// 没有并发问题的entity还是在异步线程池Event慢慢更新，有并发问题的entity才放到原来的update线程去更新（第一次update会记录entity所在线程）
@Override
public void persistAll() {
@SuppressWarnings("unchecked")
orm/src/main/java/com/zfoo/orm/manager/OrmManager.java
+7 -7
View File
@@ -511,7 +511,7 @@ public class OrmManager implements IOrmManager {
var types = ((ParameterizedType) type).getActualTypeArguments();
// 必须声明Set的泛型类
AssertionUtils.isTrue(types.length == 1, "Set type declaration in [class:{}] is incorrect, and the generic class must be declared in [field:{}]", clazz.getCanonicalName(), field.getName());
checkSubEntity(clazz, types[0]);
hasUnsafeCollectionInner(clazz, types[0]);
} else if (List.class.isAssignableFrom(fieldType)) {
// 是一个List
hasUnsafeCollection |= unsafeCollections.contains(fieldType);
@@ -523,7 +523,7 @@ public class OrmManager implements IOrmManager {
var types = ((ParameterizedType) type).getActualTypeArguments();
AssertionUtils.isTrue(types.length == 1, "List type declaration in [class:{}] is incorrect, and the generic class must be declared in [field:{}]", clazz.getCanonicalName(), field.getName());
checkSubEntity(clazz, types[0]);
hasUnsafeCollectionInner(clazz, types[0]);
} else if (Map.class.isAssignableFrom(fieldType)) {
// 是Map接口类型
hasUnsafeCollection |= unsafeCollections.contains(fieldType);
@@ -546,7 +546,7 @@ public class OrmManager implements IOrmManager {
if (!ClassUtils.isBaseType((Class<?>) keyType)) {
throw new RunException("[class:{}] type declaration is incorrect, and the key type of the Map must be the Base type", clazz.getCanonicalName());
}
hasUnsafeCollection |= checkSubEntity(clazz, valueType);
hasUnsafeCollection |= hasUnsafeCollectionInner(clazz, valueType);
} else if (ObjectId.class.isAssignableFrom(fieldType)) {
// do nothing
} else {
@@ -558,16 +558,16 @@ public class OrmManager implements IOrmManager {
}
private boolean checkSubEntity(Class<?> currentEntityClass, Type type) {
private boolean hasUnsafeCollectionInner(Class<?> currentEntityClass, Type type) {
if (type instanceof ParameterizedType) {
// 泛型类
Class<?> clazz = (Class<?>) ((ParameterizedType) type).getRawType();
if (Set.class.isAssignableFrom(clazz)) {
// Set<Set<String>>
return unsafeCollections.contains(clazz) | checkSubEntity(currentEntityClass, ((ParameterizedType) type).getActualTypeArguments()[0]);
return unsafeCollections.contains(clazz) | hasUnsafeCollectionInner(currentEntityClass, ((ParameterizedType) type).getActualTypeArguments()[0]);
} else if (List.class.isAssignableFrom(clazz)) {
// List<List<String>>
return unsafeCollections.contains(clazz) | checkSubEntity(currentEntityClass, ((ParameterizedType) type).getActualTypeArguments()[0]);
return unsafeCollections.contains(clazz) | hasUnsafeCollectionInner(currentEntityClass, ((ParameterizedType) type).getActualTypeArguments()[0]);
} else if (Map.class.isAssignableFrom(clazz)) {
// Map<List<String>, List<String>>
var types = ((ParameterizedType) type).getActualTypeArguments();
@@ -576,7 +576,7 @@ public class OrmManager implements IOrmManager {
if (!ClassUtils.isBaseType((Class<?>) keyType)) {
throw new RunException("The key of the map in the ORM must be of the Base type");
}
return unsafeCollections.contains(clazz) | checkSubEntity(currentEntityClass, valueType);
return unsafeCollections.contains(clazz) | hasUnsafeCollectionInner(currentEntityClass, valueType);
}
} else if (type instanceof Class) {
Class<?> clazz = ((Class<?>) type);