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

Questdb bulk copy support pagesize

Browse Source
This commit is contained in:
sunkaixuan 2024-04-30 11:21:46 +08:00
parent fa6c7ffd9f
commit 9cfd9c0c23
2 changed files with 43 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
Src/Asp.NetCore2/SqlSugar.QuestDb.RestApi/QuestDbPageSizeBulkCopy.cs Normal file
View File

@ -0,0 +1,38 @@
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;
namespace SqlSugar
{
public class QuestDbPageSizeBulkCopy
{
private QuestDbRestAPI questDbRestAPI;
private int pageSize;
private ISqlSugarClient db;
public QuestDbPageSizeBulkCopy(QuestDbRestAPI questDbRestAPI, int pageSize, ISqlSugarClient db)
{
this.questDbRestAPI = questDbRestAPI;
this.pageSize = pageSize;
this.db = db;
}
public int BulkCopy<T>(List<T> insertDatas, string dateFormat = "yyyy/M/d H:mm:ss") where T : class, new()
{
int result = 0;
db.Utilities.PageEach(insertDatas, pageSize, pageItems =>
{
result+=questDbRestAPI.BulkCopyAsync(pageItems, dateFormat).GetAwaiter().GetResult();
});
return result;
}
public async Task<int> BulkCopyAsync<T>(List<T> insertDatas, string dateFormat = "yyyy/M/d H:mm:ss") where T : class, new()
{
int result = 0;
await db.Utilities.PageEachAsync(insertDatas, pageSize, async pageItems =>
{
result +=await questDbRestAPI.BulkCopyAsync(pageItems, dateFormat);
});
return result;
}
}
}

5
Src/Asp.NetCore2/SqlSugar.QuestDb.RestApi/QuestDbRestAPI.cs
View File

@ -92,6 +92,11 @@ namespace SqlSugar
return BulkCopyAsync(insertData, dateFormat).GetAwaiter().GetResult();
}
public QuestDbPageSizeBulkCopy PageSize(int pageSize)
{
QuestDbPageSizeBulkCopy result = new QuestDbPageSizeBulkCopy(this,pageSize,db);
return result;
}
/// <summary>
/// 批量快速插入异步