查询仅返回4096行数据 #245

IoTSharp · Jul 4, 2023 · 91f5d5f · 91f5d5f
1 parent eb20195
commit 91f5d5f
Show file tree

Hide file tree

Showing 4 changed files with 50 additions and 4 deletions.
diff --git a/src/Example/Program.cs b/src/Example/Program.cs
@@ -64,6 +64,7 @@ private static void Main(string[] args)
                 Port = 80,
                 PoolSize = 20
             };
+            issue245.test(new TaosConnection(builder.UseWebSocket().ConnectionString));
             issues252.demo_code(builder);
 #if DEBUG
             // ExecSqlByNative(builder_cloud.UseCloud_DSN());

diff --git a/src/Example/issue245.cs b/src/Example/issue245.cs
@@ -0,0 +1,44 @@
+using IoTSharp.Data.Taos;
+using System;
+using System.Collections.Generic;
+using System.Diagnostics.Metrics;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using TaosADODemo;
+
+namespace Example
+{
+    internal class issue245
+    {
+        public static void test(TaosConnection connection)
+        {
+
+            try
+            {
+                connection.Open();
+                connection.CreateCommand($"create database if not exists  meters;").ExecuteNonQuery();
+                var lines = new List<string>();
+                for (int i = 0; i < 10000; i++)
+                {
+                    string line = string.Format($"meters,tname=cpu{i},location=California.LosAngeles{i},groupid=2 current={11.8 + i*2},voltage={221 + i},phase={0.28+i}", Program.DateTimeToLongTimeStamp()-10000+i);
+                    lines.Add(line);
+                }
+               connection.ChangeDatabase("meters");
+                connection.ExecuteLineBulkInsert(lines.ToArray(), TDengineDriver.TDengineSchemalessPrecision.TSDB_SML_TIMESTAMP_MICRO_SECONDS);
+                using var command = connection.CreateCommand();
+                command.CommandText = "select * from meters limit 1000000";
+                var reader = command.ExecuteReader();
+                var result = reader.ToDataTable();
+                Console.WriteLine(result.Rows.Count); // print 4096
+            }
+            catch (Exception ex)
+            {
+                Console.WriteLine(ex.Message);
+            }
+            finally
+            { connection.Close(); }
+
+        }
+    }
+}
diff --git a/src/IoTSharp.Data.Taos/Protocols/TDWebSocket/TaosWebSocket.cs b/src/IoTSharp.Data.Taos/Protocols/TDWebSocket/TaosWebSocket.cs
@@ -455,6 +455,7 @@ public nint Take()
 
         private void _open__schemaless(TaosConnectionStringBuilder builder)
         {
+            if (_schemaless_client == null) _schemaless_client = new ClientWebSocket();
             _open__ws_client(builder,_schemaless_client, "/rest/schemaless");
             WSExecute(_schemaless_client, "conn", new { user = builder.Username, password = builder.Password });
         }
@@ -492,9 +493,9 @@ public int ExecuteBulkInsert(string[] lines, TDengineSchemalessProtocol protocol
                 data = string.Join("\n", lines)
             }
             );
-            if (_insert != null)
+            if (_insert.code != 0)
             {
-                TaosException.ThrowExceptionForRC(new TaosErrorResult() { Code = -1, Error = "返回值错误." });
+                TaosException.ThrowExceptionForRC(new TaosErrorResult() { Code = _insert.code, Error =  _insert.message });
             }
             return lines.Length;
         }

diff --git a/src/IoTSharp.Data.Taos/Protocols/TDWebSocket/WSSchemalessRsp.cs b/src/IoTSharp.Data.Taos/Protocols/TDWebSocket/WSSchemalessRsp.cs
@@ -1,9 +1,9 @@
 namespace IoTSharp.Data.Taos.Protocols.TDWebSocket
 {
-    public class WSSchemalessRsp
+    public class WSSchemalessRsp: WSActionRsp
     {
         public int req_id { get; set; }
-        public string action { get; set; }
         public int timing { get; set; }
+
     }
 }