tk/FreeSql
1
0
Fork 0
mirror of https://github.com/nsnail/FreeSql.git synced 2025-06-19 20:38:16 +08:00
Code Issues Packages Projects Releases Wiki Activity

- 优化 UpdateDict 支持 .IsVersion 乐观锁设置；

Browse Source
This commit is contained in:
2881099
2022-10-27 11:52:54 +08:00
parent 5d11d6f4c5
commit 4cd83e4981
5 changed files with 221 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
FreeSql/Internal/CommonProvider/UpdateProvider.cs
View File

@ -138,7 +138,24 @@ namespace FreeSql.Internal.CommonProvider
throw new DbUpdateVersionException(CoreStrings.DbUpdateVersionException_RowLevelOptimisticLock(_source.Count, affrows), _table, sql, dbParms, affrows, _source.Select(a => (object)a));
foreach (var d in _source)
{
if (_versionColumn.Attribute.MapType == typeof(byte[]))
if (d is Dictionary<string, object> dict)
{
if (dict.ContainsKey(_versionColumn.CsName))
{
var val = dict[_versionColumn.CsName];
if (val == null) continue;
var valType = val.GetType();
if (valType == typeof(byte[]))
dict[_versionColumn.CsName] = _updateVersionValue;
else if (valType == typeof(string))
dict[_versionColumn.CsName] = _updateVersionValue;
else if (int.TryParse(string.Concat(val), out var tryintver))
dict[_versionColumn.CsName] = tryintver + 1;
}
continue;
}
if (_versionColumn.Attribute.MapType == typeof(byte[]))
_orm.SetEntityValueWithPropertyName(_table.Type, d, _versionColumn.CsName, _updateVersionValue);
else if (_versionColumn.Attribute.MapType == typeof(string))
_orm.SetEntityValueWithPropertyName(_table.Type, d, _versionColumn.CsName, _updateVersionValue);