wenyongda/ZrAdminNetCore
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update DbExtension.cs

Browse Source
This commit is contained in:
不做码农 2022-03-16 21:58:37 +08:00
parent fcd01439b6
commit 5f0334a999
1 changed files with 35 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
ZR.Admin.WebApi/Extensions/DbExtension.cs
View File

@ -28,7 +28,7 @@ namespace ZR.Admin.WebApi.Extensions
{ {
string connStr = Configuration.GetConnectionString(OptionsSetting.ConnAdmin); string connStr = Configuration.GetConnectionString(OptionsSetting.ConnAdmin);
string connStrBus = Configuration.GetConnectionString(OptionsSetting.ConnBus); string connStrBus = Configuration.GetConnectionString(OptionsSetting.ConnBus);
string dbKey = Configuration[OptionsSetting.DbKey];
int dbType = Convert.ToInt32(Configuration[OptionsSetting.ConnDbType]); int dbType = Convert.ToInt32(Configuration[OptionsSetting.ConnDbType]);
int dbType_bus = Convert.ToInt32(Configuration[OptionsSetting.ConnBusDbType]); int dbType_bus = Convert.ToInt32(Configuration[OptionsSetting.ConnBusDbType]);
@ -45,8 +45,10 @@ namespace ZR.Admin.WebApi.Extensions
IsAutoCloseConnection = true IsAutoCloseConnection = true
} }
}); });
//每次Sql执行前事件 SugarIocServices.ConfigurationSugar(db =>
DbScoped.SugarScope.GetConnection(0).Aop.OnLogExecuting = (sql, pars) => {
#region db0
db.GetConnection(0).Aop.OnLogExecuting = (sql, pars) =>
{ {
var param = DbScoped.SugarScope.Utilities.SerializeObject(pars.ToDictionary(it => it.ParameterName, it => it.Value)); var param = DbScoped.SugarScope.Utilities.SerializeObject(pars.ToDictionary(it => it.ParameterName, it => it.Value));
@ -54,28 +56,33 @@ namespace ZR.Admin.WebApi.Extensions
logger.Info($"{sql}，{param}"); logger.Info($"{sql}，{param}");
}; };
//出错打印日志
DbScoped.SugarScope.GetConnection(0).Aop.OnError = (e) => db.GetConnection(0).Aop.OnError = (e) =>
{ {
logger.Error(e, $"执行SQL出错：{e.Message}"); logger.Error(e, $"执行SQL出错：{e.Message}");
}; };
//SQL执行完 //SQL执行完
DbScoped.SugarScope.GetConnection(0).Aop.OnLogExecuted = (sql, pars) => db.GetConnection(0).Aop.OnLogExecuted = (sql, pars) =>
{ {
//执行完了可以输出SQL执行时间 (OnLogExecutedDelegate) //执行完了可以输出SQL执行时间 (OnLogExecutedDelegate)
}; };
#endregion
#region db1
//Db1 //Db1
DbScoped.SugarScope.GetConnection(1).Aop.OnLogExecuting = (sql, pars) => db.GetConnection(1).Aop.OnLogExecuting = (sql, pars) =>
{ {
var param = DbScoped.SugarScope.Utilities.SerializeObject(pars.ToDictionary(it => it.ParameterName, it => it.Value)); var param = DbScoped.SugarScope.Utilities.SerializeObject(pars.ToDictionary(it => it.ParameterName, it => it.Value));
logger.Info($"Sql语句：{sql}, {param}"); logger.Info($"Sql语句：{sql}, {param}");
}; };
//Db1错误日志 //Db1错误日志
DbScoped.SugarScope.GetConnection(1).Aop.OnError = (e) => db.GetConnection(1).Aop.OnError = (e) =>
{ {
logger.Error($"执行Sql语句失败：{e.Sql}，原因：{e.Message}"); logger.Error($"执行Sql语句失败：{e.Sql}，原因：{e.Message}");
}; };
#endregion
});
} }
/// <summary> /// <summary>