提交 6105ac04 编写于 作者: 麦壳饼's avatar 麦壳饼
上级 0229dd5b
...@@ -32,6 +32,7 @@ Project("{E53339B2-1760-4266-BCC7-CA923CBCF16C}") = "zeromq_taos", "Deployments\ ...@@ -32,6 +32,7 @@ Project("{E53339B2-1760-4266-BCC7-CA923CBCF16C}") = "zeromq_taos", "Deployments\
EndProject EndProject
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Tools", "Tools", "{3048484A-6A46-4E17-825C-D2C59D6D30ED}" Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Tools", "Tools", "{3048484A-6A46-4E17-825C-D2C59D6D30ED}"
ProjectSection(SolutionItems) = preProject ProjectSection(SolutionItems) = preProject
buildimage.cmd = buildimage.cmd
tools\ef_mg_add.cmd = tools\ef_mg_add.cmd tools\ef_mg_add.cmd = tools\ef_mg_add.cmd
tools\upgrade_ef.cmd = tools\upgrade_ef.cmd tools\upgrade_ef.cmd = tools\upgrade_ef.cmd
EndProjectSection EndProjectSection
......
...@@ -66,6 +66,7 @@ namespace IoTSharp.Storage ...@@ -66,6 +66,7 @@ namespace IoTSharp.Storage
TaosConnection _taos = _taospool.Get(); TaosConnection _taos = _taospool.Get();
_taos.ChangeDatabase(_taos.Database); _taos.ChangeDatabase(_taos.Database);
if (_taos.State != System.Data.ConnectionState.Open) _taos.Open(); if (_taos.State != System.Data.ConnectionState.Open) _taos.Open();
//https://github.com/taosdata/TDengine/issues/4269
string sql = $"select last_row(*) from telemetrydata where deviceid='{deviceId:N}' group by deviceid,keyname"; string sql = $"select last_row(*) from telemetrydata where deviceid='{deviceId:N}' group by deviceid,keyname";
List<TelemetryDataDto> dt = SqlToTDD(_taos, sql, "last_row(", ")", string.Empty); List<TelemetryDataDto> dt = SqlToTDD(_taos, sql, "last_row(", ")", string.Empty);
_taospool.Return(_taos); _taospool.Return(_taos);
...@@ -73,7 +74,16 @@ namespace IoTSharp.Storage ...@@ -73,7 +74,16 @@ namespace IoTSharp.Storage
} }
/// <summary>
/// 转换获取到的值
/// </summary>
/// <param name="db"></param>
/// <param name="sql"></param>
/// <param name="prefix"></param>
/// <param name="suffix"></param>
/// <param name="keyname"></param>
/// <returns></returns>
/// <exception cref="https://github.com/taosdata/TDengine/issues/4269">务必注意此bug</exception>
private List<TelemetryDataDto> SqlToTDD(TaosConnection db, string sql, string prefix, string suffix, string keyname) private List<TelemetryDataDto> SqlToTDD(TaosConnection db, string sql, string prefix, string suffix, string keyname)
{ {
List<TelemetryDataDto> dt = new List<TelemetryDataDto>(); List<TelemetryDataDto> dt = new List<TelemetryDataDto>();
...@@ -91,7 +101,7 @@ namespace IoTSharp.Storage ...@@ -91,7 +101,7 @@ namespace IoTSharp.Storage
} }
else else
{ {
datatype = (byte)DataType.String; throw new Exception($"字段{prefix}value_type{suffix}的Index={idx}小于0或者大于FieldCount{dataReader.FieldCount},更多信息请访问 HelpLink") { HelpLink= "https://github.com/taosdata/TDengine/issues/4269" };
} }
if (string.IsNullOrEmpty(keyname)) if (string.IsNullOrEmpty(keyname))
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册