From faf883b62ae9b5b175a081de7b94059a7d85aa1b Mon Sep 17 00:00:00 2001 From: 2881099 <2881099@qq.com> Date: Thu, 22 Oct 2020 20:24:49 +0800 Subject: [PATCH] =?UTF-8?q?-=20=E4=BC=98=E5=8C=96=20=E8=A1=A8=E8=BE=BE?= =?UTF-8?q?=E5=BC=8F=E6=A0=91=20SqlExt.IsNull=20=E5=AF=B9=E5=B8=83?= =?UTF-8?q?=E5=B0=94=E7=B1=BB=E5=9E=8B=E7=9A=84=E8=A7=A3=E6=9E=90=EF=BC=9B?= =?UTF-8?q?#500?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- FreeSql.DbContext/FreeSql.DbContext.xml | 16 -- FreeSql.Tests/FreeSql.Tests/UnitTest3.cs | 28 ++ FreeSql/FreeSql.xml | 347 ++++++++++++----------- FreeSql/Internal/CommonExpression.cs | 36 +-- 4 files changed, 235 insertions(+), 192 deletions(-) diff --git a/FreeSql.DbContext/FreeSql.DbContext.xml b/FreeSql.DbContext/FreeSql.DbContext.xml index ce9ce69d..d198eb6c 100644 --- a/FreeSql.DbContext/FreeSql.DbContext.xml +++ b/FreeSql.DbContext/FreeSql.DbContext.xml @@ -130,13 +130,6 @@ 清空状态数据 - - - 根据 lambda 条件删除数据 - - - - 添加 @@ -532,14 +525,5 @@ - - - 批量注入 Repository，可以参考代码自行调整 - - - - - - diff --git a/FreeSql.Tests/FreeSql.Tests/UnitTest3.cs b/FreeSql.Tests/FreeSql.Tests/UnitTest3.cs index ede9eb88..172f4232 100644 --- a/FreeSql.Tests/FreeSql.Tests/UnitTest3.cs +++ b/FreeSql.Tests/FreeSql.Tests/UnitTest3.cs @@ -177,9 +177,37 @@ namespace FreeSql.Tests public string name { get; set; } } + class tq01 + { + public Guid id { get; set; } + } + class t102 + { + public Guid id { get; set; } + public bool isxx { get; set; } + } + [Fact] public void Test03() { + var testisnullsql1 = g.sqlite.Select().Where(a => SqlExt.IsNull(a.isxx, false).Equals( true)).ToSql(); + var testisnullsql2 = g.sqlite.Select().Where(a => SqlExt.IsNull(a.isxx, false).Equals(false)).ToSql(); + + var guid1 = Guid.NewGuid(); + var guid2 = Guid.NewGuid(); + var guid3 = Guid.NewGuid(); + var tqsql = g.sqlite.Select() + .WithSql( + g.sqlite.Select().As("sub1").Where(a => a.id == guid1).ToSql(), + g.sqlite.Select().As("sub2").Where(a => a.id == guid2).ToSql(), + g.sqlite.Select().As("sub3").Where(a => a.id == guid3).ToSql() + ) + .LeftJoin((a, b, c) => a.id == b.id) + .LeftJoin((a, b, c) => b.id == c.id) + .ToSql(); + + + var updateSql = g.sqlite.Update() .AsType(typeof(testInsertNullable)) .SetDto(new { str1 = "xxx" }) diff --git a/FreeSql/FreeSql.xml b/FreeSql/FreeSql.xml index 3844b008..d3216e1f 100644 --- a/FreeSql/FreeSql.xml +++ b/FreeSql/FreeSql.xml @@ -3006,154 +3006,6 @@ - - - 测试数据库是否连接正确，本方法执行如下命令： - MySql/SqlServer/PostgreSQL/达梦/人大金仓/神通: SELECT 1 - Oracle: SELECT 1 FROM dual - - 命令超时设置(秒) - true: 成功, false: 失败 - - - - 查询，若使用读写分离，查询【从库】条件cmdText.StartsWith("SELECT ")，否则查询【主库】 - - - - - - - - - 查询，ExecuteReaderAsync(dr => {}, "select * from user where age > ?age", new { age = 25 }) - 提示：parms 参数还可以传 Dictionary<string, object> - - - - - - - 查询 - - - - - - - 查询，ExecuteArrayAsync("select * from user where age > ?age", new { age = 25 }) - 提示：parms 参数还可以传 Dictionary<string, object> - - - - - - - - 查询 - - - - - - - 查询，ExecuteDataSetAsync("select * from user where age > ?age; select 2", new { age = 25 }) - 提示：parms 参数还可以传 Dictionary<string, object> - - - - - - - - 查询 - - - - - - - 查询，ExecuteDataTableAsync("select * from user where age > ?age", new { age = 25 }) - 提示：parms 参数还可以传 Dictionary<string, object> - - - - - - - - 在【主库】执行 - - - - - - - - 在【主库】执行，ExecuteNonQueryAsync("delete from user where age > ?age", new { age = 25 }) - 提示：parms 参数还可以传 Dictionary<string, object> - - - - - - - - 在【主库】执行 - - - - - - - - 在【主库】执行，ExecuteScalarAsync("select 1 from user where age > ?age", new { age = 25 }) - 提示：parms 参数还可以传 Dictionary<string, object> - - - - - - - - 执行SQL返回对象集合，QueryAsync<User>("select * from user where age > ?age", new SqlParameter { ParameterName = "age", Value = 25 }) - - - - - - - - - - 执行SQL返回对象集合，QueryAsync<User>("select * from user where age > ?age", new { age = 25 }) - 提示：parms 参数还可以传 Dictionary<string, object> - - - - - - - - - 执行SQL返回对象集合，Query<User>("select * from user where age > ?age; select * from address", new SqlParameter { ParameterName = "age", Value = 25 }) - - - - - - - - - - 执行SQL返回对象集合，Query<User, Address>("select * from user where age > ?age; select * from address", new { age = 25 }) - 提示：parms 参数还可以传 Dictionary<string, object> - - - - - - 可自定义解析表达式 @@ -3982,12 +3834,6 @@ 超时 - - - 获取资源 - - - 使用完毕后，归还资源 @@ -4058,12 +3904,6 @@ 资源对象 - - - 从对象池获取对象成功的时候触发，通过该方法统计或初始化对象 - - 资源对象 - 归还对象给对象池的时候触发 @@ -4674,3 +4514,190 @@ +essions.Expression{System.Func{``0,``1,``2,``3,``4,System.Boolean}},System.Linq.Expressions.Expression{System.Func{``0,``1,``2,``3,``4,System.Boolean}})"> + + 使用 and 拼接两个 lambda 表达式 + + + + + + 使用 and 拼接两个 lambda 表达式 + + + true 时生效 + + + + + + 使用 or 拼接两个 lambda 表达式 + + + + + + 使用 or 拼接两个 lambda 表达式 + + + true 时生效 + + + + + + 将 lambda 表达式取反 + + + true 时生效 + + + + + 生成类似Mongodb的ObjectId有序、不重复Guid + + + + + + 插入数据 + + + + + + + 插入数据，传入实体 + + + + + + + + 插入数据，传入实体数组 + + + + + + + + 插入数据，传入实体集合 + + + + + + + + 插入数据，传入实体集合 + + + + + + + + 插入或更新数据，此功能依赖数据库特性（低版本可能不支持），参考如下： + MySql 5.6+: on duplicate key update + PostgreSQL 9.4+: on conflict do update + SqlServer 2008+: merge into + Oracle 11+: merge into + Sqlite: replace into + 达梦: merge into + 人大金仓：on conflict do update + 神通：merge into + MsAccess：不支持 + 注意区别：FreeSql.Repository 仓储也有 InsertOrUpdate 方法（不依赖数据库特性） + + + + + + + 修改数据 + + + + + + + 修改数据，传入动态条件，如：主键值 | new[]{主键值1,主键值2} | TEntity1 | new[]{TEntity1,TEntity2} | new{id=1} + + + 主键值、主键值集合、实体、实体集合、匿名对象、匿名对象集合 + + + + + 查询数据 + + + + + + + 查询数据，传入动态条件，如：主键值 | new[]{主键值1,主键值2} | TEntity1 | new[]{TEntity1,TEntity2} | new{id=1} + + + 主键值、主键值集合、实体、实体集合、匿名对象、匿名对象集合 + + + + + 删除数据 + + + + + + + 删除数据，传入动态条件，如：主键值 | new[]{主键值1,主键值2} | TEntity1 | new[]{TEntity1,TEntity2} | new{id=1} + + + 主键值、主键值集合、实体、实体集合、匿名对象、匿名对象集合 + + + + + 开启事务（不支持异步） + v1.5.0 关闭了线程事务超时自动提交的机制 + + 事务体 () => {} + + + + 开启事务（不支持异步） + v1.5.0 关闭了线程事务超时自动提交的机制 + + + 事务体 () => {} + + + + 数据库访问对象 + + + + + 所有拦截方法都在这里 + + + + + CodeFirst 模式开发相关方法 + + + + + DbFirst 模式开发相关方法 + + + + + 全局过滤设置，可默认附加为 Select/Update/Delete 条件 + + + + diff --git a/FreeSql/Internal/CommonExpression.cs b/FreeSql/Internal/CommonExpression.cs index c0f2f2a2..6952905d 100644 --- a/FreeSql/Internal/CommonExpression.cs +++ b/FreeSql/Internal/CommonExpression.cs @@ -604,23 +604,27 @@ namespace FreeSql.Internal } if (leftExp.Type.NullableTypeOrThis() == typeof(bool) && (leftExp.NodeType != ExpressionType.MemberAccess && rightExp.NodeType != ExpressionType.MemberAccess)) { - if (oper == "=") + var leftExpCall = leftExp as MethodCallExpression; + if (leftExpCall == null || !(leftExpCall.Method.DeclaringType == typeof(SqlExt) && leftExpCall.Method.Name == nameof(SqlExt.IsNull))) { - var trueVal = formatSql(true, null, null, null); - var falseVal = formatSql(false, null, null, null); - if (left == trueVal) return right; - else if (left == falseVal) return $"not({right})"; - else if (right == trueVal) return left; - else if (right == falseVal) return $"not({left})"; - } - else if (oper == "<>") - { - var trueVal = formatSql(true, null, null, null); - var falseVal = formatSql(false, null, null, null); - if (left == trueVal) return $"not({right})"; - else if (left == falseVal) return right; - else if (right == trueVal) return $"not({left})"; - else if (right == falseVal) return left; + if (oper == "=") + { + var trueVal = formatSql(true, null, null, null); + var falseVal = formatSql(false, null, null, null); + if (left == trueVal) return right; + else if (left == falseVal) return $"not({right})"; + else if (right == trueVal) return left; + else if (right == falseVal) return $"not({left})"; + } + else if (oper == "<>") + { + var trueVal = formatSql(true, null, null, null); + var falseVal = formatSql(false, null, null, null); + if (left == trueVal) return $"not({right})"; + else if (left == falseVal) return right; + else if (right == trueVal) return $"not({left})"; + else if (right == falseVal) return left; + } } } if (left == "NULL")