[增加]1. 增加DB数据库连接选项类

Author: AlianBlank

GameFrameX.DataBase/Abstractions/DbOptions.cs

@@ -0,0 +1,28 @@
+// GameFrameX 组织下的以及组织衍生的项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
+// 
+// 本项目主要遵循 MIT 许可证和 Apache 许可证（版本 2.0）进行分发和使用。许可证位于源代码树根目录中的 LICENSE 文件。
+// 
+// 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动！任何基于本项目二次开发而产生的一切法律纠纷和责任，我们不承担任何责任！
+
+namespace GameFrameX.DataBase.Abstractions;
+
+/// <summary>
+/// 数据库选项
+/// </summary>
+public sealed record DbOptions
+{
+    /// <summary>
+    /// 数据库类型
+    /// </summary>
+    public string Type { get; init; }
+
+    /// <summary>
+    /// 连接字符串
+    /// </summary>
+    public string ConnectionString { get; init; }
+
+    /// <summary>
+    /// 数据库名称
+    /// </summary>
+    public string Name { get; init; }
+}

GameFrameX.DataBase/Abstractions/IDatabaseService.cs

@@ -10,9 +10,9 @@ public interface IDatabaseService
     /// <summary>
     /// 链接数据库
     /// </summary>
-    /// <param name="url">链接地址</param>
-    /// <param name="dbName">数据库名称</param>
-    Task Open(string url, string dbName);
+    /// <param name="dbOptions">数据库配置选项</param>
+    /// <returns>返回数据库是否初始化成功</returns>
+    Task<bool> Open(DbOptions dbOptions);
 
     /// <summary>
     /// 关闭数据库连接

GameFrameX.DataBase/GameDB.cs

@@ -17,15 +17,16 @@ public static class GameDb
     /// 初始化GameDb
     /// </summary>
     /// <typeparam name="T">数据库服务的具体实现类型,必须实现IDatabaseService接口且有无参构造函数</typeparam>
-    /// <param name="mongoUrl">MongoDB连接URL,不能为null</param>
-    /// <param name="mongoDbName">MongoDB数据库的名称,不能为null</param>
-    /// <exception cref="ArgumentNullException">当mongoUrl或mongoDbName为null时抛出</exception>
-    public static async Task Init<T>(string mongoUrl, string mongoDbName) where T : IDatabaseService, new()
+    /// <param name="dbOptions">数据库配置选项</param>
+    /// <exception cref="ArgumentNullException">当  ConnectionString 或 Name 为null时抛出</exception>
+    /// <returns>返回数据库是否初始化成功</returns>
+    public static async Task<bool> Init<T>(DbOptions dbOptions) where T : IDatabaseService, new()
     {
-        ArgumentNullException.ThrowIfNull(mongoUrl, nameof(mongoUrl));
-        ArgumentNullException.ThrowIfNull(mongoDbName, nameof(mongoDbName));
+        ArgumentNullException.ThrowIfNull(dbOptions, nameof(dbOptions));
+        ArgumentNullException.ThrowIfNull(dbOptions.ConnectionString, nameof(dbOptions.ConnectionString));
+        ArgumentNullException.ThrowIfNull(dbOptions.Name, nameof(dbOptions.Name));
         _dbServiceImplementation = new T();
-        await _dbServiceImplementation.Open(mongoUrl, mongoDbName);
+        return await _dbServiceImplementation.Open(dbOptions);
     }
 
     /// <summary>

GameFrameX.DataBase/Mongo/MongoDbService.cs

@@ -23,24 +23,28 @@ public sealed partial class MongoDbService : IDatabaseService
     private MongoDbContext _mongoDbContext;
 
     /// <summary>
-    /// 打开MongoDB连接并指定URL和数据库名称。
+    /// 链接数据库
     /// </summary>
-    /// <param name="url">MongoDB连接URL。</param>
-    /// <param name="dbName">要使用的数据库名称。</param>
-    public async Task Open(string url, string dbName)
+    /// <param name="dbOptions">数据库配置选项</param>
+    /// <returns>返回数据库是否初始化成功</returns>
+    public async Task<bool> Open(DbOptions dbOptions)
     {
         try
         {
-            var settings = MongoClientSettings.FromConnectionString(url);
-            await DB.InitAsync(dbName, settings);
+            ArgumentNullException.ThrowIfNull(dbOptions.ConnectionString, nameof(dbOptions.ConnectionString));
+            ArgumentNullException.ThrowIfNull(dbOptions.Name, nameof(dbOptions.Name));
+            var settings = MongoClientSettings.FromConnectionString(dbOptions.ConnectionString);
+            await DB.InitAsync(dbOptions.Name, settings);
             _mongoDbContext = new MongoDbContext();
-            CurrentDatabase = DB.Database(dbName);
-            LogHelper.Info($"初始化MongoDB服务完成 Url:{url} DbName:{dbName}");
+            CurrentDatabase = DB.Database(dbOptions.Name);
+            LogHelper.Info($"初始化MongoDB服务完成 Url:{dbOptions.ConnectionString} DbName:{dbOptions.Name}");
+            return true;
         }
-        catch (Exception)
+        catch (Exception exception)
         {
-            LogHelper.Error($"初始化MongoDB服务失败 Url:{url} DbName:{dbName}");
-            throw;
+            LogHelper.Fatal(exception);
+            LogHelper.Error($"初始化MongoDB服务失败 Url:{dbOptions.ConnectionString} DbName:{dbOptions.Name}");
+            return false;
         }
     }