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

Split table

Browse Source
This commit is contained in:
sunkaixuna
2021-10-30 20:55:27 +08:00
parent 54e10e81f8
commit 6456c0c698
1 changed files with 106 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

106
Src/Asp.Net/SqlSugar/Abstract/InsertableProvider/SplitInsertable.cs
View File

@@ -59,6 +59,65 @@ namespace SqlSugar
return await _ExecuteCommandAsync(); return await _ExecuteCommandAsync();
} }
} }
public List<long> ExecuteReturnSnowflakeIdList()
{
if (this.Context.Ado.Transaction == null)
{
try
{
this.Context.Ado.BeginTran();
var result = _ExecuteReturnSnowflakeIdList();
this.Context.Ado.CommitTran();
return result;
}
catch (Exception ex)
{
this.Context.Ado.RollbackTran();
throw ex;
}
}
else
{
return _ExecuteReturnSnowflakeIdList();
}
}
public async Task<List<long>> ExecuteReturnSnowflakeIdListAsync()
{
if (this.Context.Ado.Transaction == null)
{
try
{
this.Context.Ado.BeginTran();
var result = await _ExecuteReturnSnowflakeIdListAsync();
this.Context.Ado.BeginTran();
return result;
}
catch (Exception ex)
{
this.Context.Ado.RollbackTran();
throw ex;
}
}
else
{
return await _ExecuteReturnSnowflakeIdListAsync();
}
}
public long ExecuteReturnSnowflakeId()
{
return ExecuteReturnSnowflakeIdList().FirstOrDefault();
}
public async Task<long> ExecuteReturnSnowflakeIdAsync()
{
var list = await ExecuteReturnSnowflakeIdListAsync();
return list.FirstOrDefault();
}
internal int _ExecuteCommand() internal int _ExecuteCommand()
{ {
CreateTable(); CreateTable();
@@ -101,6 +160,53 @@ namespace SqlSugar
} }
return result; return result;
} }
internal List<long> _ExecuteReturnSnowflakeIdList()
{
CreateTable();
var result = new List<long>();
var groups = TableNames.GroupBy(it => it.Key).ToList();
var parent = ((InsertableProvider<T>)Inserable);
var names = parent.InsertBuilder.DbColumnInfoList.GroupBy(it => it.DbColumnName).Select(i => i.Key).ToList();
foreach (var item in groups)
{
var list = item.Select(it => it.Value as T).ToList();
var groupInserable = (InsertableProvider<T>)this.Context.Insertable<T>(list);
groupInserable.InsertBuilder.TableWithString = parent.InsertBuilder.TableWithString;
groupInserable.RemoveCacheFunc = parent.RemoveCacheFunc;
groupInserable.diffModel = parent.diffModel;
groupInserable.IsEnableDiffLogEvent = parent.IsEnableDiffLogEvent;
groupInserable.InsertBuilder.IsNoInsertNull = parent.InsertBuilder.IsNoInsertNull;
groupInserable.IsOffIdentity = parent.IsOffIdentity;
var idList= groupInserable.AS(item.Key).InsertColumns(names.ToArray()).ExecuteReturnSnowflakeIdList();
result.AddRange(idList);
}
return result;
}
internal async Task<List<long>> _ExecuteReturnSnowflakeIdListAsync()
{
CreateTable();
var result = new List<long>();
var groups = TableNames.GroupBy(it => it.Key).ToList();
var parent = ((InsertableProvider<T>)Inserable);
var names = parent.InsertBuilder.DbColumnInfoList.GroupBy(it => it.DbColumnName).Select(i => i.Key).ToList();
foreach (var item in groups)
{
var list = item.Select(it => it.Value as T).ToList();
var groupInserable = (InsertableProvider<T>)this.Context.Insertable<T>(list);
groupInserable.InsertBuilder.TableWithString = parent.InsertBuilder.TableWithString;
groupInserable.RemoveCacheFunc = parent.RemoveCacheFunc;
groupInserable.diffModel = parent.diffModel;
groupInserable.IsEnableDiffLogEvent = parent.IsEnableDiffLogEvent;
groupInserable.InsertBuilder.IsNoInsertNull = parent.InsertBuilder.IsNoInsertNull;
groupInserable.IsOffIdentity = parent.IsOffIdentity;
var idList =await groupInserable.AS(item.Key).InsertColumns(names.ToArray()).ExecuteReturnSnowflakeIdListAsync();
result.AddRange(idList);
}
return result;
}
private void CreateTable() private void CreateTable()
{ {
var isLog = this.Context.Ado.IsEnableLogEvent; var isLog = this.Context.Ado.IsEnableLogEvent;