Loading src/DBManager.cpp +18 −0 Original line number Diff line number Diff line Loading @@ -58,6 +58,8 @@ void DBManager::connectAll() throw(soci::soci_error) boost::mutex::scoped_lock lock(m_sessionMutex); bool reconnect = true; std::stringstream connection; connection << " host=" << m_configuration_sp->getDatabaseHost(); Loading @@ -71,6 +73,14 @@ void DBManager::connectAll() throw(soci::soci_error) m_mainSession_sp->open(soci::mysql, connection.str()); soci::mysql_session_backend* mainBackend = static_cast<soci::mysql_session_backend*>( m_mainSession_sp->get_backend()); MYSQL* mainMysql = mainBackend->conn_; mysql_options(mainMysql, MYSQL_OPT_RECONNECT, &reconnect); connection.str(""); connection << " host=" << m_configuration_sp->getAuxDatabaseHost(); Loading @@ -83,6 +93,14 @@ void DBManager::connectAll() throw(soci::soci_error) #endif m_auxSession_sp->open(soci::mysql, connection.str()); soci::mysql_session_backend* auxBackend = static_cast<soci::mysql_session_backend*>( m_auxSession_sp->get_backend()); MYSQL* auxMysql = auxBackend->conn_; mysql_options(auxMysql, MYSQL_OPT_RECONNECT, &reconnect); } //============================================================================== Loading Loading
src/DBManager.cpp +18 −0 Original line number Diff line number Diff line Loading @@ -58,6 +58,8 @@ void DBManager::connectAll() throw(soci::soci_error) boost::mutex::scoped_lock lock(m_sessionMutex); bool reconnect = true; std::stringstream connection; connection << " host=" << m_configuration_sp->getDatabaseHost(); Loading @@ -71,6 +73,14 @@ void DBManager::connectAll() throw(soci::soci_error) m_mainSession_sp->open(soci::mysql, connection.str()); soci::mysql_session_backend* mainBackend = static_cast<soci::mysql_session_backend*>( m_mainSession_sp->get_backend()); MYSQL* mainMysql = mainBackend->conn_; mysql_options(mainMysql, MYSQL_OPT_RECONNECT, &reconnect); connection.str(""); connection << " host=" << m_configuration_sp->getAuxDatabaseHost(); Loading @@ -83,6 +93,14 @@ void DBManager::connectAll() throw(soci::soci_error) #endif m_auxSession_sp->open(soci::mysql, connection.str()); soci::mysql_session_backend* auxBackend = static_cast<soci::mysql_session_backend*>( m_auxSession_sp->get_backend()); MYSQL* auxMysql = auxBackend->conn_; mysql_options(auxMysql, MYSQL_OPT_RECONNECT, &reconnect); } //============================================================================== Loading