DbiResultPtr.tpl

Go to the documentation of this file.

// $Id: DbiResultPtr.tpl,v 1.10 2009/04/18 07:59:14 west Exp $

#include <cassert>

#include "DatabaseInterface/DbiResultKey.h"
#include "DatabaseInterface/DbiResultPtr.h"
#include "DatabaseInterface/DbiSqlContext.h"
#include "DatabaseInterface/DbiTableProxy.h"
#include "DatabaseInterface/DbiTimerManager.h"
#include "LeakChecker/Lea.h"
#include "MessageService/MsgService.h"
#include "Validity/VldTimeStamp.h"

#include <cstdlib>

ClassImpT(DbiResultPtr,T)

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

//CVSID("$Id: DbiResultPtr.tpl,v 1.10 2009/04/18 07:59:14 west Exp $");

template<class T>
map<string,DbiTableProxy*>  DbiResultPtr<T>::fgNameToProxy;

template<class T>
DbiTableProxy* DbiResultPtr<T>::fgTableProxy = 0;


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

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

template<class T>
DbiResultPtr<T>::DbiResultPtr() :
fAbortTest(Dbi::kDisabled),
fTableProxy(DbiResultPtr<T>::GetTableProxy()),
fResult(0),
fDetType(Detector::kUnknown),
fSimType(SimFlag::kUnknown )
{
//
//
//  Purpose:  Default constructor
//
//  Arguments: None
//
//  Return:    n/a
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Create ResultPtr.


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

//  None.

  LEA_CTOR    //Leak Checker

  T pet;
  MSG("Dbi", Msg::kVerbose) 
        << "Creating DbiResultPtr for " << pet.GetName()
        << " Table Proxy at " << &fTableProxy << endl;
}
//.....................................................................

template<class T>
DbiResultPtr<T>::DbiResultPtr(const DbiResultPtr& that) :
fAbortTest(that.fAbortTest),
fTableProxy(that.fTableProxy),
fResult(that.fResult),
fDetType(that.fDetType),
fSimType(that.fSimType)
{
//
//
//  Purpose:  Copy constructor

  LEA_CTOR    //Leak Checker

  T pet;
  MSG("Dbi", Msg::kVerbose) 
        << "Creating copy DbiResultPtr for " << pet.GetName()
        << " Table Proxy at " << &fTableProxy << endl;
  if ( fResult ) fResult->Connect();

}

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

template<class T>
DbiResultPtr<T>::DbiResultPtr(const VldContext& vc, 
                              Dbi::Task task,
                              Dbi::AbortTest abortTest,
                              Bool_t findFullTimeWindow) :
fAbortTest(abortTest),
fTableProxy(DbiResultPtr<T>::GetTableProxy()),
fResult(0),
fDetType(vc.GetDetector()),
fSimType(vc.GetSimFlag())
{
//
//
//  Purpose:  Construct and apply context specific query to default table.
//
//  Arguments: 
//    vc           in    The Validity Context of the new query
//    task         in    The task of the new query
//    abortTest    in    Test which if failed triggers abort.
//    findFullTimeWindow
//                 in    Attempt to find full validity of query 
//                        i.e. beyond Dbi::GetTimeGate
//
//  Return:    n/a
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Create ResultPtr.


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

//  None.

  LEA_CTOR    //Leak Checker

  T pet;
  MSG("Dbi", Msg::kVerbose) << "Creating DbiResultPtr for " 
                          << pet.GetName() << " Table Proxy at " 
                          << &fTableProxy << endl;
  NewQuery(vc, task, findFullTimeWindow);

}

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

template<class T>
DbiResultPtr<T>::DbiResultPtr(const string& tableName,
                              const VldContext& vc, 
                              Dbi::Task task,
                              Dbi::AbortTest abortTest,
                              Bool_t findFullTimeWindow) :
