diff --git a/components/db_ido_mysql/idomysqlconnection.cpp b/components/db_ido_mysql/idomysqlconnection.cpp index 54955cb22..c37058e11 100644 --- a/components/db_ido_mysql/idomysqlconnection.cpp +++ b/components/db_ido_mysql/idomysqlconnection.cpp @@ -84,10 +84,10 @@ void IdoMysqlConnection::Resume(void) void IdoMysqlConnection::Pause(void) { - DbConnection::Pause(); - m_ReconnectTimer.reset(); + DbConnection::Pause(); + m_QueryQueue.Enqueue(boost::bind(&IdoMysqlConnection::Disconnect, this)); m_QueryQueue.Join(); } diff --git a/components/db_ido_pgsql/idopgsqlconnection.cpp b/components/db_ido_pgsql/idopgsqlconnection.cpp index c27e4659f..fa63eb3c4 100644 --- a/components/db_ido_pgsql/idopgsqlconnection.cpp +++ b/components/db_ido_pgsql/idopgsqlconnection.cpp @@ -86,10 +86,10 @@ void IdoPgsqlConnection::Resume(void) void IdoPgsqlConnection::Pause(void) { - DbConnection::Pause(); - m_ReconnectTimer.reset(); + DbConnection::Pause(); + m_QueryQueue.Enqueue(boost::bind(&IdoPgsqlConnection::Disconnect, this)); m_QueryQueue.Join(); }