DbiValRecSet.cxx

Go to the documentation of this file.

// $Id: DbiValRecSet.cxx,v 1.5 2006/08/08 10:51:32 west Exp $

#include "DatabaseInterface/DbiDBProxy.h"
#include "DatabaseInterface/DbiResultNonAgg.h"
#include "DatabaseInterface/DbiResultSet.h"
#include "DatabaseInterface/DbiTableProxy.h"
#include "DatabaseInterface/DbiTableProxyRegistry.h"
#include "DatabaseInterface/DbiValidityRec.h"
#include "DatabaseInterface/DbiValRecSet.h"
#include "LeakChecker/Lea.h"
#include "MessageService/MsgService.h"

ClassImp(DbiValRecSet)


//   Definition of static data members
//   *********************************

CVSID("$Id: DbiValRecSet.cxx,v 1.5 2006/08/08 10:51:32 west Exp $");

//    Definition of all member functions (static or otherwise)
//    *******************************************************
//
//    -  ordered: ctors, dtor, operators then in alphabetical order.

//.....................................................................

DbiValRecSet::DbiValRecSet(const string& tableName,UInt_t dbNo,UInt_t seqNo) :
fDbNo(dbNo),
fResult(0)
{
//
//
//  Purpose:  Constructor
//
//  Arguments:
//    tableName    in    Table Name whose DbiValidityRecs are required.
//    dbNo         in    Database number in the cascade.
//    seqNo        in    Just this SEQNO if >0 or all if 0 [default: 0]
//
//  Return:    n/a
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o  For the required table in the required database, load every
//     DbiValidityRec into DbiResult.


//  Program Notes:-
//  =============

//  None.

  LEA_CTOR    //Leak Checker

  MSG("Dbi", Msg::kVerbose) << "Creating DbiValRecSet" << endl;

// Get Db proxy for the table.
  DbiValidityRec pet;
  const DbiDBProxy& proxy = DbiTableProxyRegistry::Instance()
                           .GetTableProxy(tableName,&pet)
                           .GetDBProxy(); 

// Collect up all validity records.
  DbiResultSet* rset = proxy.QueryAllValidities(dbNo,seqNo);
  fResult = new DbiResultNonAgg(rset,&pet,0,kFALSE);
  delete rset;

 
}


//.....................................................................

DbiValRecSet::~DbiValRecSet() {
//
//
//  Purpose: Destructor
//
//  Arguments: 
//    None.
//
//  Return:    n/a
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o  Destroy RowStream.


//  Program Notes:-
//  =============

//  None.

  LEA_DTOR    //Leak Checker

  MSG("Dbi", Msg::kVerbose) << "Destroying DbiValRecSet" << endl;
  delete fResult;

}

//.....................................................................

UInt_t DbiValRecSet::GetNumRows() const {
//
//
//  Purpose:  Return the number of rows.
//
//  Arguments: None.
//
//  Return:    
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Return the number of rows.

//  Program Notes:-
//  =============

//  None.

  return fResult ? fResult->GetNumRows() : 0;
}

//.....................................................................

const string DbiValRecSet::GetTableName() const {
//
//
//  Purpose:  Return the table name.
//
//  Arguments: None.
//
//  Return:    
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Return the table name.

//  Program Notes:-
//  =============

//  None.

  return fResult ? fResult->TableName() : "Unknown";
}

//.....................................................................

const DbiValidityRec* DbiValRecSet::GetTableRow(UInt_t rowNum) const {
//
//
//  Purpose:  Return DbiValidityRec at supplied row number.
//
//  Arguments: 
//    rowNum      in    Row number whose entry is required or 0 if none.
//
//  Return:    
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Return DbiValidityRec at supplied row number.

//  Program Notes:-
//  =============

//  None.

    return fResult ?
      dynamic_cast<const DbiValidityRec*>(fResult->GetTableRow(rowNum))
    : 0;
}

//.....................................................................

const DbiValidityRec* DbiValRecSet::GetTableRowBySeqNo(UInt_t seqNo
                                                               ) const {
//
//
//  Purpose:  Return DbiValidityRec having supplied SeqNo.
//
//  Arguments: 
//    seqNo        in    Sequence number of required entry or 0 if none.
//
//  Return:    
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Return DbiValidityRec at supplied row number.

//  Program Notes:-
//  =============

//  None.

  UInt_t numRows = GetNumRows();
  if ( numRows == 0 ) return 0;

// Create look-up table if not yet built.

  if ( fSeqNoToRec.size() == 0 ) {
    for ( UInt_t irow = 0; irow < numRows; ++irow) {
      const DbiValidityRec* vrec = GetTableRow(irow);
      fSeqNoToRec[vrec->GetSeqNo()] = vrec;
    }
  }

  map<UInt_t,const DbiValidityRec*>::const_iterator itr = fSeqNoToRec.find(seqNo);
  return ( itr == fSeqNoToRec.end() ) ? 0 : itr->second;

}

---