IsShardSameThread BUG

This commit is contained in:
sunkaixuan
2017-11-22 15:26:22 +08:00
parent d66e84c911
commit c79d2b3cf8

View File

@@ -140,33 +140,33 @@ namespace SqlSugar
} }
private void InitMppingInfo(EntityInfo entityInfo) private void InitMppingInfo(EntityInfo entityInfo)
{ {
if (this.MappingTables == null) if (this.Context.MappingTables == null)
this.MappingTables = new MappingTableList(); this.Context.MappingTables = new MappingTableList();
if (this.MappingColumns == null) if (this.Context.MappingColumns == null)
this.MappingColumns = new MappingColumnList(); this.Context.MappingColumns = new MappingColumnList();
if (this.IgnoreColumns == null) if (this.Context.IgnoreColumns == null)
this.IgnoreColumns = new IgnoreColumnList(); this.Context.IgnoreColumns = new IgnoreColumnList();
if (!this.MappingTables.Any(it => it.EntityName == entityInfo.EntityName)) if (!this.Context.MappingTables.Any(it => it.EntityName == entityInfo.EntityName))
{ {
if (entityInfo.DbTableName != entityInfo.EntityName && entityInfo.DbTableName.HasValue()) if (entityInfo.DbTableName != entityInfo.EntityName && entityInfo.DbTableName.HasValue())
{ {
this.MappingTables.Add(entityInfo.EntityName, entityInfo.DbTableName); this.Context.MappingTables.Add(entityInfo.EntityName, entityInfo.DbTableName);
} }
} }
if (entityInfo.Columns.Any(it => it.EntityName == entityInfo.EntityName)) if (entityInfo.Columns.Any(it => it.EntityName == entityInfo.EntityName))
{ {
var mappingColumnInfos = this.MappingColumns.Where(it => it.EntityName == entityInfo.EntityName); var mappingColumnInfos = this.Context.MappingColumns.Where(it => it.EntityName == entityInfo.EntityName);
foreach (var item in entityInfo.Columns.Where(it => it.IsIgnore == false)) foreach (var item in entityInfo.Columns.Where(it => it.IsIgnore == false))
{ {
if (!mappingColumnInfos.Any(it => it.PropertyName == item.PropertyName)) if (!mappingColumnInfos.Any(it => it.PropertyName == item.PropertyName))
if (item.PropertyName != item.DbColumnName && item.DbColumnName.HasValue()) if (item.PropertyName != item.DbColumnName && item.DbColumnName.HasValue())
this.MappingColumns.Add(item.PropertyName, item.DbColumnName, item.EntityName); this.Context.MappingColumns.Add(item.PropertyName, item.DbColumnName, item.EntityName);
} }
var ignoreInfos = this.IgnoreColumns.Where(it => it.EntityName == entityInfo.EntityName); var ignoreInfos = this.Context.IgnoreColumns.Where(it => it.EntityName == entityInfo.EntityName);
foreach (var item in entityInfo.Columns.Where(it => it.IsIgnore)) foreach (var item in entityInfo.Columns.Where(it => it.IsIgnore))
{ {
if (!ignoreInfos.Any(it => it.PropertyName == item.PropertyName)) if (!ignoreInfos.Any(it => it.PropertyName == item.PropertyName))
this.IgnoreColumns.Add(item.PropertyName, item.EntityName); this.Context.IgnoreColumns.Add(item.PropertyName, item.EntityName);
} }
} }
} }