C# Connector

TDengine.Connector 是 TDengine 提供的 C# 语言连接器。C# 开发人员可以通过它开发存取 TDengine 集群数据的 C# 应用软件。

TDengine.Connector 连接器支持通过 TDengine 客户端驱动（taosc）建立与 TDengine 运行实例的连接，提供数据写入、查询、订阅、schemaless 数据写入、参数绑定接口数据写入等功能 TDengine.Connector 目前暂未提供 REST 连接方式，用户可以参考 REST API 文档自行编写。

本文介绍如何在 Linux 或 Windows 环境中安装 TDengine.Connector，并通过 TDengine.Connector 连接 TDengine 集群，进行数据写入、查询等基本操作。

TDengine.Connector 的源码托管在 GitHub。

支持的平台

支持的平台和 TDengine 客户端驱动支持的平台一致。

版本支持

请参考版本支持列表

支持的功能特性

  1. 连接管理
  2. 普通查询
  3. 连续查询
  4. 参数绑定
  5. 订阅功能
  6. Schemaless

安装步骤

安装前准备

使用 dotnet CLI 安装

  • 使用 dotnet CLI 获取 C# 驱动
  • 使用源码获取 C# 驱动

可以在当前 .NET 项目的路径下，通过 dotnet 命令引用 Nuget 中发布的 TDengine.Connector 到当前项目。

  1. dotnet add package TDengine.Connector

可以下载 TDengine 的源码，直接引用最新版本的 TDengine.Connector 库

  1. git clone https://github.com/taosdata/TDengine.git
  2. cd TDengine/src/connector/C#/src/
  3. cp -r TDengineDriver/ myProject
  5. cd myProject
  6. dotnet add TDengineDriver/TDengineDriver.csproj

建立连接

  1. using TDengineDriver;
  3. namespace TDengineExample
  4. {
  6.     internal class EstablishConnection
  7.     {
  8.         static void Main(String[] args)
  9.         {
  10.             string host = "localhost";
  11.             short port = 6030;
  12.             string username = "root";
  13.             string password = "taosdata";
  14.             string dbname = "";
  16.             var conn = TDengine.Connect(host, username, password, dbname, port);
  17.             if (conn == IntPtr.Zero)
  18.             {
  19.                 Console.WriteLine("Connect to TDengine failed");
  20.             }
  21.             else
  22.             {
  23.                 Console.WriteLine("Connect to TDengine success");
  24.             }
  25.             TDengine.Close(conn);
  26.             TDengine.Cleanup();
  27.         }
  28.     }
  29. }

使用示例

写入数据

SQL 写入

  1. using TDengineDriver;
  4. namespace TDengineExample
  5. {
  6.     internal class SQLInsertExample
  7.     {
  9.         static void Main()
  10.         {
  11.             IntPtr conn = GetConnection();
  12.             IntPtr res = TDengine.Query(conn, "CREATE DATABASE power");
  13.             CheckRes(conn, res, "failed to create database");
  14.             res = TDengine.Query(conn, "USE power");
  15.             CheckRes(conn, res, "failed to change database");
  16.             res = TDengine.Query(conn, "CREATE STABLE power.meters (ts TIMESTAMP, current FLOAT, voltage INT, phase FLOAT) TAGS (location BINARY(64), groupId INT)");
  17.             CheckRes(conn, res, "failed to create stable");
  18.             var sql = "INSERT INTO d1001 USING meters TAGS(California.SanFrancisco, 2) VALUES ('2018-10-03 14:38:05.000', 10.30000, 219, 0.31000) ('2018-10-03 14:38:15.000', 12.60000, 218, 0.33000) ('2018-10-03 14:38:16.800', 12.30000, 221, 0.31000) " +
  19.                         "d1002 USING power.meters TAGS(California.SanFrancisco, 3) VALUES('2018-10-03 14:38:16.650', 10.30000, 218, 0.25000) " +
  20.                         "d1003 USING power.meters TAGS(California.LosAngeles, 2) VALUES('2018-10-03 14:38:05.500', 11.80000, 221, 0.28000)('2018-10-03 14:38:16.600', 13.40000, 223, 0.29000) " +
  21.                         "d1004 USING power.meters TAGS(California.LosAngeles, 3) VALUES('2018-10-03 14:38:05.000', 10.80000, 223, 0.29000)('2018-10-03 14:38:06.500', 11.50000, 221, 0.35000)";
  22.             res = TDengine.Query(conn, sql);
  23.             CheckRes(conn, res, "failed to insert data");
  24.             int affectedRows = TDengine.AffectRows(res);
  25.             Console.WriteLine("affectedRows " + affectedRows);
  26.             ExitProgram(conn, 0);
  27.         }
  29.         static IntPtr GetConnection()
  30.         {
  31.             string host = "localhost";
  32.             short port = 6030;
  33.             string username = "root";
  34.             string password = "taosdata";
  35.             string dbname = "";
  36.             var conn = TDengine.Connect(host, username, password, dbname, port);
  37.             if (conn == IntPtr.Zero)
  38.             {
  39.                 Console.WriteLine("Connect to TDengine failed");
  40.                 Environment.Exit(0);
  41.             }
  42.             else
  43.             {
  44.                 Console.WriteLine("Connect to TDengine success");
  45.             }
  46.             return conn;
  47.         }
  49.         static void CheckRes(IntPtr conn, IntPtr res, String errorMsg)
  50.         {
  51.             if (TDengine.ErrorNo(res) != 0)
  52.             {
  53.                 Console.Write(errorMsg + " since: " + TDengine.Error(res));
  54.                 ExitProgram(conn, 1);
  55.             }
  56.         }
  58.         static void ExitProgram(IntPtr conn, int exitCode)
  59.         {
  60.             TDengine.Close(conn);
  61.             TDengine.Cleanup();
  62.             Environment.Exit(exitCode);
  63.         }
  64.     }
  65. }
  67. // output:
  68. // Connect to TDengine success
  69. // affectedRows 8

