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

Synchronization code

Browse Source
This commit is contained in:
sunkaixuan
2023-02-27 16:20:40 +08:00
parent 6a18ca31a5
commit 55f6da1910
4 changed files with 21 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
Src/Asp.NetCore2/SqlSugar/Abstract/AdoProvider/AdoProvider.cs
View File

@@ -922,6 +922,20 @@ namespace SqlSugar
var result = SqlQuery<T, object, object, object, object, object, object>(sql, parameters);
return result.Item1;
}
public List<T> MasterSqlQuery<T>(string sql, object parameters = null)
{
var oldValue = this.Context.Ado.IsDisableMasterSlaveSeparation;
this.Context.Ado.IsDisableMasterSlaveSeparation = true;
var result = this.Context.Ado.SqlQuery<T>(sql, parameters);
return result;
}
public async Task<List<T>> MasterSqlQueryAasync<T>(string sql, object parameters = null)
{
var oldValue = this.Context.Ado.IsDisableMasterSlaveSeparation;
this.Context.Ado.IsDisableMasterSlaveSeparation = true;
var result = await this.Context.Ado.SqlQueryAsync<T>(sql, parameters);
return result;
}
public virtual List<T> SqlQuery<T>(string sql, List<SugarParameter> parameters)
{
if (parameters != null)

4
Src/Asp.NetCore2/SqlSugar/DistributedSystem/Snowflake/IdWorker.cs
View File

@@ -71,6 +71,10 @@ namespace SqlSugar.DistributedSystem.Snowflake
}
public virtual long NextId()
{
if (StaticConfig.CustomSnowFlakeFunc != null)
{
return StaticConfig.CustomSnowFlakeFunc();
}
lock(_lock)
{
var timestamp = TimeGen();

1
Src/Asp.NetCore2/SqlSugar/Infrastructure/StaticConfig.cs
View File

@@ -9,5 +9,6 @@ namespace SqlSugar
public static Func<string,string> Encode { get; set; }
public static Func<string,string> Decode{ get; set; }
public const string CodeFirst_BigString = "varcharmax,longtext,text,clob";
public static Func<long> CustomSnowFlakeFunc;
}
}

2
Src/Asp.NetCore2/SqlSugar/Interface/IAdo.cs
View File

@@ -147,6 +147,8 @@ namespace SqlSugar
List<T> SqlQuery<T>(string sql, object parameters = null);
List<T> SqlQuery<T>(string sql, params SugarParameter[] parameters);
List<T> SqlQuery<T>(string sql, List<SugarParameter> parameters);
Task<List<T>> MasterSqlQueryAasync<T>(string sql, object parameters = null);
List<T> MasterSqlQuery<T>(string sql, object parameters = null);
Task<List<T>> SqlQueryAsync<T>(string sql, object parameters = null);
Task<List<T>> SqlQueryAsync<T>(string sql, List<SugarParameter> parameters);