ODTTCciConfig Class Reference

#include <ODTTCciConfig.h>

Inheritance diagram for ODTTCciConfig:

Public Member Functions
std::string	getConfigurationScript () const
std::string	getConfigurationScriptParams () const
int	getId () const
unsigned int	getSize () const
std::string	getTable () override
std::string	getTrgMode () const
int	getTrgSleep () const
unsigned char *	getTTCciClob () const
std::string	getTTCciConfigurationFile () const
	ODTTCciConfig ()
void	setConfigurationScript (std::string x)
void	setConfigurationScriptParams (std::string x)
void	setId (int id)
void	setParameters (const std::map< std::string, std::string > &my_keys_map)
void	setSize (unsigned int id)
void	setTrgMode (std::string x)
void	setTrgSleep (int id)
void	setTTCciClob (unsigned char *x)
void	setTTCciConfigurationFile (std::string x)
	~ODTTCciConfig () override
Public Member Functions inherited from IODConfig
std::string	getConfigTag ()
void	setConfigTag (std::string x)
Public Member Functions inherited from IDBObject
oracle::occi::Connection *	getConn () const
oracle::occi::Environment *	getEnv () const
void	setConnection (oracle::occi::Environment *env, oracle::occi::Connection *conn)
virtual	~IDBObject ()

Private Member Functions
void	clear ()
void	fetchData (ODTTCciConfig *result) noexcept(false)
int	fetchID () noexcept(false)
int	fetchNextId () noexcept(false)
void	prepareWrite () noexcept(false) override
void	writeDB () noexcept(false)

Private Attributes
std::string	m_configuration_script
std::string	m_configuration_script_params
int	m_ID
int	m_size
std::string	m_trg_mode
int	m_trg_sleep
unsigned char *	m_ttcci_clob
std::string	m_ttcci_file

Friends
class	EcalCondDBInterface

Additional Inherited Members
Public Types inherited from IODConfig
typedef oracle::occi::Clob	Clob
typedef oracle::occi::SQLException	SQLException
typedef oracle::occi::Statement	Statement
typedef oracle::occi::Stream	Stream
Public Attributes inherited from IODConfig
std::string	m_config_tag
Static Public Attributes inherited from IDBObject
static int const	ECALDB_NROWS = 1024
Protected Member Functions inherited from IODConfig
void	checkPrepare () noexcept(false)
void	createReadStatement () noexcept(false)
void	populateClob (Clob &clob, std::string fname, unsigned int bufsize) noexcept(false)
unsigned char *	readClob (Clob &clob, int size) noexcept(false)
void	setPrefetchRowCount (int ncount) noexcept(false)
void	terminateReadStatement () noexcept(false)
void	terminateWriteStatement () noexcept(false)
Protected Member Functions inherited from IDBObject
void	checkConnection () const noexcept(false)
Protected Attributes inherited from IODConfig
Statement *	m_readStmt
Statement *	m_writeStmt
Protected Attributes inherited from IDBObject
oracle::occi::Connection *	m_conn
oracle::occi::Environment *	m_env

Detailed Description

Definition at line 15 of file ODTTCciConfig.h.

Constructor & Destructor Documentation

ODTTCciConfig::ODTTCciConfig

(

)

Definition at line 15 of file ODTTCciConfig.cc.

References clear().

                             {
  m_env = nullptr;
  m_conn = nullptr;
  m_writeStmt = nullptr;
  m_readStmt = nullptr;
  m_config_tag = "";
  m_configuration_script = "";
  m_configuration_script_params = "";
  m_ID = 0;
  clear();
  m_size = 0;
}

ODTTCciConfig::~ODTTCciConfig ( )

override

Definition at line 37 of file ODTTCciConfig.cc.

{}

Member Function Documentation

void ODTTCciConfig::clear ( void  )

private

Definition at line 28 of file ODTTCciConfig.cc.

References gather_cfg::cout.

                          {
  std::cout << "entering clear" << std::endl;
  m_ttcci_file = "";
  m_configuration_script = "";
  m_configuration_script_params = "";
  m_trg_mode = "";
  m_trg_sleep = 0;
}

void ODTTCciConfig::fetchData ( ODTTCciConfig *  result )

privatenoexcept

Definition at line 182 of file ODTTCciConfig.cc.