查看源码

InfluxDB 行协议写入

  1. using TDengineDriver;
  3. namespace TDengineExample
  4. {
  5.     internal class InfluxDBLineExample
  6.     {
  7.         static void Main()
  8.         {
  9.             IntPtr conn = GetConnection();
  10.             PrepareDatabase(conn);
  11.             string[] lines = {
  12.                 "meters,location=California.LosAngeles,groupid=2 current=11.8,voltage=221,phase=0.28 1648432611249",
  13.                 "meters,location=California.LosAngeles,groupid=2 current=13.4,voltage=223,phase=0.29 1648432611250",
  14.                 "meters,location=California.LosAngeles,groupid=3 current=10.8,voltage=223,phase=0.29 1648432611249",
  15.                 "meters,location=California.LosAngeles,groupid=3 current=11.3,voltage=221,phase=0.35 1648432611250"
  16.             };
  17.             IntPtr res = TDengine.SchemalessInsert(conn, lines, lines.Length, (int)TDengineSchemalessProtocol.TSDB_SML_LINE_PROTOCOL, (int)TDengineSchemalessPrecision.TSDB_SML_TIMESTAMP_MILLI_SECONDS);
  18.             if (TDengine.ErrorNo(res) != 0)
  19.             {
  20.                 Console.WriteLine("SchemalessInsert failed since " + TDengine.Error(res));
  21.                 ExitProgram(conn, 1);
  22.             }
  23.             else
  24.             {
  25.                 int affectedRows = TDengine.AffectRows(res);
  26.                 Console.WriteLine($"SchemalessInsert success, affected {affectedRows} rows");
  27.             }
  28.             TDengine.FreeResult(res);
  29.             ExitProgram(conn, 0);
  31.         }
  32.         static IntPtr GetConnection()
  33.         {
  34.             string host = "localhost";
  35.             short port = 6030;
  36.             string username = "root";
  37.             string password = "taosdata";
  38.             string dbname = "";
  39.             var conn = TDengine.Connect(host, username, password, dbname, port);
  40.             if (conn == IntPtr.Zero)
  41.             {
  42.                 Console.WriteLine("Connect to TDengine failed");
  43.                 TDengine.Cleanup();
  44.                 Environment.Exit(1);
  45.             }
  46.             else
  47.             {
  48.                 Console.WriteLine("Connect to TDengine success");
  49.             }
  50.             return conn;
  51.         }
  53.         static void PrepareDatabase(IntPtr conn)
  54.         {
  55.             IntPtr res = TDengine.Query(conn, "CREATE DATABASE test");
  56.             if (TDengine.ErrorNo(res) != 0)
  57.             {
  58.                 Console.WriteLine("failed to create database, reason: " + TDengine.Error(res));
  59.                 ExitProgram(conn, 1);
  60.             }
  61.             res = TDengine.Query(conn, "USE test");
  62.             if (TDengine.ErrorNo(res) != 0)
  63.             {
  64.                 Console.WriteLine("failed to change database, reason: " + TDengine.Error(res));
  65.                 ExitProgram(conn, 1);
  66.             }
  67.         }
  69.         static void ExitProgram(IntPtr conn, int exitCode)
  70.         {
  71.             TDengine.Close(conn);
  72.             TDengine.Cleanup();
  73.             Environment.Exit(exitCode);
  74.         }
  75.     }
  77. }

