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

Update TDengine

Browse Source
This commit is contained in:
sunkaixuan
2025-02-26 16:17:49 +08:00
parent 6bde63bb39
commit 88eb91b717
3 changed files with 68 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
Src/Asp.NetCore2/SqlSugar.TDengineCore/TDengine/Insertable/TagInserttable.cs
View File

@@ -12,13 +12,53 @@ namespace SqlSugar
internal IInsertable<T> thisValue;
internal Func<string, T, string> getChildTableNamefunc;
internal SqlSugarProvider Context;
public int ExecuteCommand()
{
var provider = (InsertableProvider<T>) thisValue;
var provider = (InsertableProvider<T>)thisValue;
var inserObjects = provider.InsertObjs;
var attr = typeof(T).GetCustomAttribute<STableAttribute>();
Check.ExceptionEasy(attr == null|| attr?.Tag1==null, $"", $"{nameof(T)}缺少特性STableAttribute和Tag1");
Check.ExceptionEasy(attr == null || attr?.Tag1 == null, $"", $"{nameof(T)}缺少特性STableAttribute和Tag1");
// 根据所有非空的 Tag 进行分组
var groups = GetGroupInfos(inserObjects, attr);
foreach (var item in groups)
{
var childTableName = getChildTableNamefunc(attr.STableName, item.First());
this.Context.Utilities.PageEach(item, 500, pageItems =>
{
var sTableName = provider.SqlBuilder.GetTranslationColumnName(attr.STableName);
var tags = new List<string>();
List<string> tagValues = GetTagValues(pageItems, attr);
var tagString = string.Join(",", tagValues.Where(v => !string.IsNullOrEmpty(v)).Select(v => $"'{v.ToSqlFilter()}'"));
tags.Add(tagString);
this.Context.Ado.ExecuteCommand($"CREATE TABLE IF NOT EXISTS {childTableName} USING {sTableName} TAGS ({tagString})");
this.Context.Insertable(pageItems).AS(childTableName).ExecuteCommand();
});
}
return inserObjects.Count();
}
private static List<string> GetTagValues(List<T> pageItems, STableAttribute attr)
{
var tagValues = new List<string>();
var obj = pageItems.First();
if (attr.Tag1 != null)
tagValues.Add(obj.GetType().GetProperty(attr.Tag1)?.GetValue(obj)?.ToString());
if (attr.Tag2 != null)
tagValues.Add(obj.GetType().GetProperty(attr.Tag2)?.GetValue(obj)?.ToString());
if (attr.Tag3 != null)
tagValues.Add(obj.GetType().GetProperty(attr.Tag3)?.GetValue(obj)?.ToString());
if (attr.Tag4 != null)
tagValues.Add(obj.GetType().GetProperty(attr.Tag4)?.GetValue(obj)?.ToString());
return tagValues;
}
private static IEnumerable<IGrouping<string, T>> GetGroupInfos(T[] inserObjects, STableAttribute? attr)
{
var groups = inserObjects.GroupBy(it =>
{
// 动态生成分组键
@@ -39,7 +79,7 @@ namespace SqlSugar
// 将非空的 Tag 值用下划线连接作为分组键
return string.Join("_", groupKey.Where(k => !string.IsNullOrEmpty(k)));
});
return inserObjects.Count();
return groups;
}
}
}