企業項目實戰 .Net Core + Vue/Angular 分庫分表日誌系統三 | 控制反轉搭配簡單業務

public interface ISqlSugarSetting
    {
        /// <summary>
        /// 配置名稱Kety
        /// </summary>
        string Name { get; set; }
        /// <summary>
        /// 數據庫鏈接字符串
        /// </summary>
        string ConnectionString { get; set; }
        /// <summary>
        /// 數據庫類型呢
        /// </summary>
        DbType DatabaseType { get; set; }
        /// <summary>
        /// 使用Sql執行日誌
        /// </summary>
        Action<string, SugarParameter[]> LogExecuting { get; set; }
    }
    public class SqlSugarSetting : ISqlSugarSetting
    {
        public string Name { get; set; }
        public string ConnectionString { get; set; }
        public DbType DatabaseType { get; set; }
        public Action<string, SugarParameter[]> LogExecuting { get; set; }
    }

2.而後修改咱們的 SqlSugarProvider類在構造函數傳遞配置進來。

public SqlSugarProvider(ISqlSugarSetting SugarSetting)
        {
            this.Sugar = this.CreateSqlSugar(SugarSetting);
            this.ProviderName = SugarSetting.Name;
        }

        private SqlSugarClient CreateSqlSugar(ISqlSugarSetting SugarSetting)
        {
       
            var db = new SqlSugarClient(
             new ConnectionConfig()
             {
                 ConnectionString = SugarSetting.ConnectionString,
                 DbType = SugarSetting.DatabaseType,//設置數據庫類型
                 IsAutoCloseConnection = true,//自動釋放數據務，若是存在事務，在事務結束後釋放
                 InitKeyType = InitKeyType.Attribute //從實體特性中讀取主鍵自增列信息
             });

            //用來打印Sql方便你調式    
            db.Aop.OnLogExecuting = SugarSetting.LogExecuting;
            return db;
        }

3.改造咱們的依賴注入部分。

services.AddSingleton<ISqlSugarProvider>(new SqlSugarProvider(new SqlSugarSetting() {

                Name = SqlSugarDbStorageConsts.DefaultProviderName,
                ConnectionString = @$"Data Source=",
                DatabaseType = DbType.Sqlite,
                LogExecuting = (sql, pars) =>
                {
                    Console.WriteLine($"sql:{sql}");
                }

            }));

app.Use(async (context, next) =>
    {
          var sqlStorage = app.ApplicationServices.GetService<ISqlSugarProviderStorage>();
          var sugarClient = sqlStorage.GetByName(null, SqlSugarDbStorageConsts.DefaultProviderName).Sugar;
          Console.WriteLine("查看sugarClient");
    });

4.鏈接多個數據庫。

尾聲

就這？控制反轉就實現完了，如今咱們 SqlSugar鏈接提供程序的數據庫鏈接串交給上層來提供ide

加一點業務試試

1.在EasyLogger.Api新建Model文件夾而後新建實體類

public class EasyLoggerProject
    {
        [SugarColumn(IsNullable = false, IsPrimaryKey = true, IsIdentity = true)] 
        public int Id { get; set; }
        /// <summary>
        /// 項目名稱
        /// </summary>
        public string Name { get; set; }
        /// <summary>
        /// 系統編碼
        /// </summary>
        public string Code { get; set; }

    }

2.在AppSetting.json裏面加入

"EasyLogger": {
    "DbName": "EasyLogger", // 數據庫名稱
  },

補：PathExtenstions.GetApplicationCurrentPath()方法代碼/這裏是爲了讓系統中使用的路徑統一，方便那天要改一頓Ctrl+C

return AppDomain.CurrentDomain.BaseDirectory + "../";

3.修改StartUp中咱們的連接字符串我使用的是SqlLite

var defaultDbPath = Path.Combine(PathExtenstions.GetApplicationCurrentPath(), $"{Configuration["EasyLogger:DbName"]}.db");

            services.AddSingleton<ISqlSugarProvider>(new SqlSugarProvider(new SqlSugarSetting()
            {

                Name = SqlSugarDbStorageConsts.DefaultProviderName,
                ConnectionString = @$"Data Source={defaultDbPath}",
                DatabaseType = DbType.Sqlite,
                LogExecuting = (sql, pars) =>
                {
                    Console.WriteLine($"sql:{sql}");
                }

            }));

4.判斷目錄下是否存在Db文件、若是不存在就建立數據庫/建立表

if (!File.Exists(defaultDbPath))
            {
                var db = new SqlSugarClient(new ConnectionConfig()
                {
                    ConnectionString = @$"Data Source={defaultDbPath}",
                    DbType = DbType.Sqlite,
                    IsAutoCloseConnection = true, // 自動釋放數據務，若是存在事務，在事務結束後釋放
                    InitKeyType = InitKeyType.Attribute// 從實體特性中讀取主鍵自增列信息
                });

                db.CodeFirst.BackupTable().InitTables<EasyLoggerProject>();

                db.Dispose();
            }