查看源码

OpenTSDB Telnet 行协议写入

  1. using TDengineDriver;
  3. namespace TDengineExample
  4. {
  5.     internal class OptsTelnetExample
  6.     {
  7.         static void Main()
  8.         {
  9.             IntPtr conn = GetConnection();
  10.             PrepareDatabase(conn);
  11.             string[] lines = {
  12.                 "meters.current 1648432611249 10.3 location=California.SanFrancisco groupid=2",
  13.                 "meters.current 1648432611250 12.6 location=California.SanFrancisco groupid=2",
  14.                 "meters.current 1648432611249 10.8 location=California.LosAngeles groupid=3",
  15.                 "meters.current 1648432611250 11.3 location=California.LosAngeles groupid=3",
  16.                 "meters.voltage 1648432611249 219 location=California.SanFrancisco groupid=2",
  17.                 "meters.voltage 1648432611250 218 location=California.SanFrancisco groupid=2",
  18.                 "meters.voltage 1648432611249 221 location=California.LosAngeles groupid=3",
  19.                 "meters.voltage 1648432611250 217 location=California.LosAngeles groupid=3",
  20.             };
  21.             IntPtr res = TDengine.SchemalessInsert(conn, lines, lines.Length, (int)TDengineSchemalessProtocol.TSDB_SML_TELNET_PROTOCOL, (int)TDengineSchemalessPrecision.TSDB_SML_TIMESTAMP_NOT_CONFIGURED);
  22.             if (TDengine.ErrorNo(res) != 0)
  23.             {
  24.                 Console.WriteLine("SchemalessInsert failed since " + TDengine.Error(res));
  25.                 ExitProgram(conn, 1);
  26.             }
  27.             else
  28.             {
  29.                 int affectedRows = TDengine.AffectRows(res);
  30.                 Console.WriteLine($"SchemalessInsert success, affected {affectedRows} rows");
  31.             }
  32.             TDengine.FreeResult(res);
  33.             ExitProgram(conn, 0);
  35.         }
  36.         static IntPtr GetConnection()
  37.         {
  38.             string host = "localhost";
  39.             short port = 6030;
  40.             string username = "root";
  41.             string password = "taosdata";
  42.             string dbname = "";
  43.             var conn = TDengine.Connect(host, username, password, dbname, port);
  44.             if (conn == IntPtr.Zero)
  45.             {
  46.                 Console.WriteLine("Connect to TDengine failed");
  47.                 TDengine.Cleanup();
  48.                 Environment.Exit(1);
  49.             }
  50.             else
  51.             {
  52.                 Console.WriteLine("Connect to TDengine success");
  53.             }
  54.             return conn;
  55.         }
  57.         static void PrepareDatabase(IntPtr conn)
  58.         {
  59.             IntPtr res = TDengine.Query(conn, "CREATE DATABASE test");
  60.             if (TDengine.ErrorNo(res) != 0)
  61.             {
  62.                 Console.WriteLine("failed to create database, reason: " + TDengine.Error(res));
  63.                 ExitProgram(conn, 1);
  64.             }
  65.             res = TDengine.Query(conn, "USE test");
  66.             if (TDengine.ErrorNo(res) != 0)
  67.             {
  68.                 Console.WriteLine("failed to change database, reason: " + TDengine.Error(res));
  69.                 ExitProgram(conn, 1);
  70.             }
  71.         }
  73.         static void ExitProgram(IntPtr conn, int exitCode)
  74.         {
  75.             TDengine.Close(conn);
  76.             TDengine.Cleanup();
  77.             Environment.Exit(exitCode);
  78.         }
  79.     }
  80. }

查看源码

