weiai/FreeSql
1
0
Fork 0
mirror of https://github.com/dotnetcore/FreeSql.git synced 2026-02-09 09:50:54 +08:00
Code Issues Packages Projects Releases Wiki Activity

TDengine TIMESTAMP特殊处理

Browse Source
This commit is contained in:
d4ilys
2025-02-18 15:24:49 +08:00
parent 087288ca9c
commit ddf187cce6
2 changed files with 6 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
FreeSql.Tests/FreeSql.Tests.Provider.TDengine/TDengine/TDengineIssue/TDengineIssueTest.cs
View File

@@ -41,12 +41,12 @@ namespace FreeSql.Tests.Provider.TDengine.TDengine.TDengineIssue
var insertAffrows = _fsql.Insert(new TDengineProcessMetrics1977() var insertAffrows = _fsql.Insert(new TDengineProcessMetrics1977()
{ {
Timestamp = DateTime.Now, Timestamp = DateTime.Now,
HostName = "host6" HostName = "host1",
StartTime = DateTime.Now
} }
).ExecuteAffrows(); ).ExecuteAffrows();
Assert.Equal(1, insertAffrows); Assert.Equal(1, insertAffrows);
} }
} }
public class TDengineProcessMetrics1977 public class TDengineProcessMetrics1977
@@ -67,6 +67,6 @@ namespace FreeSql.Tests.Provider.TDengine.TDengine.TDengineIssue
/// 进程启动时间 /// 进程启动时间
/// </summary> /// </summary>
[Column(Name = "start_time")] [Column(Name = "start_time")]
public DateTime StartTime { get; set; } public DateTime? StartTime { get; set; }
} }
} }

10
Providers/FreeSql.Provider.TDengine/TDengineProvider.cs
View File

@@ -52,17 +52,13 @@ namespace FreeSql.TDengine
case "TIMESTAMP": case "TIMESTAMP":
try try
{ {
var value = e.DataReader.GetValue(e.Index); if (e.DataReader.IsDBNull(e.Index)) e.Value = null;
if (value != null) else e.Value = e.DataReader.GetDateTime(e.Index);
e.Value = e.DataReader.GetDateTime(e.Index);
else
e.Value = null;
return; return;
} }
catch catch
{ {
e.Value = new DateTime(); e.Value = DateTime.MinValue;
return; return;
} }
} }