DatabaseSvc Class Reference

#include <DatabaseSvc.h>

Inheritance diagram for DatabaseSvc:

Public Member Functions
	DatabaseSvc (const std::string &name, ISvcLocator *sl)
virtual	~DatabaseSvc ()
virtual StatusCode	initialize ()
virtual StatusCode	finalize ()
int	query (const std::string &dbName, const std::string &sql)
int	query (const std::string &dbName, const std::string &sql, DatabaseRecordVector &res)

Friends
class	SvcFactory< DatabaseSvc >

Detailed Description

Definition at line 13 of file DatabaseSvc.h.

Constructor & Destructor Documentation

DatabaseSvc()

DatabaseSvc::DatabaseSvc	(	const std::string &	name,
		ISvcLocator *	sl
	)

Definition at line 23 of file DatabaseSvc.cxx.

                                                                 : base_class( name, sl )
{
  // Set the name of this service
  if ( IDatabaseSvc::g_serviceInUse != "" ) {
    std::ostringstream error;
    error << "There is another IDatabaseSvc registered with name "
          << IDatabaseSvc::g_serviceInUse << std::ends;
    throw "Error in DatabaseSvc: "+error.str();
  }
  IDatabaseSvc::g_serviceInUse = "DatabaseSvc";
 
  // declare properties
  declareProperty("Host",m_dbHost="");
  declareProperty("User",m_dbUser="guest");
  declareProperty("Passwd",m_dbPasswd="guestpass");
  declareProperty("Port", m_dbPort=3306);
  declareProperty("SqliteDbPath",m_dbFilePath="");
  declareProperty("DbType",m_dbType="SQLITE");
  declareProperty("ReuseConnection",m_dbReuseConnection=false);
}

~DatabaseSvc()

DatabaseSvc::~DatabaseSvc ( )

virtual

Definition at line 46 of file DatabaseSvc.cxx.

{
  if (dbInterface)
    delete dbInterface;
}

Member Function Documentation

finalize()

StatusCode DatabaseSvc::finalize ( )

virtual

Definition at line 151 of file DatabaseSvc.cxx.

{
  MsgStream log( msgSvc(), name() );
  StatusCode status = Service::finalize();
  if ( ! status.isSuccess() ) {
    log << MSG::ERROR << "Unable to finalize the Service" << endreq;
    return status;
  }
 
  if(dbInterface)
    {
      if(dbInterface->is_connected())
    dbInterface->disconnect();
      delete dbInterface;
      dbInterface = NULL;
    }
 
  log << MSG::INFO << "DatabaseSvc finalized successfully" << endreq;
  return StatusCode::SUCCESS;
}

initialize()

StatusCode DatabaseSvc::initialize ( )

virtual

Definition at line 68 of file DatabaseSvc.cxx.

