tk/FreeSql
1
0
Fork 0
mirror of https://github.com/nsnail/FreeSql.git synced 2025-04-22 02:32:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

更改CaseWhen无法更新数据问题（待修改字段值为NULL时还是无法修改）

Browse Source
This commit is contained in:
chenbo 2021-11-27 21:48:47 +08:00
parent c22d8d74d2
commit 4c7e04376f
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
FreeSql.Tests/FreeSql.Tests/ClickHouse/ClickHouseTest1.cs
View File

@ -173,6 +173,7 @@ namespace FreeSql.Tests.MySql
var repository=fsql.GetRepository<TestAuditValue>(); var repository=fsql.GetRepository<TestAuditValue>();
var list = repository.Select.ToList(); var list = repository.Select.ToList();
list.ForEach(o=>o.UpdateTime = DateTime.Now); list.ForEach(o=>o.UpdateTime = DateTime.Now);
list.ForEach(o => o.Enable = true);
repository.Update(list); repository.Update(list);
} }
@ -182,6 +183,7 @@ namespace FreeSql.Tests.MySql
{ {
var fsql = g.clickHouse; var fsql = g.clickHouse;
var state=fsql.GetRepository<TestAuditValue>().UpdateDiy.Set(o=>o.UpdateTime,DateTime.Now).Where(o=>1==1).ExecuteAffrows(); var state=fsql.GetRepository<TestAuditValue>().UpdateDiy.Set(o=>o.UpdateTime,DateTime.Now).Where(o=>1==1).ExecuteAffrows();
//var state1 = fsql.GetRepository<TestAuditValue>().UpdateDiy.Set(o => o.UpdateTime, null).Where(o => 1 == 1).ExecuteAffrows();
} }

5
Providers/FreeSql.Provider.ClickHouse/Curd/ClickHouseUpdate.cs
View File

@ -68,7 +68,10 @@ namespace FreeSql.ClickHouse.Curd
} }
sb.Append(")"); sb.Append(")");
} }
protected override void ToSqlCaseWhenEnd(StringBuilder sb, ColumnInfo col)
{
sb.Insert(sb.Length - 4, $" ELSE {_commonUtils.QuoteSqlName(col.Attribute.Name)}");
}
#if net40 #if net40
#else #else
public override Task<int> ExecuteAffrowsAsync(CancellationToken cancellationToken = default) => base.SplitExecuteAffrowsAsync(_batchRowsLimit > 0 ? _batchRowsLimit : 500, _batchParameterLimit > 0 ? _batchParameterLimit : 3000, cancellationToken); public override Task<int> ExecuteAffrowsAsync(CancellationToken cancellationToken = default) => base.SplitExecuteAffrowsAsync(_batchRowsLimit > 0 ? _batchRowsLimit : 500, _batchParameterLimit > 0 ? _batchParameterLimit : 3000, cancellationToken);