#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 ()

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 (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 ()

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) throw (std::runtime_error)

int	fetchID () throw (std::runtime_error)

int	fetchNextId () throw (std::runtime_error)

void	prepareWrite () throw (std::runtime_error)

void	writeDB () throw (std::runtime_error)

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 () throw (std::runtime_error)

void	createReadStatement () throw (std::runtime_error)

void	populateClob (Clob &clob, std::string fname, unsigned int bufsize) throw (std::runtime_error)

unsigned char *	readClob (Clob &clob, int size) throw (std::runtime_error)

void	setPrefetchRowCount (int ncount) throw (std::runtime_error)

void	terminateReadStatement () throw (std::runtime_error)

void	terminateWriteStatement () throw (std::runtime_error)

Protected Member Functions inherited from IDBObject
void	checkConnection () const throw (std::runtime_error)

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 hitfit::clear(), and NULL.

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

ODTTCciConfig::~ODTTCciConfig ( )

Definition at line 39 of file ODTTCciConfig.cc.

40 {

41 }

Member Function Documentation

void ODTTCciConfig::clear ( void )

private

Definition at line 29 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	)
throw	(	std::runtime_error
	)

private

Definition at line 207 of file ODTTCciConfig.cc.

References gather_cfg::cout, alignCSCRings::e, i, and query::result.

 {
   this->checkConnection();
   result->clear();
   if(result->getId()==0 && (result->getConfigTag()=="") ){
     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("ODTTCciConfig::fetchData():  "+e.getMessage()));
   }
 }

int ODTTCciConfig::fetchID	(		)
throw	(	std::runtime_error
	)

private

Definition at line 262 of file ODTTCciConfig.cc.

References alignCSCRings::e.

 {
   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("ODTTCciConfig::fetchID:  "+e.getMessage()));
   }
     return m_ID;
 }

int ODTTCciConfig::fetchNextId	(		)
throw	(	std::runtime_error
	)

private

Definition at line 43 of file ODTTCciConfig.cc.

References alignCSCRings::e, and query::result.

                                                         {
 
   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("ODTTCciConfig::fetchNextId():  "+e.getMessage()));
   }
 
 }

std::string ODTTCciConfig::getConfigurationScript ( ) const

inline

Definition at line 31 of file ODTTCciConfig.h.

References m_configuration_script.

31 { return m_configuration_script; }

ODTTCciConfig::m_configuration_script

std::string m_configuration_script

Definition: ODTTCciConfig.h:62

std::string ODTTCciConfig::getConfigurationScriptParams ( ) const

inline

Definition at line 33 of file ODTTCciConfig.h.

References m_configuration_script_params.

33 { return m_configuration_script_params; }

ODTTCciConfig::m_configuration_script_params

std::string m_configuration_script_params

Definition: ODTTCciConfig.h:63

int ODTTCciConfig::getId ( ) const

inline

Definition at line 25 of file ODTTCciConfig.h.

References m_ID.

25 { return m_ID; }

ODTTCciConfig::m_ID

int m_ID

Definition: ODTTCciConfig.h:59

unsigned int ODTTCciConfig::getSize ( ) const

inline

Definition at line 44 of file ODTTCciConfig.h.

References m_size.

44 { return m_size; }

ODTTCciConfig::m_size

int m_size

Definition: ODTTCciConfig.h:66

std::string ODTTCciConfig::getTable ( )

inlinevirtual

Implements IODConfig.

Definition at line 22 of file ODTTCciConfig.h.

22 { return "ECAL_TTCci_CONFIGURATION"; }

std::string ODTTCciConfig::getTrgMode ( ) const

inline

Definition at line 37 of file ODTTCciConfig.h.

References m_trg_mode.

37 { return m_trg_mode; }

ODTTCciConfig::m_trg_mode

std::string m_trg_mode

Definition: ODTTCciConfig.h:64

int ODTTCciConfig::getTrgSleep ( ) const

inline

Definition at line 39 of file ODTTCciConfig.h.

References m_trg_sleep.