fAbortTest(abortTest),
fTableProxy(DbiResultPtr<T>::GetTableProxy(tableName)),
fResult(0),
fDetType(vc.GetDetector()),
fSimType(vc.GetSimFlag())
{
//
//
//  Purpose:  Construct and apply context specific query to alternative table.
//
//  Arguments: 
//    tableName    in    Name of table to use.
//    vc           in    The Validity Context of the new query
//    task         in    The task of the new query
//    abortTest    in    Test which if failed triggers abort.
//    findFullTimeWindow
//                 in    Attempt to find full validity of query 
//                        i.e. beyond Dbi::GetTimeGate
//  Return:    n/a
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Create ResultPtr.


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

//  None.

  LEA_CTOR    //Leak Checker

  MSG("Dbi", Msg::kVerbose) << "Creating DbiResultPtr for " 
                          << tableName << " Table Proxy at " 
                          << &fTableProxy << endl;
  NewQuery(vc, task, findFullTimeWindow);

}
//.....................................................................

template<class T>
DbiResultPtr<T>::DbiResultPtr(const string& tableName,
                              const DbiSqlContext& context,
                              const Dbi::Task& task, 
                              const string& data,
                              const string& fillOpts,
                              Dbi::AbortTest abortTest) :
fAbortTest(abortTest),
fTableProxy(DbiResultPtr<T>::GetTableProxy(tableName)),
fResult(0),
fDetType(context.GetDetector()),
fSimType(context.GetSimFlag())
{
//
//
//  Purpose:  Apply an extended context query to alternative table.
//
//  Arguments: 
//    tableName    in    Name of table to use.
//    context      in    The Validity Context (see DbiSqlContext)
//    task         in    The task of the query. Default: Dbi::kAnyTask, 
//    data         in    Optional SQL extension to secondary query. Default: "".
//    fillOpts     in    Optional fill options (available to DbiTableRow)
//                       Default: "".
//    abortTest    in    Test which if failed triggers abort.
//
//  Return:    n/a
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Create ResultPtr.


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

//  None.

  LEA_CTOR    //Leak Checker

  T pet;
  MSG("Dbi", Msg::kVerbose) << "Creating DbiResultPtr for " 
           << tableName << " Table Proxy at " 
           << &fTableProxy << endl
           << "Extended context " << context.GetString() << endl;

  NewQuery(context,task,data,fillOpts);

}

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

template<class T>
DbiResultPtr<T>::DbiResultPtr(const string& tableName,
                              const DbiValidityRec& vrec,
                              Dbi::AbortTest abortTest) :
fAbortTest(abortTest),
fTableProxy(DbiResultPtr<T>::GetTableProxy(tableName)),
fResult(0)
{
//
//
//  Purpose:  Apply context specific query to alternative table.
//
//  Arguments: 
//    tableName    in    Name of table to use.
//    vrec         in    The validity record that satisfies the query.
//    abortTest    in    Test which if failed triggers abort.
//
//  Return:    n/a
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Create ResultPtr.


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

//  None.

  LEA_CTOR    //Leak Checker

  this->SetContext(vrec);
  T pet;
  MSG("Dbi", Msg::kVerbose) << "Creating DbiResultPtr for " 
                          << tableName << " Table Proxy at " 
                          << &fTableProxy << endl;
  NewQuery(vrec);

}
//.....................................................................

template<class T>
DbiResultPtr<T>::DbiResultPtr(const string& tableName,
                              UInt_t seqNo,
                              UInt_t dbNo,
                              Dbi::AbortTest abortTest) :
fAbortTest(abortTest),
fTableProxy(DbiResultPtr<T>::GetTableProxy(tableName)),
fResult(0)
{
//
//
//  Purpose:  Apply context specific query to alternative table.
//
//  Arguments: 
//    tableName    in    Name of table to use.
//    seqno        in    The SEQNO of validity record that satisfies the query.
//    dbNo         in    The database number holding the validity record
//    abortTest    in    Test which if failed triggers abort.
//
//  Return:    n/a
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Create ResultPtr.


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

//  None.

  LEA_CTOR    //Leak Checker

  
  T pet;
  MSG("Dbi", Msg::kVerbose) << "Creating DbiResultPtr for " 
                          << tableName << " Table Proxy at " 
                          << &fTableProxy << endl;
  NewQuery(seqNo,dbNo);

}

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

template<class T>
DbiResultPtr<T>::~DbiResultPtr() {
//
//
//  Purpose: Destructor
//
//  Arguments: 
//    None.
//
//  Return:    n/a
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o  Disconnect any associated Results and destroy DbiResultPtr.


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

//  None.

  LEA_DTOR    //Leak Checker

  MSG("Dbi", Msg::kVerbose) << "Destroying DbiResultPtr" << endl;
  Disconnect();

}
//.....................................................................