References edmScanValgrind::buffer, gather_cfg::cout, alignCSCRings::e, mps_fire::i, mps_fire::result, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                   {
  this->checkConnection();
  result->clear();
  if (result->getId() == 0 && (result->getConfigTag().empty())) {
    throw(std::runtime_error("ODTTCciConfig::fetchData(): no Id defined for this ODTTCciConfig "));
  }

  try {
    m_readStmt->setSQL(
        "SELECT * "
        "FROM ECAL_TTCci_CONFIGURATION  "
        " where ( ttcci_configuration_id = :1 or ttcci_tag=:2 )");
    m_readStmt->setInt(1, result->getId());
    m_readStmt->setString(2, result->getConfigTag());
    ResultSet* rset = m_readStmt->executeQuery();

    rset->next();
    // 1 is the id and 2 is the config tag

    result->setId(rset->getInt(1));
    result->setConfigTag(rset->getString(2));

    result->setTTCciConfigurationFile(rset->getString(3));
    result->setTrgMode(rset->getString(4));
    result->setTrgSleep(rset->getInt(5));

    result->setConfigurationScript(rset->getString(7));
    result->setConfigurationScriptParams(rset->getString(8));

    Clob clob = rset->getClob(6);
    cout << "Opening the clob in Read only mode" << endl;
    clob.open(OCCI_LOB_READONLY);
    int clobLength = clob.length();
    cout << "Length of the clob is: " << clobLength << endl;
    m_size = clobLength;
    unsigned char* buffer = readClob(clob, m_size);
    clob.close();
    cout << "the clob buffer is:" << endl;
    for (int i = 0; i < clobLength; ++i)
      cout << (char)buffer[i];
    cout << endl;

    result->setTTCciClob(buffer);

  } catch (SQLException& e) {
    throw(std::runtime_error(std::string("ODTTCciConfig::fetchData():  ") + e.getMessage()));
  }
}

int ODTTCciConfig::fetchID ( )

privatenoexcept

Definition at line 231 of file ODTTCciConfig.cc.

References alignCSCRings::e, and AlCaHLTBitMon_QueryRunRegistry::string.

                                           {
  if (m_ID != 0) {
    return m_ID;
  }

  this->checkConnection();

  try {
    Statement* stmt = m_conn->createStatement();
    stmt->setSQL(
        "SELECT ttcci_configuration_id FROM ecal_ttcci_configuration "
        "WHERE  ttcci_tag=:ttcci_tag ");

    stmt->setString(1, getConfigTag());

    ResultSet* rset = stmt->executeQuery();

    if (rset->next()) {
      m_ID = rset->getInt(1);
    } else {
      m_ID = 0;
    }
    m_conn->terminateStatement(stmt);
  } catch (SQLException& e) {
    throw(std::runtime_error(std::string("ODTTCciConfig::fetchID:  ") + e.getMessage()));
  }
  return m_ID;
}

int ODTTCciConfig::fetchNextId ( )

privatenoexcept

Definition at line 39 of file ODTTCciConfig.cc.

References alignCSCRings::e, mps_fire::result, and AlCaHLTBitMon_QueryRunRegistry::string.

                                               {
  int result = 0;
  try {
    this->checkConnection();

    m_readStmt = m_conn->createStatement();
    m_readStmt->setSQL("select ecal_ttcci_config_sq.NextVal from dual");
    ResultSet* rset = m_readStmt->executeQuery();
    while (rset->next()) {
      result = rset->getInt(1);
    }
    m_conn->terminateStatement(m_readStmt);
    return result;

  } catch (SQLException& e) {
    throw(std::runtime_error(std::string("ODTTCciConfig::fetchNextId():  ") + e.getMessage()));
  }
}

std::string ODTTCciConfig::getConfigurationScript ( ) const

inline

Definition at line 31 of file ODTTCciConfig.h.

References m_configuration_script.

{ return m_configuration_script; }

std::string ODTTCciConfig::getConfigurationScriptParams ( ) const

inline

Definition at line 33 of file ODTTCciConfig.h.

References m_configuration_script_params.

{ return m_configuration_script_params; }

int ODTTCciConfig::getId ( void  ) const

inline

Definition at line 25 of file ODTTCciConfig.h.

References m_ID.

{ return m_ID; }

unsigned int ODTTCciConfig::getSize ( ) const

inline

Definition at line 43 of file ODTTCciConfig.h.

References m_size.

{ return m_size; }

std::string ODTTCciConfig::getTable ( )

inlineoverridevirtual

Implements IODConfig.

Definition at line 22 of file ODTTCciConfig.h.

{ return "ECAL_TTCci_CONFIGURATION"; }

std::string ODTTCciConfig::getTrgMode ( ) const

inline

Definition at line 36 of file ODTTCciConfig.h.

References m_trg_mode.

{ return m_trg_mode; }

