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

Update QuestDb BUG

Browse Source
This commit is contained in:
sunkaixuan
2022-09-09 21:26:34 +08:00
parent 2610a76519
commit 0e0bed3428
2 changed files with 62 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
Src/Asp.Net/SqlSugar/Realization/QuestDB/QuestDBProvider.cs
View File

@@ -71,6 +71,36 @@ namespace SqlSugar
CheckConnection(); CheckConnection();
return sqlCommand; return sqlCommand;
} }
/// <summary>
/// Check connection
/// </summary>
public override void CheckConnection()
{
if (this.Connection.State != ConnectionState.Open)
{
try
{
int i = 0;
while (i < 10)
{
try
{
//QuestDb loss problem
this.Connection.Open();
break;
}
catch
{
i++;
}
}
}
catch (Exception ex)
{
Check.Exception(true, ErrorMessage.ConnnectionOpen, ex.Message);
}
}
}
public override void SetCommandToAdapter(IDataAdapter dataAdapter, DbCommand command) public override void SetCommandToAdapter(IDataAdapter dataAdapter, DbCommand command)
{ {
((NpgsqlDataAdapter)dataAdapter).SelectCommand = (NpgsqlCommand)command; ((NpgsqlDataAdapter)dataAdapter).SelectCommand = (NpgsqlCommand)command;

31
Src/Asp.NetCore2/SqlSugar/Realization/QuestDB/QuestDBProvider.cs
View File

@@ -71,6 +71,37 @@ namespace SqlSugar
CheckConnection(); CheckConnection();
return sqlCommand; return sqlCommand;
} }
/// <summary>
/// Check connection
/// </summary>
public override void CheckConnection()
{
if (this.Connection.State != ConnectionState.Open)
{
try
{
int i = 0;
while (i < 10)
{
try
{
//QuestDb loss problem
this.Connection.Open();
break;
}
catch
{
i++;
}
}
}
catch (Exception ex)
{
Check.Exception(true, ErrorMessage.ConnnectionOpen, ex.Message);
}
}
}
public override void SetCommandToAdapter(IDataAdapter dataAdapter, DbCommand command) public override void SetCommandToAdapter(IDataAdapter dataAdapter, DbCommand command)
{ {
((NpgsqlDataAdapter)dataAdapter).SelectCommand = (NpgsqlCommand)command; ((NpgsqlDataAdapter)dataAdapter).SelectCommand = (NpgsqlCommand)command;