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-17 15:43:47 +08:00
parent 1458f931af
commit ee8a5aa787
3 changed files with 52 additions and 85 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
SqlSugar/Entities/SugarList.cs
View File

@@ -25,10 +25,10 @@ namespace SqlSugar
public class IgnoreComumnList : List<IgnoreComumn>
{
public void Add(string EntityPropertyName, string EntityName)
public void Add(string propertyName, string EntityName)
{
this.RemoveAll(it => it.EntityPropertyName.Equals(EntityPropertyName, StringComparison.CurrentCultureIgnoreCase));
this.Add(new IgnoreComumn() { EntityPropertyName = EntityPropertyName, EntityName = EntityName });
this.RemoveAll(it => it.EntityPropertyName.Equals(propertyName, StringComparison.CurrentCultureIgnoreCase));
this.Add(new IgnoreComumn() { EntityPropertyName = propertyName, EntityName = EntityName });
}
public new void Clear()
@@ -39,10 +39,10 @@ namespace SqlSugar
public class MappingColumnList : List<MappingColumn>
{
public void Add(string EntityPropertyName, string dbColumnName, string entityName)
public void Add(string propertyName, string dbColumnName, string entityName)
{
this.RemoveAll(it => it.EntityPropertyName.Equals(EntityPropertyName, StringComparison.CurrentCultureIgnoreCase));
this.Add(new MappingColumn() { EntityPropertyName = EntityPropertyName, DbColumnName = dbColumnName, EntityName = entityName });
this.RemoveAll(it => it.EntityPropertyName.Equals(propertyName, StringComparison.CurrentCultureIgnoreCase));
this.Add(new MappingColumn() { EntityPropertyName = propertyName, DbColumnName = dbColumnName, EntityName = entityName });
}
public new void Clear()
{

121
SqlSugar/SqlSugarAccessory.cs
View File

@@ -9,6 +9,7 @@ namespace SqlSugar
{
public partial class SqlSugarAccessory
{
public SqlSugarClient Context { get; set; }
public string EntityNamespace { get; set; }
public IConnectionConfig CurrentConnectionConfig { get; set; }
public Dictionary<string, object> TempItems { get; set; }
@@ -21,7 +22,6 @@ namespace SqlSugar
protected EntityProvider _EntityProvider;
protected IDb _Ado;
protected ILambdaExpressions _LambdaExpressions;
protected object _Sqlable;
protected IRewritableMethods _RewritableMethods;
protected void InitConstructor()
@@ -29,87 +29,50 @@ namespace SqlSugar
this.ContextID = Guid.NewGuid();
if (this.CurrentConnectionConfig is AttrbuitesCofnig)
{
this.InitAttributeMappingTables();
this.InitAttributeMappingColumns();
string cacheKey = "Context.InitAttributeMappingTables";
CacheFactory.Action<Tuple<MappingTableList, MappingColumnList, IgnoreComumnList>>(cacheKey,
(cm, key) =>
{
var cacheInfo = cm[key];
this.MappingTables = cacheInfo.Item1;
this.MappingColumns = cacheInfo.Item2;
this.IgnoreColumns = cacheInfo.Item3;
},
(cm, key) =>
{
var entities = this.Context.EntityProvider.GetAllEntities();
foreach (var entity in entities)
{
if (!entity.DbTableName.Equals(entity.EntityName))
{
this.MappingTables.Add(entity.EntityName, entity.DbTableName);
}
foreach (var column in entity.Columns)
{
if (column.IsIgnore)
{
this.IgnoreColumns.Add(column.PropertyName, column.EnitytName);
}
else
{
if (!column.DbColumnName.Equals(column.PropertyName))
{
this.MappingColumns.Add(column.PropertyName, column.DbColumnName, column.EnitytName);
}
}
}
}
return Tuple.Create<MappingTableList, MappingColumnList, IgnoreComumnList>(this.MappingTables,this.MappingColumns,this.IgnoreColumns);
});
}
}
protected void InitAttributeMappingTables()
{
string cacheKey = "Context.InitAttributeMappingTables";
CacheFactory.Action<List<MappingTable>>(cacheKey,
(cm, key) =>
{
this.MappingTables.AddRange(cm[key]);
},
(cm, key) =>
{
var classes = Assembly.Load(this.EntityNamespace.Split('.').First()).GetTypes();
List<MappingTable> mappingList = new List<MappingTable>();
foreach (var item in classes)
{
if (item.Namespace == this.EntityNamespace)
{
var sugarTableObj = item.GetCustomAttributes(typeof(SugarTable), true).Where(it => it is SugarTable).SingleOrDefault();
if (sugarTableObj.IsValuable())
{
var sugarTable = (SugarTable)sugarTableObj;
if (item.Name != sugarTable.TableName)
mappingList.Add(new MappingTable() { EntityName = item.Name, DbTableName = sugarTable.TableName });
}
}
}
this.MappingTables.AddRange(mappingList);
return mappingList;
});
}
protected void InitAttributeMappingColumns()
{
string cacheKey = "Context.InitAttributeMappingColumns";
CacheFactory.Action<List<MappingColumn>>(cacheKey,
(cm, key) =>
{
this.MappingColumns.AddRange(cm[cacheKey]);
},
(cm, key) =>
{
var assembly = Assembly.Load(this.EntityNamespace.Split('.').First());
var entityTypeArray = assembly.GetTypes();
List<MappingColumn> mappingList = new List<MappingColumn>();
foreach (var entityType in entityTypeArray)
{
var mappingInfo = this.MappingTables.FirstOrDefault(it => it.EntityName.Equals(entityType.Name, StringComparison.CurrentCultureIgnoreCase));
var tableName = mappingInfo.IsNullOrEmpty() ? entityType.Name : mappingInfo.DbTableName;
var entityName = mappingInfo.IsNullOrEmpty() ? entityType.Name : mappingInfo.EntityName;
if (entityType.Namespace == this.EntityNamespace)
foreach (var item in assembly.GetType(this.EntityNamespace + "." + entityName).GetProperties())
{
var sugarColumnObjs = item.GetCustomAttributes(typeof(SugarColumn), true).Where(it => it is SugarColumn).ToList();
foreach (var sugarColumnObj in sugarColumnObjs)
{
var sugarColumn = (SugarColumn)sugarColumnObj;
if (sugarColumn.ColumnName.IsValuable())
{
if (item.Name != sugarColumn.ColumnName && sugarColumn.ColumnName.IsValuable())
{
this.MappingColumns.Add(item.Name, sugarColumn.ColumnName, tableName);
}
}
}
}
}
this.MappingColumns.AddRange(mappingList);
return mappingList;
});
}
protected List<JoinQueryInfo> GetJoinInfos(Expression joinExpression, SqlSugarClient context,ref string shortName, params Type[] entityTypeArray)
protected List<JoinQueryInfo> GetJoinInfos(Expression joinExpression, ref string shortName, params Type[] entityTypeArray)
{
List<JoinQueryInfo> reval = new List<JoinQueryInfo>();
var lambdaParameters = ((LambdaExpression)joinExpression).Parameters.ToList();
ExpressionContext exp = new ExpressionContext();
exp.MappingColumns = context.MappingColumns;
exp.MappingTables = context.MappingTables;
exp.MappingColumns = this.Context.MappingColumns;
exp.MappingTables = this.Context.MappingTables;
exp.Resolve(joinExpression, ResolveExpressType.Join);
int i = 0;
var joinArray = exp.Result.GetResultArray();
@@ -136,9 +99,9 @@ namespace SqlSugar
shortName = firstItem.Name;
}
var joinString = joinArray[i * 2 - 2];
joinInfo.ShortName = lambdaParameters[i-1].Name;
joinInfo.JoinType = (JoinType) Enum.Parse(typeof (JoinType), joinString);
joinInfo.JoinWhere = joinArray[i * 2-1];
joinInfo.ShortName = lambdaParameters[i - 1].Name;
joinInfo.JoinType = (JoinType)Enum.Parse(typeof(JoinType), joinString);
joinInfo.JoinWhere = joinArray[i * 2 - 1];
joinInfo.JoinIndex = i;
reval.Add((joinInfo));
}

4
SqlSugar/SqlSugarClient.cs
View File

@@ -32,6 +32,7 @@ namespace SqlSugar
/// <param name="config"></param>
public SqlSugarClient(SystemTablesConfig config)
{
base.Context = this;
base.CurrentConnectionConfig = config;
base.InitConstructor();
}
@@ -41,6 +42,7 @@ namespace SqlSugar
/// <param name="config"></param>
public SqlSugarClient(AttrbuitesCofnig config)
{
base.Context = this;
base.CurrentConnectionConfig = config;
Check.ArgumentNullException(config.EntityNamespace, ErrorMessage.EntityNamespaceError);
base.EntityNamespace = config.EntityNamespace;
@@ -53,6 +55,7 @@ namespace SqlSugar
/// <param name="slaveConnectionConfigs"></param>
public SqlSugarClient(SystemTablesConfig masterConnectionConfig, IConnectionConfig[] slaveConnectionConfigs)
{
base.Context = this;
base.CurrentConnectionConfig = masterConnectionConfig;
base.InitConstructor();
if (slaveConnectionConfigs.IsNullOrEmpty()) return;
@@ -68,6 +71,7 @@ namespace SqlSugar
/// <param name="slaveConnectionConfigs"></param>
public SqlSugarClient(AttrbuitesCofnig masterConnectionConfig, IConnectionConfig[] slaveConnectionConfigs)
{
base.Context = this;
base.CurrentConnectionConfig = masterConnectionConfig;
base.InitConstructor();
if (slaveConnectionConfigs.IsNullOrEmpty()) return;