TDbiResultSetNonAgg.cxx File Reference

#include "TDbiBinaryFile.hxx"
#include "TDbiResultKey.hxx"
#include "TDbiResultSetNonAgg.hxx"
#include "TDbiInRowStream.hxx"
#include "TDbiTableRow.hxx"
#include "TDbiTimerManager.hxx"
#include <TSK_DBI_Log.hxx>
#include <MsgFormat.h>

Include dependency graph for TDbiResultSetNonAgg.cxx:

Go to the source code of this file.

Functions
	ClassImp (TDbiResultSetNonAgg) TDbiResultSetNonAgg

---

Function Documentation

ClassImp

(

TDbiResultSetNonAgg

)

     Purpose:  Default constructor
   
     Arguments:
         resultSet    in/out Pointer TDbiInRowStream from query. May be null.
         tableRow     in     Pointer to a sample tableRow object.
                             May be null.
         vrec         in     Pointer to validity record from query.
                             May be null
         dropSeqNo    in     If = kTRUE, drop SeqNo if it is the first col.
         sqlQualifier in     Extended Context sql qualifiers
   
     Return:    n/a
   
     Contact:   N. West
   
     Specification:-
     =============
   
     o Create Result from TDbiInRowStream generated by query.  If first
       column is named SeqNo then strip it off before filling each
       TDbiTableRow and quit as soon as the SeqNo changes.
   
   
     Program Notes:-
     =============
   
     o tableRow is just used to create new subclass TDbiTableRow objects.
   
     o  The special treatment for tables that start with SeqNo allow
        a single TDbiInRowStream to fill multiple TDbiResultSet objects but does
        require that the result set is ordered by SeqNo.
   
     The look-up table is not built by default, its construction is
     triggered by use (GetTableRowByIndex).  For TDbiResultSetNonAgg
     that are part of a TDbiResultSetAgg there is no need to build the
     table.
   

Definition at line 13 of file TDbiResultSetNonAgg.cxx.

References TDbiRowStream::CurColName(), TDbiRowStream::DecrementCurCol(), TDbiInRowStream::FetchRow(), TDbiTableRow::Fill(), TDbiTimerManager::gTimerManager, TDbiRowStream::IncrementCurCol(), TDbiInRowStream::IsBeforeFirst(), TDbiInRowStream::IsExhausted(), TDbiRowStream::IsVLDTable(), TDbiTimerManager::RecFillAgg(), TDbiTableRow::SetOwner(), SK_DBI_Info, and TDbiTimerManager::StartSubWatch().

                : ctors, dtor, operators then in alphabetical order.

//
//.....................................................................
///\verbatim
///  Purpose:  Default constructor
///
///  Arguments:
///      resultSet    in/out Pointer TDbiInRowStream from query. May be null.
///      tableRow     in     Pointer to a sample tableRow object.
///                          May be null.
///      vrec         in     Pointer to validity record from query.
///                          May be null
///      dropSeqNo    in     If = kTRUE, drop SeqNo if it is the first col.
///      sqlQualifier in     Extended Context sql qualifiers
///
///  Return:    n/a
///
///  Contact:   N. West
///
///  Specification:-
///  =============
///
///  o Create Result from TDbiInRowStream generated by query.  If first
///    column is named SeqNo then strip it off before filling each
///    TDbiTableRow and quit as soon as the SeqNo changes.
///
///
///  Program Notes:-
///  =============
///
///  o tableRow is just used to create new subclass TDbiTableRow objects.
///
///  o  The special treatment for tables that start with SeqNo allow
///     a single TDbiInRowStream to fill multiple TDbiResultSet objects but does
///     require that the result set is ordered by SeqNo.
///
///  The look-up table is not built by default, its construction is
///  triggered by use (GetTableRowByIndex).  For TDbiResultSetNonAgg
///  that are part of a TDbiResultSetAgg there is no need to build the
///  table.
///\endverbatim

TDbiResultSetNonAgg::TDbiResultSetNonAgg(TDbiInRowStream* resultSet,
                                 const TDbiTableRow* tableRow,
                                 const TDbiValidityRec* vrec,
                                 Bool_t dropSeqNo,
                                 const string& sqlQualifiers) :
TDbiResultSet(resultSet,vrec,sqlQualifiers),
fBuffer(0)
{

  this->DebugCtor();

  if ( ! resultSet || resultSet->IsExhausted() || ! tableRow ) return;

  if ( vrec ) TDbiTimerManager::gTimerManager.RecFillAgg(vrec->GetAggregateNo());

//Move to first row if result set not yet started.
  TDbiInRowStream& rs = *resultSet;
  if ( rs.IsBeforeFirst() ) rs.FetchRow();
  if ( rs.IsExhausted() ) return;

//Check and load sequence number if necessary.
  Int_t seqNo = 0;
  if ( dropSeqNo && rs.CurColName() == "SEQNO" ) {
    rs >> seqNo;
    rs.DecrementCurCol();
  }

// Main (non-VLD) tables have a ROW_COUNTER (which has to be ignored when reading).
  bool hasRowCounter = ! rs.IsVLDTable();

// Create and fill table row object and move result set onto next row.

  while ( ! rs.IsExhausted() ) {

//  If stripping off sequence numbers check the next and quit,
//  having restored the last, if it changes.
    if ( seqNo != 0 ) {
      Int_t nextSeqNo;
      rs >> nextSeqNo;
      if ( nextSeqNo != seqNo ) {
        rs.DecrementCurCol();
        break;
      }
    }

//  Strip off ROW_COUNTER if present.
    if ( hasRowCounter ) rs.IncrementCurCol();
    TDbiTableRow* row = tableRow->CreateTableRow();
    if ( vrec) TDbiTimerManager::gTimerManager.StartSubWatch(3);
    row->SetOwner(this);
    row->Fill(rs,vrec);
    if ( vrec) TDbiTimerManager::gTimerManager.StartSubWatch(2);
    fRows.push_back(row);
    rs.FetchRow();
    if ( vrec) TDbiTimerManager::gTimerManager.StartSubWatch(1);
  }

  //Flag that data was read from Database.
  this->SetResultsFromDb();
  if ( seqNo  == 0 )
        SK_DBI_Info( "Created unaggregated VLD result set no. of rows: "
                                               << this->GetNumRows() << "  ");
  else  SK_DBI_Info( "Created unaggregated result set for SeqNo: " << seqNo
                                  << " no. of rows: " << this->GetNumRows() << "  ");

}

Here is the call graph for this function: