db日志打印新增配置开关

This commit is contained in:
不做码农 2023-08-14 18:11:03 +08:00
parent dcb3c55cb1
commit 0531c2b330
2 changed files with 21 additions and 17 deletions

View File

@ -68,27 +68,30 @@ namespace ZR.Admin.WebApi.Extensions
private static void SetSugarAop(SqlSugarClient db, IocConfig iocConfig, ICacheService cache) private static void SetSugarAop(SqlSugarClient db, IocConfig iocConfig, ICacheService cache)
{ {
var config = db.GetConnectionScope(iocConfig.ConfigId).CurrentConnectionConfig; var config = db.GetConnectionScope(iocConfig.ConfigId).CurrentConnectionConfig;
var showDbLog = AppSettings.Get<bool>("ShowDbLog");
string configId = config.ConfigId; string configId = config.ConfigId;
db.GetConnectionScope(configId).Aop.OnLogExecuting = (sql, pars) => db.GetConnectionScope(configId).Aop.OnLogExecuting = (sql, pars) =>
{ {
string log = $"【db{configId} SQL语句】{UtilMethods.GetSqlString(config.DbType, sql, pars)}\n"; if (showDbLog)
if (sql.TrimStart().StartsWith("SELECT", StringComparison.OrdinalIgnoreCase))
{ {
logger.Info(log); string log = $"【db{configId} SQL语句】{UtilMethods.GetSqlString(config.DbType, sql, pars)}\n";
} if (sql.TrimStart().StartsWith("SELECT", StringComparison.OrdinalIgnoreCase))
else if (sql.StartsWith("UPDATE", StringComparison.OrdinalIgnoreCase) || sql.StartsWith("INSERT", StringComparison.OrdinalIgnoreCase)) {
{ logger.Info(log);
logger.Warn(log); }
} else if (sql.StartsWith("UPDATE", StringComparison.OrdinalIgnoreCase) || sql.StartsWith("INSERT", StringComparison.OrdinalIgnoreCase))
else if (sql.StartsWith("DELETE", StringComparison.OrdinalIgnoreCase) || sql.StartsWith("TRUNCATE", StringComparison.OrdinalIgnoreCase)) {
{ logger.Warn(log);
logger.Error(log); }
} else if (sql.StartsWith("DELETE", StringComparison.OrdinalIgnoreCase) || sql.StartsWith("TRUNCATE", StringComparison.OrdinalIgnoreCase))
else {
{ logger.Error(log);
log = $"【db{configId} SQL语句】dbo.{sql} {string.Join(", ", pars.Select(x => x.ParameterName + " = " + GetParsValue(x)))};\n"; }
logger.Info(log); else
{
log = $"【db{configId} SQL语句】dbo.{sql} {string.Join(", ", pars.Select(x => x.ParameterName + " = " + GetParsValue(x)))};\n";
logger.Info(log);
}
} }
}; };
db.GetConnectionScope(configId).Aop.OnError = (ex) => db.GetConnectionScope(configId).Aop.OnError = (ex) =>

View File

@ -32,6 +32,7 @@
"Expire": 1440 //jwt "Expire": 1440 //jwt
}, },
"InjectClass": [ "ZR.Repository", "ZR.Service", "ZR.Tasks" ], // "InjectClass": [ "ZR.Repository", "ZR.Service", "ZR.Tasks" ], //
"ShowDbLog": true,//db
"InitDb": false, //db "InitDb": false, //db
"DemoMode": false, // "DemoMode": false, //
"Upload": { "Upload": {