Merge pull request #264 from taosdata/bug/245

查询仅返回4096行数据 #245

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());

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(); }
+
+ }
+ }
+}

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;
  }

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; }
+
  }
 }