TDengine 时序数据库的 ADO.Net Core 提供程序 Maikebing.EntityFrameworkCore.Taos

简介

Entity, Framework, EF, Core, Data, O/RM, entity-framework-core,TDengine

Maikebing.Data.Taos 是一个基于TDengine 的RESTful Connector构建的ADO.Net 提供器。 这将允许你通过.Net Core 访问TDengine数据库。

Maikebing.EntityFrameworkCore.Taos 是一个Entity Framework Core 的提供器， 基于Maikebing.Data.Taos构建。 此功能尚未开发完成， 暂时误作使用。

安装使用:

Install-Package Maikebing.Data.Taos -Version 1.0.0

Maikebing.Data.Taos 使用范例

///Specify the name of the database

    string database = "db_" + DateTime.Now.ToString("yyyyMMddHHmmss");

    var builder = new TaosConnectionStringBuilder()

    {

        DataSource = "http://td.gitclub.cn/rest/sql",

        DataBase = database,

        Username = "root",

        Password = "taosdata"

    };

    //Example for ADO.Net

    using (var connection = new TaosConnection(builder.ConnectionString))

    {

        connection.Open();

        Console.WriteLine("create {0} {1}", database, connection.CreateCommand($"create database {database};").ExecuteNonQuery());

        Console.WriteLine("create table t {0} {1}", database, connection.CreateCommand($"create table {database}.t (ts timestamp, cdata int);").ExecuteNonQuery());

        Console.WriteLine("insert into t values  {0}  ", connection.CreateCommand($"insert into {database}.t values ('{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.ms")}', 10);").ExecuteNonQuery());

        Console.WriteLine("insert into t values  {0} ", connection.CreateCommand($"insert into {database}.t values ('{DateTime.Now.AddMonths(1).ToString("yyyy-MM-dd HH:mm:ss.ms")}', 20);").ExecuteNonQuery());

        var cmd_select = connection.CreateCommand();

        cmd_select.CommandText = $"select * from {database}.t";

        var reader = cmd_select.ExecuteReader();

        Console.WriteLine(cmd_select.CommandText);

        Console.WriteLine("");

        ConsoleTableBuilder.From(reader.ToDataTable()).WithFormat(ConsoleTableBuilderFormat.MarkDown).ExportAndWriteLine();

        Console.WriteLine("");

        Console.WriteLine("DROP TABLE  {0} {1}", database, connection.CreateCommand($"DROP TABLE  {database}.t;").ExecuteNonQuery());

        Console.WriteLine("DROP DATABASE {0} {1}", database, connection.CreateCommand($"DROP DATABASE   {database};").ExecuteNonQuery());

        connection.Close();

    }

    //Example for  Entity Framework Core

    using (var context = new TaosContext(new DbContextOptionsBuilder()

                                            .UseTaos(builder.ConnectionString).Options))

    {

        Console.WriteLine("EnsureCreated");

        context.Database.EnsureCreated();

        for (int i = 0; i < 10; i++)

        {

            var rd = new Random();

            context.sensor.Add(new sensor() { ts = DateTime.Now.AddMilliseconds(i), degree = rd.NextDouble(), pm25 = rd.Next(0, 1000) });

        }

        Console.WriteLine("Saveing");

        context.SaveChanges();

        Console.WriteLine("");

        Console.WriteLine("from s in context.sensor where s.pm25 > 0 select s ");

        Console.WriteLine("");

        var f = from s in context.sensor where s.pm25 > 0 select s;

        var ary = f.ToArray();

        ConsoleTableBuilder.From(ary.ToList()).WithFormat(ConsoleTableBuilderFormat.MarkDown).ExportAndWriteLine();

        context.Database.EnsureDeleted();

    }

    Console.WriteLine("");

    Console.WriteLine("Pass any key to exit....");

    Console.ReadKey();