lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-11-01 00:46:50 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update TDengine

Browse Source
This commit is contained in:
sunkaixuan
2025-04-29 18:38:03 +08:00
parent 998eae3dc3
commit 60e411ff96
2 changed files with 14 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
Src/Asp.NetCore2/SqlSugar.TDengineCore/TDengine/CodeFirst/TDengineCodeFirst.cs
View File

@@ -237,7 +237,9 @@ namespace SqlSugar.TDengine
&& it.DbColumnName?.ToLower() != attr.Tag4?.ToLower()
).ToList();
}
this.Context.DbMaintenance.CreateTable(entityInfo.DbTableName, dbColumns);
var dbMain = (TDengineDbMaintenance)this.Context.DbMaintenance;
dbMain.EntityInfo = entityInfo;
dbMain.CreateTable(entityInfo.DbTableName, dbColumns);
entityInfo.DbTableName = oldTableName;
}
protected override DbColumnInfo EntityColumnToDbColumn(EntityInfo entityInfo, string tableName, EntityColumnInfo item)

11
Src/Asp.NetCore2/SqlSugar.TDengineCore/TDengine/DbMaintenance/TDengineDbMaintenance.cs
View File

@@ -10,6 +10,8 @@ namespace SqlSugar.TDengine
{
public class TDengineDbMaintenance : DbMaintenanceProvider
{
public EntityInfo EntityInfo { get; set; }
#region DML
protected override string GetViewInfoListSql => throw new NotImplementedException();
@@ -427,6 +429,15 @@ namespace SqlSugar.TDengine
var colums = STable.Tags.Select(it => this.SqlBuilder.GetTranslationTableName(it.Name)+ " VARCHAR(100) ");
tableString=tableString.Replace(SqlBuilder.GetTranslationColumnName("TagsTypeId"), string.Join(",", colums));
tableString = tableString.Replace(" VARCHAR(100) VARCHAR(100)", " VARCHAR(100)");
foreach (var item in STable.Tags)
{
var tagColumn = this.EntityInfo.Columns.FirstOrDefault(it => it.DbColumnName == item.Name || it.PropertyName == item.Name);
if (tagColumn != null&&tagColumn.UnderType!=UtilConstants.StringType)
{
var tagType= new TDengineDbBind() { Context=this.Context }.GetDbTypeName(tagColumn.UnderType.Name);
tableString = tableString.Replace($"{SqlBuilder.GetTranslationColumnName(tagColumn.DbColumnName)} VARCHAR(100)", $"{SqlBuilder.GetTranslationColumnName(tagColumn.DbColumnName)} {tagType} ");
}
}
}
this.Context.Ado.ExecuteCommand(tableString);
var createChildSql = $"CREATE TABLE IF NOT EXISTS {childTableName} USING {stableName} TAGS('default')";