Loading src/DBManager.cpp +13 −0 Original line number Diff line number Diff line Loading @@ -5,6 +5,8 @@ #include <soci/mysql/soci-mysql.h> #include <soci/use.h> #include <mysql.h> namespace MetadataExporter_ns { Loading Loading @@ -62,7 +64,18 @@ void DBManager::connect() throw(soci::soci_error) #endif for(unsigned int i=0; i<connectionNumber; ++i) { m_connectionPool_sp->at(i).open(soci::mysql, connection.str()); soci::mysql_session_backend* backend = static_cast<soci::mysql_session_backend*>( m_connectionPool_sp->at(i).get_backend()); MYSQL* mysql = backend->conn_; bool reconnect = true; mysql_options(mysql, MYSQL_OPT_RECONNECT, &reconnect); } } //============================================================================== Loading src/Server.cpp +1 −1 Original line number Diff line number Diff line Loading @@ -30,7 +30,7 @@ Server::Server(Tango::DeviceImpl* deviceImpl_p, Configuration::SP configuration_ } //============================================================================== // Server::Server() // Server::~Server() //============================================================================== Server::~Server() { Loading Loading
src/DBManager.cpp +13 −0 Original line number Diff line number Diff line Loading @@ -5,6 +5,8 @@ #include <soci/mysql/soci-mysql.h> #include <soci/use.h> #include <mysql.h> namespace MetadataExporter_ns { Loading Loading @@ -62,7 +64,18 @@ void DBManager::connect() throw(soci::soci_error) #endif for(unsigned int i=0; i<connectionNumber; ++i) { m_connectionPool_sp->at(i).open(soci::mysql, connection.str()); soci::mysql_session_backend* backend = static_cast<soci::mysql_session_backend*>( m_connectionPool_sp->at(i).get_backend()); MYSQL* mysql = backend->conn_; bool reconnect = true; mysql_options(mysql, MYSQL_OPT_RECONNECT, &reconnect); } } //============================================================================== Loading
src/Server.cpp +1 −1 Original line number Diff line number Diff line Loading @@ -30,7 +30,7 @@ Server::Server(Tango::DeviceImpl* deviceImpl_p, Configuration::SP configuration_ } //============================================================================== // Server::Server() // Server::~Server() //============================================================================== Server::~Server() { Loading