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

Synchronization code

Browse Source
This commit is contained in:
sunkaixuan 2022-11-13 19:06:59 +08:00
parent ed83b02d85
commit a3f612c835
1 changed files with 27 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
Src/Asp.NetCore2/SqlSugar/Abstract/InsertableProvider/InsertableProvider.cs
View File

@ -113,14 +113,14 @@ namespace SqlSugar
if (InsertBuilder.IsOleDb) if (InsertBuilder.IsOleDb)
{ {
var isAuto = false; var isAuto = false;
if (this.Context.CurrentConnectionConfig.IsAutoCloseConnection) if (this.Context.Ado.IsAnyTran() == false && this.Context.CurrentConnectionConfig.IsAutoCloseConnection)
{ {
isAuto = true; isAuto = this.Context.CurrentConnectionConfig.IsAutoCloseConnection;
this.Context.CurrentConnectionConfig.IsAutoCloseConnection = false; this.Context.CurrentConnectionConfig.IsAutoCloseConnection = false;
} }
result = Ado.GetInt(sql.Split(';').First(), InsertBuilder.Parameters == null ? null : InsertBuilder.Parameters.ToArray()); result = Ado.GetInt(sql.Split(';').First(), InsertBuilder.Parameters == null ? null : InsertBuilder.Parameters.ToArray());
result = Ado.GetInt(sql.Split(';').Last(), InsertBuilder.Parameters == null ? null : InsertBuilder.Parameters.ToArray()); result = Ado.GetInt(sql.Split(';').Last(), InsertBuilder.Parameters == null ? null : InsertBuilder.Parameters.ToArray());
if (isAuto) if (this.Context.Ado.IsAnyTran() == false && isAuto)
{ {
this.Ado.Close(); this.Ado.Close();
this.Context.CurrentConnectionConfig.IsAutoCloseConnection = isAuto; this.Context.CurrentConnectionConfig.IsAutoCloseConnection = isAuto;
@ -145,14 +145,14 @@ namespace SqlSugar
if (InsertBuilder.IsOleDb) if (InsertBuilder.IsOleDb)
{ {
var isAuto = false; var isAuto = false;
if (this.Context.CurrentConnectionConfig.IsAutoCloseConnection) if (this.Context.Ado.IsAnyTran()==false&&this.Context.CurrentConnectionConfig.IsAutoCloseConnection)
{ {
isAuto = true; isAuto = this.Context.CurrentConnectionConfig.IsAutoCloseConnection;
this.Context.CurrentConnectionConfig.IsAutoCloseConnection = false; this.Context.CurrentConnectionConfig.IsAutoCloseConnection = false;
} }
result = Convert.ToInt64(Ado.GetScalar(sql.Split(';').First(), InsertBuilder.Parameters == null ? null : InsertBuilder.Parameters.ToArray())); result = Convert.ToInt64(Ado.GetScalar(sql.Split(';').First(), InsertBuilder.Parameters == null ? null : InsertBuilder.Parameters.ToArray()));
result = Convert.ToInt64(Ado.GetScalar(sql.Split(';').Last(), InsertBuilder.Parameters == null ? null : InsertBuilder.Parameters.ToArray())); result = Convert.ToInt64(Ado.GetScalar(sql.Split(';').Last(), InsertBuilder.Parameters == null ? null : InsertBuilder.Parameters.ToArray()));
if (isAuto) if (this.Context.Ado.IsAnyTran() == false && isAuto)
{ {
this.Ado.Close(); this.Ado.Close();
this.Context.CurrentConnectionConfig.IsAutoCloseConnection = isAuto; this.Context.CurrentConnectionConfig.IsAutoCloseConnection = isAuto;
@ -305,14 +305,14 @@ namespace SqlSugar
if (InsertBuilder.IsOleDb) if (InsertBuilder.IsOleDb)
{ {
var isAuto = false; var isAuto = false;
if (this.Context.CurrentConnectionConfig.IsAutoCloseConnection) if (this.Context.Ado.IsAnyTran() == false && this.Context.CurrentConnectionConfig.IsAutoCloseConnection)
{ {
isAuto = true; isAuto = this.Context.CurrentConnectionConfig.IsAutoCloseConnection;
this.Context.CurrentConnectionConfig.IsAutoCloseConnection = false; this.Context.CurrentConnectionConfig.IsAutoCloseConnection = false;
} }
result = Ado.GetInt(sql.Split(';').First(), InsertBuilder.Parameters == null ? null : InsertBuilder.Parameters.ToArray()); result = Ado.GetInt(sql.Split(';').First(), InsertBuilder.Parameters == null ? null : InsertBuilder.Parameters.ToArray());
result = Ado.GetInt(sql.Split(';').Last(), InsertBuilder.Parameters == null ? null : InsertBuilder.Parameters.ToArray()); result = Ado.GetInt(sql.Split(';').Last(), InsertBuilder.Parameters == null ? null : InsertBuilder.Parameters.ToArray());
if (isAuto) if(this.Context.Ado.IsAnyTran() == false && isAuto)
{ {
this.Ado.Close(); this.Ado.Close();
this.Context.CurrentConnectionConfig.IsAutoCloseConnection = isAuto; this.Context.CurrentConnectionConfig.IsAutoCloseConnection = isAuto;
@ -379,7 +379,24 @@ namespace SqlSugar
return 0; return 0;
} }
string sql = _ExecuteReturnBigIdentity(); string sql = _ExecuteReturnBigIdentity();
var result = Convert.ToInt64(await Ado.GetScalarAsync(sql, InsertBuilder.Parameters == null ? null : InsertBuilder.Parameters.ToArray())); long result = 0;
if (InsertBuilder.IsOleDb)
{
var isAuto = false;
if (this.Context.Ado.IsAnyTran() == false && this.Context.CurrentConnectionConfig.IsAutoCloseConnection)
{
isAuto = this.Context.CurrentConnectionConfig.IsAutoCloseConnection;
this.Context.CurrentConnectionConfig.IsAutoCloseConnection = false;
}
result = Ado.GetInt(sql.Split(';').First(), InsertBuilder.Parameters == null ? null : InsertBuilder.Parameters.ToArray());
result = Ado.GetInt(sql.Split(';').Last(), InsertBuilder.Parameters == null ? null : InsertBuilder.Parameters.ToArray());
if (this.Context.Ado.IsAnyTran() == false && isAuto)
{
this.Ado.Close();
this.Context.CurrentConnectionConfig.IsAutoCloseConnection = isAuto;
}
}
result = Convert.ToInt64(await Ado.GetScalarAsync(sql, InsertBuilder.Parameters == null ? null : InsertBuilder.Parameters.ToArray()));
After(sql, result); After(sql, result);
return result; return result;
} }