TDbiInRowStream.cxx File Reference

#include <sstream>
#include "TDbiFieldType.hxx"
#include "TDbiInRowStream.hxx"
#include "TDbiString.hxx"
#include "TDbiStatement.hxx"
#include "TDbiTableMetaData.hxx"
#include <TSK_DBI_Log.hxx>
#include <MsgFormat.h>
#include "UtilString.hxx"
#include "TVldTimeStamp.hxx"

Include dependency graph for TDbiInRowStream.cxx:

Go to the source code of this file.

Defines
#define	IN(t)   istringstream in(AsString(t)); in
#define	IN2(t, m)
#define	IN3(t)
Functions
	ClassImp (TDbiInRowStream) TDbiInRowStream

---

Define Documentation

#define IN

(

t

)

istringstream in(AsString(t)); in

Definition at line 124 of file TDbiInRowStream.cxx.

Referenced by TDbiInRowStream::operator>>().

#define IN2	(	t,
		m		)

Value:

int col = CurColNum()-1;                  \
  if ( CurRowNum() == 0 ) {                 \
    istringstream in(AsString(t));          \
    in >> dest;                             \
  }                                         \
  else {                                    \
    dest = fTSQLStatement->m(col);          \
    IncrementCurCol();                      \
  }                                         \

Definition at line 129 of file TDbiInRowStream.cxx.

Referenced by TDbiInRowStream::operator>>().

#define IN3

(

t

)

Value:

int col = this->CurColNum()-1;                                      \
const TDbiFieldType& fType = this->ColFieldType(col+1);              \
if ( fType.GetSize() == 8 ) {                                       \
  dest=fTSQLStatement->GetUInt(col);                                \
}                                                                   \
else {                                                              \
  t dest_signed;                                                    \
  *this >> dest_signed;                                             \
  dest = dest_signed;                                               \
  if ( fType.GetSize() == 1 ) dest &= 0xff;                         \
  if ( fType.GetSize() == 2 ) dest &= 0xffff;                       \
  if ( fType.GetSize() == 4 ) dest &= 0xffffffff;                   \
}\

Definition at line 149 of file TDbiInRowStream.cxx.

Referenced by TDbiInRowStream::operator>>().

---

Function Documentation

ClassImp

(

TDbiInRowStream

)

   
     Purpose:  Default constructor
   
     Arguments:
        stmtDb     in  TDbiStatement to be used for query.  May be zero.
        sql        in  The query to be applied to the statement.
        metaData   in  Meta data for query.
        tableProxy in  Source TDbiTableProxy.
        dbNo       in  Cascade no. of source.
   
     Return:    n/a
   
     Contact:   N. West
   
     Specification:-
     =============
   
     o  Create ResultSet for query.
   

Definition at line 19 of file TDbiInRowStream.cxx.

References SK_DBI_Trace.

                : ctors, dtor, operators then in alphabetical order.


//.....................................................................
///\verbatim
///
///  Purpose:  Default constructor
///
///  Arguments:
///     stmtDb     in  TDbiStatement to be used for query.  May be zero.
///     sql        in  The query to be applied to the statement.
///     metaData   in  Meta data for query.
///     tableProxy in  Source TDbiTableProxy.
///     dbNo       in  Cascade no. of source.
///
///  Return:    n/a
///
///  Contact:   N. West
///
///  Specification:-
///  =============
///
///  o  Create ResultSet for query.
///\endverbatim

TDbiInRowStream::TDbiInRowStream(TDbiStatement* stmtDb,
                           const TDbiString& sql,
                           const TDbiTableMetaData* metaData,
                           const TDbiTableProxy* tableProxy,
                           UInt_t dbNo,
                           const string& fillOpts) :
TDbiRowStream(metaData),
fCurRow(0),
fDbNo(dbNo),
fStatement(stmtDb),
fTSQLStatement(0),
fExhausted(true),
fTableProxy(tableProxy),
fFillOpts(fillOpts)
{


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

//  None.


  SK_DBI_Trace( "Creating TDbiInRowStream" << "  ");

  if ( stmtDb ) {
    fTSQLStatement = stmtDb->ExecuteQuery(sql.c_str());
    if ( fTSQLStatement && fTSQLStatement->NextResultRow() ) fExhausted = false;
  }

}