lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-08-24 07:22:57 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

PgSql difflog bug

Browse Source
This commit is contained in:
sunkaixuna 2021-10-20 14:14:54 +08:00
parent 859e7d34d4
commit 43d9f8caf3
2 changed files with 17 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
Src/Asp.Net/PgSqlTest/Demo/DemoB_Aop.cs
View File

@ -46,10 +46,10 @@ namespace OrmTest
var businessData = it.BusinessData; var businessData = it.BusinessData;
var time = it.Time; var time = it.Time;
var diffType = it.DiffType;//enum insert 、update and delete var diffType = it.DiffType;//enum insert 、update and delete
Console.WriteLine(businessData); //Console.WriteLine(businessData);
Console.WriteLine(editBeforeData[0].Columns[1].Value); //Console.WriteLine(editBeforeData[0].Columns[1].Value);
Console.WriteLine("to"); //Console.WriteLine("to");
Console.WriteLine(editAfterData[0].Columns[1].Value); //Console.WriteLine(editAfterData[0].Columns[1].Value);
//Write logic //Write logic
}; };
@ -61,7 +61,7 @@ namespace OrmTest
var data = db.Queryable<Order>().First(); var data = db.Queryable<Order>().First();
data.Name = "changeName"; data.Name = "changeName";
db.Updateable(data).EnableDiffLogEvent("--update Order--").ExecuteCommand(); db.Updateable(data).EnableDiffLogEvent("--update Order--").ExecuteCommand();
db.Insertable(data).EnableDiffLogEvent("--inser Order--").ExecuteCommand();
Console.WriteLine("#### Aop End ####"); Console.WriteLine("#### Aop End ####");
} }
} }

10
Src/Asp.Net/SqlSugar/Abstract/InsertableProvider/InsertableProvider.cs
View File

@ -747,10 +747,18 @@ namespace SqlSugar
foreach (var item in this.EntityInfo.Columns.Where(it => it.IsIgnore == false && GetPrimaryKeys().Any(pk => pk.Equals(it.DbColumnName, StringComparison.CurrentCultureIgnoreCase)))) foreach (var item in this.EntityInfo.Columns.Where(it => it.IsIgnore == false && GetPrimaryKeys().Any(pk => pk.Equals(it.DbColumnName, StringComparison.CurrentCultureIgnoreCase))))
{ {
var fielddName = item.DbColumnName; var fielddName = item.DbColumnName;
var fieldValue = this.EntityInfo.Columns.FirstOrDefault(it => it.PropertyName == item.PropertyName).PropertyInfo.GetValue(this.InsertObjs.Last(), null).ObjToString(); var filedObject = this.EntityInfo.Columns.FirstOrDefault(it => it.PropertyName == item.PropertyName).PropertyInfo.GetValue(this.InsertObjs.Last(), null);
var fieldValue = filedObject.ObjToString();
if (filedObject != null && filedObject.GetType() != typeof(string)&&this.Context.CurrentConnectionConfig.DbType==DbType.PostgreSQL)
{
cons.Add(new ConditionalModel() { ConditionalType = ConditionalType.Equal, FieldName = fielddName, FieldValue = fieldValue,FieldValueConvertFunc= it => UtilMethods.ChangeType2(it, filedObject.GetType()) });
}
else
{
cons.Add(new ConditionalModel() { ConditionalType = ConditionalType.Equal, FieldName = fielddName, FieldValue = fieldValue }); cons.Add(new ConditionalModel() { ConditionalType = ConditionalType.Equal, FieldName = fielddName, FieldValue = fieldValue });
} }
} }
}
Check.Exception(cons.IsNullOrEmpty(), "Insertable.EnableDiffLogEvent need primary key"); Check.Exception(cons.IsNullOrEmpty(), "Insertable.EnableDiffLogEvent need primary key");
var sqlable = this.SqlBuilder.ConditionalModelToSql(cons); var sqlable = this.SqlBuilder.ConditionalModelToSql(cons);
whereSql = sqlable.Key; whereSql = sqlable.Key;