mcs/database.cc

   1 #include "database.h"
   2
   3 namespace remote { namespace mcs {
   4
   5 ManagedConnection::ManagedConnection() : sqlConn(true)
   6 {}
   7
   8 ManagedConnection::~ManagedConnection()
   9 {
  10         if (sqlConn.connected()) sqlConn.close();
  11 }
  12
  13 bool ManagedConnection::connect(std::string db, std::string host, std::string user, std::string password)
  14 {
  15         this->db = db; this->host = host; this->user = user; this->password = password;
  16         return sqlConn.connect(db.c_str(),host.c_str(),user.c_str(),password.c_str());
  17 }
  18
  19 mysqlpp::Connection& ManagedConnection::getConnection(bool check)
  20 {
  21         if (check) checkDBConnection();
  22         return sqlConn;
  23 }
  24
  25 void ManagedConnection::checkDBConnection()
  26 {
  27         try
  28         {
  29                 if (sqlConn.ping() !=0)
  30                 {
  31                         sqlConn.connect(db.c_str(),host.c_str(),user.c_str(),password.c_str());
  32                 }
  33         }
  34         catch ( mysqlpp::Exception e)
  35         {
  36                 sqlConn.connect(db.c_str(),host.c_str(),user.c_str(),password.c_str());
  37         }
  38 }
  39
  40 ManagedConnection dbConn;
  41
  42 }}