Crosss database query

This commit is contained in:
sunkaixuan 2022-10-04 20:41:26 +08:00
parent c35b7706b7
commit d29d2ac0aa

View File

@ -365,30 +365,6 @@ namespace SqlSugar
}
}
private SqlSugarProvider GetCrossDatabase(SqlSugarProvider db,Type type)
{
if (IsCrossQueryWithAttr == false && this.CrossQueryItems == null)
{
return db;
}
else if (IsCrossQueryWithAttr)
{
var tenant= type.GetCustomAttribute<TenantAttribute>();
if (tenant != null)
{
return db.Root.GetConnection(tenant.configId);
}
else
{
return db;
}
}
else
{
return db;
}
}
private void OneToMany(List<object> list, Func<ISugarQueryable<object>, List<object>> selector, EntityInfo listItemEntity, System.Reflection.PropertyInfo navObjectNamePropety, EntityColumnInfo navObjectNameColumnInfo)
{
var navEntity = navObjectNameColumnInfo.PropertyInfo.PropertyType.GetGenericArguments()[0];
@ -718,6 +694,31 @@ namespace SqlSugar
}
}
private SqlSugarProvider GetCrossDatabase(SqlSugarProvider db, Type type)
{
if (IsCrossQueryWithAttr == false && this.CrossQueryItems == null)
{
return db;
}
else if (IsCrossQueryWithAttr)
{
var tenant = type.GetCustomAttribute<TenantAttribute>();
if (tenant != null)
{
return db.Root.GetConnection(tenant.configId);
}
else
{
return db;
}
}
else
{
return db;
}
}
private static void AppColumns(SqlInfo result, ISugarQueryable<object> queryable, string columnName)
{
var selectPkName = queryable.SqlBuilder.GetTranslationColumnName(columnName);