chore: 修改名称

Author: cjbi

flexmodel-core/src/main/java/tech/wetech/flexmodel/ModelRegistry.java

@@ -0,0 +1,73 @@
+package tech.wetech.flexmodel;
+
+
+import tech.wetech.flexmodel.model.SchemaObject;
+import tech.wetech.flexmodel.session.AbstractSessionContext;
+
+import java.util.List;
+import java.util.Set;
+
+/**
+ * 模型注册表
+ * @author cjbi
+ */
+public interface ModelRegistry {
+
+  /**
+   * 从数据库中加载模型
+   *
+   * @param sqlContext
+   * @return
+   */
+  List<SchemaObject> loadFromDatabase(AbstractSessionContext sqlContext);
+
+  /**
+   * 从数据库中加载模型
+   *
+   * @param sqlContext
+   * @param includes
+   * @return
+   */
+  List<SchemaObject> loadFromDatabase(AbstractSessionContext sqlContext, Set<String> includes);
+
+  /**
+   * 获取所有已注册的模型
+   *
+   * @param schemaName
+   * @return
+   */
+  List<SchemaObject> getAllRegistered(String schemaName);
+
+  /**
+   * 注销模型
+   *
+   * @param schemaName
+   */
+  void unregister(String schemaName);
+
+  /**
+   * 注销模型
+   *
+   * @param schemaName
+   * @param modelName
+   */
+  void unregister(String schemaName, String modelName);
+
+  /**
+   * 注册模型
+   *
+   * @param schemaName
+   * @param object
+   */
+  void register(String schemaName, SchemaObject object);
+
+  /**
+   * 获取已注册的模型
+   *
+   * @param schemaName
+   * @param modelName
+   * @return
+   */
+  SchemaObject getRegistered(String schemaName, String modelName);
+
+}

flexmodel-core/src/main/java/tech/wetech/flexmodel/ModelRepository.java

@@ -0,0 +1,66 @@
+package tech.wetech.flexmodel.cache;
+
+import tech.wetech.flexmodel.ModelRegistry;
+import tech.wetech.flexmodel.model.SchemaObject;
+import tech.wetech.flexmodel.session.AbstractSessionContext;
+
+import java.util.List;
+import java.util.Set;
+
+/**
+ * @author cjbi
+ */
+public class CachingModelRegistry implements ModelRegistry {
+
+  private final ModelRegistry delegate;
+  private final Cache cache;
+
+  public CachingModelRegistry(ModelRegistry delegate, Cache cache) {
+    this.delegate = delegate;
+    this.cache = cache;
+  }
+
+  @Override
+  public List<SchemaObject> loadFromDatabase(AbstractSessionContext context) {
+    cache.invalidateAll();
+    return delegate.loadFromDatabase(context);
+  }
+
+  @Override
+  public List<SchemaObject> loadFromDatabase(AbstractSessionContext sqlContext, Set<String> includes) {
+    cache.invalidateAll();
+    return delegate.loadFromDatabase(sqlContext, includes);
+  }
+
+  @Override
+  public List<SchemaObject> getAllRegistered(String schemaName) {
+    return delegate.getAllRegistered(schemaName);
+  }
+
+  @Override
+  public void unregister(String schemaName) {
+    cache.invalidateAll();
+    delegate.unregister(schemaName);
+  }
+
+  @Override
+  public void unregister(String schemaName, String modelName) {
+    cache.invalidate(schemaName + ":" + modelName);
+    delegate.unregister(schemaName, modelName);
+  }
+
+  @Override
+  public void register(String schemaName, SchemaObject object) {
+    cache.put(schemaName + ":" + object.getName(), object);
+    delegate.register(schemaName, object);
+  }
+
+  @Override
+  public SchemaObject getRegistered(String schemaName, String modelName) {
+    return (SchemaObject) cache.retrieve(schemaName + ":" + modelName, () -> delegate.getRegistered(schemaName, modelName));
+  }
+
+  public Cache getCache() {
+    return cache;
+  }
+}