template<class T>
Bool_t DbiResultPtr<T>::ApplyAbortTest() {
//
//
//  Purpose:  Apply abort test and return true if must abort.

  if (    fAbortTest == Dbi::kDisabled
       || this->GetNumRows() > 0 ) return kFALSE;

  bool tableExists = fTableProxy.TableExists();

  if ( ! tableExists ) {
    MSG("Dbi",Msg::kFatal) << "Fatal error: table " 
                           << fTableProxy.GetTableName() << " does not exist"
                           << endl;
    return kTRUE;
  }
  if ( fAbortTest == Dbi::kDataMissing) {
    MSG("Dbi",Msg::kFatal) << "Fatal error: no data found in existing table  " 
                           << fTableProxy.GetTableName() << endl;
    return kTRUE;
  }

  return kFALSE;
}

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

template<class T>
void DbiResultPtr<T>::Disconnect() {
//
//
//  Purpose: Disconnect previous results. 
//
//  Arguments: None.
//
//  Return:   None. 
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o  Disconnect any previous results. 

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

//  The Disconnect message is sent to DbiResult so that DbiCache
//  knows when its DbiResult objects are free of clients.

  if ( fResult && DbiTableProxyRegistry::IsActive() ) {
    fResult->Disconnect();
  }
  fResult = 0;

}
//.....................................................................

template<class T>
const DbiResultKey* DbiResultPtr<T>::GetKey() const {
//
//
//  Purpose:  Return associated result key or an empty one if none exists.
//

  return fResult ? fResult->GetKey() : DbiResultKey::GetEmptyKey();

}
//.....................................................................

template<class T>
Int_t DbiResultPtr<T>::GetResultID() const {
//
//
//  Purpose:  Return the ID of the current DbiResult.
//
  return fResult ? fResult->GetID() : 0;

}
//.....................................................................

template<class T>
DbiTableProxy& DbiResultPtr<T>::GetTableProxy() {
//
//
//  Purpose:  Private static function to find default associated 
//            DbiTableProxy.
//
//  Arguments: None.
//    
//
//  Return:   Associated DbiTableProxy. 
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Ask Registry for default Table Proxy and return it.

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

//  This function creates an example Table Row object which
//  DbiTableProxy can copy and then use to make futher copies when 
//  processing Result Sets.

  if ( ! fgTableProxy ) {
    T pet;
    fgTableProxy = &DbiTableProxyRegistry::Instance()
                                     .GetTableProxy(pet.GetName(),&pet);
  }
  return *fgTableProxy;
}

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

template<class T>
DbiTableProxy& DbiResultPtr<T>::GetTableProxy(const string& tableName){
//
//
//  Purpose:  Private static function to find an alternative 
//            associated DbiTableProxy.
//
//  Arguments: 
//    tableName    in    Alternative table name
//
//  Return:   Associated DbiTableProxy. 
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Ask Registry for alternative  Table Proxy and return it.

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

//  This function creates an example Table Row object which
//  DbiTableProxy can copy and then use to make futher copies when 
//  processing Result Sets.


// Check for request for default table.
  if ( tableName == "" ) return  DbiResultPtr::GetTableProxy();

// See if we have seen this name before.
  map<string,DbiTableProxy*>::const_iterator itr
                                        = fgNameToProxy.find(tableName);
  if ( itr != fgNameToProxy.end() ) return *( (*itr).second );
  
// No, so ask the Registry for it and save it for next time.
  T pet;
  DbiTableProxy* proxy = &DbiTableProxyRegistry::Instance()
                                     .GetTableProxy(tableName,&pet);
  fgNameToProxy[tableName] = proxy;
  return *proxy;
}

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

template<class T>
UInt_t DbiResultPtr<T>::GetNumRows() const {
//
//
//  Purpose:  Get number or rows in query.
//
//  Arguments: None.
//    
//
//  Return:    Number of rows found in query, = 0 if no or failed query.
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Return number of rows found in query, = 0 if no or failed query.


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

//  None.

  return ( fResult && DbiTableProxyRegistry::IsActive() ) 
          ? fResult->GetNumRows() : 0;

}
//.....................................................................

