Update TDengine

This commit is contained in:
sunkaixuan
2023-08-16 17:42:34 +08:00
parent 586e1cf582
commit fa2b6f20b5
2 changed files with 54 additions and 5 deletions

View File

@@ -27,7 +27,7 @@ namespace SqlSugar.TDengine
return "varchar"; return "varchar";
} }
public override string GetPropertyTypeName(string dbTypeName) public override string GetPropertyTypeName(string dbTypeName)
{ {
if (dbTypeName.ToLower() == "int32") if (dbTypeName.ToLower() == "int32")
{ {
dbTypeName = "int"; dbTypeName = "int";
@@ -44,10 +44,14 @@ namespace SqlSugar.TDengine
{ {
dbTypeName = "string"; dbTypeName = "string";
} }
else if (dbTypeName.ToLower() == "boolean") else if (dbTypeName.ToLower() == "boolean")
{ {
dbTypeName = "bool"; dbTypeName = "bool";
} }
else if (dbTypeName.ToLower() == "sbyte")
{
dbTypeName = "sbyte";
}
return dbTypeName; return dbTypeName;
} }
public override List<KeyValuePair<string, CSharpDataType>> MappingTypes public override List<KeyValuePair<string, CSharpDataType>> MappingTypes

View File

@@ -24,11 +24,20 @@ namespace OrmTest
{ {
OnLogExecuting = (sql, p) => OnLogExecuting = (sql, p) =>
{ {
Console.WriteLine(UtilMethods.GetNativeSql(sql,p)); Console.WriteLine(UtilMethods.GetNativeSql(sql, p));
} }
} }
}); });
//简单用例
Demo1(db);
//测试用例
UnitTest(db);
}
private static void Demo1(SqlSugarClient db)
{
//建库 //建库
db.DbMaintenance.CreateDatabase(); db.DbMaintenance.CreateDatabase();
@@ -64,10 +73,10 @@ namespace OrmTest
var list = db.Queryable<MyTable02>().OrderBy(it => it.ts).ToList(); var list = db.Queryable<MyTable02>().OrderBy(it => it.ts).ToList();
//条件查询 //条件查询
var list2 = db.Queryable<MyTable02>().Where(it => it.name== "测试2").ToList(); var list2 = db.Queryable<MyTable02>().Where(it => it.name == "测试2").ToList();
var list22 = db.Queryable<MyTable02>().Where(it => it.voltage == 222).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 list222 = db.Queryable<MyTable02>().Where(it => it.phase == 1.2).ToList();
var list2222 = db.Queryable<MyTable02>().Where(it => it.isdelete==true).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 list3 = db.Queryable<MyTable02>().Where(it => it.name.Contains("a")).ToList();
@@ -99,6 +108,21 @@ namespace OrmTest
var list100 = db.Queryable<MyTable02>().ToListAsync().GetAwaiter().GetResult(); var list100 = db.Queryable<MyTable02>().ToListAsync().GetAwaiter().GetResult();
} }
private static void UnitTest(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();
}
private static List<MyTable02> GetInsertDatas() private static List<MyTable02> GetInsertDatas()
{ {
@@ -138,7 +162,28 @@ namespace OrmTest
} }
}; };
} }
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 public class MyTable02
{ {
[SugarColumn(IsPrimaryKey =true)] [SugarColumn(IsPrimaryKey =true)]