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

测试ClickHouse 批量更新DateTime问题

Browse Source
This commit is contained in:
Daily 2024-05-30 11:39:48 +08:00
parent 9aef33e3df
commit 989cf290f6
2 changed files with 14 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
FreeSql.Tests/FreeSql.Tests/ClickHouse/ClickhouseIssueTest.cs
View File

@ -22,7 +22,7 @@ namespace FreeSql.Tests.ClickHouse
_fsql = new FreeSqlBuilder().UseConnectionString(DataType.ClickHouse, _fsql = new FreeSqlBuilder().UseConnectionString(DataType.ClickHouse,
"Host=192.168.1.123;Port=8123;Database=test_issue;Compress=True;Min Pool Size=1") "Host=192.168.1.123;Port=8123;Database=test_issue;Compress=True;Min Pool Size=1")
.UseMonitorCommand(cmd => _output.WriteLine($"线程：{cmd.CommandText}\r\n")) .UseMonitorCommand(cmd => _output.WriteLine($"线程：{cmd.CommandText}\r\n"))
.UseNoneCommandParameter(false) .UseNoneCommandParameter(true)
.UseAdoConnectionPool(true) .UseAdoConnectionPool(true)
.Build(); .Build();
} }
@ -45,22 +45,25 @@ namespace FreeSql.Tests.ClickHouse
{ {
Id = "9cd7af52-85cc-4d26-898a-4020cadb0491", Id = "9cd7af52-85cc-4d26-898a-4020cadb0491",
Name = "update_name1", Name = "update_name1",
UpdateTime = DateTime.Now UpdateTime = DateTime.Now,
CreateTime = DateTime.Parse("2024-05-30 10:01:02")
}); });
updatePerson.Add(new Person updatePerson.Add(new Person
{ {
Id = "bd9f9ed6-bd03-4675-abb4-12b7fdac7678", Id = "bd9f9ed6-bd03-4675-abb4-12b7fdac7678",
Name = "update_name2", Name = "update_name2",
UpdateTime = DateTime.Now UpdateTime = DateTime.Now,
CreateTime = DateTime.Parse("2024-05-30 10:01:02")
}); });
_fsql.Update<Person>().SetSource(updatePerson).UpdateColumns(person => new var sql = _fsql.Update<Person>().SetSource(updatePerson)
{ .UpdateColumns(person => new
person.Name, {
person.UpdateTime, person.Name,
}).ExecuteAffrows(); person.UpdateTime,
person.CreateTime
}).ToSql();
} }
[Fact] [Fact]
@ -94,6 +97,7 @@ namespace FreeSql.Tests.ClickHouse
var insertMany = _fsql.Insert(persons).ExecuteAffrows(); var insertMany = _fsql.Insert(persons).ExecuteAffrows();
} }
[Fact] [Fact]
public void TestIssue1813CodeFirst2() public void TestIssue1813CodeFirst2()
{ {
@ -130,11 +134,11 @@ namespace FreeSql.Tests.ClickHouse
} }
public class Person public class Person
{ {
[Column(IsPrimary = true, IsIdentity = true)] [Column(IsPrimary = true, IsIdentity = true)]
public string Id { get; set; } public string Id { get; set; }
public string Name { get; set; } public string Name { get; set; }
public int Age { get; set; } public int Age { get; set; }
public DateTime CreateTime { get; set; } public DateTime CreateTime { get; set; }

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

@ -173,8 +173,6 @@ namespace FreeSql.ClickHouse.Curd
if (col.Attribute.MapType == typeof(DateTime) || col.Attribute.MapType == typeof(DateTime?) ) if (col.Attribute.MapType == typeof(DateTime) || col.Attribute.MapType == typeof(DateTime?) )
{ {
//获取当前实时区 //获取当前实时区
var timeZone = TimeZoneInfo.Local;
colsql = $"toDateTime({colsql},'Asia/Shanghai')"; colsql = $"toDateTime({colsql},'Asia/Shanghai')";
} }