From 7b3c5f881febbd3432346c5e0a0e36b2f7cadefc Mon Sep 17 00:00:00 2001 From: pigwing Date: Mon, 21 Mar 2022 16:36:12 +0800 Subject: [PATCH 1/2] =?UTF-8?q?reader=E7=9A=84getString=E4=B8=AD,=E5=86=85?= =?UTF-8?q?=E5=AE=B9=E5=87=BA=E7=8E=B0=E6=A8=AA=E6=9D=86(-)=E7=9A=84?= =?UTF-8?q?=E6=97=B6=E5=80=99=E4=BC=9A=E6=9C=89=E4=B8=B2=E4=B8=80=E8=B5=B7?= =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/Example/Program.cs | 24 +++++++++++++------ .../Maikebing.Data.Taos.csproj | 2 +- 2 files changed, 18 insertions(+), 8 deletions(-) diff --git a/src/Example/Program.cs b/src/Example/Program.cs index c74bd2a..d34c917 100644 --- a/src/Example/Program.cs +++ b/src/Example/Program.cs @@ -20,7 +20,7 @@ static void Main(string[] args) string database = "db_" + DateTime.Now.ToString("yyyyMMddHHmmss"); var builder = new TaosConnectionStringBuilder() { - DataSource = "taos", + DataSource = "airleaderserver", DataBase = database, Username = "root", Password = "taosdata", @@ -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 From aa29c8daf7b53256697fba236370378da04b511d Mon Sep 17 00:00:00 2001 From: pigwing Date: Mon, 21 Mar 2022 16:37:01 +0800 Subject: [PATCH 2/2] =?UTF-8?q?=E6=94=B9=E5=9B=9E=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E6=BA=90=E5=90=8D=E7=A7=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/Example/Program.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/Example/Program.cs b/src/Example/Program.cs index d34c917..1a6ddf5 100644 --- a/src/Example/Program.cs +++ b/src/Example/Program.cs @@ -20,7 +20,7 @@ static void Main(string[] args) string database = "db_" + DateTime.Now.ToString("yyyyMMddHHmmss"); var builder = new TaosConnectionStringBuilder() { - DataSource = "airleaderserver", + DataSource = "taos", DataBase = database, Username = "root", Password = "taosdata",