HCALConfigDB.cc

Go to the documentation of this file.

//
// Gena Kukartsev (Brown), Feb 1, 2008
// $Id:
//

#include <iostream>
#include <cstring>

#ifdef HAVE_XDAQ
#include <toolbox/string.h>
#else
#include "CaloOnlineTools/HcalOnlineDb/interface/xdaq_compat.h"  // Replaces toolbox::toString
#endif


#include "OnlineDB/Oracle/interface/Oracle.h"

#include "CaloOnlineTools/HcalOnlineDb/interface/HCALConfigDB.h"
#include "CalibCalorimetry/HcalTPGAlgos/interface/XMLProcessor.h"
#include "CaloOnlineTools/HcalOnlineDb/interface/ConfigurationDatabase.hh"
#include "CaloOnlineTools/HcalOnlineDb/interface/ConfigurationDatabaseImplOracle.hh"
#include "CaloOnlineTools/HcalOnlineDb/interface/ConfigurationDatabaseImplXMLFile.hh"
#include "CaloOnlineTools/HcalOnlineDb/interface/ConfigurationItemNotFoundException.hh"
#include "DataFormats/HcalDetId/interface/HcalDetId.h"

using namespace std;
using namespace oracle::occi;
using namespace hcal;

HCALConfigDB::HCALConfigDB( void )
{    
  database = nullptr;
  database2 = nullptr;
}

HCALConfigDB::HCALConfigDB( std::string _accessor )
{    
  database = nullptr;
  database2 = nullptr;
  accessor = _accessor;
}


HCALConfigDB::~HCALConfigDB( void )
{    
  delete database;
  delete database2;
}


void HCALConfigDB::setAccessor( std::string _accessor )
{      
  accessor = _accessor;
}

void HCALConfigDB::connect( std::string _accessor )
{

  accessor = _accessor;

  std::string::size_type i = accessor . find( "occi://" );
  if ( i!=std::string::npos )
    {
      database = new ConfigurationDatabaseImplOracle();
      database -> connect( accessor );
    }
  else
    {
      database = new ConfigurationDatabaseImplXMLFile();
      database -> connect( accessor );
    }
}



void HCALConfigDB::connect( std::string _accessor1, std::string _accessor2 )
{

  connect (_accessor1 );

  accessor2 = _accessor2;

  std::string::size_type i = accessor2 . find( "occi://" );
  if ( i!=std::string::npos )
    {
      database2 = new ConfigurationDatabaseImplOracle();
      database2 -> connect( accessor2 );
    }
  else
    {
      database2 = new ConfigurationDatabaseImplXMLFile();
      database2 -> connect( accessor2 );
    }
}




void HCALConfigDB::disconnect( void )
{
  if ( database != nullptr ) database -> disconnect();
  if ( database2 != nullptr ) database2 -> disconnect();
}



std::vector<unsigned int> HCALConfigDB::getOnlineLUT( std::string tag, int crate, int slot, int topbottom, int fiber, int channel, int luttype )
{

  //connect( accessor );

  std::vector<unsigned int> result;

  hcal::ConfigurationDatabase::FPGASelection _fpga;
  if ( topbottom == 0 ) _fpga = hcal::ConfigurationDatabase::Bottom;
  else if ( topbottom == 1 ) _fpga = hcal::ConfigurationDatabase::Top;
  else
    {
      std::cout << "topbottom out of range" << std::endl;
      exit(-1);
    }

  hcal::ConfigurationDatabase::LUTType _lt;
  if ( luttype == 1 ) _lt = hcal::ConfigurationDatabase::LinearizerLUT;
  else if ( luttype == 2 ) _lt = hcal::ConfigurationDatabase::CompressionLUT;
  else
    {
      std::cout << "LUT type out of range" << std::endl;
      exit(-1);
    }

  hcal::ConfigurationDatabase::LUTId _lutid( crate, slot, _fpga, fiber, channel, _lt );
  std::map<hcal::ConfigurationDatabase::LUTId, hcal::ConfigurationDatabase::LUT> testLUTs;

  XMLProcessor::getInstance();

  try {
    database -> getLUTs(tag, crate, slot, testLUTs);
  } catch (hcal::exception::ConfigurationItemNotFoundException& e) {
    std::cout << "Found nothing!" << std::endl;
  } catch (hcal::exception::Exception& e2) {
    std::cout << "Exception: " << e2.what() << std::endl;
  }

  result = testLUTs[_lutid];

  //database -> disconnect();

  return result;
}

