shaba/one
1
0
Fork 0
mirror of https://github.com/OpenNebula/one.git synced 2025-02-28 17:57:22 +03:00
Code Releases Wiki Activity

B #5196: fix mysql reconnect (#5198)

Browse Source 
(cherry picked from commit 3b12e4ae2dc1adb774d587c5272d4eba0f8ea5e4)
This commit is contained in:
Anton Todorov 2020-12-15 14:55:28 +02:00 committed by Ruben S. Montero
parent 21c6e1ca2d
commit 09716b971f
No known key found for this signature in database
GPG Key ID: A0CEA6FA880A1D87
1 changed files with 7 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
src/sql/MySqlDB.cc
View File

@ -196,7 +196,7 @@ MySqlDB::MySqlDB(const string& s, int p, const string& u, const string& _p,
}
// -------------------------------------------------------------------------
// Create connection pool to the server
// Create connection pool to the server and database
// -------------------------------------------------------------------------
for (int i=0 ; i < max_connections ; i++)
{
@ -205,8 +205,11 @@ MySqlDB::MySqlDB(const string& s, int p, const string& u, const string& _p,
bool reconnect = true;
mysql_options(connections[i], MYSQL_OPT_RECONNECT, &reconnect);
mysql_options(connections[i], MYSQL_SET_CHARSET_NAME, encoding.c_str());
rc = mysql_real_connect(connections[i], server.c_str(), user.c_str(),
password.c_str(), 0, port, NULL, 0);
password.c_str(), database.c_str(), port, NULL,
CLIENT_REMEMBER_OPTIONS);
if ( rc == nullptr)
{
@ -215,6 +218,8 @@ MySqlDB::MySqlDB(const string& s, int p, const string& u, const string& _p,
throw runtime_error(error);
}
db_connect.push(connections[i]);
}
// -------------------------------------------------------------------------
@ -241,32 +246,6 @@ MySqlDB::MySqlDB(const string& s, int p, const string& u, const string& _p,
throw runtime_error(error);
}
// -------------------------------------------------------------------------
// Connect to OpenNebula Database
// -------------------------------------------------------------------------
string use_sql = "USE " + database;
for (int i=0 ; i < max_connections ; i++)
{
if ( mysql_query(connections[i], use_sql.c_str()) != 0 )
{
string error = "Could not connect to database: ";
error.append(mysql_error(connections[i]));
throw runtime_error(error);
}
if ( mysql_set_character_set(connections[i], encoding.c_str()) != 0 )
{
string error = "Could not set encoding : ";
error.append(mysql_error(connections[i]));
throw runtime_error(error);
}
db_connect.push(connections[i]);
}
oss << "Set up " << max_connections << " DB connections using encoding " <<
encoding;