tk/FreeSql
1
0
Fork 0
mirror of https://github.com/nsnail/FreeSql.git synced 2025-04-22 10:42:52 +08:00
Code Issues Packages Projects Releases Wiki Activity

- 优化 字典crud TableInfo 合并规则；#1180

Browse Source
This commit is contained in:
2881099 2022-07-07 09:43:05 +08:00
parent 86c6aac4c2
commit 25065522c9
3 changed files with 25 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

51
FreeSql/Internal/CommonProvider/InsertOrUpdateProvider.cs
View File

@ -94,10 +94,7 @@ namespace FreeSql.Internal.CommonProvider
public static void AuditDataValue(object sender, T1 data, IFreeSql orm, TableInfo table, Dictionary<string, bool> changedDict)
{
if (data == null || table == null) return;
if (typeof(T1) == typeof(object) && new[]
{
table.Type, table.TypeLazy
}.Contains(data.GetType()) == false)
if (typeof(T1) == typeof(object) && new[] { table.Type, table.TypeLazy }.Contains(data.GetType()) == false)
throw new Exception(CoreStrings.DataType_AsType_Inconsistent(data.GetType().DisplayCsharp(), table.Type.DisplayCsharp()));
if (orm.Aop.AuditValueHandler == null) return;
foreach (var col in table.Columns.Values)
@ -116,32 +113,11 @@ namespace FreeSql.Internal.CommonProvider
}
}
public IInsertOrUpdate<T1> SetSource(T1 source) => this.SetSource(new[]
{
source
});
public IInsertOrUpdate<T1> SetSource(T1 source) => this.SetSource(new[] { source });
public IInsertOrUpdate<T1> SetSource(IEnumerable<T1> source, Expression<Func<T1, object>> tempPrimarys = null)
{
if (source == null || source.Any() == false) return this;
if (source is IEnumerable<IDictionary<string, object>> dicType)
{
var tempDict = new Dictionary<string, object>();
foreach (var item in dicType)
{
foreach (string key in item.Keys)
{
if (!tempDict.ContainsKey(key) && !(item[key] is null))
{
tempDict[key] = item[key];
}
}
}
UpdateProvider<IDictionary>.GetDictionaryTableInfo(tempDict, _orm, ref _table);
}
else
{
UpdateProvider<T1>.GetDictionaryTableInfo(source.FirstOrDefault(), _orm, ref _table);
}
UpdateProvider<T1>.GetDictionaryTableInfo(source, _orm, ref _table);
AuditDataValue(this, source, _orm, _table, _auditValueChangedDict);
_source.AddRange(source.Where(a => a != null));
@ -248,7 +224,7 @@ namespace FreeSql.Internal.CommonProvider
}
}
byte _SplitSourceByIdentityValueIsNullFlag = 0;//防止重复计算 SplitSource
byte _SplitSourceByIdentityValueIsNullFlag = 0 ;//防止重复计算 SplitSource
/// <summary>
/// 如果实体类有自增属性，分成两个 List，有值的Item1 merge，无值的Item2 insert
/// </summary>
@ -257,23 +233,15 @@ namespace FreeSql.Internal.CommonProvider
public NativeTuple<List<T1>[], List<T1>[]> SplitSourceByIdentityValueIsNull(List<T1> source)
{
if (source.Any() == false) return NativeTuple.Create(new List<T1>[0], new List<T1>[0]);
if (_SplitSourceByIdentityValueIsNullFlag == 1)
return NativeTuple.Create(new[]
{
source
}, new List<T1>[0]);
if (_SplitSourceByIdentityValueIsNullFlag == 2)
return NativeTuple.Create(new List<T1>[0], new[]
{
source
});
if (_SplitSourceByIdentityValueIsNullFlag == 1) return NativeTuple.Create(new[] { source }, new List<T1>[0]);
if (_SplitSourceByIdentityValueIsNullFlag == 2) return NativeTuple.Create(new List<T1>[0], new[] { source });
if (IdentityColumn == null || _tempPrimarys != _table.Primarys) return NativeTuple.Create(LocalSplitSourceByAsTable(source), new List<T1>[0]);
var item1 = new List<T1>();
var item2 = new List<T1>();
foreach (var item in source)
{
if (object.Equals(_orm.GetEntityValueWithPropertyName(_table.Type, item, IdentityColumn.CsName), IdentityColumn.CsType.CreateInstanceGetDefaultValue()))
item2.Add(item);//自增无值的，记录为直接插入
item2.Add(item); //自增无值的，记录为直接插入
else
item1.Add(item);
}
@ -291,10 +259,7 @@ namespace FreeSql.Internal.CommonProvider
}).GroupBy(a => a.splitKey, a => a.item).Select(a => a.ToList()).ToArray();
return atarr;
}
return new[]
{
loc1
};
return new[] { loc1 };
}
}

4
FreeSql/Internal/CommonProvider/InsertProvider.cs
View File

@ -133,7 +133,7 @@ namespace FreeSql.Internal.CommonProvider
{
if (source != null)
{
UpdateProvider<T1>.GetDictionaryTableInfo(source.FirstOrDefault(), _orm, ref _table);
UpdateProvider<T1>.GetDictionaryTableInfo(source, _orm, ref _table);
AuditDataValue(this, source, _orm, _table, _auditValueChangedDict);
_source.AddRange(source);
}
@ -144,7 +144,7 @@ namespace FreeSql.Internal.CommonProvider
if (source != null)
{
source = source.Where(a => a != null).ToList();
UpdateProvider<T1>.GetDictionaryTableInfo(source.FirstOrDefault(), _orm, ref _table);
UpdateProvider<T1>.GetDictionaryTableInfo(source, _orm, ref _table);
AuditDataValue(this, source, _orm, _table, _auditValueChangedDict);
_source.AddRange(source);

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

@ -451,6 +451,20 @@ namespace FreeSql.Internal.CommonProvider
}
}
public static void GetDictionaryTableInfo(IEnumerable<T1> source, IFreeSql orm, ref TableInfo table)
{
if (table == null && typeof(T1) == typeof(Dictionary<string, object>) && source is IEnumerable<Dictionary<string, object>> dicType)
{
var tempDict = new Dictionary<string, object>();
foreach (var item in dicType)
foreach (string key in item.Keys)
if (!tempDict.ContainsKey(key) && !(item[key] is null))
tempDict[key] = item[key];
UpdateProvider<Dictionary<string, object>>.GetDictionaryTableInfo(tempDict, orm, ref table);
return;
}
GetDictionaryTableInfo(source.FirstOrDefault(), orm, ref table);
}
public static void GetDictionaryTableInfo(T1 source, IFreeSql orm, ref TableInfo table)
{
if (table == null && typeof(T1) == typeof(Dictionary<string, object>))
@ -493,7 +507,7 @@ namespace FreeSql.Internal.CommonProvider
public IUpdate<T1> SetSource(IEnumerable<T1> source, Expression<Func<T1, object>> tempPrimarys = null, bool ignoreVersion = false)
{
if (source == null || source.Any() == false) return this;
GetDictionaryTableInfo(source.FirstOrDefault(), _orm, ref _table);
GetDictionaryTableInfo(source, _orm, ref _table);
AuditDataValue(this, source, _orm, _table, _auditValueChangedDict);
_source.AddRange(source.Where(a => a != null));