lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-12-21 19:09:57 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

-

Browse Source
This commit is contained in:
sunkaixuan
2019-05-19 10:27:47 +08:00
parent 9487d68557
commit 274ddea6ec
1 changed files with 13 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
Src/Asp.Net/SqlSugar/Abstract/AdoProvider/AdoProvider.cs
View File

@@ -1184,17 +1184,6 @@ namespace SqlSugar
} }
} }
private static void NextResult(IDataReader dataReader)
{
try
{
dataReader.NextResult();
}
catch
{
Check.Exception(true, ErrorMessage.GetThrowMessage("Please reduce the number of T. Save Queue Changes queries don't have so many results", "请减少T的数量，SaveQueueChanges 查询没有这么多结果"));
}
}
public virtual T SqlQuerySingle<T>(string sql, object parameters = null) public virtual T SqlQuerySingle<T>(string sql, object parameters = null)
{ {
var result = SqlQuery<T>(sql, parameters); var result = SqlQuery<T>(sql, parameters);
@@ -1325,7 +1314,7 @@ namespace SqlSugar
{ {
return ExecuteCommand(sql, GetParameters(parameters)); return ExecuteCommand(sql, GetParameters(parameters));
} }
public virtual int ExecuteCommandAsync(string sql, List<SugarParameter> parameters) public virtual int ExecuteCommand(string sql, List<SugarParameter> parameters)
{ {
if (parameters == null) if (parameters == null)
{ {
@@ -1340,7 +1329,7 @@ namespace SqlSugar
{ {
return ExecuteCommandAsync(sql, GetParameters(parameters)); return ExecuteCommandAsync(sql, GetParameters(parameters));
} }
public virtual Task<int> ExecuteCommand(string sql, List<SugarParameter> parameters) public virtual Task<int> ExecuteCommandAsync(string sql, List<SugarParameter> parameters)
{ {
if (parameters == null) if (parameters == null)
{ {
@@ -1354,14 +1343,17 @@ namespace SqlSugar
#endregion #endregion
#region Helper #region Helper
//private void TaskStart<Type>(Task<Type> result) private static void NextResult(IDataReader dataReader)
//{ {
// if (this.Context.CurrentConnectionConfig.IsShardSameThread) try
// { {
// Check.Exception(true, "IsShardSameThread=true can't be used async method"); dataReader.NextResult();
// } }
// result.Start(); catch
//} {
Check.Exception(true, ErrorMessage.GetThrowMessage("Please reduce the number of T. Save Queue Changes queries don't have so many results", "请减少T的数量，SaveQueueChanges 查询没有这么多结果"));
}
}
private void ExecuteProcessingSQL(ref string sql, SugarParameter[] parameters) private void ExecuteProcessingSQL(ref string sql, SugarParameter[] parameters)
{ {
var result = this.ProcessingEventStartingSQL(sql, parameters); var result = this.ProcessingEventStartingSQL(sql, parameters);