template<class T>
const T* DbiResultPtr<T>::GetRow(UInt_t rowNum) const {
//
//
//  Purpose: Return pointer to concrete Table Row object at given row.  
//
//  Arguments: 
//    rowNum       in    Required row number
//
//  Return:        Pointer to concrete Table Row object at given row, 
//                 =0 if none 
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Return pointer to concrete Table Row object at given row or 
//    0 if none.

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

// None.

  return ( fResult && DbiTableProxyRegistry::IsActive() ) ?
      dynamic_cast<const T*>(fResult->GetTableRow(rowNum))
    : 0;
}
//.....................................................................

template<class T>
const T* DbiResultPtr<T>::GetRowByIndex(UInt_t index) const {
//
//
//  Purpose: Return pointer to concrete Table Row object at given index.
//
//  Arguments: 
//    rowNum       in    Required index number.
//
//  Return:        Pointer to concrete Table Row object at given index, 
//                 =0 if none 
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Return pointer to concrete Table Row object at given index or 
//    0 if none.

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

//  None.

  return ( fResult && DbiTableProxyRegistry::IsActive() ) ?
      dynamic_cast<const T*>(fResult->GetTableRowByIndex(index))
    : 0;
}

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

template<class T>
const DbiValidityRec* DbiResultPtr<T>::GetValidityRec(
                              const DbiTableRow* row) const {
//
//
//  Purpose:  Return associated DbiValidityRec (if any).
//
//  Contact:   N. West

  return ( fResult && DbiTableProxyRegistry::IsActive() )
      ? &(fResult->GetValidityRec(row)) : 0 ;
 
}

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

template<class T>
UInt_t DbiResultPtr<T>::NextQuery(Bool_t forwards) {
//
//
//  Purpose:  Get next validity range for previous query.
//
//  Arguments: 
//    forwards     in    true to step direction forwards (default)
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Take the validity range of the current query and step across 
//    the boundary to the adjacent range.


// Door stops.
  static VldTimeStamp startOfTime(0,0);
  static VldTimeStamp endOfTime(0x7FFFFFFF,0);

  if ( ! fResult ) return 0;

  MSG("Dbi",Msg::kSynopsis)  << "\n\nStarting next query: direction " 
                             << ( forwards ?  "forwards" : "backwards" ) << "\n" << endl;

  const DbiValidityRec& vrec = fResult->GetValidityRec();
  const VldRange& vrnge      = vrec.GetVldRange();

  // If we are heading towards the final boundary, just return the same query.
  if (   forwards && vrnge.GetTimeEnd()   == endOfTime )   return fResult->GetNumRows();
  if ( ! forwards && vrnge.GetTimeStart() == startOfTime ) return fResult->GetNumRows();

  // Step across boundary and construct new context.
  // The end time limit is exclusive, so stepping to the end
  // does cross the boundary
  time_t ts = forwards ? vrnge.GetTimeEnd().GetSec()
                       : vrnge.GetTimeStart().GetSec() - 1;
  VldContext vc(fDetType,fSimType,VldTimeStamp(ts,0));

  return this->NewQuery(vc,vrec.GetTask(), true);

}


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

template<class T>
UInt_t DbiResultPtr<T>::NewQuery(VldContext vc, 
                                 Dbi::Task task,
                                 Bool_t findFullTimeWindow) {
//
//
//  Purpose:  Apply new query.
//
//  Arguments: 
//    vc           in    The Validity Context of the new query
//    task         in    The task of the new query
//    findFullTimeWindow
//                 in    Attempt to find full validity of query 
//                        i.e. beyond Dbi::GetTimeGate
//
//
//  Return:    The number of rows retrieved by query.  =0 if error.
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Disconnect any previous results and apply new query to
//    associated database table

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

//  None.

  if ( ! DbiTableProxyRegistry::IsActive() ) {
    fResult = 0;
    return 0;
  }
  fDetType = vc.GetDetector();
  fSimType = vc.GetSimFlag();

  MSG("Dbi",Msg::kSynopsis)  << "\n\nStarting context query: " 
                             << vc  << " task " << task << "\n" << endl;

  DbiTimerManager::gTimerManager.RecBegin(fTableProxy.GetTableName(), sizeof(T));
  Disconnect();
  fResult = fTableProxy.Query(vc,task,findFullTimeWindow);
  fResult->Connect();
  DbiTimerManager::gTimerManager.RecEnd(fResult->GetNumRows());

  if ( this->ApplyAbortTest() ) {
    MSG("Dbi",Msg::kFatal) << "while applying validity context query for "
                           << vc.AsString() << " with task " << task << endl;
    abort();
  }
  MSG("Dbi",Msg::kSynopsis)  << "\nCompleted context query: " 
                             << vc  << " task " << task 
                             << " Found:  " << fResult->GetNumRows() << " rows\n" << endl;
  return fResult->GetNumRows();

}
//.....................................................................

