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

-

Browse Source
This commit is contained in:
sunkaixuan
2017-05-21 02:40:13 +08:00
parent dc5adfc6a7
commit 95a11a8284
1 changed files with 31 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
SqlSugar/Abstract/Core/SqlBuilder/DMLBuilder/UpdateBuilder.cs
View File

@@ -42,11 +42,11 @@ namespace SqlSugar
{
get
{
return @"UPDATE S SET {{0}} FROM {0} S INNER JOIN
return @"UPDATE S SET {0} FROM {1} S {2} INNER JOIN
(
{ { 1} }
{{0}}
) T ON ";
) T ON {{1}}";
}
}
@@ -90,6 +90,14 @@ namespace SqlSugar
return result;
}
}
public virtual string GetTableNameStringNoWith
{
get
{
var result = Builder.GetTranslationTableName(TableName);
return result;
}
}
public virtual ExpressionResult GetExpressionValue(Expression expression, ResolveExpressType resolveType, bool isMapping = true)
{
ILambdaExpressions resolveExpress = this.LambdaExpressions;
@@ -149,30 +157,44 @@ namespace SqlSugar
else
{
Check.Exception(PrimaryKeys == null || PrimaryKeys.Count == 0, " Update List<T> need Primary key");
var whereString = string.Join(",", PrimaryKeys.Select(it => string.Format("T.{0}=S.{0}", Builder.GetTranslationColumnName(it))));
string setValues = string.Join(",", groupList.First().Select(it =>
{
if (SetValues.IsValuable())
{
var setValue = SetValues.Where(sv => sv.Key == Builder.GetTranslationColumnName(it.DbColumnName));
if (setValue != null && setValue.Any())
{
return setValue.First().Value;
}
}
var result =string.Format("S.{0}=T.{0}", Builder.GetTranslationColumnName(it.DbColumnName));
return result;
}));
StringBuilder batchUpdateSql = new StringBuilder();
batchUpdateSql.AppendFormat(SqlTemplateBatch,setValues,GetTableNameStringNoWith, TableWithString);
int pageSize = 200;
int pageIndex = 1;
int totalRecord = groupList.Count;
int pageCount = (totalRecord + pageSize - 1) / pageSize;
StringBuilder updateTable = new StringBuilder();
while (pageCount >= pageIndex)
{
batchUpdateSql.AppendFormat(SqlTemplateBatch, GetTableNameString, "");
int i = 0;
foreach (var columns in groupList.Skip((pageIndex - 1) * pageSize).Take(pageSize).ToList())
{
var isFirst = i == 0;
if (!isFirst)
{
batchUpdateSql.Append(SqlTemplateBatchUnion);
updateTable.Append(SqlTemplateBatchUnion);
}
batchUpdateSql.Append("\r\n SELECT " + string.Join(",", columns.Select(it => string.Format(SqlTemplateBatchSelect, FormatValue(it.Value), it.DbColumnName))));
updateTable.Append("\r\n SELECT " + string.Join(",", columns.Select(it => string.Format(SqlTemplateBatchSelect, FormatValue(it.Value), it.DbColumnName))));
++i;
}
pageIndex++;
batchUpdateSql.Append("\r\nGO\r\n");
updateTable.Append("\r\nGO\r\n");
}
return batchUpdateSql.ToString();
return string.Format(batchUpdateSql.ToString(), updateTable.ToString(),"");
}
}