diff --git a/FreeSql.Tests/FreeSql.Tests/UnitTest1.cs b/FreeSql.Tests/FreeSql.Tests/UnitTest1.cs index 0d2dfc44..13ed35bc 100644 --- a/FreeSql.Tests/FreeSql.Tests/UnitTest1.cs +++ b/FreeSql.Tests/FreeSql.Tests/UnitTest1.cs @@ -403,10 +403,56 @@ namespace FreeSql.Tests [Navigate("AuthorId")] public List Post { get; set; } } + public class TestGuidId + { + public Guid? Id { get; set; } + public string xxx { get; set; } + } [Fact] public void Test1() { + g.sqlite.Insert(new TestGuidId { xxx = "111" }).ExecuteAffrows(); + g.sqlite.Insert(new TestGuidId { xxx = "222" }).ExecuteAffrows(); + var gkkdk1 = g.sqlite.Select().Where(a => true).ToList(); + using (var testguididdb = g.sqlite.CreateDbContext()) + { + var gkkdk11 = testguididdb.Set().Select.Where(a => true).ToList(); + } + + g.oracle.Insert(new TestGuidId { xxx = "111" }).ExecuteAffrows(); + g.oracle.Insert(new TestGuidId { xxx = "222" }).ExecuteAffrows(); + var gkkdk2 = g.oracle.Select().Where(a => true).ToList(); + using (var testguididdb = g.sqlite.CreateDbContext()) + { + var gkkdk22 = testguididdb.Set().Select.Where(a => true).ToList(); + } + + g.pgsql.Insert(new TestGuidId { xxx = "111" }).ExecuteAffrows(); + g.pgsql.Insert(new TestGuidId { xxx = "222" }).ExecuteAffrows(); + var gkkdk3 = g.pgsql.Select().Where(a => true).ToList(); + using (var testguididdb = g.sqlite.CreateDbContext()) + { + var gkkdk22 = testguididdb.Set().Select.Where(a => true).ToList(); + } + + g.mysql.Insert(new TestGuidId { xxx = "111" }).ExecuteAffrows(); + g.mysql.Insert(new TestGuidId { xxx = "222" }).ExecuteAffrows(); + var gkkdk4 = g.mysql.Select().Where(a => true).ToList(); + using (var testguididdb = g.sqlite.CreateDbContext()) + { + var gkkdk22 = testguididdb.Set().Select.Where(a => true).ToList(); + } + + g.sqlserver.Insert(new TestGuidId { xxx = "111" }).ExecuteAffrows(); + g.sqlserver.Insert(new TestGuidId { xxx = "222" }).ExecuteAffrows(); + var gkkdk5 = g.sqlserver.Select().Where(a => true).ToList(); + using (var testguididdb = g.sqlite.CreateDbContext()) + { + var gkkdk22 = testguididdb.Set().Select.Where(a => true).ToList(); + } + + var testlistinsert = new List(); g.sqlite.Insert(testlistinsert).ExecuteAffrows(); diff --git a/FreeSql/Extensions/EntityUtilExtensions.cs b/FreeSql/Extensions/EntityUtilExtensions.cs index 98ab49e7..7ec6cc31 100644 --- a/FreeSql/Extensions/EntityUtilExtensions.cs +++ b/FreeSql/Extensions/EntityUtilExtensions.cs @@ -53,41 +53,29 @@ namespace FreeSql.Extensions.EntityUtil Expression expthen = null; if (isguid) { - if (pks[a].Attribute.MapType == pks[a].CsType) - { - expthen = Expression.Block( - new Expression[]{ - Expression.Assign(Expression.MakeMemberAccess(var1Parm, _table.Properties[pks[a].CsName]), Expression.Call(MethodFreeUtilNewMongodbId)), - a > 0 ? Expression.Call(var2Sb, MethodStringBuilderAppend, Expression.Constant(splitString)) : null, - Expression.Call(var2Sb, MethodStringBuilderAppend, - Expression.Convert(Expression.MakeMemberAccess(var1Parm, _table.Properties[pks[a].CsName]), typeof(object)) - ) - }.Where(c => c != null).ToArray() - ); - } - else - { - expthen = Expression.Block( - new Expression[]{ - Expression.Assign(Expression.MakeMemberAccess(var1Parm, _table.Properties[pks[a].CsName]), FreeSql.Internal.Utils.GetDataReaderValueBlockExpression(pks[a].CsType, Expression.Call(MethodFreeUtilNewMongodbId))), - a > 0 ? Expression.Call(var2Sb, MethodStringBuilderAppend, Expression.Constant(splitString)) : null, - Expression.Call(var2Sb, MethodStringBuilderAppend, - Expression.Convert(Expression.MakeMemberAccess(var1Parm, _table.Properties[pks[a].CsName]), typeof(object)) - ) - }.Where(c => c != null).ToArray() - ); - } + Expression newguid = Expression.Call(MethodFreeUtilNewMongodbId); + if (pks[a].Attribute.MapType != pks[a].CsType) newguid = FreeSql.Internal.Utils.GetDataReaderValueBlockExpression(pks[a].CsType, newguid); + if (pks[a].CsType == typeof(Guid?)) newguid = Expression.Convert(newguid, typeof(Guid?)); + expthen = Expression.Block( + new Expression[]{ + Expression.Assign(Expression.MakeMemberAccess(var1Parm, _table.Properties[pks[a].CsName]), newguid), + a > 0 ? Expression.Call(var2Sb, MethodStringBuilderAppend, Expression.Constant(splitString)) : null, + Expression.Call(var2Sb, MethodStringBuilderAppend, + Expression.Convert(Expression.MakeMemberAccess(var1Parm, _table.Properties[pks[a].CsName]), typeof(object)) + ) + }.Where(c => c != null).ToArray() + ); } else if (pks.Length > 1 && pks[a].Attribute.IsIdentity) { expthen = Expression.Block( - new Expression[]{ - a > 0 ? Expression.Call(var2Sb, MethodStringBuilderAppend, Expression.Constant(splitString)) : null, - Expression.Call(var2Sb, MethodStringBuilderAppend, - Expression.Convert(Expression.MakeMemberAccess(var1Parm, _table.Properties[pks[a].CsName]), typeof(object)) - ) - }.Where(c => c != null).ToArray() - ); + new Expression[]{ + a > 0 ? Expression.Call(var2Sb, MethodStringBuilderAppend, Expression.Constant(splitString)) : null, + Expression.Call(var2Sb, MethodStringBuilderAppend, + Expression.Convert(Expression.MakeMemberAccess(var1Parm, _table.Properties[pks[a].CsName]), typeof(object)) + ) + }.Where(c => c != null).ToArray() + ); } else {