mirror of
https://gitee.com/dotnetchina/SqlSugar.git
synced 2025-04-24 18:04:52 +08:00
1536 lines
58 KiB
C#
1536 lines
58 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.Data;
|
||
using System.Diagnostics;
|
||
using System.Dynamic;
|
||
using System.Linq;
|
||
using System.Linq.Expressions;
|
||
using System.Reflection;
|
||
using System.Text;
|
||
using System.Threading;
|
||
using System.Threading.Tasks;
|
||
|
||
namespace SqlSugar
|
||
{
|
||
public partial class SqlSugarClient : ISqlSugarClient, ITenant
|
||
{
|
||
#region Gobal Property
|
||
private SqlSugarProvider _Context = null;
|
||
private string _ThreadId;
|
||
private ConnectionConfig _CurrentConnectionConfig;
|
||
private List<SugarTenant> _AllClients;
|
||
private bool _IsAllTran = false;
|
||
private bool _IsOpen = false;
|
||
private MappingTableList _MappingTables;
|
||
private MappingColumnList _MappingColumns;
|
||
private IgnoreColumnList _IgnoreColumns;
|
||
private IgnoreColumnList _IgnoreInsertColumns;
|
||
|
||
|
||
internal Guid? AsyncId { get; set; }
|
||
internal bool? IsSingleInstance { get; set; }
|
||
|
||
#endregion
|
||
|
||
#region Constructor
|
||
public SqlSugarClient(ConnectionConfig config)
|
||
{
|
||
Check.Exception(config == null, "ConnectionConfig config is null");
|
||
InitContext(config);
|
||
}
|
||
|
||
public SqlSugarClient(List<ConnectionConfig> configs)
|
||
{
|
||
Check.Exception(configs.IsNullOrEmpty(), "List<ConnectionConfig> configs is null or count=0");
|
||
InitConfigs(configs);
|
||
var config = configs.First();
|
||
InitContext(config);
|
||
_AllClients = configs.Select(it => new SugarTenant() { ConnectionConfig = it }).ToList(); ;
|
||
_AllClients.First(it => it.ConnectionConfig.ConfigId == config.ConfigId).Context = this.Context;
|
||
}
|
||
public SqlSugarClient(ConnectionConfig config ,Action<SqlSugarClient> configAction)
|
||
{
|
||
Check.Exception(config == null, "ConnectionConfig config is null");
|
||
InitContext(config);
|
||
configAction(this);
|
||
}
|
||
|
||
public SqlSugarClient(List<ConnectionConfig> configs, Action<SqlSugarClient> configAction)
|
||
{
|
||
Check.Exception(configs.IsNullOrEmpty(), "List<ConnectionConfig> configs is null or count=0");
|
||
InitConfigs(configs);
|
||
var config = configs.First();
|
||
InitContext(config);
|
||
_AllClients = configs.Select(it => new SugarTenant() { ConnectionConfig = it }).ToList(); ;
|
||
_AllClients.First(it => it.ConnectionConfig.ConfigId == config.ConfigId).Context = this.Context;
|
||
configAction(this);
|
||
}
|
||
#endregion
|
||
|
||
#region Global variable
|
||
public SugarActionType SugarActionType { get { return this.Context.SugarActionType; }set { this.Context.SugarActionType = value; } }
|
||
public SqlSugarProvider Context { get { return GetContext(); } }
|
||
public bool IsSystemTablesConfig => this.Context.IsSystemTablesConfig;
|
||
public ConnectionConfig CurrentConnectionConfig { get { return _CurrentConnectionConfig; } set { _CurrentConnectionConfig = value; } }
|
||
public Guid ContextID { get { return this.Context.ContextID; } set { this.Context.ContextID = value; } }
|
||
public ConfigQuery ConfigQuery { get { return this.Context.ConfigQuery; } set { this.Context.ConfigQuery = value; } }
|
||
|
||
public MappingTableList MappingTables { get { return _MappingTables; } set { _MappingTables = value; } }
|
||
public MappingColumnList MappingColumns { get { return _MappingColumns; } set { _MappingColumns = value; } }
|
||
public IgnoreColumnList IgnoreColumns { get { return _IgnoreColumns; } set { _IgnoreColumns = value; } }
|
||
public IgnoreColumnList IgnoreInsertColumns { get { return _IgnoreInsertColumns; } set { _IgnoreInsertColumns = value; } }
|
||
public Dictionary<string, object> TempItems { get { return this.Context.TempItems; } set { this.Context.TempItems = value; } }
|
||
#endregion
|
||
|
||
#region SimpleClient
|
||
|
||
public T CreateContext<T>(bool isTran=true) where T : SugarUnitOfWork, new()
|
||
{
|
||
T result = new T();
|
||
_CreateContext(isTran, result);
|
||
var type = typeof(T);
|
||
var ps = type.GetProperties();
|
||
var cacheKey = "SugarUnitOfWork" + typeof(T).FullName + typeof(T).GetHashCode();
|
||
var properies = new ReflectionInoCacheService().GetOrCreate(cacheKey,
|
||
() =>
|
||
ps.Where(it =>
|
||
|
||
(it.PropertyType.BaseType != null && it.PropertyType.BaseType.Name.StartsWith("SimpleClient`"))
|
||
||
|
||
it.PropertyType.Name.StartsWith("SimpleClient`")
|
||
|
||
));
|
||
foreach (var item in properies)
|
||
{
|
||
var value = Activator.CreateInstance(item.PropertyType);
|
||
TenantAttribute tenantAttribute = item.PropertyType.GetGenericArguments()[0].GetCustomAttribute<TenantAttribute>();
|
||
if (tenantAttribute == null)
|
||
{
|
||
value.GetType().GetProperty("Context").SetValue(value, this);
|
||
}
|
||
else
|
||
{
|
||
value.GetType().GetProperty("Context").SetValue(value, this.GetConnection(tenantAttribute.configId));
|
||
}
|
||
item.SetValue(result, value);
|
||
}
|
||
return result;
|
||
}
|
||
public SugarUnitOfWork CreateContext(bool isTran = true)
|
||
{
|
||
SugarUnitOfWork sugarUnitOf = new SugarUnitOfWork();
|
||
return _CreateContext(isTran, sugarUnitOf);
|
||
}
|
||
|
||
private SugarUnitOfWork _CreateContext(bool isTran, SugarUnitOfWork sugarUnitOf)
|
||
{
|
||
sugarUnitOf.Db = this;
|
||
sugarUnitOf.Tenant = this;
|
||
sugarUnitOf.IsTran = isTran;
|
||
this.Open();
|
||
if (isTran)
|
||
this.BeginTran();
|
||
return sugarUnitOf;
|
||
}
|
||
public SimpleClient<T> GetSimpleClient<T>() where T : class, new()
|
||
{
|
||
return this.Context.GetSimpleClient<T>();
|
||
}
|
||
public RepositoryType GetRepository<RepositoryType>() where RepositoryType : ISugarRepository , new()
|
||
{
|
||
Type type = typeof(RepositoryType);
|
||
var isAnyParamter = type.GetConstructors().Any(z => z.GetParameters().Any());
|
||
object o = null;
|
||
if (isAnyParamter)
|
||
{
|
||
o = Activator.CreateInstance(type, new string[] { null });
|
||
}
|
||
else
|
||
{
|
||
o = Activator.CreateInstance(type);
|
||
}
|
||
var result = (RepositoryType)o;
|
||
if (result.Context == null)
|
||
{
|
||
result.Context = this.Context;
|
||
}
|
||
return result;
|
||
}
|
||
#endregion
|
||
|
||
#region Insertable
|
||
public IInsertable<Dictionary<string, object>> InsertableByDynamic(object insertDynamicObject)
|
||
{
|
||
return this.Context.InsertableByDynamic(insertDynamicObject);
|
||
}
|
||
public InsertMethodInfo InsertableByObject(object singleEntityObjectOrListObject)
|
||
{
|
||
return this.Context.InsertableByObject(singleEntityObjectOrListObject);
|
||
}
|
||
public IInsertable<T> Insertable<T>(Dictionary<string, object> columnDictionary) where T : class, new()
|
||
{
|
||
return this.Context.Insertable<T>(columnDictionary);
|
||
}
|
||
|
||
public IInsertable<T> Insertable<T>(dynamic insertDynamicObject) where T : class, new()
|
||
{
|
||
return this.Context.Insertable<T>(insertDynamicObject);
|
||
}
|
||
|
||
public IInsertable<T> Insertable<T>(List<T> insertObjs) where T : class, new()
|
||
{
|
||
return this.Context.Insertable<T>(insertObjs);
|
||
}
|
||
|
||
public IInsertable<T> Insertable<T>(T insertObj) where T : class, new()
|
||
{
|
||
Check.Exception(typeof(T).FullName.Contains("System.Collections.Generic.List`"), " need where T: class, new() ");
|
||
if (typeof(T).Name == "Object")
|
||
{
|
||
Check.ExceptionEasy("Object type use db.InsertableByObject(obj).ExecuteCommand()", "检测到T为Object类型，请使用 db.InsertableByObject(obj).ExecuteCommand()，Insertable不支持object，InsertableByObject可以(缺点：功能比较少)");
|
||
}
|
||
return this.Context.Insertable<T>(insertObj);
|
||
}
|
||
|
||
public IInsertable<T> Insertable<T>(T[] insertObjs) where T : class, new()
|
||
{
|
||
return this.Context.Insertable<T>(insertObjs);
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region Queryable
|
||
|
||
#region Nav CUD
|
||
public InsertNavTaskInit<T,T> InsertNav<T>(T data) where T : class, new()
|
||
{
|
||
return this.Context.InsertNav(data);
|
||
}
|
||
public InsertNavTaskInit<T, T> InsertNav<T>(List<T> datas) where T : class, new()
|
||
{
|
||
return this.Context.InsertNav(datas);
|
||
}
|
||
public InsertNavTaskInit<T, T> InsertNav<T>(T data, InsertNavRootOptions rootOptions) where T : class, new()
|
||
{
|
||
return this.Context.InsertNav(data, rootOptions);
|
||
}
|
||
public InsertNavTaskInit<T, T> InsertNav<T>(List<T> datas, InsertNavRootOptions rootOptions) where T : class, new()
|
||
{
|
||
return this.Context.InsertNav(datas, rootOptions);
|
||
}
|
||
public DeleteNavTaskInit<T, T> DeleteNav<T>(T data) where T : class, new()
|
||
{
|
||
return this.Context.DeleteNav(data);
|
||
}
|
||
public DeleteNavTaskInit<T, T> DeleteNav<T>(List<T> datas) where T : class, new()
|
||
{
|
||
return this.Context.DeleteNav(datas);
|
||
}
|
||
public DeleteNavTaskInit<T, T> DeleteNav<T>(Expression<Func<T, bool>> whereExpression) where T : class, new()
|
||
{
|
||
return this.Context.DeleteNav(whereExpression);
|
||
}
|
||
|
||
public DeleteNavTaskInit<T, T> DeleteNav<T>(T data, DeleteNavRootOptions options) where T : class, new()
|
||
{
|
||
return this.Context.DeleteNav(data, options);
|
||
}
|
||
public DeleteNavTaskInit<T, T> DeleteNav<T>(List<T> datas, DeleteNavRootOptions options) where T : class, new()
|
||
{
|
||
return this.Context.DeleteNav(datas, options);
|
||
}
|
||
public DeleteNavTaskInit<T, T> DeleteNav<T>(Expression<Func<T, bool>> whereExpression, DeleteNavRootOptions options) where T : class, new()
|
||
{
|
||
return this.Context.DeleteNav(whereExpression, options);
|
||
}
|
||
|
||
public UpdateNavTaskInit<T, T> UpdateNav<T>(T data) where T : class, new()
|
||
{
|
||
return this.Context.UpdateNav(data);
|
||
}
|
||
public UpdateNavTaskInit<T, T> UpdateNav<T>(List<T> datas,UpdateNavRootOptions rootOptions) where T : class, new()
|
||
{
|
||
return this.Context.UpdateNav(datas, rootOptions);
|
||
}
|
||
public UpdateNavTaskInit<T, T> UpdateNav<T>(T data, UpdateNavRootOptions rootOptions) where T : class, new()
|
||
{
|
||
return this.Context.UpdateNav(data,rootOptions);
|
||
}
|
||
public UpdateNavTaskInit<T, T> UpdateNav<T>(List<T> datas) where T : class, new()
|
||
{
|
||
return this.Context.UpdateNav(datas);
|
||
}
|
||
#endregion
|
||
|
||
#region Union
|
||
public ISugarQueryable<T> Union<T>(List<ISugarQueryable<T>> queryables) where T : class, new()
|
||
{
|
||
return this.Context.Union(queryables);
|
||
}
|
||
|
||
public ISugarQueryable<T> Union<T>(params ISugarQueryable<T>[] queryables) where T : class, new()
|
||
{
|
||
return this.Context.Union(queryables);
|
||
}
|
||
|
||
public ISugarQueryable<T> UnionAll<T>(List<ISugarQueryable<T>> queryables) where T : class, new()
|
||
{
|
||
return this.Context.UnionAll(queryables);
|
||
}
|
||
|
||
public ISugarQueryable<T> UnionAll<T>(params ISugarQueryable<T>[] queryables) where T : class, new()
|
||
{
|
||
return this.Context.UnionAll(queryables);
|
||
}
|
||
#endregion
|
||
|
||
public ISugarQueryable<T> MasterQueryable<T>()
|
||
{
|
||
return this.Context.MasterQueryable<T>();
|
||
}
|
||
public ISugarQueryable<T> SlaveQueryable<T>()
|
||
{
|
||
return this.Context.SlaveQueryable<T>();
|
||
}
|
||
public ISugarQueryable<T> SqlQueryable<T>(string sql) where T : class, new()
|
||
{
|
||
return this.Context.SqlQueryable<T>(sql);
|
||
}
|
||
public ISugarQueryable<ExpandoObject> Queryable(string tableName, string shortName)
|
||
{
|
||
return this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.Queryable(joinExpression);
|
||
}
|
||
|
||
public ISugarQueryable<T, T2, T3, T4> Queryable<T, T2, T3, T4>(Expression<Func<T, T2, T3, T4, JoinQueryInfos>> joinExpression)
|
||
{
|
||
return this.Context.Queryable(joinExpression);
|
||
}
|
||
|
||
public ISugarQueryable<T, T2, T3, T4> Queryable<T, T2, T3, T4>(Expression<Func<T, T2, T3, T4, object[]>> joinExpression)
|
||
{
|
||
return this.Context.Queryable(joinExpression);
|
||
}
|
||
|
||
public ISugarQueryable<T, T2, T3> Queryable<T, T2, T3>(Expression<Func<T, T2, T3, bool>> joinExpression) where T : class, new()
|
||
{
|
||
return this.Context.Queryable(joinExpression);
|
||
}
|
||
|
||
public ISugarQueryable<T, T2, T3> Queryable<T, T2, T3>(Expression<Func<T, T2, T3, JoinQueryInfos>> joinExpression)
|
||
{
|
||
return this.Context.Queryable(joinExpression);
|
||
}
|
||
|
||
public ISugarQueryable<T, T2, T3> Queryable<T, T2, T3>(Expression<Func<T, T2, T3, object[]>> joinExpression)
|
||
{
|
||
return this.Context.Queryable(joinExpression);
|
||
}
|
||
|
||
public ISugarQueryable<T, T2> Queryable<T, T2>(Expression<Func<T, T2, bool>> joinExpression) where T : class, new()
|
||
{
|
||
return this.Context.Queryable(joinExpression);
|
||
}
|
||
|
||
public ISugarQueryable<T, T2> Queryable<T, T2>(Expression<Func<T, T2, JoinQueryInfos>> joinExpression)
|
||
{
|
||
return this.Context.Queryable(joinExpression);
|
||
}
|
||
|
||
public ISugarQueryable<T, T2> Queryable<T, T2>(Expression<Func<T, T2, object[]>> joinExpression)
|
||
{
|
||
return this.Context.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 this.Context.Queryable(joinQueryable1, joinQueryable2, joinExpression).With(SqlWith.Null);
|
||
}
|
||
|
||
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 this.Context.Queryable(joinQueryable1, joinQueryable2, joinType, joinExpression).With(SqlWith.Null);
|
||
}
|
||
|
||
|
||
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 this.Context.Queryable(joinQueryable1, joinQueryable2, joinQueryable3, joinType1, joinExpression1, joinType2, joinExpression2).With(SqlWith.Null);
|
||
}
|
||
public ISugarQueryable<T, T2, T3,T4> Queryable<T, T2, T3, T4>(ISugarQueryable<T> joinQueryable1, ISugarQueryable<T2> joinQueryable2, ISugarQueryable<T3> joinQueryable3, ISugarQueryable<T4> joinQueryable4,
|
||
JoinType joinType1, Expression<Func<T, T2, T3,T4, bool>> joinExpression1,
|
||
JoinType joinType2, Expression<Func<T, T2, T3, T4, bool>> joinExpression2,
|
||
JoinType joinType3, Expression<Func<T, T2, T3, T4, bool>> joinExpression3)
|
||
where T : class, new()
|
||
where T2 : class, new()
|
||
where T3 : class, new()
|
||
where T4 : class ,new ()
|
||
{
|
||
return this.Context.Queryable(joinQueryable1, joinQueryable2, joinQueryable3, joinQueryable4, joinType1, joinExpression1, joinType2, joinExpression2,joinType3, joinExpression3).With(SqlWith.Null);
|
||
}
|
||
|
||
public ISugarQueryable<T> Queryable<T>()
|
||
{
|
||
return this.Context.Queryable<T>();
|
||
}
|
||
|
||
public ISugarQueryable<T> Queryable<T>(ISugarQueryable<T> queryable)
|
||
{
|
||
|
||
var result= this.Context.Queryable<T>(queryable);
|
||
var QueryBuilder = queryable.QueryBuilder;
|
||
result.QueryBuilder.IsQueryInQuery = true;
|
||
var appendIndex = result.QueryBuilder.Parameters==null?1:result.QueryBuilder.Parameters.Count+1;
|
||
result.QueryBuilder.WhereIndex = (QueryBuilder.WhereIndex+1);
|
||
result.QueryBuilder.LambdaExpressions.ParameterIndex = (QueryBuilder.LambdaExpressions.ParameterIndex+ appendIndex);
|
||
return result;
|
||
}
|
||
|
||
public ISugarQueryable<T> Queryable<T>(string shortName)
|
||
{
|
||
return this.Context.Queryable<T>(shortName);
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region Saveable
|
||
public StorageableDataTable Storageable(DataTable data)
|
||
{
|
||
return this.Context.Storageable(data);
|
||
}
|
||
public StorageableDataTable Storageable(List<Dictionary<string,object>> dictionaryList,string tableName)
|
||
{
|
||
DataTable dt = this.Context.Utilities.DictionaryListToDataTable(dictionaryList);
|
||
dt.TableName = tableName;
|
||
return this.Context.Storageable(dt);
|
||
}
|
||
public StorageableDataTable Storageable(Dictionary<string, object> dictionary, string tableName)
|
||
{
|
||
DataTable dt = this.Context.Utilities.DictionaryListToDataTable(new List<Dictionary<string, object>>() { dictionary });
|
||
dt.TableName = tableName;
|
||
return this.Context.Storageable(dt);
|
||
}
|
||
|
||
public IStorageable<T> Storageable<T>(List<T> dataList) where T : class, new()
|
||
{
|
||
return this.Context.Storageable(dataList);
|
||
}
|
||
public IStorageable<T> Storageable<T>(T data) where T : class, new()
|
||
{
|
||
Check.Exception(typeof(T).FullName.Contains("System.Collections.Generic.List`"), " need where T: class, new() ");
|
||
return this.Context.Storageable(new List<T> { data});
|
||
}
|
||
|
||
[Obsolete("use Storageable")]
|
||
public ISaveable<T> Saveable<T>(List<T> saveObjects) where T : class, new()
|
||
{
|
||
return this.Context.Saveable<T>(saveObjects);
|
||
}
|
||
[Obsolete("use Storageable")]
|
||
public ISaveable<T> Saveable<T>(T saveObject) where T : class, new()
|
||
{
|
||
return this.Context.Saveable(saveObject);
|
||
}
|
||
public StorageableMethodInfo StorageableByObject(object singleEntityObjectOrListObject)
|
||
{
|
||
return this.Context.StorageableByObject(singleEntityObjectOrListObject);
|
||
}
|
||
#endregion
|
||
|
||
#region Reportable
|
||
public IReportable<T> Reportable<T>(T data)
|
||
{
|
||
return this.Context.Reportable(data);
|
||
}
|
||
public IReportable<T> Reportable<T>(List<T> list)
|
||
{
|
||
return this.Context.Reportable(list);
|
||
}
|
||
public IReportable<T> Reportable<T>(T [] array)
|
||
{
|
||
return this.Context.Reportable(array);
|
||
}
|
||
#endregion
|
||
|
||
#region Queue
|
||
public QueueList Queues { get { return this.Context.Queues; } set { this.Context.Queues = value; } }
|
||
public void AddQueue(string sql, object parsmeters = null)
|
||
{
|
||
this.Context.AddQueue(sql, parsmeters);
|
||
}
|
||
|
||
public void AddQueue(string sql, List<SugarParameter> parsmeters)
|
||
{
|
||
this.Context.AddQueue(sql, parsmeters);
|
||
}
|
||
|
||
public void AddQueue(string sql, SugarParameter parsmeter)
|
||
{
|
||
this.Context.AddQueue(sql, parsmeter);
|
||
}
|
||
public int SaveQueues(bool isTran = true)
|
||
{
|
||
return this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.SaveQueues<T, T2, T3, T4>(isTran);
|
||
}
|
||
|
||
public Tuple<List<T>, List<T2>, List<T3>> SaveQueues<T, T2, T3>(bool isTran = true)
|
||
{
|
||
return this.Context.SaveQueues<T, T2, T3>(isTran);
|
||
}
|
||
|
||
public Tuple<List<T>, List<T2>> SaveQueues<T, T2>(bool isTran = true)
|
||
{
|
||
return this.Context.SaveQueues<T, T2>(isTran);
|
||
}
|
||
|
||
public List<T> SaveQueues<T>(bool isTran = true)
|
||
{
|
||
return this.Context.SaveQueues<T>(isTran);
|
||
}
|
||
|
||
public Task<int> SaveQueuesAsync(bool isTran = true)
|
||
{
|
||
return this.Context.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 this.Context.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 this.Context.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 this.Context.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 this.Context.SaveQueuesAsync<T, T2, T3, T4>(isTran);
|
||
}
|
||
|
||
public Task<Tuple<List<T>, List<T2>, List<T3>>> SaveQueuesAsync<T, T2, T3>(bool isTran = true)
|
||
{
|
||
return this.Context.SaveQueuesAsync<T, T2, T3>(isTran);
|
||
}
|
||
|
||
public Task<Tuple<List<T>, List<T2>>> SaveQueuesAsync<T, T2>(bool isTran = true)
|
||
{
|
||
return this.Context.SaveQueuesAsync<T, T2>(isTran);
|
||
}
|
||
|
||
public Task<List<T>> SaveQueuesAsync<T>(bool isTran = true)
|
||
{
|
||
return this.Context.SaveQueuesAsync<T>(isTran);
|
||
}
|
||
#endregion
|
||
|
||
#region Updateable
|
||
public IUpdateable<Dictionary<string, object>> UpdateableByDynamic(object updateDynamicObject)
|
||
{
|
||
return this.Context.UpdateableByDynamic(updateDynamicObject);
|
||
}
|
||
public UpdateMethodInfo UpdateableByObject(object singleEntityObjectOrListObject)
|
||
{
|
||
return this.Context.UpdateableByObject(singleEntityObjectOrListObject);
|
||
}
|
||
public IUpdateable<T> Updateable<T>() where T : class, new()
|
||
{
|
||
return this.Context.Updateable<T>();
|
||
}
|
||
|
||
public IUpdateable<T> Updateable<T>(Dictionary<string, object> columnDictionary) where T : class, new()
|
||
{
|
||
return this.Context.Updateable<T>(columnDictionary);
|
||
}
|
||
|
||
public IUpdateable<T> Updateable<T>(dynamic updateDynamicObject) where T : class, new()
|
||
{
|
||
return this.Context.Updateable<T>(updateDynamicObject);
|
||
}
|
||
|
||
public IUpdateable<T> Updateable<T>(Expression<Func<T, bool>> columns) where T : class, new()
|
||
{
|
||
return this.Context.Updateable<T>(columns);
|
||
}
|
||
|
||
public IUpdateable<T> Updateable<T>(Expression<Func<T, T>> columns) where T : class, new()
|
||
{
|
||
return this.Context.Updateable<T>(columns);
|
||
}
|
||
|
||
public IUpdateable<T> Updateable<T>(List<T> UpdateObjs) where T : class, new()
|
||
{
|
||
return this.Context.Updateable<T>(UpdateObjs);
|
||
}
|
||
|
||
public IUpdateable<T> Updateable<T>(T UpdateObj) where T : class, new()
|
||
{
|
||
return this.Context.Updateable<T>(UpdateObj);
|
||
}
|
||
|
||
public IUpdateable<T> Updateable<T>(T[] UpdateObjs) where T : class, new()
|
||
{
|
||
return this.Context.Updateable<T>(UpdateObjs);
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region Ado
|
||
public IAdo Ado => this.Context.Ado;
|
||
|
||
#endregion
|
||
|
||
#region Deleteable
|
||
public DeleteMethodInfo DeleteableByObject(object singleEntityObjectOrListObject)
|
||
{
|
||
return this.Context.DeleteableByObject(singleEntityObjectOrListObject);
|
||
}
|
||
public IDeleteable<T> Deleteable<T>() where T : class, new()
|
||
{
|
||
return this.Context.Deleteable<T>();
|
||
}
|
||
|
||
public IDeleteable<T> Deleteable<T>(dynamic primaryKeyValue) where T : class, new()
|
||
{
|
||
return this.Context.Deleteable<T>(primaryKeyValue);
|
||
}
|
||
|
||
public IDeleteable<T> Deleteable<T>(dynamic[] primaryKeyValues) where T : class, new()
|
||
{
|
||
return this.Context.Deleteable<T>(primaryKeyValues);
|
||
}
|
||
|
||
public IDeleteable<T> Deleteable<T>(Expression<Func<T, bool>> expression) where T : class, new()
|
||
{
|
||
return this.Context.Deleteable(expression);
|
||
}
|
||
|
||
public IDeleteable<T> Deleteable<T>(List<dynamic> pkValue) where T : class, new()
|
||
{
|
||
return this.Context.Deleteable<T>(pkValue);
|
||
}
|
||
|
||
public IDeleteable<T> Deleteable<T>(List<T> deleteObjs) where T : class, new()
|
||
{
|
||
return this.Context.Deleteable<T>(deleteObjs);
|
||
}
|
||
|
||
public IDeleteable<T> Deleteable<T>(T deleteObj) where T : class, new()
|
||
{
|
||
return this.Context.Deleteable<T>(deleteObj);
|
||
}
|
||
|
||
|
||
#endregion
|
||
|
||
#region Fastest
|
||
public IFastest<T> Fastest<T>() where T : class, new()
|
||
{
|
||
return this.Context.Fastest<T>();
|
||
}
|
||
#endregion
|
||
|
||
#region ThenMapper
|
||
public void ThenMapper<T>(IEnumerable<T> list, Action<T> action)
|
||
{
|
||
this.Context.ThenMapper(list, action);
|
||
}
|
||
public Task ThenMapperAsync<T>(IEnumerable<T> list, Func<T, Task> action)
|
||
{
|
||
return this.Context.ThenMapperAsync(list,action);
|
||
}
|
||
#endregion
|
||
|
||
#region More api
|
||
public IContextMethods Utilities { get { return this.Context.Utilities; } set { this.Context.Utilities = value; } }
|
||
public AopProvider Aop => this.Context.Aop;
|
||
public ICodeFirst CodeFirst => this.Context.CodeFirst;
|
||
public IDbFirst DbFirst => this.Context.DbFirst;
|
||
public IDbMaintenance DbMaintenance => this.Context.DbMaintenance;
|
||
public EntityMaintenance EntityMaintenance { get { return this.Context.EntityMaintenance; } set { this.Context.EntityMaintenance = value; } }
|
||
public QueryFilterProvider QueryFilter { get { return this.Context.QueryFilter; } set { this.Context.QueryFilter = value; } }
|
||
#endregion
|
||
|
||
#region TenantManager
|
||
public ITenant AsTenant()
|
||
{
|
||
var tenant= this as ITenant;
|
||
return tenant;
|
||
}
|
||
public SqlSugarTransaction UseTran()
|
||
{
|
||
return new SqlSugarTransaction(this);
|
||
}
|
||
public void RemoveConnection(dynamic configId)
|
||
{
|
||
var removeData= this._AllClients.FirstOrDefault(it => ((object)it.ConnectionConfig.ConfigId).ObjToString()== ((object)configId).ObjToString());
|
||
object currentId= this.CurrentConnectionConfig.ConfigId;
|
||
if (removeData != null)
|
||
{
|
||
if (removeData.Context.Ado.IsAnyTran())
|
||
{
|
||
Check.ExceptionEasy("RemoveConnection error has tran",$"删除失败{removeData.ConnectionConfig.ConfigId}存在未提交事务");
|
||
}
|
||
else if (((object)removeData.ConnectionConfig.ConfigId).ObjToString()== currentId.ObjToString())
|
||
{
|
||
Check.ExceptionEasy("Default ConfigId cannot be deleted", $"默认库不能删除{removeData.ConnectionConfig.ConfigId}");
|
||
}
|
||
this._AllClients.Remove(removeData);
|
||
}
|
||
}
|
||
public void AddConnection(ConnectionConfig connection)
|
||
{
|
||
Check.ArgumentNullException(connection, "AddConnection.connection can't be null");
|
||
InitTenant();
|
||
var db = this._AllClients.FirstOrDefault(it => ((object)it.ConnectionConfig.ConfigId).ObjToString() == ((object)connection.ConfigId).ObjToString());
|
||
if (db == null)
|
||
{
|
||
if (this._AllClients == null)
|
||
{
|
||
this._AllClients = new List<SugarTenant>();
|
||
}
|
||
var provider = new SqlSugarProvider(connection);
|
||
if (connection.AopEvents != null)
|
||
{
|
||
provider.Ado.IsEnableLogEvent = true;
|
||
}
|
||
this._AllClients.Add(new SugarTenant()
|
||
{
|
||
ConnectionConfig = connection,
|
||
Context = provider
|
||
});
|
||
}
|
||
}
|
||
public SqlSugarProvider GetConnectionWithAttr<T>()
|
||
{
|
||
var attr = typeof(T).GetCustomAttribute<TenantAttribute>();
|
||
if (attr == null)
|
||
return this.GetConnection(this.CurrentConnectionConfig.ConfigId);
|
||
var configId = attr.configId;
|
||
return this.GetConnection(configId);
|
||
}
|
||
public SqlSugarScopeProvider GetConnectionScopeWithAttr<T>()
|
||
{
|
||
var attr = typeof(T).GetCustomAttribute<TenantAttribute>();
|
||
if (attr == null)
|
||
return this.GetConnectionScope(this.CurrentConnectionConfig.ConfigId);
|
||
var configId = attr.configId;
|
||
return this.GetConnectionScope(configId);
|
||
}
|
||
public SqlSugarProvider GetConnection(dynamic configId)
|
||
{
|
||
InitTenant();
|
||
var db = this._AllClients.FirstOrDefault(it =>Convert.ToString(it.ConnectionConfig.ConfigId) ==Convert.ToString(configId));
|
||
if (db == null)
|
||
{
|
||
Check.Exception(true, "ConfigId was not found {0}", configId);
|
||
}
|
||
if (db.Context == null)
|
||
{
|
||
db.Context = new SqlSugarProvider(db.ConnectionConfig);
|
||
}
|
||
var intiAop=db.Context.Aop;
|
||
if (db.Context.CurrentConnectionConfig.AopEvents == null)
|
||
{
|
||
db.Context.CurrentConnectionConfig.AopEvents = new AopEvents();
|
||
}
|
||
if (_IsAllTran && db.Context.Ado.Transaction == null)
|
||
{
|
||
db.Context.Ado.BeginTran();
|
||
}
|
||
db.Context.Root = this;
|
||
return db.Context;
|
||
}
|
||
|
||
public SqlSugarScopeProvider GetConnectionScope(dynamic configId)
|
||
{
|
||
var conn = GetConnection(configId);
|
||
return new SqlSugarScopeProvider(conn);
|
||
}
|
||
public bool IsAnyConnection(dynamic configId)
|
||
{
|
||
InitTenant();
|
||
var db = this._AllClients.FirstOrDefault(it => Convert.ToString(it.ConnectionConfig.ConfigId) == Convert.ToString(configId));
|
||
return db != null;
|
||
|
||
}
|
||
public void ChangeDatabase(dynamic configId)
|
||
{
|
||
configId =Convert.ToString(configId);
|
||
var isLog = _Context.Ado.IsEnableLogEvent;
|
||
Check.Exception(!_AllClients.Any(it =>Convert.ToString( it.ConnectionConfig.ConfigId) == configId), "ConfigId was not found {0}", configId);
|
||
InitTenant(_AllClients.First(it => Convert.ToString(it.ConnectionConfig.ConfigId )== configId));
|
||
if (this._IsAllTran)
|
||
this.Ado.BeginTran();
|
||
if (this._IsOpen)
|
||
this.Open();
|
||
_Context.Ado.IsEnableLogEvent = isLog;
|
||
if (_CurrentConnectionConfig.AopEvents==null)
|
||
_CurrentConnectionConfig.AopEvents = new AopEvents();
|
||
}
|
||
public void ChangeDatabase(Func<ConnectionConfig, bool> changeExpression)
|
||
{
|
||
var isLog = _Context.Ado.IsEnableLogEvent;
|
||
var allConfigs = _AllClients.Select(it => it.ConnectionConfig);
|
||
Check.Exception(!allConfigs.Any(changeExpression), "changeExpression was not found {0}", changeExpression.ToString());
|
||
InitTenant(_AllClients.First(it => it.ConnectionConfig == allConfigs.First(changeExpression)));
|
||
if (this._IsAllTran)
|
||
this.Ado.BeginTran();
|
||
if (this._IsOpen)
|
||
this.Open();
|
||
_Context.Ado.IsEnableLogEvent = isLog;
|
||
if (_CurrentConnectionConfig.AopEvents == null)
|
||
_CurrentConnectionConfig.AopEvents = new AopEvents();
|
||
}
|
||
public void BeginTran()
|
||
{
|
||
_IsAllTran = true;
|
||
AllClientEach(it => it.Ado.BeginTran());
|
||
}
|
||
|
||
public void BeginTran(IsolationLevel iso)
|
||
{
|
||
_IsAllTran = true;
|
||
AllClientEach(it => it.Ado.BeginTran(iso));
|
||
}
|
||
|
||
public async Task BeginTranAsync()
|
||
{
|
||
_IsAllTran = true;
|
||
await AllClientEachAsync(async it => await it.Ado.BeginTranAsync());
|
||
}
|
||
|
||
public async Task BeginTranAsync(IsolationLevel iso)
|
||
{
|
||
_IsAllTran = true;
|
||
await AllClientEachAsync(async it => await it.Ado.BeginTranAsync(iso));
|
||
}
|
||
|
||
public void CommitTran()
|
||
{
|
||
this.Context.Ado.CommitTran();
|
||
AllClientEach(it =>
|
||
{
|
||
|
||
try
|
||
{
|
||
it.Ado.CommitTran();
|
||
}
|
||
catch
|
||
{
|
||
SugarRetry.Execute(() => it.Ado.CommitTran(), new TimeSpan(0, 0, 5), 3);
|
||
}
|
||
|
||
});
|
||
_IsAllTran = false;
|
||
}
|
||
|
||
public async Task CommitTranAsync()
|
||
{
|
||
await this.Context.Ado.CommitTranAsync();
|
||
await AllClientEachAsync(async it =>
|
||
{
|
||
|
||
try
|
||
{
|
||
await it.Ado.CommitTranAsync();
|
||
}
|
||
catch
|
||
{
|
||
SugarRetry.Execute(() => it.Ado.CommitTran(), new TimeSpan(0, 0, 5), 3);
|
||
}
|
||
|
||
});
|
||
_IsAllTran = false;
|
||
}
|
||
public DbResult<bool> UseTran(Action action, Action<Exception> errorCallBack = null)
|
||
{
|
||
var result = new DbResult<bool>();
|
||
try
|
||
{
|
||
this.BeginTran();
|
||
if (action != null)
|
||
action();
|
||
this.CommitTran();
|
||
result.Data = result.IsSuccess = true;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
result.ErrorException = ex;
|
||
result.ErrorMessage = ex.Message;
|
||
result.IsSuccess = false;
|
||
this.RollbackTran();
|
||
if (errorCallBack != null)
|
||
{
|
||
errorCallBack(ex);
|
||
}
|
||
}
|
||
return result;
|
||
}
|
||
|
||
public async Task<DbResult<bool>> UseTranAsync(Func<Task> action, Action<Exception> errorCallBack = null)
|
||
{
|
||
var result = new DbResult<bool>();
|
||
try
|
||
{
|
||
await this.BeginTranAsync();
|
||
if (action != null)
|
||
await action();
|
||
await this.CommitTranAsync();
|
||
result.Data = result.IsSuccess = true;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
result.ErrorException = ex;
|
||
result.ErrorMessage = ex.Message;
|
||
result.IsSuccess = false;
|
||
await this.RollbackTranAsync();
|
||
if (errorCallBack != null)
|
||
{
|
||
errorCallBack(ex);
|
||
}
|
||
}
|
||
return result;
|
||
}
|
||
|
||
public DbResult<T> UseTran<T>(Func<T> action, Action<Exception> errorCallBack = null)
|
||
{
|
||
var result = new DbResult<T>();
|
||
try
|
||
{
|
||
this.BeginTran();
|
||
if (action != null)
|
||
result.Data = action();
|
||
this.CommitTran();
|
||
result.IsSuccess = true;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
result.ErrorException = ex;
|
||
result.ErrorMessage = ex.Message;
|
||
result.IsSuccess = false;
|
||
this.RollbackTran();
|
||
if (errorCallBack != null)
|
||
{
|
||
errorCallBack(ex);
|
||
}
|
||
}
|
||
return result;
|
||
}
|
||
|
||
public async Task<DbResult<T>> UseTranAsync<T>(Func<Task<T>> action, Action<Exception> errorCallBack = null)
|
||
{
|
||
var result = new DbResult<T>();
|
||
try
|
||
{
|
||
this.BeginTran();
|
||
T data=default(T);
|
||
if (action != null)
|
||
data = await action();
|
||
this.CommitTran();
|
||
result.IsSuccess = true;
|
||
result.Data = data;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
result.ErrorException = ex;
|
||
result.ErrorMessage = ex.Message;
|
||
result.IsSuccess = false;
|
||
this.RollbackTran();
|
||
if (errorCallBack != null)
|
||
{
|
||
errorCallBack(ex);
|
||
}
|
||
}
|
||
return result;
|
||
}
|
||
|
||
public void RollbackTran()
|
||
{
|
||
this.Context.Ado.RollbackTran();
|
||
AllClientEach(it =>
|
||
{
|
||
|
||
try
|
||
{
|
||
it.Ado.RollbackTran();
|
||
}
|
||
catch
|
||
{
|
||
SugarRetry.Execute(() => it.Ado.RollbackTran(), new TimeSpan(0, 0, 5), 3);
|
||
}
|
||
|
||
});
|
||
_IsAllTran = false;
|
||
}
|
||
public async Task RollbackTranAsync()
|
||
{
|
||
await this.Context.Ado.RollbackTranAsync();
|
||
await AllClientEachAsync(async it =>
|
||
{
|
||
|
||
try
|
||
{
|
||
await it.Ado.RollbackTranAsync();
|
||
}
|
||
catch
|
||
{
|
||
SugarRetry.Execute(() => it.Ado.RollbackTran(), new TimeSpan(0, 0, 5), 3);
|
||
}
|
||
|
||
});
|
||
_IsAllTran = false;
|
||
}
|
||
public void Close()
|
||
{
|
||
this.Context.Close();
|
||
AllClientEach(it => it.Close());
|
||
_IsOpen = false;
|
||
}
|
||
public void Open()
|
||
{
|
||
this.Context.Open();
|
||
_IsOpen = true;
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region IDispose
|
||
public void Dispose()
|
||
{
|
||
AllClientEach(it => it.Ado.RollbackTran());
|
||
AllClientEach(it => it.Dispose());
|
||
}
|
||
|
||
#endregion
|
||
|
||
#region Cache
|
||
public SugarCacheProvider DataCache
|
||
{
|
||
get { return this.Context.DataCache; }
|
||
}
|
||
#endregion
|
||
|
||
#region Other method
|
||
public DynamicBuilder DynamicBuilder()
|
||
{
|
||
return this.Context.DynamicBuilder();
|
||
}
|
||
public void Tracking<T>(T data) where T : class, new()
|
||
{
|
||
this.Context.Tracking(data);
|
||
}
|
||
public void Tracking<T>(List<T> datas) where T : class, new()
|
||
{
|
||
this.Context.Tracking(datas);
|
||
}
|
||
public SqlSugarClient CopyNew()
|
||
{
|
||
var result= new SqlSugarClient(UtilMethods.CopyConfig(this.Ado.Context.CurrentConnectionConfig));
|
||
result.QueryFilter = this.QueryFilter;
|
||
return result;
|
||
}
|
||
public DateTime GetDate()
|
||
{
|
||
return this.Context.GetDate();
|
||
}
|
||
public void InitMappingInfo(Type type)
|
||
{
|
||
this.Context.InitMappingInfo(type);
|
||
}
|
||
public void InitMappingInfo<T>()
|
||
{
|
||
this.Context.InitMappingInfo(typeof(T));
|
||
}
|
||
#endregion
|
||
|
||
#region Helper
|
||
public Task<SugarAsyncLock> AsyncLock(int timeOutSeconds = 30)
|
||
{
|
||
return this.Context.AsyncLock(timeOutSeconds);
|
||
}
|
||
public SplitTableContext SplitHelper<T>() where T:class,new()
|
||
{
|
||
return this.Context.SplitHelper<T>();
|
||
}
|
||
public SplitTableContext SplitHelper(Type entityType)
|
||
{
|
||
return this.Context.SplitHelper(entityType);
|
||
}
|
||
public SplitTableContextResult<T> SplitHelper<T>(T data) where T : class, new()
|
||
{
|
||
return this.Context.SplitHelper(data);
|
||
}
|
||
public SplitTableContextResult<T> SplitHelper<T>(List<T> dataList) where T : class, new()
|
||
{
|
||
return this.Context.SplitHelper(dataList);
|
||
}
|
||
private SqlSugarProvider GetContext()
|
||
{
|
||
SqlSugarProvider result = null;
|
||
//if (IsSameThreadAndShard())
|
||
//{
|
||
// result = SameThreadAndShard();
|
||
//}
|
||
//else if (IsNoSameThreadAndShard())
|
||
//{
|
||
// result = NoSameThreadAndShard();
|
||
//}
|
||
//else
|
||
//{
|
||
result = Synchronization();
|
||
//}
|
||
///Because SqlSugarScope implements thread safety
|
||
//else if (IsSingleInstanceAsync())
|
||
//{
|
||
// result = Synchronization();//Async no support Single Instance
|
||
//}
|
||
//else if (IsAsync())
|
||
//{
|
||
// result = Synchronization();
|
||
//}
|
||
//else
|
||
//{
|
||
// StackTrace st = new StackTrace(true);
|
||
// var methods = st.GetFrames();
|
||
// var isAsync = UtilMethods.IsAnyAsyncMethod(methods);
|
||
// if (isAsync)
|
||
// {
|
||
// result = Synchronization();
|
||
// }
|
||
// else
|
||
// {
|
||
// result = NoSameThread();
|
||
// }
|
||
//}
|
||
if (result.Root == null)
|
||
{
|
||
result.Root = this;
|
||
}
|
||
return result;
|
||
}
|
||
|
||
private SqlSugarProvider NoSameThreadAsync()
|
||
{
|
||
var result = GetCallContext();
|
||
return result;
|
||
}
|
||
private SqlSugarProvider NoSameThread()
|
||
{
|
||
if (CallContext.ContextList.Value == null)
|
||
{
|
||
var context = CopyClient();
|
||
AddCallContext(context);
|
||
return context;
|
||
}
|
||
else
|
||
{
|
||
var result = GetCallContext();
|
||
if (result == null)
|
||
{
|
||
var copy = CopyClient();
|
||
AddCallContext(copy);
|
||
return copy;
|
||
}
|
||
else
|
||
{
|
||
return result;
|
||
}
|
||
}
|
||
}
|
||
private void InitTenant()
|
||
{
|
||
if (this._AllClients == null)
|
||
{
|
||
this._AllClients = new List<SugarTenant>();
|
||
this._AllClients.Add(new SugarTenant()
|
||
{
|
||
ConnectionConfig = this.CurrentConnectionConfig,
|
||
Context = this.Context
|
||
});
|
||
}
|
||
}
|
||
|
||
private SqlSugarProvider Synchronization()
|
||
{
|
||
_Context.MappingColumns = _MappingColumns;
|
||
_Context.MappingTables = _MappingTables;
|
||
_Context.IgnoreColumns = _IgnoreColumns;
|
||
_Context.IgnoreInsertColumns = _IgnoreInsertColumns;
|
||
return _Context;
|
||
}
|
||
|
||
private SqlSugarProvider NoSameThreadAndShard()
|
||
{
|
||
if (CallContext.ContextList.Value.IsNullOrEmpty())
|
||
{
|
||
var copy = CopyClient();
|
||
AddCallContext(copy);
|
||
return copy;
|
||
}
|
||
else
|
||
{
|
||
var result = GetCallContext();
|
||
if (result == null)
|
||
{
|
||
var copy = CopyClient();
|
||
AddCallContext(copy);
|
||
return copy;
|
||
}
|
||
else
|
||
{
|
||
return result;
|
||
}
|
||
}
|
||
}
|
||
|
||
private SqlSugarProvider SameThreadAndShard()
|
||
{
|
||
if (CallContext.ContextList.Value.IsNullOrEmpty())
|
||
{
|
||
AddCallContext(_Context);
|
||
return _Context;
|
||
}
|
||
else
|
||
{
|
||
var result = GetCallContext();
|
||
if (result == null)
|
||
{
|
||
var copy = CopyClient();
|
||
AddCallContext(copy);
|
||
return copy;
|
||
}
|
||
else
|
||
{
|
||
return result;
|
||
}
|
||
}
|
||
}
|
||
|
||
private bool IsAsync()
|
||
{
|
||
return AsyncId != null;
|
||
}
|
||
|
||
private bool IsSingleInstanceAsync()
|
||
{
|
||
return IsSingleInstance == true && AsyncId != null;
|
||
}
|
||
|
||
private bool IsSynchronization()
|
||
{
|
||
return _ThreadId == Thread.CurrentThread.ManagedThreadId.ToString();
|
||
}
|
||
|
||
//private bool IsNoSameThreadAndShard()
|
||
//{
|
||
// return CurrentConnectionConfig.IsShardSameThread && _ThreadId != Thread.CurrentThread.ManagedThreadId.ToString();
|
||
//}
|
||
|
||
//private bool IsSameThreadAndShard()
|
||
//{
|
||
// return CurrentConnectionConfig.IsShardSameThread && _ThreadId == Thread.CurrentThread.ManagedThreadId.ToString();
|
||
//}
|
||
|
||
private SqlSugarProvider CopyClient()
|
||
{
|
||
var result = new SqlSugarProvider(this.CurrentConnectionConfig);
|
||
result.MappingColumns = _MappingColumns;
|
||
result.MappingTables = _MappingTables;
|
||
result.IgnoreColumns = _IgnoreColumns;
|
||
result.IgnoreInsertColumns = _IgnoreInsertColumns;
|
||
|
||
return result;
|
||
}
|
||
private void AddCallContext(SqlSugarProvider context)
|
||
{
|
||
CallContext.ContextList.Value = new List<SqlSugarProvider>();
|
||
CallContext.ContextList.Value.Add(context);
|
||
}
|
||
|
||
private SqlSugarProvider GetCallContext()
|
||
{
|
||
return CallContext.ContextList.Value.FirstOrDefault(it =>
|
||
it.CurrentConnectionConfig.DbType == _Context.CurrentConnectionConfig.DbType &&
|
||
it.CurrentConnectionConfig.ConnectionString == _Context.CurrentConnectionConfig.ConnectionString &&
|
||
it.CurrentConnectionConfig.InitKeyType == _Context.CurrentConnectionConfig.InitKeyType &&
|
||
it.CurrentConnectionConfig.IsAutoCloseConnection == _Context.CurrentConnectionConfig.IsAutoCloseConnection
|
||
);
|
||
}
|
||
|
||
protected virtual void InitContext(ConnectionConfig config)
|
||
{
|
||
var aopIsNull = config.AopEvents == null;
|
||
if (aopIsNull)
|
||
{
|
||
config.AopEvents = new AopEvents();
|
||
}
|
||
_Context = new SqlSugarProvider(config);
|
||
if (!aopIsNull)
|
||
_Context.Ado.IsEnableLogEvent = true;
|
||
this.CurrentConnectionConfig = config;
|
||
_ThreadId = Thread.CurrentThread.ManagedThreadId.ToString();
|
||
if (this.MappingTables == null)
|
||
this.MappingTables = new MappingTableList();
|
||
if (this.MappingColumns == null)
|
||
this.MappingColumns = new MappingColumnList();
|
||
if (this.IgnoreColumns == null)
|
||
this.IgnoreColumns = new IgnoreColumnList();
|
||
if (this.IgnoreInsertColumns == null)
|
||
this.IgnoreInsertColumns = new IgnoreColumnList();
|
||
}
|
||
|
||
private void InitConfigs(List<ConnectionConfig> configs)
|
||
{
|
||
foreach (var item in configs)
|
||
{
|
||
if (item.ConfigId == null)
|
||
{
|
||
item.ConfigId = Guid.NewGuid().ToString();
|
||
}
|
||
}
|
||
}
|
||
private void AllClientEach(Action<ISqlSugarClient> action)
|
||
{
|
||
if (this._AllClients == null)
|
||
{
|
||
this._AllClients = new List<SugarTenant>();
|
||
this._AllClients.Add(new SugarTenant() { ConnectionConfig=this.CurrentConnectionConfig, Context=this.Context });
|
||
}
|
||
if (_AllClients.HasValue())
|
||
{
|
||
foreach (var item in _AllClients.Where(it => it.Context.HasValue()))
|
||
{
|
||
action(item.Context);
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
private async Task AllClientEachAsync(Func<ISqlSugarClient,Task> action)
|
||
{
|
||
if (this._AllClients == null)
|
||
{
|
||
this._AllClients = new List<SugarTenant>();
|
||
this._AllClients.Add(new SugarTenant() { ConnectionConfig = this.CurrentConnectionConfig, Context = this.Context });
|
||
}
|
||
if (_AllClients.HasValue())
|
||
{
|
||
foreach (var item in _AllClients.Where(it => it.Context.HasValue()))
|
||
{
|
||
await action(item.Context);
|
||
}
|
||
}
|
||
}
|
||
private void InitTenant(SugarTenant Tenant)
|
||
{
|
||
if (Tenant.Context == null)
|
||
{
|
||
Tenant.Context = new SqlSugarProvider(Tenant.ConnectionConfig);
|
||
}
|
||
_Context = Tenant.Context;
|
||
this.CurrentConnectionConfig = Tenant.ConnectionConfig;
|
||
}
|
||
#endregion
|
||
|
||
#region Tenant Crud
|
||
public ISugarQueryable<T> QueryableWithAttr<T>()
|
||
{
|
||
var result= this.GetConnectionWithAttr<T>().Queryable<T>();
|
||
result.QueryBuilder.IsCrossQueryWithAttr= true;
|
||
return result;
|
||
}
|
||
public IInsertable<T> InsertableWithAttr<T>(T insertObj) where T : class, new()
|
||
{
|
||
return this.GetConnectionWithAttr<T>().Insertable(insertObj);
|
||
}
|
||
public IInsertable<T> InsertableWithAttr<T>(List<T> insertObjs) where T : class, new()
|
||
{
|
||
return this.GetConnectionWithAttr<T>().Insertable(insertObjs);
|
||
}
|
||
public IUpdateable<T> UpdateableWithAttr<T>(T updateObj) where T : class, new()
|
||
{
|
||
return this.GetConnectionWithAttr<T>().Updateable(updateObj);
|
||
}
|
||
public IUpdateable<T> UpdateableWithAttr<T>() where T : class, new()
|
||
{
|
||
return this.GetConnectionWithAttr<T>().Updateable<T>();
|
||
}
|
||
public IUpdateable<T> UpdateableWithAttr<T>(List<T> updateObjs) where T : class, new()
|
||
{
|
||
return this.GetConnectionWithAttr<T>().Updateable(updateObjs);
|
||
}
|
||
public IDeleteable<T> DeleteableWithAttr<T>(T deleteObject) where T : class, new()
|
||
{
|
||
return this.GetConnectionWithAttr<T>().Deleteable(deleteObject);
|
||
}
|
||
public IDeleteable<T> DeleteableWithAttr<T>() where T : class, new()
|
||
{
|
||
return this.GetConnectionWithAttr<T>().Deleteable<T>();
|
||
}
|
||
public IDeleteable<T> DeleteableWithAttr<T>(List<T> deleteObjects) where T : class, new()
|
||
{
|
||
return this.GetConnectionWithAttr<T>().Deleteable(deleteObjects);
|
||
}
|
||
#endregion
|
||
}
|
||
}
|