int ODTTCciConfig::getTrgSleep ( ) const

inline

Definition at line 38 of file ODTTCciConfig.h.

References m_trg_sleep.

{ return m_trg_sleep; }

unsigned char* ODTTCciConfig::getTTCciClob ( ) const

inline

Definition at line 41 of file ODTTCciConfig.h.

References m_ttcci_clob.

{ return m_ttcci_clob; }

std::string ODTTCciConfig::getTTCciConfigurationFile ( ) const

inline

Definition at line 28 of file ODTTCciConfig.h.

References m_ttcci_file.

{ return m_ttcci_file; }

void ODTTCciConfig::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IODConfig.

Definition at line 58 of file ODTTCciConfig.cc.

References gather_cfg::cout, alignCSCRings::e, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                 {
  this->checkConnection();

  int next_id = fetchNextId();

  try {
    m_writeStmt = m_conn->createStatement();
    m_writeStmt->setSQL(
        "INSERT INTO ECAL_TTCci_CONFIGURATION (ttcci_configuration_id, ttcci_tag, "
        " TTCCI_configuration_file, TRG_MODE, TRG_SLEEP, Configuration, configuration_script, "
        "configuration_script_params  ) "
        "VALUES (:1, :2, :3, :4, :5, :6, :7, :8  )");
    m_writeStmt->setInt(1, next_id);
    m_writeStmt->setString(2, getConfigTag());
    m_writeStmt->setString(3, getTTCciConfigurationFile());
    m_writeStmt->setString(4, getTrgMode());
    m_writeStmt->setInt(5, getTrgSleep());
    m_writeStmt->setString(7, getConfigurationScript());
    m_writeStmt->setString(8, getConfigurationScriptParams());

    // and now the clob
    oracle::occi::Clob clob(m_conn);
    clob.setEmpty();
    m_writeStmt->setClob(6, clob);
    m_writeStmt->executeUpdate();
    m_ID = next_id;

    m_conn->terminateStatement(m_writeStmt);
    std::cout << "TTCci Clob inserted into CONFIGURATION with id=" << next_id << std::endl;

    // now we read and update it
    m_writeStmt = m_conn->createStatement();
    m_writeStmt->setSQL(
        "SELECT Configuration FROM ECAL_TTCci_CONFIGURATION WHERE"
        " ttcci_configuration_id=:1 FOR UPDATE");

    std::cout << "updating the clob 0" << std::endl;

  } catch (SQLException& e) {
    throw(std::runtime_error(std::string("ODTTCciConfig::prepareWrite():  ") + e.getMessage()));
  }

  std::cout << "updating the clob 1 " << std::endl;
}

void ODTTCciConfig::setConfigurationScript ( std::string  x )

inline

Definition at line 30 of file ODTTCciConfig.h.

References m_configuration_script, and x.

{ m_configuration_script = x; }

void ODTTCciConfig::setConfigurationScriptParams ( std::string  x )

inline

Definition at line 32 of file ODTTCciConfig.h.

References m_configuration_script_params, and x.

{ m_configuration_script_params = x; }

void ODTTCciConfig::setId ( int  id )

inline

Definition at line 24 of file ODTTCciConfig.h.

References gpuClustering::id, and m_ID.

{ m_ID = id; }

void ODTTCciConfig::setParameters

(

const std::map< std::string, std::string > &

my_keys_map

)

Definition at line 103 of file ODTTCciConfig.cc.

References gather_cfg::cout, dataset::end, alignmentValidation::fname, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                           {
  // parses the result of the XML parser that is a map of
  // string string with variable name variable value

  for (std::map<std::string, std::string>::const_iterator ci = my_keys_map.begin(); ci != my_keys_map.end(); ci++) {
    if (ci->first == "TRG_MODE")
      setTrgMode(ci->second);
    if (ci->first == "TRG_SLEEP")
      setTrgSleep(atoi(ci->second.c_str()));
    if (ci->first == "TTCci_CONFIGURATION_ID")
      setConfigTag(ci->second);
    if (ci->first == "CONFIGURATION_SCRIPT")
      setConfigurationScript(ci->second);
    if (ci->first == "CONFIGURATION_SCRIPT_PARAMS")
      setConfigurationScriptParams(ci->second);
    if (ci->first == "CONFIGURATION_SCRIPT_PARAMETERS")
      setConfigurationScriptParams(ci->second);
    if (ci->first == "Configuration") {
      std::string fname = ci->second;
      string str3;
      size_t pos, pose;

      pos = fname.find('=');  // position of "live" in str
      pose = fname.size();    // position of "]" in str
      str3 = fname.substr(pos + 1, pose - pos - 2);

      cout << "fname=" << fname << " and reduced is: " << str3 << endl;
      setTTCciConfigurationFile(str3);

      // here we must open the file and read the LTC Clob
      std::cout << "Going to read file: " << str3 << endl;

      ifstream inpFile;
      inpFile.open(str3.c_str());

      // tell me size of file
      int bufsize = 0;
      inpFile.seekg(0, ios::end);
      bufsize = inpFile.tellg();
      std::cout << " bufsize =" << bufsize << std::endl;
      // set file pointer to start again
      inpFile.seekg(0, ios::beg);

      inpFile.close();
      m_size = bufsize;
    }
  }
}

