EcalDBConnection Class Reference

#include <EcalDBConnection.h>

Inheritance diagram for EcalDBConnection:

Public Member Functions
void	commit ()
oracle::occi::Statement *	createStatement ()
	EcalDBConnection (std::string host, std::string sid, std::string user, std::string pass, int port=1521) noexcept(false)
	EcalDBConnection (std::string sid, std::string user, std::string pass) noexcept(false)
oracle::occi::Clob	getClobLocator ()
oracle::occi::Connection *	getConn () const
oracle::occi::Environment *	getEnv () const
void	rollback ()
void	terminateStatement (oracle::occi::Statement *stmt)
virtual	~EcalDBConnection () noexcept(false)

Protected Attributes
oracle::occi::Connection *	conn
oracle::occi::Environment *	env
std::string	host
std::string	pass
int	port
std::string	sid
oracle::occi::Statement *	stmt
std::string	user

Detailed Description

A wrapper class for the oracle Connection and Environment classes along with any OCCI-dependent methods that are useful for any database

Definition at line 15 of file EcalDBConnection.h.

Constructor & Destructor Documentation

EcalDBConnection() [1/2]

EcalDBConnection::EcalDBConnection ( std::string  host, std::string  sid, std::string  user, std::string  pass, int  port = 1521  )

noexcept

Constructor Makes a connection to an oracle database without TNS_ADMIN

EcalDBConnection() [2/2]

EcalDBConnection::EcalDBConnection ( std::string  sid, std::string  user, std::string  pass  )

noexcept

Constructor Makes a connection to an oracle database using TNS_ADMIN

~EcalDBConnection()

EcalDBConnection::~EcalDBConnection ( )

virtualnoexcept

Destructor

Definition at line 50 of file EcalDBConnection.cc.

References getInfo::conn, MillePedeFileConverter_cfg::e, and web.browse_db::env.

                                                    {
  //Close database conection and terminate environment
  try {
    conn->terminateStatement(stmt);
    env->terminateConnection(conn);
    Environment::terminateEnvironment(env);
  } catch (SQLException &e) {
    throw(std::runtime_error("ERROR:  Destructor Failed:  " + e.getMessage()));
  }
}

Member Function Documentation

commit()

void EcalDBConnection::commit ( )

inline

Tranaction manaagement

Definition at line 55 of file EcalDBConnection.h.

References conn.

{ conn->commit(); }

createStatement()

oracle::occi::Statement* EcalDBConnection::createStatement ( )

inline

Get a new Statement

Definition at line 42 of file EcalDBConnection.h.

References conn, and gather_cfg::cout.

                                                {
    std::cout << "Creating statement" << std::endl;
    return conn->createStatement();
  }

getClobLocator()

oracle::occi::Clob EcalDBConnection::getClobLocator ( )

inline

Get a new clob locator

Definition at line 61 of file EcalDBConnection.h.

References conn.

{ return oracle::occi::Clob(conn); }

getConn()

oracle::occi::Connection* EcalDBConnection::getConn ( ) const

inline

Definition at line 64 of file EcalDBConnection.h.

References conn.

{ return conn; };

getEnv()

oracle::occi::Environment* EcalDBConnection::getEnv ( ) const

inline

Definition at line 63 of file EcalDBConnection.h.

References env.

{ return env; };

rollback()

void EcalDBConnection::rollback ( )

inline

Definition at line 56 of file EcalDBConnection.h.

References conn.

{ conn->rollback(); }

terminateStatement()

void EcalDBConnection::terminateStatement ( oracle::occi::Statement *  stmt )

inline

Definition at line 47 of file EcalDBConnection.h.

References conn, gather_cfg::cout, and stmt.

                                                            {
    std::cout << "Creating statement" << std::endl;
    conn->terminateStatement(stmt);
  }

Member Data Documentation

conn

oracle::occi::Connection* EcalDBConnection::conn

protected

Definition at line 72 of file EcalDBConnection.h.

Referenced by commit(), createStatement(), EcalCondDBInterface::EcalCondDBInterface(), EcalCondDBInterface::fetchConfigDataSet(), EcalCondDBInterface::fetchConfigSet(), EcalCondDBInterface::fetchDataSet(), EcalCondDBInterface::fetchDataSetWithMap(), EcalCondDBInterface::fetchDCSDataSet(), EcalCondDBInterface::fetchLastConfigSet(), EcalCondDBInterface::fetchValidDataSet(), getClobLocator(), getConn(), EcalCondDBInterface::insertConfigDataArraySet(), EcalCondDBInterface::insertConfigDataSet(), EcalCondDBInterface::insertConfigSet(), EcalCondDBInterface::insertDataArraySet(), EcalCondDBInterface::insertDataSet(), EcalCondDBInterface::insertDataSetVector(), rollback(), and terminateStatement().

env

oracle::occi::Environment* EcalDBConnection::env

protected

Definition at line 64 of file EcalDBConnection.h.

Referenced by EcalCondDBInterface::EcalCondDBInterface(), EcalCondDBInterface::fetchConfigDataSet(), EcalCondDBInterface::fetchConfigSet(), EcalCondDBInterface::fetchDataSet(), EcalCondDBInterface::fetchDataSetWithMap(), EcalCondDBInterface::fetchDCSDataSet(), EcalCondDBInterface::fetchLastConfigSet(), EcalCondDBInterface::fetchValidDataSet(), getEnv(), EcalCondDBInterface::insertConfigDataArraySet(), EcalCondDBInterface::insertConfigDataSet(), EcalCondDBInterface::insertConfigSet(), EcalCondDBInterface::insertDataArraySet(), EcalCondDBInterface::insertDataSet(), and EcalCondDBInterface::insertDataSetVector().

host

std::string EcalDBConnection::host

protected

Definition at line 75 of file EcalDBConnection.h.

pass

std::string EcalDBConnection::pass

protected

Definition at line 79 of file EcalDBConnection.h.

port

int EcalDBConnection::port

protected

Definition at line 76 of file EcalDBConnection.h.

sid

std::string EcalDBConnection::sid

protected

Definition at line 77 of file EcalDBConnection.h.

stmt

oracle::occi::Statement* EcalDBConnection::stmt

protected

Definition at line 73 of file EcalDBConnection.h.

Referenced by terminateStatement().

user

std::string EcalDBConnection::user

protected

Definition at line 78 of file EcalDBConnection.h.

Referenced by dataset.BaseDataset::printInfo(), DTWorkflow.DTWorkflow::remote_out_path(), production_tasks.CheckDatasetExists::run(), production_tasks.GenerateMask::run(), production_tasks.SourceCFG::run(), production_tasks.FullCFG::run(), production_tasks.MonitorJobs::run(), and production_tasks.CleanJobFiles::run().