{
  StatusCode status = Service::initialize();
  if ( !status.isSuccess() ) return status;
 
  MsgStream log( msgSvc(), name() );
  IDatabaseSvc::g_serviceInUse = name();
  setProperties();
 
  bool use_sqlite = false;
  bool use_mysql = false;
 
  std::transform(m_dbType.begin(), m_dbType.end(), m_dbType.begin(), ::toupper);
 
  if(m_dbType=="MYSQL")
    use_mysql = true;
 
  if(m_dbType=="SQLITE")
    use_sqlite = true;
 
  log << MSG::DEBUG << "Using " << m_dbType
      << " interface with options:" << endreq;
 
  try {
    if(use_mysql)
      {
    log << MSG::DEBUG << "  dbHost " << m_dbHost << endreq;
    log << MSG::DEBUG << "  dbPort " << m_dbPort << endreq;
    log << MSG::DEBUG << "  dbUser " << m_dbUser << endreq;
    log << MSG::DEBUG << "  dbPasswd " << m_dbPasswd << endreq;
 
    dbInterface = new MysqlInterface();
    dbInterface->set_host(m_dbHost);
    dbInterface->set_port(m_dbPort);
    dbInterface->set_user(m_dbUser);
    dbInterface->set_passwd(m_dbPasswd);
      }
    else if(use_sqlite)
      {
    log << MSG::DEBUG << "  dbFilepath " << m_dbFilePath << endreq;
 
    dbInterface = new SqliteInterface();
    dbInterface->set_dbpath(m_dbFilePath);
      }
    else
      {
    log << MSG::FATAL << "No valid database type is set. Please choose either MYSQL or SQLITE " << endreq;
    return StatusCode::FAILURE;
      }
 
    if(m_dbReuseConnection)
      log << MSG::DEBUG << "One connection per job is used" << endreq;
    else
      log << MSG::DEBUG << "One connection per query is used" << endreq;
 
    if( m_dbReuseConnection )
      {
    dbInterface->set_reuse_connection(true);
    dbInterface->connect();
      }
 
  } catch ( std::exception &e ) {
 
    log << MSG::FATAL << "Exception in DataSvc initialization:" << endreq;
    log << MSG::FATAL << "***  error message: " << e.what()         << endreq;
    return StatusCode::FAILURE;
 
  } catch (char* mess) {
    log << MSG::FATAL << "Exception DataSvc initialization caught: " << mess << endreq;
    return StatusCode::FAILURE;
  }
  catch (...) {
    log << MSG::FATAL << "UNKNOWN exception in DataSvc session initialization caught" << endreq;
    return StatusCode::FAILURE;
  }
 
  log << MSG::INFO << "DatabaseSvc initialized successfully" << endreq;
  return StatusCode::SUCCESS;
}

query() [1/2]

int DatabaseSvc::query	(	const std::string &	dbName,
		const std::string &	sql
	)

Definition at line 288 of file DatabaseSvc.cxx.

{
#ifndef BEAN
  MsgStream log( msgSvc(), name() );
 
  log << MSG::DEBUG << "Query database " << dbName << " SQL: " << sql << endreq;
#endif
 
  try{
    int status = dbInterface->query(dbName, sql);
    if (status<0)
      {
#ifndef BEAN
    log << MSG::ERROR << "Query " << sql << " failed" << endreq;
#else
        cerr << "Query " << sql << " failed" << endl;
#endif
    return -1;
      }
  }
  catch(...)
    {
#ifndef BEAN
      log << MSG::ERROR << "Could not execute query " << sql << endreq;
#else
      cerr << "Could not execute query " << sql << endl;
#endif
      return -1;
    }
 
  return 0;
}

Referenced by FieldDBUtil::ConnectionDB::getReadSC_MagnetInfo().

query() [2/2]

int DatabaseSvc::query	(	const std::string &	dbName,
		const std::string &	sql,
		DatabaseRecordVector &	res
	)

Definition at line 250 of file DatabaseSvc.cxx.

{
#ifndef BEAN
  MsgStream log( msgSvc(), name() );
 
  //maqm log << MSG::DEBUG << "Query database " << dbName << " SQL: " << sql << endreq;
#endif
 
  result.clear();
 
  try{
    int status = dbInterface->query(dbName, sql, result);
    if (status<0)
      {
#ifndef BEAN
    log << MSG::ERROR << "Query " << sql << " failed" << endreq;
#else
        cout << "Query " << sql << " failed" << endl;
#endif
    return -1;
      }
  }
  catch(...)
    {
#ifndef BEAN
      log << MSG::ERROR << "Could not execute query " << sql << endreq;
#else
      cout << "Could not execute query " << sql << endl;
#endif
      return -1;
    }
 
  return result.size();
}

Friends And Related Function Documentation

SvcFactory< DatabaseSvc >

friend class SvcFactory< DatabaseSvc >

friend

Definition at line 1 of file DatabaseSvc.h.

---

The documentation for this class was generated from the following files:

• DatabaseSvc.h
• DatabaseSvc.cxx