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

Update 达梦 BulkCopy Identity

Browse Source
This commit is contained in:
sunkaixuan 2023-11-04 00:32:29 +08:00
parent a051641dca
commit 4f09dc51be
2 changed files with 31 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Src/Asp.NetCore2/SqlSugar/Abstract/FastestProvider/Private.cs
View File

@ -33,7 +33,9 @@ namespace SqlSugar
resultConnector.CharacterSet = this.CharacterSet;
return resultConnector;
case DbType.Dm:
return new DmFastBuilder();
var result3= new DmFastBuilder();
result3.DbFastestProperties.IsOffIdentity = this.IsOffIdentity;
return result3;
case DbType.ClickHouse:
var resultConnectorClickHouse = InstanceFactory.CreateInstance<IFastBuilder>("SqlSugar.ClickHouse.ClickHouseFastBuilder");
resultConnectorClickHouse.CharacterSet = this.CharacterSet;

29
Src/Asp.NetCore2/SqlSugar/Realization/Dm/SqlBuilder/DmFastBuilder.cs
View File

@ -17,7 +17,34 @@ namespace SqlSugar
};
public async Task<int> ExecuteBulkCopyAsync(DataTable dt)
{
return await _Execute(dt);
if (DbFastestProperties?.IsOffIdentity == true)
{
var isNoTran = this.Context.Ado.IsNoTran()&&this.Context.CurrentConnectionConfig.IsAutoCloseConnection;
try
{
if(isNoTran)
this.Context.Ado.BeginTran();
this.Context.Ado.ExecuteCommand($"SET IDENTITY_INSERT {dt.TableName} ON");
var result=await _Execute(dt);
this.Context.Ado.ExecuteCommand($"SET IDENTITY_INSERT {dt.TableName} OFF");
if (isNoTran)
this.Context.Ado.CommitTran();
return result;
}
catch (Exception)
{
if (isNoTran)
this.Context.Ado.CommitTran();
throw;
}
}
else
{
return await _Execute(dt);
}
}
private async Task<int> _Execute(DataTable dt)