lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-04-05 17:37:58 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update TDengine Demo

Browse Source
This commit is contained in:
sunkaixuan 2023-10-01 15:25:49 +08:00
parent 14ef1bee7a
commit e53e17d75a
11 changed files with 619 additions and 514 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Src/Asp.NetCore2/TDengineTest/Config.cs
View File

@ -4,7 +4,7 @@ using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace OrmTest
namespace TDengineTest
{
/// <summary>
/// Setting up the database name does not require you to create the database

516
Src/Asp.NetCore2/TDengineTest/Demo/ORMTest.cs
View File

@ -9,9 +9,9 @@ using System.Threading.Tasks;
using SqlSugar;
using TDengineDriver;
namespace OrmTest
namespace TDengineTest
{
public class ORMTest
public partial class ORMTest
{
public static void Init()
@ -31,519 +31,15 @@ namespace OrmTest
});
//简单用例
Demo1(db);
Demo1(db);
//测试用例
UnitTest(db);
Console.WriteLine("执行完成");
Console.ReadKey();
}
private static void Demo1(SqlSugarClient db)
{
//建库
db.DbMaintenance.CreateDatabase();
//建超级表
db.Ado.ExecuteCommand("CREATE STABLE IF NOT EXISTS St01 (ts TIMESTAMP, current FLOAT, voltage INT, phase FLOAT, isdelete BOOL, name BINARY(64)) TAGS (location BINARY(64), groupId INT)");
//创建子表
db.Ado.ExecuteCommand(@"create table IF NOT EXISTS MyTable02 using St01 tags('California.SanFrancisco',1)");
//查询子表
var dt = db.Ado.GetDataTable("select * from MyTable02 ");
//插入单条子表
db.Insertable(new MyTable02()
{
ts = DateTime.Now,
current = Convert.ToSingle(1.1),
groupId = 1,
isdelete = true,
name = "haha",
location = "aa",
phase = Convert.ToSingle(1.2),
voltage = 11
}).ExecuteCommand();
//批量插入子表
db.Insertable(GetInsertDatas()).ExecuteCommand();
//查询子表(主表字段也能查出来)
var list = db.Queryable<MyTable02>().OrderBy(it => it.ts).ToList();
//条件查询
var list2 = db.Queryable<MyTable02>().Where(it => it.name == "测试2").ToList();
var list22 = db.Queryable<MyTable02>().Where(it => it.voltage == 222).ToList();
var list222 = db.Queryable<MyTable02>().Where(it => it.phase == 1.2).ToList();
var list2222 = db.Queryable<MyTable02>().Where(it => it.isdelete == true).ToList();
//模糊查询
var list3 = db.Queryable<MyTable02>().Where(it => it.name.Contains("a")).ToList();
//时间差函数
var list31 = db.Queryable<MyTable02>().Select(it =>
new
{
diff = SqlFunc.DateDiff(DateType.Day, it.ts, DateTime.Now),
time=it.ts
}).ToList();
//时间加1天
var list32 = db.Queryable<MyTable02>().Select(it =>
new
{
addTime = SqlFunc.DateAdd(it.ts,1, DateType.Day),
oldime = it.ts
}).ToList();
//自定义函数:实现时间加1天
var list33 = db.Queryable<MyTable02>().Select(it =>
new
{
addTime =SqlFunc.MappingColumn<DateTime>(" `ts`+1d "),
oldime = it.ts
}).ToList();
//分页
var Count = 0;
var list4 = db.Queryable<MyTable02>().Where(it => it.voltage == 111)
.ToPageList(1, 2, ref Count);
//删除子表
var ts = list.First().ts;
var de = DateTime.Now.AddYears(-1);
var count = db.Deleteable<MyTable02>().Where(it => it.ts > de).ExecuteCommand();
//异步
db.Insertable(new MyTable02()
{
ts = DateTime.Now,
current = Convert.ToSingle(1.1),
groupId = 1,
isdelete = true,
name = "haha",
location = "aa",
phase = Convert.ToSingle(1.2),
voltage = 11
}).ExecuteCommandAsync().GetAwaiter().GetResult();
var list100 = db.Queryable<MyTable02>().ToListAsync().GetAwaiter().GetResult();
//联表查询:不支持left join只能这样
var list101= db.Queryable<MyTable02, MyTable02>((x, y) => x.ts == y.ts)
.Select((x,y) => new
{
xts=x.ts,
yts=y.ts
}).ToList();
//联表查询在分页
var list102 = db.Queryable<MyTable02, MyTable02>((x, y) => x.ts == y.ts)
.Select((x, y) => new
{
xts = x.ts,
yts = y.ts
}).ToPageList(1,2);
}
private static void UnitTest(SqlSugarClient db)
{
//类型测试
DbType(db);
DbType2(db);
//纳秒
NS();
//微秒
US();
}
private static void DbType2(SqlSugarClient db)
{
//建库
//db.Ado.ExecuteCommand("CREATE DATABASE IF NOT EXISTS db WAL_RETENTION_PERIOD 3600");
db.Ado.ExecuteCommand(@"CREATE DATABASE IF NOT EXISTS db123456
KEEP 1080
DURATION 10
BUFFER 16
WAL_LEVEL 1
CACHEMODEL 'both'");//不支持 UPDATE 1 选项
//建超级表
// DeviceType INT,
// DeviceCode BINARY(12),
db.Ado.ExecuteCommand(
@"CREATE STABLE IF NOT EXISTS ConveryTable
(
ts TIMESTAMP,
Action INT,
TaskNo INT,
Stime TIMESTAMP,
Etime TIMESTAMP,
GoodsType INT,
BarCode NCHAR(64),
FromNode NCHAR(24),
ToNode NCHAR(24),
Speed FLOAT,
AccSpeed FLOAT,
DecSpeed FLOAT,
Field1 NCHAR(256),
Field2 NCHAR(256),
Field3 NCHAR(256),
Field4 NCHAR(256),
Field5 NCHAR(256),
Field6 NCHAR(256),
Remark NCHAR(500)
)
TAGS
(
DeviceType INT, DeviceCode BINARY(12)
)");
var random = new Random();
string tablename = "t1118_" + (1000 + 99);
db.Ado.ExecuteCommand("create table IF NOT EXISTS t1118_1099 using ConveryTable tags(1,'1099')");
var curdb = db;
List<ConveryTable> rows = new List<ConveryTable>();
for (int k = 0; k < 10; k++)
{
rows.Add(new ConveryTable()
{
ts = DateTime.Now.AddDays(random.Next(1, 9)),
AccSpeed = random.Next(1, 9),
Action = 2,
BarCode = "1111" + k,
DecSpeed = random.Next(1, 9),
DeviceCode = "1001",
DeviceType = 1,
Etime = DateTime.Now.AddSeconds(k),
FromNode = "001001001",
ToNode = "002002" + k.ToString("d3"),
GoodsType = 3,
TaskNo = random.Next(1, 900),
Speed = random.Next(7, 90),
Stime = DateTime.Now,
});
}
curdb.Insertable(rows).AS(tablename).ExecuteCommand(); ;
curdb.Queryable<ConveryTable>().AS(tablename).ToList();
}
private static void DbType(SqlSugarClient db)
{
//更多类型查询测试
db.Ado.ExecuteCommand(@"
CREATE STABLE IF NOT EXISTS `fc_data` (
`upload_time` TIMESTAMP,
`voltage` SMALLINT,
`temperature` FLOAT,
`data_id` SMALLINT,
`speed_hex` VARCHAR(80),
`gateway_mac` VARCHAR(8),
`ruminate` SMALLINT,
`rssi` TINYINT) TAGS (`tag_id` VARCHAR(12))");
var list = db.Queryable<fc_data>().ToList();
//创建子表
db.Ado.ExecuteCommand(@"create table IF NOT EXISTS fc_data01 using `fc_data` tags('1')");
db.Insertable(new fc_data()
{
data_id = 1,
gateway_mac = "mac",
rssi = 11,
ruminate = 1,
speed_hex = "x",
temperature = 1,
upload_time = DateTime.Now,
voltage = 1
}).AS("fc_data01").ExecuteCommand();
var list2 = db.Queryable<fc_data>().AS("fc_data01").ToList();
}
private static void NS()
{
//说明:
//字符串中指定TsType=config_ns
//实体加上 SqlParameterDbType =typeof(DateTime19)
SqlSugarClient db = new SqlSugarClient(new ConnectionConfig() {
DbType=SqlSugar.DbType.TDengine,
IsAutoCloseConnection=true,
ConnectionString = "Host=localhost;Port=6030;Username=root;Password=taosdata;Database=nstest;TsType=config_ns" });
//删除库-库上限比太少只能删了测试
if(db.DbMaintenance.GetDataBaseList().Any(it=>it== "nstest"))
{
db.Ado.ExecuteCommand("drop database nstest");
}
db.DbMaintenance.CreateDatabase();//创建纳秒库
//建超级表
db.Ado.ExecuteCommand("CREATE STABLE IF NOT EXISTS St01 (ts TIMESTAMP, current FLOAT, voltage INT, phase FLOAT, isdelete BOOL, name BINARY(64)) TAGS (location BINARY(64), groupId INT)");
//创建子表
db.Ado.ExecuteCommand(@"create table IF NOT EXISTS MyTable02 using St01 tags('California.SanFrancisco',1)");
//查询子表
var dt = db.Ado.GetDataTable("select * from MyTable02 ");
//插入单条子表
db.Insertable(new MyTable02_NS()
{
ts = DateTime.Now,
current = Convert.ToSingle(1.1),
groupId = 1,
isdelete = true,
name = "haha",
location = "aa",
phase = Convert.ToSingle(1.2),
voltage = 11
}).ExecuteCommand();
var list=db.Queryable<MyTable02_NS>().ToList();
db.Ado.ExecuteCommand(@" CREATE TABLE aoi_recordsuper (fcreatetime timestamp, fsncode VARCHAR(50), fmachineno VARCHAR(50),lotno VARCHAR(50),billno VARCHAR(50),fresult VARCHAR(50)
,fproduct VARCHAR(50),machinetime VARCHAR(50),id VARCHAR(50),uploadtype VARCHAR(50),dimbin VARCHAR(50))
TAGS (workstation VARCHAR(50));");
var dt2=Convert.ToDateTime("2023-09-23 08:00:00.12345");
db.Ado.ExecuteCommand(@"
INSERT INTO aoirecord_2309 USING aoi_recordsuper TAGS (""AOI"")
VALUES ('2023-09-23', ""10.2"", ""A219"",""2309050001"",""B03123"",""OK"",""681-ABC"",""2023-9-5"",""123"",""首测"",""A"")
(now, ""10.2"", ""A219"",""2309050001"",""B03123"",""OK"",""681-ABC"",""2023-9-5"",""123"",""首测"",""A"")");
var date = Convert.ToDateTime("2023-9-25 00:00:00");
var list3=db.Queryable<T_TD_AOIRecord>().ToList();
var list2 = db.Queryable<T_TD_AOIRecord>()
.Where(t => t.fcreatetime >= date).ToList();
if (list2.Count != 1)
{
throw new Exception("unit error");
}
}
private static void US()
{
//clear static config
SqlSugar.TDengine.TDengineProvider._IsIsNanosecond = false;
SqlSugar.TDengine.TDengineProvider._IsMicrosecond = false;
//说明:
//字符串中指定TsType=config_ns
//实体加上 SqlParameterDbType =typeof(DateTime19)
SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
{
DbType = SqlSugar.DbType.TDengine,
IsAutoCloseConnection = true,
ConnectionString = "Host=localhost;Port=6030;Username=root;Password=taosdata;Database=nstest;TsType=config_us"
});
//删除库-库上限比太少只能删了测试
db.Ado.ExecuteCommand("drop database nstest");
db.DbMaintenance.CreateDatabase();//创建纳秒库
//建超级表
db.Ado.ExecuteCommand("CREATE STABLE IF NOT EXISTS St01 (ts TIMESTAMP, current FLOAT, voltage INT, phase FLOAT, isdelete BOOL, name BINARY(64)) TAGS (location BINARY(64), groupId INT)");
//创建子表
db.Ado.ExecuteCommand(@"create table IF NOT EXISTS MyTable02 using St01 tags('California.SanFrancisco',1)");
//查询子表
var dt = db.Ado.GetDataTable("select * from MyTable02 ");
//插入单条子表
db.Insertable(new MyTable02_US()
{
ts = DateTime.Now,
current = Convert.ToSingle(1.1),
groupId = 1,
isdelete = true,
name = "haha",
location = "aa",
phase = Convert.ToSingle(1.2),
voltage = 11
}).ExecuteCommand();
var list = db.Queryable<MyTable02_US>().ToList();
db.Ado.ExecuteCommand(@" CREATE TABLE aoi_recordsuper (fcreatetime timestamp, fsncode VARCHAR(50), fmachineno VARCHAR(50),lotno VARCHAR(50),billno VARCHAR(50),fresult VARCHAR(50)
,fproduct VARCHAR(50),machinetime VARCHAR(50),id VARCHAR(50),uploadtype VARCHAR(50),dimbin VARCHAR(50))
TAGS (workstation VARCHAR(50));");
var dt2 = Convert.ToDateTime("2023-09-23 08:00:00.12345");
db.Ado.ExecuteCommand(@"
INSERT INTO aoirecord_2309 USING aoi_recordsuper TAGS (""AOI"")
VALUES ('2023-09-23', ""10.2"", ""A219"",""2309050001"",""B03123"",""OK"",""681-ABC"",""2023-9-5"",""123"",""首测"",""A"")
(now, ""10.2"", ""A219"",""2309050001"",""B03123"",""OK"",""681-ABC"",""2023-9-5"",""123"",""首测"",""A"")");
var date = Convert.ToDateTime("2023-9-25 00:00:00");
var list3 = db.Queryable<T_TD_AOIRecord>().ToList();
var list2 = db.Queryable<T_TD_AOIRecord>()
.Where(t => t.fcreatetime >= date).ToList();
if (list2.Count != 1)
{
throw new Exception("unit error");
}
}
private static List<MyTable02> GetInsertDatas()
{
return new List<MyTable02>() {
new MyTable02()
{
ts = DateTime.Now.AddDays(-1),
current = Convert.ToSingle(1.1),
groupId = 1,
isdelete = false,
name = "测试1",
location = "false",
phase = Convert.ToSingle(1.1),
voltage = 222
},
new MyTable02()
{
ts = DateTime.Now.AddDays(-2),
current = Convert.ToSingle(1.1),
groupId = 1,
isdelete = false,
name = "测试2",
location = "false",
phase = Convert.ToSingle(1.1),
voltage = 222
},
new MyTable02()
{
ts = DateTime.Now,
current = Convert.ToSingle(1.1),
groupId = 1,
isdelete = true,
name = "测试3",
location = "true",
phase = Convert.ToSingle(1.1),
voltage = 111
}
};
}
public class fc_data
{
public DateTime upload_time { get; set; }
public int voltage { get; set; }
public float temperature { get; set; }
public int data_id { get; set; }
public string speed_hex { get; set; }
public string gateway_mac { get; set; }
public int ruminate { get; set; }
public sbyte rssi { get; set; }
}
public class MyTable02
{
[SugarColumn(IsPrimaryKey =true)]
public DateTime ts { get; set; }
public float current { get; set; }
public bool isdelete { get; set; }
public string name { get; set; }
public int voltage { get; set; }
public float phase { get; set; }
[SugarColumn(IsOnlyIgnoreInsert =true,IsOnlyIgnoreUpdate =true)]
public string location { get; set; }
[SugarColumn(IsOnlyIgnoreInsert = true, IsOnlyIgnoreUpdate = true)]
public int groupId { get; set; }
}
}
}

123
Src/Asp.NetCore2/TDengineTest/Demo/ORMTest_Partial/1_DemoMain.cs Normal file
View File

@ -0,0 +1,123 @@
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
namespace TDengineTest
{
public partial class ORMTest
{
private static void Demo1(SqlSugarClient db)
{
//建库
db.DbMaintenance.CreateDatabase();
//建超级表
db.Ado.ExecuteCommand("CREATE STABLE IF NOT EXISTS St01 (ts TIMESTAMP, current FLOAT, voltage INT, phase FLOAT, isdelete BOOL, name BINARY(64)) TAGS (location BINARY(64), groupId INT)");
//创建子表
db.Ado.ExecuteCommand(@"create table IF NOT EXISTS MyTable02 using St01 tags('California.SanFrancisco',1)");
//查询子表
var dt = db.Ado.GetDataTable("select * from MyTable02 ");
//插入单条子表
db.Insertable(new MyTable02()
{
ts = DateTime.Now,
current = Convert.ToSingle(1.1),
groupId = 1,
isdelete = true,
name = "haha",
location = "aa",
phase = Convert.ToSingle(1.2),
voltage = 11
}).ExecuteCommand();
//批量插入子表
db.Insertable(GetInsertDatas()).ExecuteCommand();
//查询子表(主表字段也能查出来)
var list = db.Queryable<MyTable02>().OrderBy(it => it.ts).ToList();
//条件查询
var list2 = db.Queryable<MyTable02>().Where(it => it.name == "测试2").ToList();
var list22 = db.Queryable<MyTable02>().Where(it => it.voltage == 222).ToList();
var list222 = db.Queryable<MyTable02>().Where(it => it.phase == 1.2).ToList();
var list2222 = db.Queryable<MyTable02>().Where(it => it.isdelete == true).ToList();
//模糊查询
var list3 = db.Queryable<MyTable02>().Where(it => it.name.Contains("a")).ToList();
//时间差函数
var list31 = db.Queryable<MyTable02>().Select(it =>
new
{
diff = SqlFunc.DateDiff(DateType.Day, it.ts, DateTime.Now),
time = it.ts
}).ToList();
//时间加1天
var list32 = db.Queryable<MyTable02>().Select(it =>
new
{
addTime = SqlFunc.DateAdd(it.ts, 1, DateType.Day),
oldime = it.ts
}).ToList();
//自定义函数:实现时间加1天
var list33 = db.Queryable<MyTable02>().Select(it =>
new
{
addTime = SqlFunc.MappingColumn<DateTime>(" `ts`+1d "),
oldime = it.ts
}).ToList();
//分页
var Count = 0;
var list4 = db.Queryable<MyTable02>().Where(it => it.voltage == 111)
.ToPageList(1, 2, ref Count);
//删除子表
var ts = list.First().ts;
var de = DateTime.Now.AddYears(-1);
var count = db.Deleteable<MyTable02>().Where(it => it.ts > de).ExecuteCommand();
//异步
db.Insertable(new MyTable02()
{
ts = DateTime.Now,
current = Convert.ToSingle(1.1),
groupId = 1,
isdelete = true,
name = "haha",
location = "aa",
phase = Convert.ToSingle(1.2),
voltage = 11
}).ExecuteCommandAsync().GetAwaiter().GetResult();
var list100 = db.Queryable<MyTable02>().ToListAsync().GetAwaiter().GetResult();
//联表查询:不支持left join只能这样
var list101 = db.Queryable<MyTable02, MyTable02>((x, y) => x.ts == y.ts)
.Select((x, y) => new
{
xts = x.ts,
yts = y.ts
}).ToList();
//联表查询在分页
var list102 = db.Queryable<MyTable02, MyTable02>((x, y) => x.ts == y.ts)
.Select((x, y) => new
{
xts = x.ts,
yts = y.ts
}).ToPageList(1, 2);
}
}
}

25
Src/Asp.NetCore2/TDengineTest/Demo/ORMTest_Partial/1_UnitMain.cs Normal file
View File

@ -0,0 +1,25 @@
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Text;
namespace TDengineTest
{
public partial class ORMTest
{
private static void UnitTest(SqlSugarClient db)
{
//类型测试
DbType(db);
DbType2(db);
//纳秒
NS();
//微秒
US();
}
}
}

92
Src/Asp.NetCore2/TDengineTest/Demo/ORMTest_Partial/Helper.cs Normal file
View File

@ -0,0 +1,92 @@
using System;
using System.Collections.Generic;
using System.ComponentModel.DataAnnotations;
using System.ComponentModel.DataAnnotations.Schema;
using System.Linq;
using System.Runtime.CompilerServices;
using System.Text;
using System.Threading.Tasks;
using SqlSugar;
using TDengineDriver;
namespace TDengineTest
{
public partial class ORMTest
{
private static List<MyTable02> GetInsertDatas()
{
return new List<MyTable02>() {
new MyTable02()
{
ts = DateTime.Now.AddDays(-1),
current = Convert.ToSingle(1.1),
groupId = 1,
isdelete = false,
name = "测试1",
location = "false",
phase = Convert.ToSingle(1.1),
voltage = 222
},
new MyTable02()
{
ts = DateTime.Now.AddDays(-2),
current = Convert.ToSingle(1.1),
groupId = 1,
isdelete = false,
name = "测试2",
location = "false",
phase = Convert.ToSingle(1.1),
voltage = 222
},
new MyTable02()
{
ts = DateTime.Now,
current = Convert.ToSingle(1.1),
groupId = 1,
isdelete = true,
name = "测试3",
location = "true",
phase = Convert.ToSingle(1.1),
voltage = 111
}
};
}
public class fc_data
{
public DateTime upload_time { get; set; }
public int voltage { get; set; }
public float temperature { get; set; }
public int data_id { get; set; }
public string speed_hex { get; set; }
public string gateway_mac { get; set; }
public int ruminate { get; set; }
public sbyte rssi { get; set; }
}
public class MyTable02
{
[SugarColumn(IsPrimaryKey = true)]
public DateTime ts { get; set; }
public float current { get; set; }
public bool isdelete { get; set; }
public string name { get; set; }
public int voltage { get; set; }
public float phase { get; set; }
[SugarColumn(IsOnlyIgnoreInsert = true, IsOnlyIgnoreUpdate = true)]
public string location { get; set; }
[SugarColumn(IsOnlyIgnoreInsert = true, IsOnlyIgnoreUpdate = true)]
public int groupId { get; set; }
}
}
}

155
Src/Asp.NetCore2/TDengineTest/Demo/ORMTest_Partial/Time.cs Normal file
View File

@ -0,0 +1,155 @@
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Text;
using System.Linq;
namespace TDengineTest
{
public partial class ORMTest
{
/// <summary>
/// 纳秒
/// </summary>
/// <exception cref="Exception"></exception>
private static void NS()
{
//说明:
//字符串中指定TsType=config_ns
//实体加上 SqlParameterDbType =typeof(DateTime19)
SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
{
DbType = SqlSugar.DbType.TDengine,
IsAutoCloseConnection = true,
ConnectionString = "Host=localhost;Port=6030;Username=root;Password=taosdata;Database=nstest;TsType=config_ns"
});
//删除库-库上限比太少只能删了测试
if (db.DbMaintenance.GetDataBaseList().Any(it => it == "nstest"))
{
db.Ado.ExecuteCommand("drop database nstest");
}
db.DbMaintenance.CreateDatabase();//创建纳秒库
//建超级表
db.Ado.ExecuteCommand("CREATE STABLE IF NOT EXISTS St01 (ts TIMESTAMP, current FLOAT, voltage INT, phase FLOAT, isdelete BOOL, name BINARY(64)) TAGS (location BINARY(64), groupId INT)");
//创建子表
db.Ado.ExecuteCommand(@"create table IF NOT EXISTS MyTable02 using St01 tags('California.SanFrancisco',1)");
//查询子表
var dt = db.Ado.GetDataTable("select * from MyTable02 ");
//插入单条子表
db.Insertable(new MyTable02_NS()
{
ts = DateTime.Now,
current = Convert.ToSingle(1.1),
groupId = 1,
isdelete = true,
name = "haha",
location = "aa",
phase = Convert.ToSingle(1.2),
voltage = 11
}).ExecuteCommand();
var list = db.Queryable<MyTable02_NS>().ToList();
db.Ado.ExecuteCommand(@" CREATE TABLE aoi_recordsuper (fcreatetime timestamp, fsncode VARCHAR(50), fmachineno VARCHAR(50),lotno VARCHAR(50),billno VARCHAR(50),fresult VARCHAR(50)
,fproduct VARCHAR(50),machinetime VARCHAR(50),id VARCHAR(50),uploadtype VARCHAR(50),dimbin VARCHAR(50))
TAGS (workstation VARCHAR(50));");
var dt2 = Convert.ToDateTime("2023-09-23 08:00:00.12345");
db.Ado.ExecuteCommand(@"
INSERT INTO aoirecord_2309 USING aoi_recordsuper TAGS (""AOI"")
VALUES ('2023-09-23', ""10.2"", ""A219"",""2309050001"",""B03123"",""OK"",""681-ABC"",""2023-9-5"",""123"",""首测"",""A"")
(now, ""10.2"", ""A219"",""2309050001"",""B03123"",""OK"",""681-ABC"",""2023-9-5"",""123"",""首测"",""A"")");
var date = Convert.ToDateTime("2023-9-25 00:00:00");
var list3 = db.Queryable<T_TD_AOIRecord>().ToList();
var list2 = db.Queryable<T_TD_AOIRecord>()
.Where(t => t.fcreatetime >= date).ToList();
if (list2.Count != 1)
{
throw new Exception("unit error");
}
}
/// <summary>
/// 微妙
/// </summary>
/// <exception cref="Exception"></exception>
private static void US()
{
//clear static config
SqlSugar.TDengine.TDengineProvider._IsIsNanosecond = false;
SqlSugar.TDengine.TDengineProvider._IsMicrosecond = false;
//说明:
//字符串中指定TsType=config_ns
//实体加上 SqlParameterDbType =typeof(DateTime19)
SqlSugarClient db = new SqlSugarClient(new ConnectionConfig()
{
DbType = SqlSugar.DbType.TDengine,
IsAutoCloseConnection = true,
ConnectionString = "Host=localhost;Port=6030;Username=root;Password=taosdata;Database=nstest;TsType=config_us"
});
//删除库-库上限比太少只能删了测试
db.Ado.ExecuteCommand("drop database nstest");
db.DbMaintenance.CreateDatabase();//创建纳秒库
//建超级表
db.Ado.ExecuteCommand("CREATE STABLE IF NOT EXISTS St01 (ts TIMESTAMP, current FLOAT, voltage INT, phase FLOAT, isdelete BOOL, name BINARY(64)) TAGS (location BINARY(64), groupId INT)");
//创建子表
db.Ado.ExecuteCommand(@"create table IF NOT EXISTS MyTable02 using St01 tags('California.SanFrancisco',1)");
//查询子表
var dt = db.Ado.GetDataTable("select * from MyTable02 ");
//插入单条子表
db.Insertable(new MyTable02_US()
{
ts = DateTime.Now,
current = Convert.ToSingle(1.1),
groupId = 1,
isdelete = true,
name = "haha",
location = "aa",
phase = Convert.ToSingle(1.2),
voltage = 11
}).ExecuteCommand();
var list = db.Queryable<MyTable02_US>().ToList();
db.Ado.ExecuteCommand(@" CREATE TABLE aoi_recordsuper (fcreatetime timestamp, fsncode VARCHAR(50), fmachineno VARCHAR(50),lotno VARCHAR(50),billno VARCHAR(50),fresult VARCHAR(50)
,fproduct VARCHAR(50),machinetime VARCHAR(50),id VARCHAR(50),uploadtype VARCHAR(50),dimbin VARCHAR(50))
TAGS (workstation VARCHAR(50));");
var dt2 = Convert.ToDateTime("2023-09-23 08:00:00.12345");
db.Ado.ExecuteCommand(@"
INSERT INTO aoirecord_2309 USING aoi_recordsuper TAGS (""AOI"")
VALUES ('2023-09-23', ""10.2"", ""A219"",""2309050001"",""B03123"",""OK"",""681-ABC"",""2023-9-5"",""123"",""首测"",""A"")
(now, ""10.2"", ""A219"",""2309050001"",""B03123"",""OK"",""681-ABC"",""2023-9-5"",""123"",""首测"",""A"")");
var date = Convert.ToDateTime("2023-9-25 00:00:00");
var list3 = db.Queryable<T_TD_AOIRecord>().ToList();
var list2 = db.Queryable<T_TD_AOIRecord>()
.Where(t => t.fcreatetime >= date).ToList();
if (list2.Count != 1)
{
throw new Exception("unit error");
}
}
}
}

185
Src/Asp.NetCore2/TDengineTest/Demo/ORMTest_Partial/Type.cs Normal file
View File

@ -0,0 +1,185 @@
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Text;
namespace TDengineTest
{
public partial class ORMTest
{
private static void DbType2(SqlSugarClient db)
{
//建库
//db.Ado.ExecuteCommand("CREATE DATABASE IF NOT EXISTS db WAL_RETENTION_PERIOD 3600");
db.Ado.ExecuteCommand(@"CREATE DATABASE IF NOT EXISTS db123456
KEEP 1080
DURATION 10
BUFFER 16
WAL_LEVEL 1
CACHEMODEL 'both'");//不支持 UPDATE 1 选项
//建超级表
// DeviceType INT,
// DeviceCode BINARY(12),
db.Ado.ExecuteCommand(
@"CREATE STABLE IF NOT EXISTS ConveryTable
(
ts TIMESTAMP,
Action INT,
TaskNo INT,
Stime TIMESTAMP,
Etime TIMESTAMP,
GoodsType INT,
BarCode NCHAR(64),
FromNode NCHAR(24),
ToNode NCHAR(24),
Speed FLOAT,
AccSpeed FLOAT,
DecSpeed FLOAT,
Field1 NCHAR(256),
Field2 NCHAR(256),
Field3 NCHAR(256),
Field4 NCHAR(256),
Field5 NCHAR(256),
Field6 NCHAR(256),
Remark NCHAR(500)
)
TAGS
(
DeviceType INT, DeviceCode BINARY(12)
)");
var random = new Random();
string tablename = "t1118_" + (1000 + 99);
db.Ado.ExecuteCommand("create table IF NOT EXISTS t1118_1099 using ConveryTable tags(1,'1099')");
var curdb = db;
List<ConveryTable> rows = new List<ConveryTable>();
for (int k = 0; k < 10; k++)
{
rows.Add(new ConveryTable()
{
ts = DateTime.Now.AddDays(random.Next(1, 9)),
AccSpeed = random.Next(1, 9),
Action = 2,
BarCode = "1111" + k,
DecSpeed = random.Next(1, 9),
DeviceCode = "1001",
DeviceType = 1,
Etime = DateTime.Now.AddSeconds(k),
FromNode = "001001001",
ToNode = "002002" + k.ToString("d3"),
GoodsType = 3,
TaskNo = random.Next(1, 900),
Speed = random.Next(7, 90),
Stime = DateTime.Now,
});
}
curdb.Insertable(rows).AS(tablename).ExecuteCommand(); ;
curdb.Queryable<ConveryTable>().AS(tablename).ToList();
}
private static void DbType(SqlSugarClient db)
{
//更多类型查询测试
db.Ado.ExecuteCommand(@"
CREATE STABLE IF NOT EXISTS `fc_data` (
`upload_time` TIMESTAMP,
`voltage` SMALLINT,
`temperature` FLOAT,
`data_id` SMALLINT,
`speed_hex` VARCHAR(80),
`gateway_mac` VARCHAR(8),
`ruminate` SMALLINT,
`rssi` TINYINT) TAGS (`tag_id` VARCHAR(12))");
var list = db.Queryable<fc_data>().ToList();
//创建子表
db.Ado.ExecuteCommand(@"create table IF NOT EXISTS fc_data01 using `fc_data` tags('1')");
db.Insertable(new fc_data()
{
data_id = 1,
gateway_mac = "mac",
rssi = 11,
ruminate = 1,
speed_hex = "x",
temperature = 1,
upload_time = DateTime.Now,
voltage = 1
}).AS("fc_data01").ExecuteCommand();
var list2 = db.Queryable<fc_data>().AS("fc_data01").ToList();
}
}
}

29
Src/Asp.NetCore2/TDengineTest/Models/Unit/CodeFirstTest1.cs Normal file
View File

@ -0,0 +1,29 @@
using System;
using System.Collections.Generic;
using System.Text;
namespace TDengineTest
{
public class AllCSharpTypes
{
public bool Boolean { get; set; }
public byte Byte { get; set; }
public sbyte SByte { get; set; }
public char Char { get; set; }
public decimal Decimal { get; set; }
[SqlSugar.SugarColumn(Length =18,DecimalDigits =2)]
public decimal Decimal2 { get; set; }
[SqlSugar.SugarColumn(Length = 18, DecimalDigits = 2)]
public double Double { get; set; }
public float Float { get; set; }
public int Int32 { get; set; }
public uint UInt32 { get; set; }
public long Int64 { get; set; }
public ulong UInt64 { get; set; }
public short Int16 { get; set; }
public ushort UInt16 { get; set; }
public string String { get; set; }
[SqlSugar.SugarColumn(Length =100)]
public string String2 { get; set; }
}
}

2
Src/Asp.NetCore2/TDengineTest/Models/Unit/ConveryTable.cs
View File

@ -4,7 +4,7 @@ using System.Collections.Generic;
using System.ComponentModel.DataAnnotations;
using System.Text;
namespace OrmTest
namespace TDengineTest
{
public class ConveryTable
{

2
Src/Asp.NetCore2/TDengineTest/Models/Unit/MyTable02_NS.cs
View File

@ -3,7 +3,7 @@ using System;
using System.Collections.Generic;
using System.Text;
namespace OrmTest
namespace TDengineTest
{
/// <summary>
/// 纳秒

2
Src/Asp.NetCore2/TDengineTest/Models/Unit/T_TD_AOIRecord.cs
View File

@ -4,7 +4,7 @@ using System;
using System.Collections.Generic;
using System.Text;
namespace OrmTest
namespace TDengineTest
{
[SugarTable("aoi_recordsuper")]