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

-

Browse Source
This commit is contained in:
sunkaixuan
2022-07-24 16:55:43 +08:00
parent 91ee5d1d0e
commit 85053943f2
1 changed files with 17 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
Src/Asp.Net/SqlSugar/Abstract/UpdateProvider/UpdateableProvider.cs
View File

@@ -64,8 +64,13 @@ namespace SqlSugar
{ {
var updateData = UpdateObjs.FirstOrDefault(); var updateData = UpdateObjs.FirstOrDefault();
if (updateData == null) return 0; if (updateData == null) return 0;
_ExecuteCommandWithOptLock(updateData); var name=_ExecuteCommandWithOptLock(updateData);
return this.ExecuteCommand(); var result= this.ExecuteCommand();
if (result == 0 && IsVersionValidation)
{
throw new VersionExceptions(string.Format("UpdateVersionValidation {0} Not the latest version ", name));
}
return result;
} }
public virtual int ExecuteCommand() public virtual int ExecuteCommand()
@@ -87,8 +92,13 @@ namespace SqlSugar
{ {
var updateData = UpdateObjs.FirstOrDefault(); var updateData = UpdateObjs.FirstOrDefault();
if (updateData == null) return 0; if (updateData == null) return 0;
_ExecuteCommandWithOptLock(updateData); var name=_ExecuteCommandWithOptLock(updateData);
return await this.ExecuteCommandAsync(); var result= await this.ExecuteCommandAsync();
if (result == 0 && IsVersionValidation)
{
throw new VersionExceptions(string.Format("UpdateVersionValidation {0} Not the latest version ", name));
}
return result;
} }
public virtual async Task<int> ExecuteCommandAsync() public virtual async Task<int> ExecuteCommandAsync()
{ {
@@ -868,7 +878,7 @@ namespace SqlSugar
this.RemoveCacheFunc(); this.RemoveCacheFunc();
} }
} }
private void _ExecuteCommandWithOptLock(T updateData) private string _ExecuteCommandWithOptLock(T updateData)
{ {
Check.ExceptionEasy(UpdateParameterIsNull == true, "Optimistic lock can only be an entity update method", "乐观锁只能是实体更新方式"); Check.ExceptionEasy(UpdateParameterIsNull == true, "Optimistic lock can only be an entity update method", "乐观锁只能是实体更新方式");
var verColumn = this.EntityInfo.Columns.FirstOrDefault(it => it.IsEnableUpdateVersionValidation); var verColumn = this.EntityInfo.Columns.FirstOrDefault(it => it.IsEnableUpdateVersionValidation);
@@ -882,6 +892,7 @@ namespace SqlSugar
it.PropertyName.EqualCase(verColumn.PropertyName)); it.PropertyName.EqualCase(verColumn.PropertyName));
data.Value = newValue; data.Value = newValue;
var pks = GetPrimaryKeys(); var pks = GetPrimaryKeys();
Check.ExceptionEasy(pks.Count == 0, "need primary key or WhereColumn", "需要主键或者WhereColumn");
this.Where(verColumn.DbColumnName, "=", oldValue); this.Where(verColumn.DbColumnName, "=", oldValue);
foreach (var p in pks) foreach (var p in pks)
{ {
@@ -889,6 +900,7 @@ namespace SqlSugar
it => it.DbColumnName.EqualCase(p) || it.PropertyName.EqualCase(p)); it => it.DbColumnName.EqualCase(p) || it.PropertyName.EqualCase(p));
this.Where(pkColumn.DbColumnName, "=", pkColumn.PropertyInfo.GetValue(updateData)); this.Where(pkColumn.DbColumnName, "=", pkColumn.PropertyInfo.GetValue(updateData));
} }
return verColumn.PropertyName;
} }
private void Before(string sql) private void Before(string sql)
{ {