OpenTSDB JSON 行协议写入

  1. using TDengineDriver;
  3. namespace TDengineExample
  4. {
  5.     internal class OptsJsonExample
  6.     {
  7.         static void Main()
  8.         {
  9.             IntPtr conn = GetConnection();
  10.             PrepareDatabase(conn);
  11.             string[] lines = { "[{\"metric\": \"meters.current\", \"timestamp\": 1648432611249, \"value\": 10.3, \"tags\": {\"location\": \"California.SanFrancisco\", \"groupid\": 2}}," +
  12.                 " {\"metric\": \"meters.voltage\", \"timestamp\": 1648432611249, \"value\": 219, \"tags\": {\"location\": \"California.LosAngeles\", \"groupid\": 1}}, " +
  13.                 "{\"metric\": \"meters.current\", \"timestamp\": 1648432611250, \"value\": 12.6, \"tags\": {\"location\": \"California.SanFrancisco\", \"groupid\": 2}}," +
  14.                 " {\"metric\": \"meters.voltage\", \"timestamp\": 1648432611250, \"value\": 221, \"tags\": {\"location\": \"California.LosAngeles\", \"groupid\": 1}}]"
  15.             };
  17.             IntPtr res = TDengine.SchemalessInsert(conn, lines, 1, (int)TDengineSchemalessProtocol.TSDB_SML_JSON_PROTOCOL, (int)TDengineSchemalessPrecision.TSDB_SML_TIMESTAMP_NOT_CONFIGURED);
  18.             if (TDengine.ErrorNo(res) != 0)
  19.             {
  20.                 Console.WriteLine("SchemalessInsert failed since " + TDengine.Error(res));
  21.                 ExitProgram(conn, 1);
  22.             }
  23.             else
  24.             {
  25.                 int affectedRows = TDengine.AffectRows(res);
  26.                 Console.WriteLine($"SchemalessInsert success, affected {affectedRows} rows");
  27.             }
  28.             TDengine.FreeResult(res);
  29.             ExitProgram(conn, 0);
  31.         }
  32.         static IntPtr GetConnection()
  33.         {
  34.             string host = "localhost";
  35.             short port = 6030;
  36.             string username = "root";
  37.             string password = "taosdata";
  38.             string dbname = "";
  39.             var conn = TDengine.Connect(host, username, password, dbname, port);
  40.             if (conn == IntPtr.Zero)
  41.             {
  42.                 Console.WriteLine("Connect to TDengine failed");
  43.                 TDengine.Cleanup();
  44.                 Environment.Exit(1);
  45.             }
  46.             else
  47.             {
  48.                 Console.WriteLine("Connect to TDengine success");
  49.             }
  50.             return conn;
  51.         }
  53.         static void PrepareDatabase(IntPtr conn)
  54.         {
  55.             IntPtr res = TDengine.Query(conn, "CREATE DATABASE test");
  56.             if (TDengine.ErrorNo(res) != 0)
  57.             {
  58.                 Console.WriteLine("failed to create database, reason: " + TDengine.Error(res));
  59.                 ExitProgram(conn, 1);
  60.             }
  61.             res = TDengine.Query(conn, "USE test");
  62.             if (TDengine.ErrorNo(res) != 0)
  63.             {
  64.                 Console.WriteLine("failed to change database, reason: " + TDengine.Error(res));
  65.                 ExitProgram(conn, 1);
  66.             }
  67.         }
  69.         static void ExitProgram(IntPtr conn, int exitCode)
  70.         {
  71.             TDengine.Close(conn);
  72.             TDengine.Cleanup();
  73.             Environment.Exit(exitCode);
  74.         }
  75.     }
  76. }

查看源码

查询数据

