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

Synchronization code

Browse Source
This commit is contained in:
sunkaixuan 2023-12-13 02:39:47 +08:00
parent 279aeb5a5b
commit baeb43a485
2 changed files with 31 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
Src/Asp.Net/SqlSugar/Abstract/InsertableProvider/ParameterInsertable.cs
View File

@ -104,27 +104,31 @@ namespace SqlSugar
var tableWithString = inserable.InsertBuilder.TableWithString; var tableWithString = inserable.InsertBuilder.TableWithString;
var removeCacheFunc = inserable.RemoveCacheFunc; var removeCacheFunc = inserable.RemoveCacheFunc;
var objects = inserable.InsertObjs; var objects = inserable.InsertObjs;
if (objects == null || objects.Count() == 0 || (objects.Count() == 1 && objects.First() == null)) if (objects == null || objects.Count() == 0 || (objects.Count() == 1 && objects.First() == null))
{ {
return result; return result;
} }
var identityList = inserable.EntityInfo.Columns.Where(it => it.IsIdentity).Select(it => it.PropertyName).ToArray(); var identityList = inserable.EntityInfo.Columns.Where(it => it.IsIdentity).Select(it => it.PropertyName).ToArray();
if (inserable.IsOffIdentity) if (inserable.IsOffIdentity)
{ {
identityList = new string[] { }; identityList = new string[] { };
} }
this.Context.Utilities.PageEach(objects, 100, pagelist => var pageSize = 100;
var count = inserable.EntityInfo.Columns.Count();
pageSize = GetPageSize(pageSize, count);
this.Context.Utilities.PageEach(objects, pageSize, pagelist =>
{ {
StringBuilder batchInsetrSql; StringBuilder batchInsetrSql;
List<SugarParameter> allParamter=new List<SugarParameter>(); List<SugarParameter> allParamter=new List<SugarParameter>();
GetInsertValues(identityList,columns, tableWithString, removeCacheFunc, pagelist, out batchInsetrSql, allParamter); GetInsertValues(identityList,columns, tableWithString, removeCacheFunc, pagelist, out batchInsetrSql, allParamter);
result += this.Context.Ado.ExecuteCommand(batchInsetrSql.ToString(), allParamter); result += this.Context.Ado.ExecuteCommand(batchInsetrSql.ToString(), allParamter);
}); });
return result; return result;
} }
public async Task<int> ValuesExecuteCommandAsync() public async Task<int> ValuesExecuteCommandAsync()
{ {
int result = 0; int result = 0;
@ -150,6 +154,24 @@ namespace SqlSugar
return result; return result;
} }
#region Values Helper #region Values Helper
private static int GetPageSize(int pageSize, int count)
{
if (pageSize * count > 2100)
{
pageSize = 50;
}
if (pageSize * count > 2100)
{
pageSize = 20;
}
if (pageSize * count > 2100)
{
pageSize = 10;
}
return pageSize;
}
private void GetInsertValues(string[] identitys, List<string> columns, string tableWithString, Action removeCacheFunc, List<T> items, out StringBuilder batchInsetrSql, List<SugarParameter> allParamter) private void GetInsertValues(string[] identitys, List<string> columns, string tableWithString, Action removeCacheFunc, List<T> items, out StringBuilder batchInsetrSql, List<SugarParameter> allParamter)
{ {
var itemable = this.Context.Insertable(items); var itemable = this.Context.Insertable(items);

1
Src/Asp.Net/SqlSugar/Abstract/UpdateProvider/UpdateableHelper.cs
View File

@ -325,6 +325,7 @@ namespace SqlSugar
foreach (var column in EntityInfo.Columns) foreach (var column in EntityInfo.Columns)
{ {
if (column.IsIgnore) continue; if (column.IsIgnore) continue;
Check.ExceptionEasy(item == null, "db.Updateable(data) data is required ", "db.Updateable(data) data不能是null");
var columnInfo = new DbColumnInfo() var columnInfo = new DbColumnInfo()
{ {
Value = column.PropertyInfo.GetValue(item, null), Value = column.PropertyInfo.GetValue(item, null),