TestDbAlg Class Reference

#include <TestDbAlg.h>

Inheritance diagram for TestDbAlg:

Public Member Functions
	TestDbAlg (const std::string &name, ISvcLocator *pSvcLocator)
StatusCode	initialize ()
StatusCode	execute ()
StatusCode	finalize ()

Detailed Description

Definition at line 3 of file TestDbAlg.h.

Constructor & Destructor Documentation

TestDbAlg()

TestDbAlg::TestDbAlg	(	const std::string &	name,
		ISvcLocator *	pSvcLocator )

Definition at line 16 of file TestDbAlg.cxx.

    : Algorithm( name, pSvcLocator ) {}

Member Function Documentation

execute()

StatusCode TestDbAlg::execute

(

)

Definition at line 132 of file TestDbAlg.cxx.

                              {
  MsgStream log( msgSvc(), name() );
 
  log << "TestDbAlg execute()" << endl;
 
  return StatusCode::SUCCESS;
}

finalize()

StatusCode TestDbAlg::finalize

(

)

Definition at line 142 of file TestDbAlg.cxx.

{ return StatusCode::SUCCESS; }

initialize()

StatusCode TestDbAlg::initialize

(

)

Definition at line 21 of file TestDbAlg.cxx.

                                 {
  MsgStream log( msgSvc(), name() );
 
  IDatabaseSvc* m_dbsvc;
  StatusCode    sc = serviceLocator()->service( "DatabaseSvc", m_dbsvc, true );
  if ( sc.isFailure() )
  {
    log << MSG::ERROR << "Unable to find DatabaseSvc " << endmsg;
    return sc;
  }
 
  std::cout << "*************************************************************" << std::endl;
  std::cout << "Test 1: Numbers" << std::endl;
  std::cout << "*************************************************************" << std::endl;
 
  char stmt[255];
  sprintf( stmt, "select Vx, Vy, Vz, SigmaVx, SigmaVy, SigmaVz,RunNo from BeamPar where RunNo "
                 "> 9950 and RunNo < 9980 and SftVer='6.5.1'" );
 
  DatabaseRecordVector res;
  int                  row_no;
  row_no = m_dbsvc->query( "offlinedb", stmt, res );
  if ( row_no < 0 )
  {
    std::cerr << "Query \"" << stmt << "\" failed" << std::endl;
    return StatusCode::FAILURE;
  }
 
  int    row;
  double vx, svx;
  vx  = 0;
  svx = 0;
 
  for ( row = 0; row < row_no; row++ )
  {
    DatabaseRecord& records = *res[row];
    sscanf( records["Vx"], "%lf", &vx );
    sscanf( records["SigmaVx"], "%lf", &svx );
    cout << "Read from DB: RunNo " << records["RunNo"] << " Vx= " << vx << " SigmaVx= " << svx
         << endl;
    cout << "                    " << records.GetLong( "RunNo" )
         << " Vx= " << records.GetDouble( "Vx" )
         << " SigmaVx= " << records.GetDouble( "SigmaVx" ) << endl;
  }
 
  // Check BLOBs
  std::cout << "*************************************************************" << std::endl;
  std::cout << "Test 2: BLOBs" << std::endl;
  std::cout << "*************************************************************" << std::endl;
 
  res.clear();
  sprintf( stmt, "select EndTofPar,BarTofPar from TofCalConst where RunFrom <= 11000 and "
                 "RunTo >= 11000 and SftVer='6.5.1'" );
  row_no = m_dbsvc->query( "offlinedb", stmt, res );
  if ( row_no < 0 )
  {
    std::cerr << "Query \"" << stmt << "\" failed" << std::endl;
    return StatusCode::FAILURE;
  }
  for ( row = 0; row < row_no; row++ )
  {
    DatabaseRecord& records = *res[row];
    //  TBuffer *buf1 = new TBuffer(TBuffer::kRead);
    TBufferFile* buf1 = new TBufferFile( TBuffer::kRead );
    buf1->SetBuffer( records["EndTofPar"], 32768, kFALSE );
    TTree* curvetree = new TTree();
    curvetree->Streamer( *buf1 );
    double cnvAtten[8];
    curvetree->SetBranchAddress( "Atten0", &cnvAtten[0] );
    curvetree->SetBranchAddress( "Atten1", &cnvAtten[1] );
    curvetree->SetBranchAddress( "Atten2", &cnvAtten[2] );
    curvetree->SetBranchAddress( "Atten3", &cnvAtten[3] );
    curvetree->SetBranchAddress( "Atten4", &cnvAtten[4] );
    int entries = curvetree->GetEntries();
    if ( entries > 10 ) entries = 10;
    for ( int iiii = 0; iiii < entries; iiii++ )
    {
      curvetree->GetEntry( iiii );
      for ( int jjj = 0; jjj < 5; jjj++ )
      { std::cout << "cnvAtten[" << jjj << "]=" << cnvAtten[jjj] << " "; }
      std::cout << std::endl;
    }
  }
 
  // sleep(600);
  //  Test strings
  std::cout << "*************************************************************" << std::endl;
  std::cout << "Test 3: Strings" << std::endl;
  std::cout << "*************************************************************" << std::endl;
 
  res.clear();
  sprintf( stmt, "select XtTree,QtTree,T0Tree,SdTree,RunFrom,RunTo,CalParVer,FileName from "
                 "MdcCalConst where SftVer = '6.5.3'" );
  row_no = m_dbsvc->query( "offlinedb", stmt, res );
  if ( row_no < 0 )
  {
    std::cerr << "Query \"" << stmt << "\" failed" << std::endl;
    return StatusCode::FAILURE;
  }
 
  for ( row = 0; row < row_no; row++ )
  {
    DatabaseRecord& records = *res[row];
    cout << "Read from DB: Runs " << records["RunFrom"] << " " << records["RunTo"]
         << " FileName = " << records["FileName"] << endl;
  }
 
  return StatusCode::SUCCESS;
}

---

The documentation for this class was generated from the following files:

• TestDbAlg.h
• TestDbAlg.cxx