Attempt to fix MySQL timeout
This commit is contained in:
@@ -14,6 +14,7 @@ public class SQLHelper
|
|||||||
{
|
{
|
||||||
lock (connection)
|
lock (connection)
|
||||||
{
|
{
|
||||||
|
EnsureConnected();
|
||||||
using MySqlCommand command = connection.CreateCommand();
|
using MySqlCommand command = connection.CreateCommand();
|
||||||
command.CommandText = query;
|
command.CommandText = query;
|
||||||
foreach (KeyValuePair<string, dynamic> parameter in parameters)
|
foreach (KeyValuePair<string, dynamic> parameter in parameters)
|
||||||
@@ -28,6 +29,7 @@ public class SQLHelper
|
|||||||
{
|
{
|
||||||
lock (connection)
|
lock (connection)
|
||||||
{
|
{
|
||||||
|
EnsureConnected();
|
||||||
using MySqlCommand command = connection.CreateCommand();
|
using MySqlCommand command = connection.CreateCommand();
|
||||||
|
|
||||||
command.CommandText = query;
|
command.CommandText = query;
|
||||||
@@ -43,6 +45,7 @@ public class SQLHelper
|
|||||||
{
|
{
|
||||||
lock (connection)
|
lock (connection)
|
||||||
{
|
{
|
||||||
|
EnsureConnected();
|
||||||
using MySqlCommand command = connection.CreateCommand();
|
using MySqlCommand command = connection.CreateCommand();
|
||||||
|
|
||||||
command.CommandText = query;
|
command.CommandText = query;
|
||||||
@@ -55,4 +58,21 @@ public class SQLHelper
|
|||||||
return Convert.ToInt32(command.ExecuteScalar());
|
return Convert.ToInt32(command.ExecuteScalar());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public bool EnsureConnected()
|
||||||
|
{
|
||||||
|
if (connection.State != System.Data.ConnectionState.Open)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
connection.Close();
|
||||||
|
connection.Open();
|
||||||
|
}
|
||||||
|
catch (Exception)
|
||||||
|
{
|
||||||
|
throw; // TODO add logging here
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user