同步查询

  1. using TDengineDriver;
  2. using System.Runtime.InteropServices;
  4. namespace TDengineExample
  5. {
  6.     internal class QueryExample
  7.     {
  8.         static void Main()
  9.         {
  10.             IntPtr conn = GetConnection();
  11.             // run query
  12.             IntPtr res = TDengine.Query(conn, "SELECT * FROM test.meters LIMIT 2");
  13.             if (TDengine.ErrorNo(res) != 0)
  14.             {
  15.                 Console.WriteLine("Failed to query since: " + TDengine.Error(res));
  16.                 TDengine.Close(conn);
  17.                 TDengine.Cleanup();
  18.                 return;
  19.             }
  21.             // get filed count
  22.             int fieldCount = TDengine.FieldCount(res);
  23.             Console.WriteLine("fieldCount=" + fieldCount);
  25.             // print column names
  26.             List<TDengineMeta> metas = TDengine.FetchFields(res);
  27.             for (int i = 0; i < metas.Count; i++)
  28.             {
  29.                 Console.Write(metas[i].name + "\t");
  30.             }
  31.             Console.WriteLine();
  33.             // print values
  34.             IntPtr row;
  35.             while ((row = TDengine.FetchRows(res)) != IntPtr.Zero)
  36.             {
  37.                 List<TDengineMeta> metaList = TDengine.FetchFields(res);
  38.                 int numOfFiled = TDengine.FieldCount(res);
  40.                 List<String> dataRaw = new List<string>();
  42.                 IntPtr colLengthPrt = TDengine.FetchLengths(res);
  43.                 int[] colLengthArr = new int[numOfFiled];
  44.                 Marshal.Copy(colLengthPrt, colLengthArr, 0, numOfFiled);
  46.                 for (int i = 0; i < numOfFiled; i++)
  47.                 {
  48.                     TDengineMeta meta = metaList[i];
  49.                     IntPtr data = Marshal.ReadIntPtr(row, IntPtr.Size * i);
  51.                     if (data == IntPtr.Zero)
  52.                     {
  53.                         Console.Write("NULL\t");
  54.                         continue;
  55.                     }
  56.                     switch ((TDengineDataType)meta.type)
  57.                     {
  58.                         case TDengineDataType.TSDB_DATA_TYPE_BOOL:
  59.                             bool v1 = Marshal.ReadByte(data) == 0 ? false : true;
  60.                             Console.Write(v1.ToString() + "\t");
  61.                             break;
  62.                         case TDengineDataType.TSDB_DATA_TYPE_TINYINT:
  63.                             sbyte v2 = (sbyte)Marshal.ReadByte(data);
  64.                             Console.Write(v2.ToString() + "\t");
  65.                             break;
  66.                         case TDengineDataType.TSDB_DATA_TYPE_SMALLINT:
  67.                             short v3 = Marshal.ReadInt16(data);
  68.                             Console.Write(v3.ToString() + "\t");
  69.                             break;
  70.                         case TDengineDataType.TSDB_DATA_TYPE_INT:
  71.                             int v4 = Marshal.ReadInt32(data);
  72.                             Console.Write(v4.ToString() + "\t");
  73.                             break;
  74.                         case TDengineDataType.TSDB_DATA_TYPE_BIGINT:
  75.                             long v5 = Marshal.ReadInt64(data);
  76.                             Console.Write(v5.ToString() + "\t");
  77.                             break;
  78.                         case TDengineDataType.TSDB_DATA_TYPE_FLOAT:
  79.                             float v6 = (float)Marshal.PtrToStructure(data, typeof(float));
  80.                             Console.Write(v6.ToString() + "\t");
  81.                             break;
  82.                         case TDengineDataType.TSDB_DATA_TYPE_DOUBLE:
  83.                             double v7 = (double)Marshal.PtrToStructure(data, typeof(double));
  84.                             Console.Write(v7.ToString() + "\t");
  85.                             break;
  86.                         case TDengineDataType.TSDB_DATA_TYPE_BINARY:
  87.                             string v8 = Marshal.PtrToStringUTF8(data, colLengthArr[i]);
  88.                             Console.Write(v8 + "\t");
  89.                             break;
  90.                         case TDengineDataType.TSDB_DATA_TYPE_TIMESTAMP:
  91.                             long v9 = Marshal.ReadInt64(data);
  92.                             Console.Write(v9.ToString() + "\t");
  93.                             break;
  94.                         case TDengineDataType.TSDB_DATA_TYPE_NCHAR:
  95.                             string v10 = Marshal.PtrToStringUTF8(data, colLengthArr[i]);
  96.                             Console.Write(v10 + "\t");
  97.                             break;
  98.                         case TDengineDataType.TSDB_DATA_TYPE_UTINYINT:
  99.                             byte v12 = Marshal.ReadByte(data);
  100.                             Console.Write(v12.ToString() + "\t");
  101.                             break;
  102.                         case TDengineDataType.TSDB_DATA_TYPE_USMALLINT:
  103.                             ushort v13 = (ushort)Marshal.ReadInt16(data);
  104.                             Console.Write(v13.ToString() + "\t");
  105.                             break;
  106.                         case TDengineDataType.TSDB_DATA_TYPE_UINT:
  107.                             uint v14 = (uint)Marshal.ReadInt32(data);
  108.                             Console.Write(v14.ToString() + "\t");
  109.                             break;
  110.                         case TDengineDataType.TSDB_DATA_TYPE_UBIGINT:
  111.                             ulong v15 = (ulong)Marshal.ReadInt64(data);
  112.                             Console.Write(v15.ToString() + "\t");
  113.                             break;
  114.                         case TDengineDataType.TSDB_DATA_TYPE_JSONTAG:
  115.                             string v16 = Marshal.PtrToStringUTF8(data, colLengthArr[i]);
  116.                             Console.Write(v16 + "\t");
  117.                             break;
  118.                         default:
  119.                             Console.Write("nonsupport data type value");
  120.                             break;
  121.                     }
  123.                 }
  124.                 Console.WriteLine();
  125.             }
  126.             if (TDengine.ErrorNo(res) != 0)
  127.             {
  128.                 Console.WriteLine($"Query is not complete, Error {TDengine.ErrorNo(res)} {TDengine.Error(res)}");
  129.             }
  130.             // exit
  131.             TDengine.FreeResult(res);
  132.             TDengine.Close(conn);
  133.             TDengine.Cleanup();
  134.         }
  135.         static IntPtr GetConnection()
  136.         {
  137.             string host = "localhost";
  138.             short port = 6030;
  139.             string username = "root";
  140.             string password = "taosdata";
  141.             string dbname = "power";
  142.             var conn = TDengine.Connect(host, username, password, dbname, port);
  143.             if (conn == IntPtr.Zero)
  144.             {
  145.                 Console.WriteLine("Connect to TDengine failed");
  146.                 System.Environment.Exit(0);
  147.             }
  148.             else
  149.             {
  150.                 Console.WriteLine("Connect to TDengine success");
  151.             }
  152.             return conn;
  153.         }
  154.     }
  155. }
  157. // output:
  158. // Connect to TDengine success
  159. // fieldCount=6
  160. // ts      current voltage phase   location        groupid
  161. // 1648432611249   10.3    219     0.31    California.SanFrancisco        2
  162. // 1648432611749   12.6    218     0.33    California.SanFrancisco        2

