---

DbFederationObj.cpp

Go to the documentation of this file.

//====================================================================
//      DbFederation handle implementation
//--------------------------------------------------------------------
//
//      Package    : DbCnv ( The LHCb Offline System)
//
//  Description: Generic data persistency
//
//      Author     : M.Frank
//====================================================================
#define DBCNV_DBFEDERATION_CPP

// Framework include files
#include "GaudiDb/DbOOMs.h"
#include "GaudiDb/IOODataBase.h"
#include "GaudiDb/DbFederation.h"
#include "GaudiDb/DbDataBase.h"
#include "GaudiDb/DbAccessObj.h"
#include "GaudiDb/DbSession.h"
#include "GaudiDb/DbObject.h"
#include "DbFederationObj.h"
#include "DbDataBaseObj.h"
#include "DbContainerObj.h"

// Gaudi Header files
#include "GaudiKernel/System.h"
#include "GaudiKernel/MsgStream.h"

DbFederation::DbFederation(const dbHandle<DbSession>& sessionH, const std::string& name, DbAccessMode mode)
: m_session(sessionH)
{
  m_name    = name;
  m_mode    = mode;
  m_info    = 0;
  m_type    = m_session.type();
  m_dbOOMs  = m_session.db();
  m_msgSvc  = m_session.msgSvc();
  if ( 0 == m_dbOOMs )    {
    MsgStream log(m_msgSvc, m_name);
    log << MSG::ERROR
        << "--> Access   DbFederation "
        << " Type:" << "UNKNOWN" 
        << " Mode:" << DbOOMs::accessMode(m_mode) 
        << " impossible. Cannot link to implementation."
        << endreq;
    return;
  }
  m_info = m_dbOOMs->createFederation();
  DbResult res = m_session.add( m_name, this );
  if ( DbOOMs::DbError == res )    {
    MsgStream log(m_msgSvc,m_name);
    log << MSG::ERROR
        << "--> Access   DbFederation "
        << " Type:" << m_dbOOMs->name() 
        << " Mode:" << DbOOMs::accessMode(m_mode) 
        << " impossible. Error inserting Federation!"
        << endreq;
    return;
  }
  MsgStream log(m_msgSvc,m_name);
  log << MSG::INFO
      << "--> Access   DbFederation "
      << " Type:" << m_dbOOMs->name() 
      << " Mode:" << DbOOMs::accessMode(m_mode) 
      << endreq;
}

DbFederation::~DbFederation()  {
  clearEntries();
  if ( m_session.isValid() )    {
    DbFederation* p = m_session.find(m_name);
    if ( p )   {
      m_session.remove ( p );
    }
  }
  if ( 0 != m_info )    {
    m_info->release();
  }
  MsgStream log(m_msgSvc,m_name);
  std::string dbtyp((m_dbOOMs) ? m_dbOOMs->name() : "UNKNOWN");
  log << MSG::INFO
      << "--> Deaccess DbFederation "
      << " Type:" << dbtyp
      << " Mode:" << DbOOMs::accessMode(m_mode) 
      << endreq;
}

bool DbFederation::existsDbase( const std::string& name )   const   {
  return (m_info) ? m_info->existsDbase( name ) : false;
}

DbResult DbFederation::open()   const   {
  return (m_info) ? m_info->open( m_session, m_name, m_mode ) : DbOOMs::DbError;
}

DbResult DbFederation::closeDataBases()  const  {
  DbFederation* fed = const_cast<DbFederation*>(this);
  iterator i = fed->begin(), stop = fed->end();
  while ( i != stop )   {
    (*i)->close();
    i = fed->begin();
    stop = fed->end();
  }
  if ( m_info )    {
    m_info->close();
  }
  return DbOOMs::DbSuccess;
}

DbResult DbFederation::close()   const   {
  if ( m_session.isValid() )    {
    closeDataBases();
    //std::cout << "--> Close    DbFederation  " << m_name << std::endl;
    DbFederation* p = m_session.find(m_name);
    if ( p )   {
      m_session.remove ( p );
    }
    m_session = dbHandle<DbSession>(m_type);
    return DbOOMs::DbSuccess;
  }
  return DbOOMs::DbError;
}

---