mirror of
https://gitee.com/dotnetchina/SqlSugar.git
synced 2025-04-24 18:04:52 +08:00
698 lines
27 KiB
C#
698 lines
27 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Diagnostics;
|
|
using System.Dynamic;
|
|
using System.Linq.Expressions;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace SqlSugar
|
|
{
|
|
public class SqlSugarScope: ISqlSugarClient, ITenant
|
|
{
|
|
private List<ConnectionConfig> _configs;
|
|
private Action<SqlSugarClient> _configAction;
|
|
private SqlSugarScope()
|
|
{
|
|
|
|
}
|
|
public SqlSugarScope(ConnectionConfig config)
|
|
{
|
|
_configs=new List<ConnectionConfig>() { config};
|
|
}
|
|
public SqlSugarScope(List<ConnectionConfig> configs)
|
|
{
|
|
_configs = configs;
|
|
}
|
|
public SqlSugarScope(ConnectionConfig config, Action<SqlSugarClient> configAction)
|
|
{
|
|
_configs = new List<ConnectionConfig>() { config };
|
|
this._configAction = configAction;
|
|
}
|
|
public SqlSugarScope(List<ConnectionConfig> configs, Action<SqlSugarClient> configAction)
|
|
{
|
|
_configs = configs;
|
|
this._configAction = configAction;
|
|
}
|
|
public SqlSugarClient ScopedContext{ get{ return GetContext();}}
|
|
|
|
public MappingTableList MappingTables { get => ScopedContext.MappingTables; set => ScopedContext.MappingTables = value; }
|
|
public MappingColumnList MappingColumns { get => ScopedContext.MappingColumns; set => ScopedContext.MappingColumns=value; }
|
|
public IgnoreColumnList IgnoreColumns { get => ScopedContext.IgnoreColumns; set => ScopedContext.IgnoreColumns=value; }
|
|
public IgnoreColumnList IgnoreInsertColumns { get => ScopedContext.IgnoreInsertColumns; set => ScopedContext.IgnoreInsertColumns=value; }
|
|
public Dictionary<string, object> TempItems { get => ScopedContext.TempItems; set => ScopedContext.TempItems=value; }
|
|
public ConfigQuery ConfigQuery { get => ScopedContext.ConfigQuery; set => ScopedContext.ConfigQuery = value; }
|
|
|
|
public bool IsSystemTablesConfig => ScopedContext.IsSystemTablesConfig;
|
|
|
|
public Guid ContextID { get => ScopedContext.ContextID; set => ScopedContext.ContextID=value; }
|
|
public ConnectionConfig CurrentConnectionConfig { get => ScopedContext.CurrentConnectionConfig; set => ScopedContext.CurrentConnectionConfig=value; }
|
|
|
|
public IAdo Ado => ScopedContext.Ado;
|
|
|
|
public AopProvider Aop => ScopedContext.Aop;
|
|
|
|
public ICodeFirst CodeFirst => ScopedContext.CodeFirst;
|
|
|
|
public IDbFirst DbFirst => ScopedContext.DbFirst;
|
|
|
|
public IDbMaintenance DbMaintenance => ScopedContext.DbMaintenance;
|
|
|
|
public EntityMaintenance EntityMaintenance { get => ScopedContext.EntityMaintenance; set => ScopedContext.EntityMaintenance=value; }
|
|
public QueryFilterProvider QueryFilter { get => ScopedContext.QueryFilter; set => ScopedContext.QueryFilter=value; }
|
|
public IContextMethods Utilities { get => ScopedContext.Utilities; set => ScopedContext.Utilities=value; }
|
|
public QueueList Queues { get => ScopedContext.Queues; set => ScopedContext.Queues=value; }
|
|
|
|
public SugarCacheProvider DataCache => ScopedContext.DataCache;
|
|
|
|
public ITenant AsTenant()
|
|
{
|
|
return ScopedContext.AsTenant();
|
|
}
|
|
public void AddConnection(ConnectionConfig connection)
|
|
{
|
|
ScopedContext.AddConnection(connection);
|
|
}
|
|
|
|
public void AddQueue(string sql, object parsmeters = null)
|
|
{
|
|
ScopedContext.AddQueue(sql, parsmeters);
|
|
}
|
|
|
|
public void AddQueue(string sql, List<SugarParameter> parsmeters)
|
|
{
|
|
ScopedContext.AddQueue(sql,parsmeters);
|
|
}
|
|
|
|
public void AddQueue(string sql, SugarParameter parsmeter)
|
|
{
|
|
ScopedContext.AddQueue(sql,parsmeter);
|
|
}
|
|
|
|
public void BeginTran()
|
|
{
|
|
ScopedContext.BeginTran();
|
|
}
|
|
|
|
public void ChangeDatabase(dynamic configId)
|
|
{
|
|
ScopedContext.ChangeDatabase(configId);
|
|
}
|
|
|
|
public void ChangeDatabase(Func<ConnectionConfig, bool> changeExpression)
|
|
{
|
|
ScopedContext.ChangeDatabase(changeExpression);
|
|
}
|
|
|
|
public void Close()
|
|
{
|
|
ScopedContext.Close();
|
|
}
|
|
|
|
public void CommitTran()
|
|
{
|
|
ScopedContext.CommitTran();
|
|
}
|
|
|
|
public IDeleteable<T> Deleteable<T>() where T : class, new()
|
|
{
|
|
return ScopedContext.Deleteable<T>();
|
|
}
|
|
|
|
public IDeleteable<T> Deleteable<T>(dynamic primaryKeyValue) where T : class, new()
|
|
{
|
|
return ScopedContext.Deleteable<T>(primaryKeyValue);
|
|
}
|
|
|
|
public IDeleteable<T> Deleteable<T>(dynamic[] primaryKeyValues) where T : class, new()
|
|
{
|
|
return ScopedContext.Deleteable<T>(primaryKeyValues);
|
|
}
|
|
|
|
public IDeleteable<T> Deleteable<T>(Expression<Func<T, bool>> expression) where T : class, new()
|
|
{
|
|
return ScopedContext.Deleteable(expression);
|
|
}
|
|
|
|
public IDeleteable<T> Deleteable<T>(List<dynamic> pkValue) where T : class, new()
|
|
{
|
|
return ScopedContext.Deleteable<T>(pkValue);
|
|
}
|
|
|
|
public IDeleteable<T> Deleteable<T>(List<T> deleteObjs) where T : class, new()
|
|
{
|
|
return ScopedContext.Deleteable(deleteObjs);
|
|
}
|
|
|
|
public IDeleteable<T> Deleteable<T>(T deleteObj) where T : class, new()
|
|
{
|
|
return ScopedContext.Deleteable(deleteObj);
|
|
}
|
|
|
|
public void Dispose()
|
|
{
|
|
ScopedContext.Dispose();
|
|
}
|
|
|
|
public SqlSugarProvider GetConnection(dynamic configId)
|
|
{
|
|
return ScopedContext.GetConnection(configId);
|
|
}
|
|
|
|
public DateTime GetDate()
|
|
{
|
|
return ScopedContext.GetDate();
|
|
}
|
|
|
|
public SimpleClient<T> GetSimpleClient<T>() where T : class, new()
|
|
{
|
|
return ScopedContext.GetSimpleClient<T>();
|
|
}
|
|
|
|
public void InitMappingInfo(Type type)
|
|
{
|
|
ScopedContext.InitMappingInfo(type);
|
|
}
|
|
|
|
public void InitMappingInfo<T>()
|
|
{
|
|
ScopedContext.InitMappingInfo<T>();
|
|
}
|
|
|
|
public IInsertable<T> Insertable<T>(Dictionary<string, object> columnDictionary) where T : class, new()
|
|
{
|
|
return ScopedContext.Insertable<T>(columnDictionary);
|
|
}
|
|
|
|
public IInsertable<T> Insertable<T>(dynamic insertDynamicObject) where T : class, new()
|
|
{
|
|
return ScopedContext.Insertable<T>((object)insertDynamicObject);
|
|
}
|
|
|
|
public IInsertable<T> Insertable<T>(List<T> insertObjs) where T : class, new()
|
|
{
|
|
return ScopedContext.Insertable(insertObjs);
|
|
}
|
|
|
|
public IInsertable<T> Insertable<T>(T insertObj) where T : class, new()
|
|
{
|
|
return ScopedContext.Insertable(insertObj);
|
|
}
|
|
|
|
public IInsertable<T> Insertable<T>(T[] insertObjs) where T : class, new()
|
|
{
|
|
return ScopedContext.Insertable(insertObjs);
|
|
}
|
|
|
|
public void Open()
|
|
{
|
|
ScopedContext.Open();
|
|
}
|
|
|
|
public ISugarQueryable<ExpandoObject> Queryable(string tableName, string shortName)
|
|
{
|
|
return ScopedContext.Queryable(tableName,shortName);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> Queryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>(Expression<Func<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, bool>> joinExpression) where T : class, new()
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> Queryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>(Expression<Func<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, JoinQueryInfos>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> Queryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12>(Expression<Func<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, object[]>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> Queryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>(Expression<Func<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, bool>> joinExpression) where T : class, new()
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> Queryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>(Expression<Func<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, JoinQueryInfos>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> Queryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11>(Expression<Func<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, object[]>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10> Queryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10>(Expression<Func<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, bool>> joinExpression) where T : class, new()
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10> Queryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10>(Expression<Func<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, JoinQueryInfos>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10> Queryable<T, T2, T3, T4, T5, T6, T7, T8, T9, T10>(Expression<Func<T, T2, T3, T4, T5, T6, T7, T8, T9, T10, object[]>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7, T8, T9> Queryable<T, T2, T3, T4, T5, T6, T7, T8, T9>(Expression<Func<T, T2, T3, T4, T5, T6, T7, T8, T9, bool>> joinExpression) where T : class, new()
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7, T8, T9> Queryable<T, T2, T3, T4, T5, T6, T7, T8, T9>(Expression<Func<T, T2, T3, T4, T5, T6, T7, T8, T9, JoinQueryInfos>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7, T8, T9> Queryable<T, T2, T3, T4, T5, T6, T7, T8, T9>(Expression<Func<T, T2, T3, T4, T5, T6, T7, T8, T9, object[]>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7, T8> Queryable<T, T2, T3, T4, T5, T6, T7, T8>(Expression<Func<T, T2, T3, T4, T5, T6, T7, T8, bool>> joinExpression) where T : class, new()
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7, T8> Queryable<T, T2, T3, T4, T5, T6, T7, T8>(Expression<Func<T, T2, T3, T4, T5, T6, T7, T8, JoinQueryInfos>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7, T8> Queryable<T, T2, T3, T4, T5, T6, T7, T8>(Expression<Func<T, T2, T3, T4, T5, T6, T7, T8, object[]>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7> Queryable<T, T2, T3, T4, T5, T6, T7>(Expression<Func<T, T2, T3, T4, T5, T6, T7, bool>> joinExpression) where T : class, new()
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7> Queryable<T, T2, T3, T4, T5, T6, T7>(Expression<Func<T, T2, T3, T4, T5, T6, T7, JoinQueryInfos>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6, T7> Queryable<T, T2, T3, T4, T5, T6, T7>(Expression<Func<T, T2, T3, T4, T5, T6, T7, object[]>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6> Queryable<T, T2, T3, T4, T5, T6>(Expression<Func<T, T2, T3, T4, T5, T6, bool>> joinExpression) where T : class, new()
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6> Queryable<T, T2, T3, T4, T5, T6>(Expression<Func<T, T2, T3, T4, T5, T6, JoinQueryInfos>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5, T6> Queryable<T, T2, T3, T4, T5, T6>(Expression<Func<T, T2, T3, T4, T5, T6, object[]>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5> Queryable<T, T2, T3, T4, T5>(Expression<Func<T, T2, T3, T4, T5, bool>> joinExpression) where T : class, new()
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5> Queryable<T, T2, T3, T4, T5>(Expression<Func<T, T2, T3, T4, T5, JoinQueryInfos>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4, T5> Queryable<T, T2, T3, T4, T5>(Expression<Func<T, T2, T3, T4, T5, object[]>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4> Queryable<T, T2, T3, T4>(Expression<Func<T, T2, T3, T4, bool>> joinExpression) where T : class, new()
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4> Queryable<T, T2, T3, T4>(Expression<Func<T, T2, T3, T4, JoinQueryInfos>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3, T4> Queryable<T, T2, T3, T4>(Expression<Func<T, T2, T3, T4, object[]>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3> Queryable<T, T2, T3>(Expression<Func<T, T2, T3, bool>> joinExpression) where T : class, new()
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3> Queryable<T, T2, T3>(Expression<Func<T, T2, T3, JoinQueryInfos>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3> Queryable<T, T2, T3>(Expression<Func<T, T2, T3, object[]>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2> Queryable<T, T2>(Expression<Func<T, T2, bool>> joinExpression) where T : class, new()
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2> Queryable<T, T2>(Expression<Func<T, T2, JoinQueryInfos>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2> Queryable<T, T2>(Expression<Func<T, T2, object[]>> joinExpression)
|
|
{
|
|
return ScopedContext.Queryable(joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2> Queryable<T, T2>(ISugarQueryable<T> joinQueryable1, ISugarQueryable<T2> joinQueryable2, Expression<Func<T, T2, bool>> joinExpression)
|
|
where T : class, new()
|
|
where T2 : class, new()
|
|
{
|
|
return ScopedContext.Queryable(joinQueryable1,joinQueryable2, joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2> Queryable<T, T2>(ISugarQueryable<T> joinQueryable1, ISugarQueryable<T2> joinQueryable2, JoinType joinType, Expression<Func<T, T2, bool>> joinExpression)
|
|
where T : class, new()
|
|
where T2 : class, new()
|
|
{
|
|
return ScopedContext.Queryable(joinQueryable1, joinQueryable2, joinType, joinExpression);
|
|
}
|
|
|
|
public ISugarQueryable<T, T2, T3> Queryable<T, T2, T3>(ISugarQueryable<T> joinQueryable1, ISugarQueryable<T2> joinQueryable2, ISugarQueryable<T3> joinQueryable3, JoinType joinType1, Expression<Func<T, T2, T3, bool>> joinExpression1, JoinType joinType2, Expression<Func<T, T2, T3, bool>> joinExpression2)
|
|
where T : class, new()
|
|
where T2 : class, new()
|
|
where T3 : class, new()
|
|
{
|
|
return ScopedContext.Queryable(joinQueryable1, joinQueryable2, joinQueryable3,joinType1,joinExpression1,joinType2,joinExpression2);
|
|
}
|
|
|
|
public ISugarQueryable<T> Queryable<T>()
|
|
{
|
|
return ScopedContext.Queryable<T>();
|
|
}
|
|
|
|
public ISugarQueryable<T> Queryable<T>(ISugarQueryable<T> queryable) where T : class, new()
|
|
{
|
|
return ScopedContext.Queryable(queryable);
|
|
}
|
|
|
|
public ISugarQueryable<T> Queryable<T>(string shortName)
|
|
{
|
|
return ScopedContext.Queryable<T>(shortName);
|
|
}
|
|
|
|
public IReportable<T> Reportable<T>(T data)
|
|
{
|
|
return ScopedContext.Reportable(data);
|
|
}
|
|
|
|
public IReportable<T> Reportable<T>(List<T> list)
|
|
{
|
|
return ScopedContext.Reportable(list);
|
|
}
|
|
|
|
public IReportable<T> Reportable<T>(T[] array)
|
|
{
|
|
return ScopedContext.Reportable(array);
|
|
}
|
|
|
|
public void RollbackTran()
|
|
{
|
|
ScopedContext.RollbackTran();
|
|
}
|
|
|
|
public ISaveable<T> Saveable<T>(List<T> saveObjects) where T : class, new()
|
|
{
|
|
return ScopedContext.Saveable(saveObjects);
|
|
}
|
|
|
|
public ISaveable<T> Saveable<T>(T saveObject) where T : class, new()
|
|
{
|
|
return ScopedContext.Saveable(saveObject);
|
|
}
|
|
|
|
public int SaveQueues(bool isTran = true)
|
|
{
|
|
return ScopedContext.SaveQueues(isTran);
|
|
}
|
|
|
|
public Tuple<List<T>, List<T2>, List<T3>, List<T4>, List<T5>, List<T6>, List<T7>> SaveQueues<T, T2, T3, T4, T5, T6, T7>(bool isTran = true)
|
|
{
|
|
return ScopedContext.SaveQueues<T, T2, T3, T4, T5, T6, T7>(isTran);
|
|
}
|
|
|
|
public Tuple<List<T>, List<T2>, List<T3>, List<T4>, List<T5>, List<T6>> SaveQueues<T, T2, T3, T4, T5, T6>(bool isTran = true)
|
|
{
|
|
return ScopedContext.SaveQueues<T, T2, T3, T4, T5, T6>(isTran);
|
|
}
|
|
|
|
public Tuple<List<T>, List<T2>, List<T3>, List<T4>, List<T5>> SaveQueues<T, T2, T3, T4, T5>(bool isTran = true)
|
|
{
|
|
return ScopedContext.SaveQueues<T, T2, T3, T4, T5>(isTran);
|
|
}
|
|
|
|
public Tuple<List<T>, List<T2>, List<T3>, List<T4>> SaveQueues<T, T2, T3, T4>(bool isTran = true)
|
|
{
|
|
return ScopedContext.SaveQueues<T, T2, T3, T4>(isTran);
|
|
}
|
|
|
|
public Tuple<List<T>, List<T2>, List<T3>> SaveQueues<T, T2, T3>(bool isTran = true)
|
|
{
|
|
return ScopedContext.SaveQueues<T, T2, T3>(isTran);
|
|
}
|
|
|
|
public Tuple<List<T>, List<T2>> SaveQueues<T, T2>(bool isTran = true)
|
|
{
|
|
return ScopedContext.SaveQueues<T, T2>(isTran);
|
|
}
|
|
|
|
public List<T> SaveQueues<T>(bool isTran = true)
|
|
{
|
|
return ScopedContext.SaveQueues<T>(isTran);
|
|
}
|
|
|
|
public Task<int> SaveQueuesAsync(bool isTran = true)
|
|
{
|
|
return ScopedContext.SaveQueuesAsync(isTran);
|
|
}
|
|
|
|
public Task<Tuple<List<T>, List<T2>, List<T3>, List<T4>, List<T5>, List<T6>, List<T7>>> SaveQueuesAsync<T, T2, T3, T4, T5, T6, T7>(bool isTran = true)
|
|
{
|
|
return ScopedContext.SaveQueuesAsync<T, T2, T3, T4, T5, T6, T7>(isTran);
|
|
}
|
|
|
|
public Task<Tuple<List<T>, List<T2>, List<T3>, List<T4>, List<T5>, List<T6>>> SaveQueuesAsync<T, T2, T3, T4, T5, T6>(bool isTran = true)
|
|
{
|
|
return ScopedContext.SaveQueuesAsync<T, T2, T3, T4, T5, T6>(isTran);
|
|
}
|
|
|
|
public Task<Tuple<List<T>, List<T2>, List<T3>, List<T4>, List<T5>>> SaveQueuesAsync<T, T2, T3, T4, T5>(bool isTran = true)
|
|
{
|
|
return ScopedContext.SaveQueuesAsync<T, T2, T3, T4, T5>(isTran);
|
|
}
|
|
|
|
public Task<Tuple<List<T>, List<T2>, List<T3>, List<T4>>> SaveQueuesAsync<T, T2, T3, T4>(bool isTran = true)
|
|
{
|
|
return ScopedContext.SaveQueuesAsync<T, T2, T3, T4>(isTran);
|
|
}
|
|
|
|
public Task<Tuple<List<T>, List<T2>, List<T3>>> SaveQueuesAsync<T, T2, T3>(bool isTran = true)
|
|
{
|
|
return ScopedContext.SaveQueuesAsync<T, T2, T3>(isTran);
|
|
}
|
|
|
|
public Task<Tuple<List<T>, List<T2>>> SaveQueuesAsync<T, T2>(bool isTran = true)
|
|
{
|
|
return ScopedContext.SaveQueuesAsync<T, T2>(isTran);
|
|
}
|
|
|
|
public Task<List<T>> SaveQueuesAsync<T>(bool isTran = true)
|
|
{
|
|
return ScopedContext.SaveQueuesAsync<T>(isTran);
|
|
}
|
|
|
|
public ISugarQueryable<T> SqlQueryable<T>(string sql) where T : class, new()
|
|
{
|
|
return ScopedContext.SqlQueryable<T>(sql);
|
|
}
|
|
|
|
public IStorageable<T> Storageable<T>(List<T> dataList) where T : class, new()
|
|
{
|
|
return ScopedContext.Storageable(dataList);
|
|
}
|
|
|
|
public IStorageable<T> Storageable<T>(T data) where T : class, new()
|
|
{
|
|
return ScopedContext.Storageable(data);
|
|
}
|
|
|
|
public ISugarQueryable<T> Union<T>(List<ISugarQueryable<T>> queryables) where T : class, new()
|
|
{
|
|
return ScopedContext.Union(queryables);
|
|
}
|
|
|
|
public ISugarQueryable<T> Union<T>(params ISugarQueryable<T>[] queryables) where T : class, new()
|
|
{
|
|
return ScopedContext.Union(queryables);
|
|
}
|
|
|
|
public ISugarQueryable<T> UnionAll<T>(List<ISugarQueryable<T>> queryables) where T : class, new()
|
|
{
|
|
return ScopedContext.UnionAll(queryables);
|
|
}
|
|
|
|
public ISugarQueryable<T> UnionAll<T>(params ISugarQueryable<T>[] queryables) where T : class, new()
|
|
{
|
|
return ScopedContext.UnionAll(queryables);
|
|
}
|
|
|
|
public IUpdateable<T> Updateable<T>() where T : class, new()
|
|
{
|
|
return ScopedContext.Updateable<T>();
|
|
}
|
|
|
|
public IUpdateable<T> Updateable<T>(Dictionary<string, object> columnDictionary) where T : class, new()
|
|
{
|
|
return ScopedContext.Updateable<T>(columnDictionary);
|
|
}
|
|
|
|
public IUpdateable<T> Updateable<T>(dynamic updateDynamicObject) where T : class, new()
|
|
{
|
|
return ScopedContext.Updateable<T>((object)updateDynamicObject);
|
|
}
|
|
|
|
public IUpdateable<T> Updateable<T>(Expression<Func<T, bool>> columns) where T : class, new()
|
|
{
|
|
return ScopedContext.Updateable(columns);
|
|
}
|
|
|
|
public IUpdateable<T> Updateable<T>(Expression<Func<T, T>> columns) where T : class, new()
|
|
{
|
|
return ScopedContext.Updateable(columns);
|
|
}
|
|
|
|
public IUpdateable<T> Updateable<T>(List<T> UpdateObjs) where T : class, new()
|
|
{
|
|
return ScopedContext.Updateable(UpdateObjs);
|
|
}
|
|
|
|
public IUpdateable<T> Updateable<T>(T UpdateObj) where T : class, new()
|
|
{
|
|
return ScopedContext.Updateable(UpdateObj);
|
|
}
|
|
|
|
public IUpdateable<T> Updateable<T>(T[] UpdateObjs) where T : class, new()
|
|
{
|
|
return ScopedContext.Updateable(UpdateObjs);
|
|
}
|
|
public SplitTableContext SplitHelper<T>() where T : class, new()
|
|
{
|
|
return ScopedContext.SplitHelper<T>();
|
|
}
|
|
public SplitTableContextResult<T> SplitHelper<T>(T data) where T : class, new()
|
|
{
|
|
return ScopedContext.SplitHelper(data);
|
|
}
|
|
public SplitTableContextResult<T> SplitHelper<T>(List<T> dataList) where T : class, new()
|
|
{
|
|
return ScopedContext.SplitHelper(dataList);
|
|
}
|
|
public SqlSugarTransaction UseTran()
|
|
{
|
|
return ScopedContext.UseTran();
|
|
}
|
|
public DbResult<bool> UseTran(Action action, Action<Exception> errorCallBack = null)
|
|
{
|
|
return ScopedContext.UseTran(action,errorCallBack);
|
|
}
|
|
|
|
public DbResult<T> UseTran<T>(Func<T> action, Action<Exception> errorCallBack = null)
|
|
{
|
|
return ScopedContext.UseTran(action,errorCallBack);
|
|
}
|
|
|
|
public Task<DbResult<bool>> UseTranAsync(Func<Task> action, Action<Exception> errorCallBack = null)
|
|
{
|
|
return ScopedContext.UseTranAsync(action, errorCallBack);
|
|
}
|
|
|
|
public Task<DbResult<T>> UseTranAsync<T>(Func<Task<T>> action, Action<Exception> errorCallBack = null)
|
|
{
|
|
return ScopedContext.UseTranAsync(action, errorCallBack);
|
|
}
|
|
|
|
public bool IsAnyConnection(dynamic configId)
|
|
{
|
|
return ScopedContext.IsAnyConnection(configId);
|
|
}
|
|
|
|
public IFastest<T> Fastest<T>() where T : class, new()
|
|
{
|
|
return ScopedContext.Fastest<T>();
|
|
}
|
|
private SqlSugarClient GetContext()
|
|
{
|
|
SqlSugarClient result = null;
|
|
var key = _configs.GetHashCode().ToString();
|
|
StackTrace st = new StackTrace(true);
|
|
var methods = st.GetFrames();
|
|
var isAsync = UtilMethods.IsAnyAsyncMethod(methods);
|
|
if (isAsync)
|
|
{
|
|
result = GetAsyncContext(key);
|
|
}
|
|
else
|
|
{
|
|
result = GetThreadContext(key);
|
|
}
|
|
return result;
|
|
}
|
|
|
|
private SqlSugarClient GetAsyncContext(string key)
|
|
{
|
|
SqlSugarClient result = CallContextAsync<SqlSugarClient>.GetData(key);
|
|
if (result == null)
|
|
{
|
|
CallContextAsync<SqlSugarClient>.SetData(key, new SqlSugarClient(_configs));
|
|
result = CallContextAsync<SqlSugarClient>.GetData(key);
|
|
if (this._configAction != null)
|
|
{
|
|
this._configAction(result);
|
|
}
|
|
}
|
|
|
|
return result;
|
|
}
|
|
|
|
private SqlSugarClient GetThreadContext(string key)
|
|
{
|
|
SqlSugarClient result = CallContextThread<SqlSugarClient>.GetData(key);
|
|
if (result == null)
|
|
{
|
|
CallContextThread<SqlSugarClient>.SetData(key, new SqlSugarClient(_configs));
|
|
result = CallContextThread<SqlSugarClient>.GetData(key);
|
|
if (this._configAction != null)
|
|
{
|
|
this._configAction(result);
|
|
}
|
|
}
|
|
return result;
|
|
}
|
|
}
|
|
}
|