TestDbAlg.cxx

Go to the documentation of this file.

#include "GaudiKernel/MsgStream.h"
#include "GaudiKernel/SmartDataPtr.h"
 
#include "Database/DatabaseRecord.h"
#include "Database/TestDbAlg.h"
#include "DatabaseSvc/IDatabaseSvc.h"
 
#include "TBufferFile.h"
#include "TTree.h"
#include <iostream>
 
using namespace std;
 
/////////////////////////////////////////////////////////////////////////////
 
TestDbAlg::TestDbAlg( const std::string& name, ISvcLocator* pSvcLocator )
    : Algorithm( name, pSvcLocator ) {}
 
// * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
 
StatusCode TestDbAlg::initialize() {
  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;
}
 
// * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
StatusCode TestDbAlg::execute() {
  MsgStream log( msgSvc(), name() );
 
  log << "TestDbAlg execute()" << endl;
 
  return StatusCode::SUCCESS;
}
 
// * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
 
StatusCode TestDbAlg::finalize() { return StatusCode::SUCCESS; }