tk/FreeSql
1
0
Fork 0
mirror of https://github.com/nsnail/FreeSql.git synced 2025-04-22 02:32:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

- 优化QuestDb-RestAPI异常提示

Browse Source
This commit is contained in:
dailyccc 2023-02-22 13:21:34 +08:00
parent 0574e794a8
commit c201864de0
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Providers/FreeSql.Provider.QuestDb/Curd/QuestDbUpdate.cs
View File

@ -33,7 +33,6 @@ namespace FreeSql.QuestDb.Curd
private int InternelExecuteAffrows() private int InternelExecuteAffrows()
{ {
//如果设置了RestAPI的Url则走HTTP
var sql = ToSql(); var sql = ToSql();
var execAsync = RestAPIExtension.ExecAsync(sql).GetAwaiter().GetResult(); var execAsync = RestAPIExtension.ExecAsync(sql).GetAwaiter().GetResult();
var resultHash = new Hashtable(); var resultHash = new Hashtable();
@ -45,7 +44,7 @@ namespace FreeSql.QuestDb.Curd
{ {
if (execAsync.Contains("401")) if (execAsync.Contains("401"))
{ {
throw new Exception("请确认QuestDb设置的RestAPI账号是否正确."); throw new Exception("请确认new FreeSqlBuilder().UseQuestDbRestAPI()中设置的用户名密码是否正确.");
} }
} }
var ddl = resultHash["ddl"]?.ToString(); var ddl = resultHash["ddl"]?.ToString();
@ -55,6 +54,7 @@ namespace FreeSql.QuestDb.Curd
public override int ExecuteAffrows() public override int ExecuteAffrows()
{ {
//如果设置了RestAPI中Url则走HTTP
if (string.IsNullOrWhiteSpace(RestAPIExtension.BaseUrl)) if (string.IsNullOrWhiteSpace(RestAPIExtension.BaseUrl))
{ {
return base.SplitExecuteAffrows(_batchRowsLimit > 0 ? _batchRowsLimit : 500, return base.SplitExecuteAffrows(_batchRowsLimit > 0 ? _batchRowsLimit : 500,