查看源码

异步查询

  1. using TDengineDriver;
  2. using System.Runtime.InteropServices;
  4. namespace TDengineExample
  5. {
  6.     public class AsyncQueryExample
  7.     {
  8.         static void Main()
  9.         {
  10.             IntPtr conn = GetConnection();
  11.             QueryAsyncCallback queryAsyncCallback = new QueryAsyncCallback(QueryCallback);
  12.             TDengine.QueryAsync(conn, "select * from meters", queryAsyncCallback, IntPtr.Zero);
  13.             Thread.Sleep(2000);
  14.             TDengine.Close(conn);
  15.             TDengine.Cleanup();
  16.         }
  18.         static void QueryCallback(IntPtr param, IntPtr taosRes, int code)
  19.         {
  20.             if (code == 0 && taosRes != IntPtr.Zero)
  21.             {
  22.                 FetchRowAsyncCallback fetchRowAsyncCallback = new FetchRowAsyncCallback(FetchRowCallback);
  23.                 TDengine.FetchRowAsync(taosRes, fetchRowAsyncCallback, param);
  24.             }
  25.             else
  26.             {
  27.                 Console.WriteLine($"async query data failed, failed code {code}");
  28.             }
  29.         }
  31.         static void FetchRowCallback(IntPtr param, IntPtr taosRes, int numOfRows)
  32.         {
  33.             if (numOfRows > 0)
  34.             {
  35.                 Console.WriteLine($"{numOfRows} rows async retrieved");
  36.                 DisplayRes(taosRes);
  37.                 TDengine.FetchRowAsync(taosRes, FetchRowCallback, param);
  38.             }
  39.             else
  40.             {
  41.                 if (numOfRows == 0)
  42.                 {
  43.                     Console.WriteLine("async retrieve complete.");
  45.                 }
  46.                 else
  47.                 {
  48.                     Console.WriteLine($"FetchRowAsync callback error, error code {numOfRows}");
  49.                 }
  50.                 TDengine.FreeResult(taosRes);
  51.             }
  52.         }
  54.         public static void DisplayRes(IntPtr res)
  55.         {
  56.             if (!IsValidResult(res))
  57.             {
  58.                 TDengine.Cleanup();
  59.                 System.Environment.Exit(1);
  60.             }
  62.             List<TDengineMeta> metaList = TDengine.FetchFields(res);
  63.             int fieldCount = metaList.Count;
  64.             // metaList.ForEach((item) => { Console.Write("{0} ({1}) \t|\t", item.name, item.size); });
  66.             List<object> dataList = QueryRes(res, metaList);
  67.             for (int index = 0; index < dataList.Count; index++)
  68.             {
  69.                 if (index % fieldCount == 0 && index != 0)
  70.                 {
  71.                     Console.WriteLine("");
  72.                 }
  73.                 Console.Write("{0} \t|\t", dataList[index].ToString());
  75.             }
  76.             Console.WriteLine("");
  77.         }
  79.         public static bool IsValidResult(IntPtr res)
  80.         {
  81.             if ((res == IntPtr.Zero) || (TDengine.ErrorNo(res) != 0))
  82.             {
  83.                 if (res != IntPtr.Zero)
  84.                 {
  85.                     Console.Write("reason: " + TDengine.Error(res));
  86.                     return false;
  87.                 }
  88.                 Console.WriteLine("");
  89.                 return false;
  90.             }
  91.             return true;
  92.         }
  94.         private static List<object> QueryRes(IntPtr res, List<TDengineMeta> meta)
  95.         {
  96.             IntPtr taosRow;
  97.             List<object> dataRaw = new();
  98.             while ((taosRow = TDengine.FetchRows(res)) != IntPtr.Zero)
  99.             {
  100.                 dataRaw.AddRange(FetchRow(taosRow, res));
  101.             }
  102.             if (TDengine.ErrorNo(res) != 0)
  103.             {
  104.                 Console.Write("Query is not complete, Error {0} {1}", TDengine.ErrorNo(res), TDengine.Error(res));
  105.             }
  106.             TDengine.FreeResult(res);
  107.             Console.WriteLine("");
  108.             return dataRaw;
  109.         }
  111.         public static List<object> FetchRow(IntPtr taosRow, IntPtr taosRes)//, List<TDengineMeta> metaList, int numOfFiled
  112.         {
  113.             List<TDengineMeta> metaList = TDengine.FetchFields(taosRes);
  114.             int numOfFiled = TDengine.FieldCount(taosRes);
  117.             List<object> dataRaw = new();
  119.             IntPtr colLengthPrt = TDengine.FetchLengths(taosRes);
  120.             int[] colLengthArr = new int[numOfFiled];
  121.             Marshal.Copy(colLengthPrt, colLengthArr, 0, numOfFiled);
  123.             for (int i = 0; i < numOfFiled; i++)
  124.             {
  125.                 TDengineMeta meta = metaList[i];
  126.                 IntPtr data = Marshal.ReadIntPtr(taosRow, IntPtr.Size * i);
  128.                 if (data == IntPtr.Zero)
  129.                 {
  130.                     dataRaw.Add("NULL");
  131.                     continue;
  132.                 }
  133.                 switch ((TDengineDataType)meta.type)
  134.                 {
  135.                     case TDengineDataType.TSDB_DATA_TYPE_BOOL:
  136.                         bool v1 = Marshal.ReadByte(data) != 0;
  137.                         dataRaw.Add(v1);
  138.                         break;
  139.                     case TDengineDataType.TSDB_DATA_TYPE_TINYINT:
  140.                         sbyte v2 = (sbyte)Marshal.ReadByte(data);
  141.                         dataRaw.Add(v2);
  142.                         break;
  143.                     case TDengineDataType.TSDB_DATA_TYPE_SMALLINT:
  144.                         short v3 = Marshal.ReadInt16(data);
  145.                         dataRaw.Add(v3);
  146.                         break;
  147.                     case TDengineDataType.TSDB_DATA_TYPE_INT:
  148.                         int v4 = Marshal.ReadInt32(data);
  149.                         dataRaw.Add(v4);
  150.                         break;
  151.                     case TDengineDataType.TSDB_DATA_TYPE_BIGINT:
  152.                         long v5 = Marshal.ReadInt64(data);
  153.                         dataRaw.Add(v5);
  154.                         break;
  155.                     case TDengineDataType.TSDB_DATA_TYPE_FLOAT:
  156.                         float v6 = (float)Marshal.PtrToStructure(data, typeof(float));
  157.                         dataRaw.Add(v6);
  158.                         break;
  159.                     case TDengineDataType.TSDB_DATA_TYPE_DOUBLE:
  160.                         double v7 = (double)Marshal.PtrToStructure(data, typeof(double));
  161.                         dataRaw.Add(v7);
  162.                         break;
  163.                     case TDengineDataType.TSDB_DATA_TYPE_BINARY:
  164.                         string v8 = Marshal.PtrToStringUTF8(data, colLengthArr[i]);
  165.                         dataRaw.Add(v8);
  166.                         break;
  167.                     case TDengineDataType.TSDB_DATA_TYPE_TIMESTAMP:
  168.                         long v9 = Marshal.ReadInt64(data);
  169.                         dataRaw.Add(v9);
  170.                         break;
  171.                     case TDengineDataType.TSDB_DATA_TYPE_NCHAR:
  172.                         string v10 = Marshal.PtrToStringUTF8(data, colLengthArr[i]);
  173.                         dataRaw.Add(v10);
  174.                         break;
  175.                     case TDengineDataType.TSDB_DATA_TYPE_UTINYINT:
  176.                         byte v12 = Marshal.ReadByte(data);
  177.                         dataRaw.Add(v12.ToString());
  178.                         break;
  179.                     case TDengineDataType.TSDB_DATA_TYPE_USMALLINT:
  180.                         ushort v13 = (ushort)Marshal.ReadInt16(data);
  181.                         dataRaw.Add(v13);
  182.                         break;
  183.                     case TDengineDataType.TSDB_DATA_TYPE_UINT:
  184.                         uint v14 = (uint)Marshal.ReadInt32(data);
  185.                         dataRaw.Add(v14);
  186.                         break;
  187.                     case TDengineDataType.TSDB_DATA_TYPE_UBIGINT:
  188.                         ulong v15 = (ulong)Marshal.ReadInt64(data);
  189.                         dataRaw.Add(v15);
  190.                         break;
  191.                     case TDengineDataType.TSDB_DATA_TYPE_JSONTAG:
  192.                         string v16 = Marshal.PtrToStringUTF8(data, colLengthArr[i]);
  193.                         dataRaw.Add(v16);
  194.                         break;
  195.                     default:
  196.                         dataRaw.Add("nonsupport data type");
  197.                         break;
  198.                 }
  200.             }
  201.             return dataRaw;
  202.         }
  204.         static IntPtr GetConnection()
  205.         {
  206.             string host = "localhost";
  207.             short port = 6030;
  208.             string username = "root";
  209.             string password = "taosdata";
  210.             string dbname = "power";
  211.             var conn = TDengine.Connect(host, username, password, dbname, port);
  212.             if (conn == IntPtr.Zero)
  213.             {
  214.                 Console.WriteLine("Connect to TDengine failed");
  215.                 Environment.Exit(0);
  216.             }
  217.             else
  218.             {
  219.                 Console.WriteLine("Connect to TDengine success");
  220.             }
  221.             return conn;
  222.         }
  223.     }
  224. }
  226. //output:
  227. // Connect to TDengine success
  228. // 8 rows async retrieved
  230. // 1538548685500   |       11.8    |       221     |       0.28    |       california.losangeles   |       2       |
  231. // 1538548696600   |       13.4    |       223     |       0.29    |       california.losangeles   |       2       |
  232. // 1538548685000   |       10.8    |       223     |       0.29    |       california.losangeles   |       3       |
  233. // 1538548686500   |       11.5    |       221     |       0.35    |       california.losangeles   |       3       |
  234. // 1538548685000   |       10.3    |       219     |       0.31    |       california.sanfrancisco         |       2       |
  235. // 1538548695000   |       12.6    |       218     |       0.33    |       california.sanfrancisco         |       2       |
  236. // 1538548696800   |       12.3    |       221     |       0.31    |       california.sanfrancisco         |       2       |
  237. // 1538548696650   |       10.3    |       218     |       0.25    |       california.sanfrancisco         |       3       |
  238. // async retrieve complete.