39 { return m_trg_sleep; }

ODTTCciConfig::m_trg_sleep

int m_trg_sleep

Definition: ODTTCciConfig.h:65

unsigned char* ODTTCciConfig::getTTCciClob ( ) const

inline

Definition at line 42 of file ODTTCciConfig.h.

References m_ttcci_clob.

42 { return m_ttcci_clob; }

ODTTCciConfig::m_ttcci_clob

unsigned char * m_ttcci_clob

Definition: ODTTCciConfig.h:60

std::string ODTTCciConfig::getTTCciConfigurationFile ( ) const

inline

Definition at line 28 of file ODTTCciConfig.h.

References m_ttcci_file.

28 { return m_ttcci_file; }

ODTTCciConfig::m_ttcci_file

std::string m_ttcci_file

Definition: ODTTCciConfig.h:61

void ODTTCciConfig::prepareWrite	(		)
throw	(	std::runtime_error
	)

privatevirtual

Implements IODConfig.

Definition at line 67 of file ODTTCciConfig.cc.

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

 {
   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("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.

30 { m_configuration_script = x; }

ODTTCciConfig::m_configuration_script

std::string m_configuration_script

Definition: ODTTCciConfig.h:62

x

Definition: DDAxes.h:10

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

inline

Definition at line 32 of file ODTTCciConfig.h.

References m_configuration_script_params, and x.

32 { m_configuration_script_params = x; }

ODTTCciConfig::m_configuration_script_params

std::string m_configuration_script_params

Definition: ODTTCciConfig.h:63

x

Definition: DDAxes.h:10

void ODTTCciConfig::setId ( int id )

inline

Definition at line 24 of file ODTTCciConfig.h.

References m_ID.

24 { m_ID = id; }

ODTTCciConfig::m_ID

int m_ID

Definition: ODTTCciConfig.h:59

void ODTTCciConfig::setParameters ( std::map< std::string, std::string > my_keys_map )

Definition at line 113 of file ODTTCciConfig.cc.

References gather_cfg::cout, end, alignmentValidation::fname, pos, 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 >::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 43 of file ODTTCciConfig.h.

References m_size.

43 { m_size = id; }

ODTTCciConfig::m_size

int m_size

Definition: ODTTCciConfig.h:66

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

inline

Definition at line 36 of file ODTTCciConfig.h.

References m_trg_mode, and x.

36 { m_trg_mode = x; }

ODTTCciConfig::m_trg_mode

std::string m_trg_mode

Definition: ODTTCciConfig.h:64

x

Definition: DDAxes.h:10

void ODTTCciConfig::setTrgSleep ( int id )

inline

Definition at line 38 of file ODTTCciConfig.h.

References m_trg_sleep.

38 { m_trg_sleep = id; }

ODTTCciConfig::m_trg_sleep

int m_trg_sleep

Definition: ODTTCciConfig.h:65

void ODTTCciConfig::setTTCciClob ( unsigned char * x )

inline

Definition at line 41 of file ODTTCciConfig.h.

References m_ttcci_clob, and x.

41 { m_ttcci_clob = x; }

ODTTCciConfig::m_ttcci_clob

unsigned char * m_ttcci_clob

Definition: ODTTCciConfig.h:60

x

Definition: DDAxes.h:10

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

inline

Definition at line 27 of file ODTTCciConfig.h.

References m_ttcci_file, and x.

27 { m_ttcci_file = x; }

ODTTCciConfig::m_ttcci_file

std::string m_ttcci_file

Definition: ODTTCciConfig.h:61

x

Definition: DDAxes.h:10

void ODTTCciConfig::writeDB	(		)
throw	(	std::runtime_error
	)

private

Definition at line 163 of file ODTTCciConfig.cc.

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

 {
 
 
   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("ODTTCciConfig::writeDB():  "+e.getMessage()));
   }
   // Now get the ID
   if (!this->fetchID()) {
     throw(std::runtime_error("ODTTCciConfig::writeDB:  Failed to write"));
   }
 
 }