flexmodel-core/src/main/java/tech/wetech/flexmodel/cache/CachingModelRegistry.java

@@ -1,6 +1,6 @@
 package tech.wetech.flexmodel.cache;
 
-import tech.wetech.flexmodel.ModelRepository;
+import tech.wetech.flexmodel.ModelRegistry;
 import tech.wetech.flexmodel.model.SchemaObject;
 import tech.wetech.flexmodel.session.AbstractSessionContext;
 
@@ -9,23 +9,23 @@
 /**
  * @author cjbi
  */
-public class InMemoryModelRepository implements ModelRepository {
+public class InMemoryModelRegistry implements ModelRegistry {
 
   private final Map<String, Map<String, SchemaObject>> map = new HashMap<>();
 
   @Override
-  public List<SchemaObject> syncFromDatabase(AbstractSessionContext context) {
+  public List<SchemaObject> loadFromDatabase(AbstractSessionContext context) {
     // ignore
     return Collections.emptyList();
   }
 
   @Override
-  public List<SchemaObject> syncFromDatabase(AbstractSessionContext sqlContext, Set<String> includes) {
+  public List<SchemaObject> loadFromDatabase(AbstractSessionContext sqlContext, Set<String> includes) {
     return Collections.emptyList();
   }
 
   @Override
-  public List<SchemaObject> findAll(String schemaName) {
+  public List<SchemaObject> getAllRegistered(String schemaName) {
     List<SchemaObject> result = new ArrayList<>();
 
     // 从内存映射中获取
@@ -38,17 +38,17 @@ public List<SchemaObject> findAll(String schemaName) {
   }
 
   @Override
-  public void deleteAll(String schemaName) {
+  public void unregister(String schemaName) {
     map.clear();
   }
 
   @Override
-  public void delete(String schemaName, String modelName) {
+  public void unregister(String schemaName, String modelName) {
     map.get(schemaName).remove(modelName);
   }
 
   @Override
-  public void save(String schemaName, SchemaObject object) {
+  public void register(String schemaName, SchemaObject object) {
     map.compute(schemaName, (key, value) -> {
       if (value == null) {
         value = new HashMap<>();
@@ -59,7 +59,7 @@ public void save(String schemaName, SchemaObject object) {
   }
 
   @Override
-  public SchemaObject find(String schemaName, String modelName) {
+  public SchemaObject getRegistered(String schemaName, String modelName) {
     // 从内存映射中查找
     return map.getOrDefault(schemaName, Collections.emptyMap()).get(modelName);
   }

flexmodel-core/src/main/java/tech/wetech/flexmodel/cache/CachingModelRepository.java

@@ -3,7 +3,7 @@
 import com.mongodb.client.MongoDatabase;
 import tech.wetech.flexmodel.ExpressionCalculator;
 import tech.wetech.flexmodel.JsonObjectConverter;
-import tech.wetech.flexmodel.ModelRepository;
+import tech.wetech.flexmodel.ModelRegistry;
 import tech.wetech.flexmodel.model.field.ScalarType;
 import tech.wetech.flexmodel.session.AbstractSessionContext;
 import tech.wetech.flexmodel.session.SessionFactory;
@@ -21,8 +21,8 @@ public class MongoContext extends AbstractSessionContext {
   private ExpressionCalculator<String> conditionCalculator;
   private final Map<String, TypeHandler<?>> typeHandlerMap = new HashMap<>();
 
-  public MongoContext(String schemaName, MongoDatabase mongoDatabase, ModelRepository mappedModels, JsonObjectConverter jsonObjectConverter, SessionFactory factory) {
-    super(schemaName, mappedModels, jsonObjectConverter, factory);
+  public MongoContext(String schemaName, MongoDatabase mongoDatabase, ModelRegistry modelRegistry, JsonObjectConverter jsonObjectConverter, SessionFactory factory) {
+    super(schemaName, modelRegistry, jsonObjectConverter, factory);
     this.mongoDatabase = mongoDatabase;
     this.conditionCalculator = new DefaultMongoExpressionCalculator();