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

fix：pgSql没有nvarchar类型

Browse Source
This commit is contained in:
不做码农 2023-05-12 15:10:45 +08:00
parent 335db343c9
commit 13e6d9e17c
1 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -60,7 +60,7 @@ namespace ZR.Admin.WebApi.Extensions
var config = db.GetConnection(iocConfig.ConfigId).CurrentConnectionConfig; var config = db.GetConnection(iocConfig.ConfigId).CurrentConnectionConfig;
string configId = config.ConfigId; string configId = config.ConfigId;
db.GetConnectionScope(configId).Aop.OnLogExecuted = (sql, pars) => db.GetConnectionScope(configId).Aop.OnLogExecuting = (sql, pars) =>
{ {
string log = $"【db{configId} SQL语句】{UtilMethods.GetSqlString(config.DbType, sql, pars)}\n"; string log = $"【db{configId} SQL语句】{UtilMethods.GetSqlString(config.DbType, sql, pars)}\n";
if (sql.TrimStart().StartsWith("SELECT", StringComparison.OrdinalIgnoreCase)) if (sql.TrimStart().StartsWith("SELECT", StringComparison.OrdinalIgnoreCase))
@ -82,9 +82,12 @@ namespace ZR.Admin.WebApi.Extensions
} }
}; };
db.GetConnectionScope(configId).Aop.OnError = (e) => db.GetConnectionScope(configId).Aop.OnError = (ex) =>
{ {
logger.Error(e, $"执行SQL出错：{e.Message}，{e.StackTrace}"); var pars = db.Utilities.SerializeObject(((SugarParameter[])ex.Parametres).ToDictionary(it => it.ParameterName, it => it.Value));
string sql = "【错误SQL】" + UtilMethods.GetSqlString(config.DbType, ex.Sql, (SugarParameter[])ex.Parametres) + "\r\n";
logger.Error(ex, $"{sql}\r\n{ex.Message}\r\n{ex.StackTrace}");
}; };
db.GetConnectionScope(configId).CurrentConnectionConfig.MoreSettings = new ConnMoreSettings() db.GetConnectionScope(configId).CurrentConnectionConfig.MoreSettings = new ConnMoreSettings()
@ -93,7 +96,14 @@ namespace ZR.Admin.WebApi.Extensions
}; };
db.GetConnectionScope(configId).CurrentConnectionConfig.ConfigureExternalServices = new ConfigureExternalServices() db.GetConnectionScope(configId).CurrentConnectionConfig.ConfigureExternalServices = new ConfigureExternalServices()
{ {
DataInfoCacheService = cache DataInfoCacheService = cache,
EntityService = (c, p) =>
{
if (db.GetConnectionScope(configId).CurrentConnectionConfig.DbType == DbType.PostgreSQL && p.DataType != null && p.DataType.Contains("nvarchar"))
{
p.DataType = "text";
}
}
}; };
} }