template<class T>
UInt_t DbiResultPtr<T>::NewQuery(const DbiSqlContext& context,
                                 const Dbi::Task& task, 
                                 const string& data,
                                 const string& fillOpts) {
//
//
//  Purpose:  Apply new query.
//
//  Arguments: 
//    context      in    The Validity Context (see DbiSqlContext)
//    task         in    The task of the query. Default: 0
//    data         in    Optional SQL extension to secondary query. Default: "".
//    fillOpts     in    Optional fill options (available to DbiTableRow)
//
//
//  Return:    The number of rows retrieved by query.  =0 if error.
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Disconnect any previous results and apply new query to
//    associated database table

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

//  None.

  if ( ! DbiTableProxyRegistry::IsActive() ) {
    fResult = 0;
    return 0;
  }
  fDetType = context.GetDetector();
  fSimType = context.GetSimFlag();

  MSG("Dbi",Msg::kSynopsis)  << "\n\nStarting extended context query: " 
                             << context.GetString()  << " task " << task 
                             << " data " << data << " fillOpts " << fillOpts << "\n" <<endl;

  DbiTimerManager::gTimerManager.RecBegin(fTableProxy.GetTableName(), sizeof(T));
  Disconnect();
  fResult = fTableProxy.Query(context.GetString(),task,data,fillOpts);
  fResult->Connect();
  DbiTimerManager::gTimerManager.RecEnd(fResult->GetNumRows());
  if ( this->ApplyAbortTest() ) {
    MSG("Dbi",Msg::kFatal) << "while applying extended context query for "
                           <<  context.c_str()<< " with task " << task 
                           << " secondary query SQL: " << data
                           << "  and fill options: " << fillOpts << endl;
    abort();
  }

  MSG("Dbi",Msg::kSynopsis)  << "\n\nCompleted extended context query: " 
                             << context.GetString()  << " task " << task 
                             << " data " << data << " fillOpts" << fillOpts 
                             << " Found:  " << fResult->GetNumRows() << " rows\n" << endl;

  return fResult->GetNumRows();

}
//.....................................................................

template<class T>
UInt_t DbiResultPtr<T>::NewQuery(const DbiValidityRec& vrec) {
//
//
//  Purpose:  Apply new query.
//
//  Arguments: 
//    vrec         in    The validity record that satisfies the query.
//
//
//  Return:    The number of rows retrieved by query.  =0 if error.
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Disconnect any previous results and apply new query to
//    associated database table

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

//  None.

  if ( ! DbiTableProxyRegistry::IsActive() ) {
    fResult = 0;
    return 0;
  }
  MSG("Dbi",Msg::kSynopsis)  << "\n\nStarting DbiValidityRec query: " 
                             << vrec << "\n" << endl;

  this->SetContext(vrec);
  DbiTimerManager::gTimerManager.RecBegin(fTableProxy.GetTableName(), sizeof(T));
  Disconnect();

// Play safe and don't allow result to be used; it's validity may not
// have been trimmed by neighbouring records.
  fResult = fTableProxy.Query(vrec,kFALSE);
  fResult->Connect();
  DbiTimerManager::gTimerManager.RecEnd(fResult->GetNumRows());
  if ( this->ApplyAbortTest() ) {
    MSG("Dbi",Msg::kFatal) << "while applying validity rec query for "
                           << vrec << endl;
    abort();
  }
  MSG("Dbi",Msg::kSynopsis)  << "\n\nCompletedDbiValidityRec query: " 
                             << vrec 
                             << " Found:  " << fResult->GetNumRows() << " rows\n"  << endl;
  return fResult->GetNumRows();

}
//.....................................................................

