[增加]1. 增加数据库查询函数的自动创建参数

Author: AlianBlank

GameFrameX.DataBase/Abstractions/IDatabaseService.cs

@@ -24,17 +24,19 @@ public interface IDatabaseService
     /// </summary>
     /// <param name="id">数据的唯一ID</param>
     /// <param name="filter">查询条件</param>
+    /// <param name="isCreateIfNotExists">是否创建不存在的文档</param>
     /// <typeparam name="TState">实现ICacheState接口的类型。</typeparam>
     /// <returns>返回符合条件的数据对象</returns>
-    Task<TState> FindAsync<TState>(long id, Expression<Func<TState, bool>> filter = null) where TState : BaseCacheState, new();
+    Task<TState> FindAsync<TState>(long id, Expression<Func<TState, bool>> filter = null, bool isCreateIfNotExists = true) where TState : BaseCacheState, new();
 
     /// <summary>
     /// 查询单条数据
     /// </summary>
     /// <param name="filter">查询条件</param>
+    /// <param name="isCreateIfNotExists">是否创建不存在的文档</param>
     /// <typeparam name="TState">实现ICacheState接口的类型。</typeparam>
     /// <returns>返回符合条件的数据对象</returns>
-    Task<TState> FindAsync<TState>(Expression<Func<TState, bool>> filter) where TState : BaseCacheState, new();
+    Task<TState> FindAsync<TState>(Expression<Func<TState, bool>> filter, bool isCreateIfNotExists = true) where TState : BaseCacheState, new();
 
     /// <summary>
     /// 查询数据

GameFrameX.DataBase/GameDB.cs

@@ -136,11 +136,12 @@ public static void Close()
     /// <typeparam name="TState">文档的类型,必须继承自BaseCacheState且有无参构造函数</typeparam>
     /// <param name="id">要查找的文档ID</param>
     /// <param name="filter">可选的附加过滤条件</param>
+    /// <param name="isCreateIfNotExists">是否创建不存在的文档</param>
     /// <returns>找到的文档,如果不存在则返回新的空文档</returns>
-    public static Task<TState> FindAsync<TState>(long id, Expression<Func<TState, bool>> filter = null) where TState : BaseCacheState, new()
+    public static Task<TState> FindAsync<TState>(long id, Expression<Func<TState, bool>> filter = null, bool isCreateIfNotExists = true) where TState : BaseCacheState, new()
     {
         ArgumentNullException.ThrowIfNull(_dbServiceImplementation, nameof(_dbServiceImplementation));
-        return _dbServiceImplementation.FindAsync(id, filter);
+        return _dbServiceImplementation.FindAsync(id, filter, isCreateIfNotExists);
     }
 
     /// <summary>
@@ -149,11 +150,12 @@ public static void Close()
     /// </summary>
     /// <typeparam name="TState">文档的类型,必须继承自BaseCacheState</typeparam>
     /// <param name="filter">用于筛选文档的Lambda表达式</param>
+    /// <param name="isCreateIfNotExists">是否创建不存在的文档</param>
     /// <returns>找到的第一个匹配文档,如果没有匹配项则返回null</returns>
-    public static Task<TState> FindAsync<TState>(Expression<Func<TState, bool>> filter) where TState : BaseCacheState, new()
+    public static Task<TState> FindAsync<TState>(Expression<Func<TState, bool>> filter, bool isCreateIfNotExists = true) where TState : BaseCacheState, new()
     {
         ArgumentNullException.ThrowIfNull(_dbServiceImplementation, nameof(_dbServiceImplementation));
-        return _dbServiceImplementation.FindAsync(filter);
+        return _dbServiceImplementation.FindAsync(filter, isCreateIfNotExists);
     }
 
     /// <summary>

GameFrameX.DataBase/Mongo/MongoDbService.Query.cs

@@ -23,11 +23,17 @@ public sealed partial class MongoDbService
     /// <typeparam name="TState">缓存状态的类型，必须是BaseCacheState的子类，并具有无参数构造函数。</typeparam>
     /// <param name="id">要加载的缓存状态的ID。</param>
     /// <param name="filter">可选的过滤器，用于进一步限制查询结果的条件。</param>
+    /// <param name="isCreateIfNotExists">是否创建不存在的文档</param>
     /// <returns>加载的缓存状态，如果未找到则返回新创建的状态。</returns>
-    public async Task<TState> FindAsync<TState>(long id, Expression<Func<TState, bool>> filter = null) where TState : BaseCacheState, new()
+    public async Task<TState> FindAsync<TState>(long id, Expression<Func<TState, bool>> filter = null, bool isCreateIfNotExists = true) where TState : BaseCacheState, new()
     {
         var findExpression = GetDefaultFindExpression(filter);
         var state = await _mongoDbContext.Find<TState>().Match(findExpression).OneAsync(id);
+        if (!isCreateIfNotExists)
+        {
+            return state;
+        }
+
         var isNew = state == null;
 
         if (state == null)
@@ -38,6 +44,7 @@ public sealed partial class MongoDbService
 
         // 调用后处理方法以加载状态的其他数据
         state.LoadFromDbPostHandler(isNew);
+
         return state;
     }
 
@@ -47,11 +54,18 @@ public sealed partial class MongoDbService
     /// </summary>
     /// <typeparam name="TState">缓存状态的类型，必须是BaseCacheState的子类，并具有无参数构造函数。</typeparam>
     /// <param name="filter">查询条件，用于限制查找的结果。</param>
+    /// <param name="isCreateIfNotExists">是否创建不存在的文档</param>
     /// <returns>满足条件的缓存状态，如果未找到则返回新创建的状态。</returns>
-    public async Task<TState> FindAsync<TState>(Expression<Func<TState, bool>> filter) where TState : BaseCacheState, new()
+    public async Task<TState> FindAsync<TState>(Expression<Func<TState, bool>> filter, bool isCreateIfNotExists = true) where TState : BaseCacheState, new()
     {
         var findExpression = GetDefaultFindExpression(filter);
         var state = await _mongoDbContext.Queryable<TState>().Where(findExpression).SingleOrDefaultAsync();
+
+        if (!isCreateIfNotExists)
+        {
+            return state;
+        }
+
         var isNew = state == null;
 
         if (state == null)
@@ -62,6 +76,7 @@ public sealed partial class MongoDbService
 
         // 调用后处理方法以加载状态的其他数据
         state.LoadFromDbPostHandler(isNew);
+
         return state;
     }