TestDbAlg Class Reference

#include <TestDbAlg.h>

List of all members.

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	(	const std::string &	name,
		ISvcLocator *	pSvcLocator
	)

Definition at line 15 of file TestDbAlg.cxx.

                                                                    : Algorithm(name, pSvcLocator){
}

---

Member Function Documentation

StatusCode TestDbAlg::execute

(

)

Definition at line 120 of file TestDbAlg.cxx.

References msgSvc().

                              {
  MsgStream log(msgSvc(), name());
  
  log << "TestDbAlg execute()" << endl;

  return StatusCode::SUCCESS;
}

StatusCode TestDbAlg::finalize

(

)

Definition at line 130 of file TestDbAlg.cxx.

                               {
  return StatusCode::SUCCESS;
}

StatusCode TestDbAlg::initialize

(

)

Definition at line 20 of file TestDbAlg.cxx.

References DatabaseRecordVector::clear(), calibUtil::ERROR, and IDatabaseSvc::query().

                                {
  MsgStream log(messageService(), name());

  IDatabaseSvc* m_dbsvc;
  StatusCode  sc = serviceLocator()->service("DatabaseSvc",m_dbsvc,true);
  if (sc .isFailure() ) {
    log << MSG::ERROR << "Unable to find DatabaseSvc " << endreq;
    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;
}

---