Synchronization code

This commit is contained in:
sunkaixuan
2024-04-29 15:05:40 +08:00
parent 0f04e00ba1
commit c7cf1a5845

View File

@@ -307,6 +307,8 @@ namespace SqlSugar
Check.Exception(updateColumns == null || updateColumns.Count() == 0, "set columns count=0"); Check.Exception(updateColumns == null || updateColumns.Count() == 0, "set columns count=0");
var isAuto = this.context.CurrentConnectionConfig.IsAutoCloseConnection; var isAuto = this.context.CurrentConnectionConfig.IsAutoCloseConnection;
this.context.CurrentConnectionConfig.IsAutoCloseConnection = false; this.context.CurrentConnectionConfig.IsAutoCloseConnection = false;
var old = this.context.Ado.IsDisableMasterSlaveSeparation;
this.context.Ado.IsDisableMasterSlaveSeparation = true;
DataTable dt = ToDdateTable(datas); DataTable dt = ToDdateTable(datas);
IFastBuilder buider = GetBuider(); IFastBuilder buider = GetBuider();
ActionIgnoreColums(whereColumns, updateColumns, dt, buider.IsActionUpdateColumns); ActionIgnoreColums(whereColumns, updateColumns, dt, buider.IsActionUpdateColumns);
@@ -321,6 +323,7 @@ namespace SqlSugar
} }
this.context.CurrentConnectionConfig.IsAutoCloseConnection = isAuto; this.context.CurrentConnectionConfig.IsAutoCloseConnection = isAuto;
buider.CloseDb(); buider.CloseDb();
this.context.Ado.IsDisableMasterSlaveSeparation = old;
End(datas, false); End(datas, false);
return result; return result;
} }
@@ -374,6 +377,8 @@ namespace SqlSugar
Check.Exception(updateColumns == null || updateColumns.Count() == 0, "set columns count=0"); Check.Exception(updateColumns == null || updateColumns.Count() == 0, "set columns count=0");
var isAuto = this.context.CurrentConnectionConfig.IsAutoCloseConnection; var isAuto = this.context.CurrentConnectionConfig.IsAutoCloseConnection;
this.context.CurrentConnectionConfig.IsAutoCloseConnection = false; this.context.CurrentConnectionConfig.IsAutoCloseConnection = false;
var old = this.context.Ado.IsDisableMasterSlaveSeparation;
this.context.Ado.IsDisableMasterSlaveSeparation = true;
dataTable.TableName = this.queryable.SqlBuilder.GetTranslationTableName(tableName); dataTable.TableName = this.queryable.SqlBuilder.GetTranslationTableName(tableName);
DataTable dt = GetCopyWriteDataTableUpdate(dataTable); DataTable dt = GetCopyWriteDataTableUpdate(dataTable);
IFastBuilder buider = GetBuider(); IFastBuilder buider = GetBuider();
@@ -397,6 +402,7 @@ namespace SqlSugar
} }
this.context.CurrentConnectionConfig.IsAutoCloseConnection = isAuto; this.context.CurrentConnectionConfig.IsAutoCloseConnection = isAuto;
buider.CloseDb(); buider.CloseDb();
this.context.Ado.IsDisableMasterSlaveSeparation = old;
End(datas, false); End(datas, false);
return result; return result;
} }