template<class T>
UInt_t DbiResultPtr<T>::NewQuery(UInt_t seqNo,UInt_t dbNo) {
//
//
//  Purpose:  Apply new query.
//    seqno        in    The SEQNO of validity record that satisfies the query.
//    dbNo         in    The database number holding the validity record
//
//  Arguments: 
//
//
//  Return:    The number of rows retrieved by query.  =0 if error.
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Disconnect any previous results and apply new query to
//    associated database table

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

//  None.

  if ( ! DbiTableProxyRegistry::IsActive() ) {
    fResult = 0;
    return 0;
  }
  MSG("Dbi",Msg::kSynopsis)  << "\n\nStarting SeqNo query: " 
                             << seqNo << "\n" << endl;
  DbiTimerManager::gTimerManager.RecBegin(fTableProxy.GetTableName(), sizeof(T));
  Disconnect();
  fResult = fTableProxy.Query(seqNo,dbNo);
  fResult->Connect();
  DbiTimerManager::gTimerManager.RecEnd(fResult->GetNumRows());
  if ( this->ApplyAbortTest() ) {
    MSG("Dbi",Msg::kFatal) << "while applying SEQNO query for "
                           << seqNo << " on database " << dbNo << endl;
    abort();
  }
  this->SetContext(fResult->GetValidityRec());
  MSG("Dbi",Msg::kSynopsis)  << "\n\nCompleted SeqNo query: " 
                             << seqNo
                             << " Found:  " << fResult->GetNumRows() << " rows\n" << endl;
  return fResult->GetNumRows();

}

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

template<class T>
Bool_t DbiResultPtr<T>::ResultsFromDb() const {
//
//
//  Purpose: Return true if at least part of result comes directly from
//           database (as opposed to memory or level 2 disk cache). 

  return fResult ? fResult->ResultsFromDb() : kFALSE;

}
//.....................................................................

template<class T>
void DbiResultPtr<T>::SetContext(const DbiValidityRec& vrec) {
//
//
//  Purpose:  Attempt to construct context detector type and sim flag
//
//  Arguments: 
//    vrec         in    DbiValidityRec from which to construct context
//
//
//  Contact:   N. West
//

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

//  Queries that step to an adjacent validity range need a detector 
//  type and simulation flag from which to construct a context. However
//  queries can be made using a DbiValidityRec and then only a VldRange
//  is known so all we can do is choose representative values from
//  its detector and simulation masks.

  const VldRange& vrng = vrec.GetVldRange();
  Int_t detMask        = vrng.GetDetectorMask();
  Int_t simMask        = vrng.GetSimMask();

  fDetType = Detector::kUnknown;
  if      ( detMask & Detector::kFar )      fDetType = Detector::kFar;
  else if ( detMask & Detector::kNear)      fDetType = Detector::kNear;
  else if ( detMask & Detector::kCalDet)    fDetType = Detector::kCalDet;
  else if ( detMask & Detector::kCalib)     fDetType = Detector::kCalib;
  else if ( detMask & Detector::kTestStand) fDetType = Detector::kTestStand;
  else if ( detMask & Detector::kMapper)    fDetType = Detector::kMapper;

  fSimType = SimFlag::kUnknown;
  if      ( simMask & SimFlag::kData)        fSimType = SimFlag::kData;
  else if ( simMask & SimFlag::kMC)          fSimType = SimFlag::kMC;
  else if ( simMask & SimFlag::kReroot)      fSimType = SimFlag::kReroot;
  else if ( simMask & SimFlag::kDaqFakeData) fSimType = SimFlag::kDaqFakeData;

}

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

template<class T>
DbiTableProxy& DbiResultPtr<T>::TableProxy() const  {
//
//
//  Purpose:  Return associated DbiTableProxy (if any).
//
//  Contact:   N. West

  assert( DbiTableProxyRegistry::IsActive() );
  return fTableProxy; 
}

/*    Template for New Member Function

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

template<class T>
DbiResultPtr<T>:: {
//
//
//  Purpose:  
//
//  Arguments: 
//    xxxxxxxxx    in    yyyyyy
//
//  Return:    
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o 

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

//  None.


}

*/

---