std::vector<unsigned int> HCALConfigDB::getOnlineLUT( std::string tag, uint32_t _rawid, hcal::ConfigurationDatabase::LUTType _lt )
{
  std::vector<unsigned int> result;
  HcalDetId _id( _rawid );

  double _condition_data_set_id;
  unsigned int _crate, _slot, _fiber, _channel;
  hcal::ConfigurationDatabase::FPGASelection _fpga;

  int side   = _id . zside();
  int etaAbs = _id . ietaAbs();
  int phi    = _id . iphi();
  int depth  = _id . depth();
  std::string subdetector;
  if ( _id . subdet() == HcalBarrel) subdetector = "HB";
  else if ( _id . subdet() == HcalEndcap) subdetector = "HE";
  else if ( _id . subdet() == HcalOuter) subdetector = "HO";
  else if ( _id . subdet() == HcalForward) subdetector = "HF";

  oracle::occi::Connection * _connection = database -> getConnection();

  try {
    Statement* stmt = _connection -> createStatement();
    std::string query = ("SELECT RECORD_ID, CRATE, HTR_SLOT, HTR_FPGA, HTR_FIBER, FIBER_CHANNEL ");
    query += " FROM CMS_HCL_HCAL_CONDITION_OWNER.HCAL_HARDWARE_LOGICAL_MAPS_V3 ";
    query += toolbox::toString(" WHERE SIDE=%d AND ETA=%d AND PHI=%d AND DEPTH=%d AND SUBDETECTOR='%s'", side, etaAbs, phi, depth, subdetector . c_str() );
    
    //SELECT
    ResultSet *rs = stmt->executeQuery(query);

    _condition_data_set_id = 0.0;

    while (rs->next()) {
      double _cdsi = rs -> getDouble(1);
      if ( _condition_data_set_id < _cdsi )
    {
      _condition_data_set_id = _cdsi;
      _crate    = rs -> getInt(2);
      _slot     = rs -> getInt(3);
      std::string fpga_ = getOraString(rs,4);
      if ( fpga_ == "top" ) _fpga = hcal::ConfigurationDatabase::Top;
      else _fpga  = hcal::ConfigurationDatabase::Bottom;
      _fiber    = rs -> getInt(5);
      _channel  = rs -> getInt(6);
      
      int topbottom, luttype;
      if ( _fpga == hcal::ConfigurationDatabase::Top ) topbottom = 1;
      else topbottom = 0;
      if ( _lt == hcal::ConfigurationDatabase::LinearizerLUT ) luttype = 1;
      else luttype = 2;
      
      result = getOnlineLUT( tag, _crate, _slot, topbottom, _fiber, _channel, luttype );
    }
    }
    //Always terminate statement
    _connection -> terminateStatement(stmt);
  } catch (SQLException& e) {
    XCEPT_RAISE(hcal::exception::ConfigurationDatabaseException,::toolbox::toString("Oracle  exception : %s",getOraMessage(&e)));
  }
  return result;
}


std::vector<unsigned int> HCALConfigDB::getOnlineLUTFromXML( std::string tag, uint32_t _rawid, hcal::ConfigurationDatabase::LUTType _lt ){

  std::vector<unsigned int> result;

  if ( database && database2 ){
    
    HcalDetId _id( _rawid );
    
    double _condition_data_set_id;
    unsigned int _crate, _slot, _fiber, _channel;
    hcal::ConfigurationDatabase::FPGASelection _fpga;
    
    int side   = _id . zside();
    int etaAbs = _id . ietaAbs();
    int phi    = _id . iphi();
    int depth  = _id . depth();
    std::string subdetector;
    if ( _id . subdet() == HcalBarrel) subdetector = "HB";
    else if ( _id . subdet() == HcalEndcap) subdetector = "HE";
    else if ( _id . subdet() == HcalOuter) subdetector = "HO";
    else if ( _id . subdet() == HcalForward) subdetector = "HF";
    
    oracle::occi::Connection * _connection = database2 -> getConnection();
    
    try {
      Statement* stmt = _connection -> createStatement();
      std::string query = ("SELECT RECORD_ID, CRATE, HTR_SLOT, HTR_FPGA, HTR_FIBER, FIBER_CHANNEL ");
      query += " FROM CMS_HCL_HCAL_CONDITION_OWNER.HCAL_HARDWARE_LOGICAL_MAPS_V3 ";
      query += toolbox::toString(" WHERE SIDE=%d AND ETA=%d AND PHI=%d AND DEPTH=%d AND SUBDETECTOR='%s'", side, etaAbs, phi, depth, subdetector . c_str() );
      
      //SELECT
      ResultSet *rs = stmt->executeQuery(query);
      
      _condition_data_set_id = 0.0;
      
      while (rs->next()) {
    double _cdsi = rs -> getDouble(1);
    if ( _condition_data_set_id < _cdsi )
      {
        _condition_data_set_id = _cdsi;
        _crate    = rs -> getInt(2);
        _slot     = rs -> getInt(3);
        std::string fpga_ = getOraString(rs, 4);
        if ( fpga_ == "top" ) _fpga = hcal::ConfigurationDatabase::Top;
        else _fpga  = hcal::ConfigurationDatabase::Bottom;
        _fiber    = rs -> getInt(5);
        _channel  = rs -> getInt(6);
        
        //
        int topbottom, luttype;
        if ( _fpga == hcal::ConfigurationDatabase::Top ) topbottom = 1;
        else topbottom = 0;
        if ( _lt == hcal::ConfigurationDatabase::LinearizerLUT ) luttype = 1;
        else luttype = 2;
        result = getOnlineLUT( tag, _crate, _slot, topbottom, _fiber, _channel, luttype );
      }
      }
      //Always terminate statement
      _connection -> terminateStatement(stmt);

    } catch (SQLException& e) {
      XCEPT_RAISE(hcal::exception::ConfigurationDatabaseException,::toolbox::toString("Oracle  exception : %s",getOraMessage(&e)));
    }
  }
  else{
    std::cout << "Either the XML file with LUTs or the database with LMap are not defined" << std::endl;
  }

  return result;
}


oracle::occi::Connection * HCALConfigDB::getConnection( void ){
  return database -> getConnection();
}

oracle::occi::Environment * HCALConfigDB::getEnvironment( void ){
  return database -> getEnvironment();
}



//Utility function that cnverts oracle::occi::Clob to std::string
string HCALConfigDB::clobToString(const oracle::occi::Clob& _clob){
        oracle::occi::Clob clob = _clob;
                Stream *instream = clob.getStream (1,0);
        unsigned int size = clob.length();
                char *cbuffer = new char[size];
                memset (cbuffer, 0, size);
                instream->readBuffer (cbuffer, size);
                std::string str(cbuffer,size);
        return str;
}