ConnectionDBBase.cxx

Go to the documentation of this file.

#include "ReadDBBase/ConnectionDBBase.h"
#include "facilities/Util.h"
#include "rdbModel/Management/Manager.h"
#include "rdbModel/Management/XercesBuilder.h"
 
#include "rdbModel/Db/MysqlConnection.h"
#include "rdbModel/Db/MysqlResults.h"
#include "rdbModel/Rdb.h"
#include "rdbModel/RdbException.h"
#include "rdbModel/Tables/Assertion.h"
#include "rdbModel/Tables/Column.h"
#include "rdbModel/Tables/Table.h"
#include <cstdio>
#include <iostream>
 
// namespace RealDBUtil {
 
ConnectionDBBase::ConnectionDBBase( const std::string& host, const std::string& table,
                                    const std::string& dbName )
    : m_readCxt( 0 )
    , m_writeCxt( 0 )
    , m_host( host )
    , m_table( table )
    , m_dbName( dbName )
    , m_userName( "maqm" )
    , m_password( "12345" )
    , m_man( 0 )
    , m_rdb( 0 )
    , m_match( false ) {
  // if (table.compare("*") == 0) m_table = std::string("$(MYSQL_METATABLE)");
  // if (host.compare("*") == 0) m_host = std::string("$(MYSQL_HOST)");
}
ConnectionDBBase::ConnectionDBBase( const std::string& host, const std::string& dbName,
                                    const std::string& userName, const std::string& password )
    : m_readCxt( 0 )
    , m_writeCxt( 0 )
    , m_host( host )
    , m_dbName( dbName )
    , m_userName( userName )
    , m_password( password )
    , m_man( 0 )
    , m_rdb( 0 )
    , m_match( false ) {}
 
ConnectionDBBase::~ConnectionDBBase() {
  disconnectRead();
  disconnectWrite();
  if ( m_man ) delete m_man;
}
 
// The next 5 methods concern connection to the server
bool ConnectionDBBase::connect( rdbModel::Connection* cxt, std::string& host,
                                const std::string& user, const std::string& pw, eRet& err,
                                const std::string& dbName ) {
 
  bool connected = cxt->open( host, user, pw, dbName );
  if ( connected )
  {
    err = RETOk;
    return true;
  }
  else
  {
    err = RETNoConnect;
    return false;
  }
}
 
bool ConnectionDBBase::connectRead( eRet& err ) {
  if ( m_readCxt == 0 )
  {
    // for now use std::cout, std::cerr
    m_readCxt = new rdbModel::MysqlConnection();
    bool ok   = connect( m_readCxt, m_host, m_userName, m_password, err, m_dbName );
    if ( !ok )
    {
      delete m_readCxt;
      m_readCxt = 0;
    }
    else {}
    return ok;
  }
  else return true;
}
 
bool ConnectionDBBase::connectWrite( eRet& err ) {
  if ( m_writeCxt == 0 )
  {
    m_writeCxt = new rdbModel::MysqlConnection();
    bool ok;
 
    ok = connect( m_writeCxt, m_host, m_userName, m_password, err, m_dbName );
 
    if ( !ok )
    {
      delete m_readCxt;
      m_readCxt = 0;
    }
    else {}
 
    return ok;
  }
  else return true;
}
 
void ConnectionDBBase::disconnectRead() {
  if ( m_readCxt )
  {
    m_readCxt->close();
    delete m_readCxt;
    m_readCxt = 0;
  }
}
 
void ConnectionDBBase::disconnectWrite() {
  if ( m_writeCxt )
  {
    m_writeCxt->close();
    delete m_writeCxt;
    m_writeCxt = 0;
  }
}
//}