DatabaseSvc Class Reference

#include <DatabaseSvc.h>

Inheritance diagram for DatabaseSvc:

Public Member Functions
	DatabaseSvc (const std::string &name, ISvcLocator *sl)
	~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)
std::string &	serviceInUse ()

Detailed Description

Definition at line 12 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 ), m_serviceInuse( "" ), dbInterface( nullptr ) {
  // Set the name of this service
  if ( m_serviceInuse != "" )
  {
    std::ostringstream error;
    error << "There is another IDatabaseSvc registered with name " << m_serviceInuse
          << std::ends;
    throw "Error in DatabaseSvc: " + error.str();
  }
  m_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 );
}

Referenced by DatabaseSvc().

~DatabaseSvc()

DatabaseSvc::~DatabaseSvc

(

)

Definition at line 47 of file DatabaseSvc.cxx.

                          {
  if ( dbInterface ) delete dbInterface;
}

Member Function Documentation

finalize()

StatusCode DatabaseSvc::finalize ( )

virtual

Definition at line 146 of file DatabaseSvc.cxx.

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

initialize()

StatusCode DatabaseSvc::initialize ( )

virtual

Definition at line 66 of file DatabaseSvc.cxx.

                                   {
  StatusCode status = Service::initialize();
  if ( !status.isSuccess() ) return status;
 
  MsgStream log( msgSvc(), name() );
  // IDatabaseSvc::g_serviceInUse = name();
  m_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:" << endmsg;
 
  try
  {
    if ( use_mysql )
    {
      log << MSG::DEBUG << "    dbHost " << m_dbHost << endmsg;
      log << MSG::DEBUG << "    dbPort " << m_dbPort << endmsg;
      log << MSG::DEBUG << "    dbUser " << m_dbUser << endmsg;
      log << MSG::DEBUG << "    dbPasswd " << m_dbPasswd << endmsg;
 
      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 << endmsg;
 
      dbInterface = new SqliteInterface();
      dbInterface->set_dbpath( m_dbFilePath );
    }
    else
    {
      log << MSG::FATAL
          << "No valid database type is set. Please choose either MYSQL or SQLITE " << endmsg;
      return StatusCode::FAILURE;
    }
 
    if ( m_dbReuseConnection ) log << MSG::DEBUG << "One connection per job is used" << endmsg;
    else log << MSG::DEBUG << "One connection per query is used" << endmsg;
 
    if ( m_dbReuseConnection )
    {
      dbInterface->set_reuse_connection( true );
      dbInterface->connect();
    }
  } catch ( std::exception& e )
  {
 
    log << MSG::FATAL << "Exception in DataSvc initialization:" << endmsg;
    log << MSG::FATAL << "***  error message: " << e.what() << endmsg;
    return StatusCode::FAILURE;
  } catch ( char* mess )
  {
    log << MSG::FATAL << "Exception DataSvc initialization caught: " << mess << endmsg;
    return StatusCode::FAILURE;
  } catch ( ... )
  {
    log << MSG::FATAL << "UNKNOWN exception in DataSvc session initialization caught"
        << endmsg;
    return StatusCode::FAILURE;
  }
 
  log << MSG::INFO << "DatabaseSvc initialized successfully" << endmsg;
  return StatusCode::SUCCESS;
}

query() [1/2]

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

Definition at line 267 of file DatabaseSvc.cxx.

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

query() [2/2]

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

Definition at line 230 of file DatabaseSvc.cxx.

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

serviceInUse()

std::string & DatabaseSvc::serviceInUse ( )

inline

Definition at line 55 of file DatabaseSvc.h.

{ return m_serviceInuse; }

---

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

• DatabaseSvc.h
• DatabaseSvc.cxx