---

DbDatabaseCnv.cpp

Go to the documentation of this file.

//------------------------------------------------------------------------------
//
// Implementation of class :  DbDatabaseCnv
//
// Author :                   Markus Frank
//
//------------------------------------------------------------------------------
// $Header: /nfs/slac/g/glast/ground/cvs/GaudiDb/src/NTuples/DbDatabaseCnv.cpp,v 1.1.1.1 2001/04/18 21:13:35 tlindner Exp $
#define DBCNV_DBDATABASECNV_CPP

// Include files
#include "DbDatabaseCnv.h"
#include "GaudiDb/DbFederation.h"
#include "GaudiDb/IDataBaseMgr.h"
#include "GaudiDb/DbCnvFactory.h"

#include "GaudiKernel/IConversionSvc.h"
#include "GaudiKernel/IOpaqueAddress.h"
#include "GaudiKernel/MsgStream.h"
#include "GaudiKernel/NTuple.h"

// Factory declaration
static DbOOMsCnvFactory<DbDatabaseCnv> s_factory;
const ICnvFactory& DbOOMsDbDatabaseCnvFactory = s_factory;

DbDatabaseCnv::DbDatabaseCnv(IOODataBase* db, ISvcLocator* svc)
: DbDirectoryCnv(classID(), db, svc),
  m_cnvSvc(0)
{
}

DbDatabaseCnv::~DbDatabaseCnv()   {
  if ( m_cnvSvc ) m_cnvSvc->release();
  m_cnvSvc = 0;
}

// Inquire class type (used by factory)
const CLID& DbDatabaseCnv::classID()    {
  return CLID_NTupleFile;
}

// Initialize the converter
StatusCode DbDatabaseCnv::initialize()   {
  StatusCode status = DbDirectoryCnv::initialize();
  MsgStream log(messageService(),"DbDirectoryCnv");
  if ( !status.isSuccess() )   {
    log << MSG::ERROR << "Cannot initialize base class \"DbDirectoryCnv\"" << endreq;
    return status;
  }
  status = m_dbaseMgr->queryInterface(IID_IConversionSvc, (void**)&m_cnvSvc);
  if ( !status.isSuccess() )    {
    log << MSG::ERROR << "Cannot connect to \"" << m_svcName << "\"(IConversionSvc)" << endreq;
    return status;
  }
  return status;
}

// Finalize the Db converter 
StatusCode DbDatabaseCnv::finalize()   {
  if ( m_cnvSvc ) m_cnvSvc->release();
  m_cnvSvc = 0;
  return DbDirectoryCnv::finalize();
}

// Create database object
StatusCode DbDatabaseCnv::createObj(IOpaqueAddress* pAddress, DataObject*& refpObject)   {
  StatusCode status = StatusCode::FAILURE;
  MsgStream log(msgSvc(), "DbDatabaseCnv");
  dbHandle<DbFederation>& fedH = m_dbaseMgr->defaultFederationHdl();
  if ( fedH.isValid() )   {
    char mode = char(pAddress->genericLink()->genericInfo()->m_info[1]);
    std::string fname   = pAddress->dbName();
    std::string oname   = pAddress->objectName();
    bool exists = fedH.existsDbase(fname);
    bool create = mode == 'N';
    bool update = mode == 'U';
    bool read   = mode == 'O';
    status = StatusCode::SUCCESS;
    if ( !exists && create )    {
      status = m_cnvSvc->connectOutput(fname);
      if ( status.isSuccess() )   {
        log << MSG::INFO << "Opened NEW Database file:" << fname 
            << " as " << oname << endreq;
      }
    }
    else if ( exists && update )    {
      status = m_cnvSvc->connectOutput(fname);
      if ( status.isSuccess() )   {
        log << MSG::INFO << "Connect to existing Database file:" << fname 
            << " as " << oname << " for UPDATE" << endreq;
      }
    }
    else if ( exists && read )    {
      log << MSG::INFO << "Connect to existing Database file:" << fname 
          << " as " << oname << " for READ" << endreq;
    }
    else if ( exists && create )   {
      log << MSG::ERROR << "Cannot recreate existing database:" << fname << endreq;
      status = StatusCode::FAILURE;
    }
    else    {
      log << MSG::ERROR << "Don't know what to do:" << fname << endreq;
      status = StatusCode::FAILURE;
    }
    // Now create object
    if ( status.isSuccess() )   {
      NTuple::File* pFile = new NTuple::File(objType(), fname, oname);
      pFile->setOpen(false);
      refpObject = pFile;
    }
  }
  return status;
}

---