void ODTTCciConfig::setSize ( unsigned int  id )

inline

Definition at line 42 of file ODTTCciConfig.h.

References gpuClustering::id, and m_size.

{ m_size = id; }

void ODTTCciConfig::setTrgMode ( std::string  x )

inline

Definition at line 35 of file ODTTCciConfig.h.

References m_trg_mode, and x.

{ m_trg_mode = x; }

void ODTTCciConfig::setTrgSleep ( int  id )

inline

Definition at line 37 of file ODTTCciConfig.h.

References gpuClustering::id, and m_trg_sleep.

{ m_trg_sleep = id; }

void ODTTCciConfig::setTTCciClob ( unsigned char *  x )

inline

Definition at line 40 of file ODTTCciConfig.h.

References m_ttcci_clob, and x.

{ m_ttcci_clob = x; }

void ODTTCciConfig::setTTCciConfigurationFile ( std::string  x )

inline

Definition at line 27 of file ODTTCciConfig.h.

References m_ttcci_file, and x.

{ m_ttcci_file = x; }

void ODTTCciConfig::writeDB ( )

privatenoexcept

Definition at line 152 of file ODTTCciConfig.cc.

References gather_cfg::cout, alignCSCRings::e, and AlCaHLTBitMon_QueryRunRegistry::string.

                                            {
  std::cout << "updating the clob 2" << std::endl;

  try {
    m_writeStmt->setInt(1, m_ID);
    ResultSet* rset = m_writeStmt->executeQuery();

    while (rset->next()) {
      oracle::occi::Clob clob = rset->getClob(1);
      cout << "Opening the clob in read write mode" << endl;
      cout << "Populating the clob" << endl;
      populateClob(clob, getTTCciConfigurationFile(), m_size);
      int clobLength = clob.length();
      cout << "Length of the clob is: " << clobLength << endl;
      //        clob.close ();
    }

    m_writeStmt->executeUpdate();

    m_writeStmt->closeResultSet(rset);

  } catch (SQLException& e) {
    throw(std::runtime_error(std::string("ODTTCciConfig::writeDB():  ") + e.getMessage()));
  }
  // Now get the ID
  if (!this->fetchID()) {
    throw(std::runtime_error("ODTTCciConfig::writeDB:  Failed to write"));
  }
}

Friends And Related Function Documentation

friend class EcalCondDBInterface

friend

Definition at line 17 of file ODTTCciConfig.h.

Member Data Documentation

std::string ODTTCciConfig::m_configuration_script

private

Definition at line 59 of file ODTTCciConfig.h.

Referenced by getConfigurationScript(), and setConfigurationScript().

std::string ODTTCciConfig::m_configuration_script_params

private

Definition at line 60 of file ODTTCciConfig.h.

Referenced by getConfigurationScriptParams(), and setConfigurationScriptParams().

int ODTTCciConfig::m_ID

private

Definition at line 56 of file ODTTCciConfig.h.

Referenced by getId(), and setId().

int ODTTCciConfig::m_size

private

Definition at line 63 of file ODTTCciConfig.h.

Referenced by getSize(), and setSize().

std::string ODTTCciConfig::m_trg_mode

private

Definition at line 61 of file ODTTCciConfig.h.

Referenced by getTrgMode(), and setTrgMode().

int ODTTCciConfig::m_trg_sleep

private

Definition at line 62 of file ODTTCciConfig.h.

Referenced by getTrgSleep(), and setTrgSleep().

unsigned char* ODTTCciConfig::m_ttcci_clob

private

Definition at line 57 of file ODTTCciConfig.h.

Referenced by getTTCciClob(), and setTTCciClob().

std::string ODTTCciConfig::m_ttcci_file

private

Definition at line 58 of file ODTTCciConfig.h.

Referenced by getTTCciConfigurationFile(), and setTTCciConfigurationFile().