diff --git a/src/Example/Program.cs b/src/Example/Program.cs index c74bd2a..1a6ddf5 100644 --- a/src/Example/Program.cs +++ b/src/Example/Program.cs @@ -74,13 +74,22 @@ static void Main(string[] args) connection.ChangeDatabase("IoTSharp"); connection.CreateCommand("CREATE TABLE IF NOT EXISTS telemetrydata (ts timestamp,value_type tinyint, value_boolean bool, value_string binary(10240), value_long bigint,value_datetime timestamp,value_double double) TAGS (deviceid binary(32),keyname binary(64));").ExecuteNonQuery(); //connection.CreateCommand($"CREATE TABLE dev_Thermometer USING telemetrydata TAGS (\"Temperature\")").ExecuteNonQuery(); - var devid = $"{Guid.NewGuid():N}"; - UploadTelemetryData(connection, devid, "Temperature", 999); - UploadTelemetryData(connection,devid, "Humidity", 888); + var devid1 = $"{Guid.NewGuid():N}"; var devid2 = $"{Guid.NewGuid():N}"; - UploadTelemetryData(connection, devid2, "Temperature", 777); - UploadTelemetryData(connection, devid2, "Humidity", 666); + UploadTelemetryData(connection, devid1, "1#air-compressor-two-level-discharge-temperature", 2000); + UploadTelemetryData(connection, devid2, "1#air-compressor-load-rate", 2000); var reader2 = connection.CreateCommand("select last_row(*) from telemetrydata group by deviceid,keyname ;").ExecuteReader(); + var reader3 = connection.CreateCommand("select * from telemetrydata").ExecuteReader(); + + List list = new List(); + while (reader3.Read()) + { + list.Add(reader3.GetString("keyname")); + } + + var k = list.GroupBy(e => e); + var dic = k.ToDictionary(en => en.Key, en => en.ToList()); + ConsoleTableBuilder.From(reader2.ToDataTable()).WithFormat(ConsoleTableBuilderFormat.Default).ExportAndWriteLine(); @@ -117,11 +126,12 @@ static void Main(string[] args) } + static void UploadTelemetryData( TaosConnection connection, string devid, string keyname, int count) { for (int i = 0; i < count; i++) { - connection.CreateCommand($"INSERT INTO device_{devid}_{keyname} USING telemetrydata TAGS(\"{devid}\",\"{keyname}\") (ts,value_type,value_long) values (now,2,{i});").ExecuteNonQuery(); + connection.CreateCommand($"INSERT INTO device_{devid} USING telemetrydata TAGS(\"{devid}\",\"{keyname}\") (ts,value_type,value_long) values (now,2,{i});").ExecuteNonQuery(); } } } diff --git a/src/Maikebing.Data.Taos/Maikebing.Data.Taos.csproj b/src/Maikebing.Data.Taos/Maikebing.Data.Taos.csproj index b6e15b0..f6b359a 100644 --- a/src/Maikebing.Data.Taos/Maikebing.Data.Taos.csproj +++ b/src/Maikebing.Data.Taos/Maikebing.Data.Taos.csproj @@ -16,7 +16,7 @@ Maikebing.Data.Taos.TaosParameter Maikebing.Data.Taos.TaosTransaction - net5;netstandard2.0;net45 + net5;netstandard2.0 Taos;Data;ADO.NET;Entity Framework,;EF; Core;Data O/RM,;entity-framework-core;TDengine