查看源码

更多示例程序

示例程序示例程序描述
C#checker使用 TDengine.Connector 可以通过 help 命令中提供的参数，测试C# Driver的同步写入和查询
TDengineTest使用 TDengine.Connector 实现的简单写入和查询的示例
insertCn使用 TDengine.Connector 实现的写入和查询中文字符的示例
jsonTag使用 TDengine.Connector 实现的写入和查询 json tag 类型数据的示例
stmt使用 TDengine.Connector 实现的参数绑定的示例
schemaless使用 TDengine.Connector 实现的使用 schemaless 写入的示例
benchmark使用 TDengine.Connector 实现的简易 Benchmark
async query使用 TDengine.Connector 实现的异步查询的示例
subscribe使用 TDengine.Connector 实现的订阅数据的示例

重要更新记录

TDengine.Connector说明
1.0.6修复 schemaless 在 1.0.4 和 1.0.5 中失效 bug。
1.0.5修复 Windows 同步查询中文报错 bug。
1.0.4新增异步查询，订阅等功能。修复绑定参数 bug。
1.0.3新增参数绑定、schemaless、 json tag等功能。
1.0.2新增连接管理、同步查询、错误信息等功能。

其他说明

第三方驱动

Maikebing.Data.Taos 是一个 TDengine 的 ADO.NET 连接器，支持 Linux，Windows 平台。该连接器由社区贡献者麦壳饼@@maikebing 提供，具体请参考:

常见问题

  1. “Unable to establish connection”，”Unable to resolve FQDN”

    一般是因为 FQDN 配置不正确。可以参考如何彻底搞懂 TDengine 的 FQDN解决。

  2. Unhandled exception. System.DllNotFoundException: Unable to load DLL ‘taos’ or one of its dependencies: 找不到指定的模块。

    一般是因为程序没有找到依赖的客户端驱动。解决方法为：Windows 下可以将 C:\TDengine\driver\taos.dll 拷贝到 C:\Windows\System32\ 目录下，Linux 下建立如下软链接 ln -s /usr/local/taos/driver/libtaos.so.x.x.x.x /usr/lib/libtaos.so 即可。

API 参考

API 参考