Add bulkCopy

This commit is contained in:
sunkaixuan 2025-04-22 20:16:38 +08:00
parent f3d3dfdac1
commit c4b00dad49
2 changed files with 58 additions and 2 deletions

View File

@ -6,6 +6,7 @@ using System.Linq;
using System.Runtime.CompilerServices;
using System.Text;
using System.Threading.Tasks;
using Dm;
using SqlSugar;
using SqlSugar.DbConvert;
@ -35,6 +36,9 @@ namespace TDengineTest
//自动建表
InsertUsingTag(db);
//BulkCopy(自动建表
BulkCopy(db);
//生成实体
DbFirst(db);
@ -47,8 +51,7 @@ namespace TDengineTest
Console.WriteLine("执行完成");
Console.ReadKey();
}
}
}
}

View File

@ -0,0 +1,53 @@
using SqlSugar;
using SqlSugar.TDengine;
using System;
using System.Collections.Generic;
using System.Diagnostics.CodeAnalysis;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace TDengineTest
{
public partial class ORMTest
{
public static void BulkCopy(ISqlSugarClient db)
{
//建表
db.CodeFirst.InitTables<BulkDemo2>();
//插入
TDengineFastBuilder.SetTags(db, (tag,stable) => $"{stable}_{tag}", "Tag1");//设置子表格式和Tag字段
db.Fastest<BulkDemo2>().BulkCopy(new List<BulkDemo2>(){
new BulkDemo2()
{
Boolean = true,
Tag1 = "a",
Ts = DateTime.Now.AddMilliseconds(1)//没启用微秒纳秒时间不能一样
},
new BulkDemo2()
{
Boolean = false,
Tag1 = "a",
Ts = DateTime.Now.AddSeconds(1)
},
new BulkDemo2()
{
Boolean = true,
Tag1 = "b",
Ts = DateTime.Now.AddMilliseconds(333)
}});
var list= db.Queryable<BulkDemo2>().ToList();
}
[STableAttribute(STableName = "BulkDemo2", Tag1 = nameof(Tag1))]
public class BulkDemo2
{
[SqlSugar.SugarColumn(IsPrimaryKey = true)]
public DateTime Ts { get; set; }
public bool Boolean { get; set; }
public string Tag1 { get; set; }
}
}
}