Code optimization

This commit is contained in:
sunkaixuna
2021-10-22 21:22:07 +08:00
parent 2b15279ece
commit 56a3290818
3 changed files with 19 additions and 19 deletions

View File

@@ -14,15 +14,15 @@ namespace SqlSugar
{
if (_Filters == null)
_Filters = new List<SqlFilterItem>();
if (this.Context.CurrentConnectionConfig.IsShardSameThread)
{
if (!_Filters.Select(it => it.FilterValue(this.Context).Sql).Contains(filter.FilterValue(this.Context).Sql))
_Filters.Add(filter);
}
else
{
//if (this.Context.CurrentConnectionConfig.IsShardSameThread)
//{
// if (!_Filters.Select(it => it.FilterValue(this.Context).Sql).Contains(filter.FilterValue(this.Context).Sql))
// _Filters.Add(filter);
//}
//else
//{
_Filters.Add(filter);
}
//}
return this;
}

View File

@@ -31,9 +31,9 @@ namespace SqlSugar
public InitKeyType InitKeyType = InitKeyType.Attribute;
/// <summary>
///If true, there is only one connection instance in the same thread within the same connection string
[Obsolete("use SqlSugar.Ioc")]
/// </summary>
public bool IsShardSameThread { get; set; }
//[Obsolete("use SqlSugar.Ioc")]
///// </summary>
//public bool IsShardSameThread { get; set; }
/// <summary>
/// Configure External Services replace default services,For example, Redis storage
/// </summary>

View File

@@ -1003,15 +1003,15 @@ namespace SqlSugar
return _ThreadId == Thread.CurrentThread.ManagedThreadId.ToString();
}
private bool IsNoSameThreadAndShard()
{
return CurrentConnectionConfig.IsShardSameThread && _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 bool IsSameThreadAndShard()
//{
// return CurrentConnectionConfig.IsShardSameThread && _ThreadId == Thread.CurrentThread.ManagedThreadId.ToString();
//}
private SqlSugarProvider CopyClient()
{