DbiCascader Class Reference

Concept A cascade (prioritorised list) of DbiConnections, one for each database in the cascade. Purpose Implements the concept of a cascade allowing user to overrride parts of the standard database by introducing higher priority non-standard ones above it in a cascade. More...

#include <DbiCascader.h>

List of all members.

Public Types
enum	Status { kFailed, kClosed, kOpen }
Public Member Functions
DbiStatement *	CreateStatement (UInt_t dbNo) const
	Create a DbiStatement. Caller must delete.
const DbiConnection *	GetConnection (UInt_t dbNo) const
	Return associated DbiConnection. DbiCascader retains ownership.
DbiConnection *	GetConnection (UInt_t dbNo)
string	GetDbName (UInt_t dbNo) const
Int_t	GetDbNo (const string &dbName) const
Int_t	GetStatus (UInt_t dbNo) const
string	GetStatusAsString (UInt_t dbNo) const
string	GetURL (UInt_t dbNo) const
Bool_t	IsTemporaryTable (const string &tableName, Int_t dbNo) const
Int_t	AllocateSeqNo (const string &tableName, Int_t requireGlobal=0, Int_t dbNo=0) const
Int_t	GetAuthorisingDbNo () const
UInt_t	GetNumDb () const
Int_t	GetTableDbNo (const string &tableName, Int_t selectDbNo=-1) const
Bool_t	TableExists (const string &tableName, Int_t selectDbNo=-1) const
Int_t	CreateTemporaryTable (const string &tableName, const string &tableDescr)
void	HoldConnections ()
void	ReleaseConnections ()
void	SetPermanent (UInt_t dbNo, Bool_t permanent=true)
Private Member Functions
Int_t	ReserveNextSeqNo (const string &tableName, Bool_t isGlobal, UInt_t dbNo) const
void	SetAuthorisingEntry (Int_t entry)
	DbiCascader ()
virtual	~DbiCascader ()
	DbiCascader (const DbiCascader &)
Private Attributes
Int_t	fGlobalSeqNoDbNo
	1st db in cascade with GlobalSeqNo table
vector< DbiConnection * >	fConnections
	Vector of DbiConnections, one for each DB.
std::map< string, Int_t >	fTemporaryTables
	Mapping Name->DbNo for temporary tables.
Friends
class	DbiTableProxyRegistry
class	DbiValidate
ostream &	operator<< (ostream &s, const DbiCascader &cascader)

---

Detailed Description

Concept A cascade (prioritorised list) of DbiConnections, one for each database in the cascade. Purpose Implements the concept of a cascade allowing user to overrride parts of the standard database by introducing higher priority non-standard ones above it in a cascade.

Id

DbiCascader.h,v 1.28 2008/08/22 10:27:29 nwest Exp

DatabaseInterface

Contact: n.west1@physics.ox.ac.uk

Definition at line 51 of file DbiCascader.h.

---

Member Enumeration Documentation

enum DbiCascader::Status

Enumeration values: kFailed  kClosed  kOpen  Definition at line 61 of file DbiCascader.h. { kFailed, kClosed, kOpen };

---

Constructor & Destructor Documentation

DbiCascader::DbiCascader (   )  [private]

Definition at line 38 of file DbiCascader.cxx. References gSystem(), LEA_CTOR, MSG, DbiConnection::Open(), and UtilString::StringTok(). : fGlobalSeqNoDbNo(-1) { // // // Purpose: Default constructor // // Arguments: // // Return: n/a // // Contact: N. West // // Specification:- // ============= // // o Create Cascader. // Program Notes:- // ============= // Current cascader configuration comes from 3 environmental // variables:- // // ENV_TSQL_URL a semi-colon separated list of URLs // ENV_TSQL_USER user name (one or a semi-colon separated list) // ENV_TSQL_PSWD password (one or a semi-colon separated list) // // or the _UPDATE alternatives e.g. ENV_TSQL_UPDATE_USER // // The _UPDATE versions take priority. LEA_CTOR //Leak Checker MSG("Dbi", Msg::kVerbose) << "Creating DbiCascader" << endl; // Extract args from ENV_TSQL environmental variables const char* strUser = gSystem->Getenv("ENV_TSQL_UPDATE_USER"); if ( ! strUser ) strUser = gSystem->Getenv("ENV_TSQL_USER"); const char* strPswd = gSystem->Getenv("ENV_TSQL_UPDATE_PSWD"); if ( ! strPswd ) strPswd = gSystem->Getenv("ENV_TSQL_PSWD"); const char* strUrl = gSystem->Getenv("ENV_TSQL_UPDATE_URL"); if ( !strUrl ) strUrl = gSystem->Getenv("ENV_TSQL_URL"); string userList = ( strUser ) ? strUser : ""; string pswdList = ( strPswd ) ? strPswd : ""; string urlList = ( strUrl ) ? strUrl : ""; if ( urlList == "" || userList == "" || pswdList == "" ) { MSG("Dbi",Msg::kFatal) << "Cannnot open a Database cascade;\n" << " the environmental variables ENV_TSQL_*:-" << endl << "USER: \"" << userList << "\" PSWD:\"" << pswdList << "\" URL:\"" << urlList << endl << " are either not defined or empty.\n" << " Please check your settings of ENV_TSQL_USER," << " ENV_TSQL_PSWD and ENV_TSQL_URL\n" << "Aborting due to above errors" << endl; exit(1); } std::vector<std::string> users, pswds, urls; UtilString::StringTok(users, userList, ";"); UtilString::StringTok(pswds, pswdList, ";"); UtilString::StringTok(urls, urlList, ";"); bool fail = false; for (unsigned entry = 0; entry < urls.size(); ++entry ) { string url = urls[entry]; string user = ( entry >= users.size() ) ? users[0] : users[entry]; string pswd = ( entry >= pswds.size() ) ? pswds[0] : pswds[entry]; // Handle empty password designated as '\0' (an empty null terminated character string) if ( pswd == "\\0" ) pswd = ""; DbiConnection* con = new DbiConnection(url,user,pswd); fConnections.push_back(con); if ( ! con->Open() ) { fail = true; continue; } // Attempt to locate first GlobalSeqNo/GLOBALSEQNO table. if ( fGlobalSeqNoDbNo != -1 ) continue; auto_ptr<DbiStatement> stmtDb(new DbiStatement(*con)); if ( ! stmtDb.get() ) continue; TSQLStatement* stmt = stmtDb->ExecuteQuery("Select * from GLOBALSEQNO where 1=0"); if ( stmt ) { fGlobalSeqNoDbNo = fConnections.size()-1; delete stmt; stmt = 0; } // Check for presence of a DBI_STATE_FLAG table if ( this->GetTableDbNo("DBI_STATE_FLAGS",entry) != -1 ) { MSG("Dbi",Msg::kFatal) << " POSSIBLE VERSION SHEAR DETECTED !!!\n" << " The DBI_STATE_FLAGS table is present on cascade entry " << entry << ". This table will\n" << " only be introduced to manage backward incompatible changes that could lead\n" << " to version shear between the code and the database. This version of the\n" << " code does not support the change the presence of that table indicates\n" << " so has to shut down. \n"; fail = true; } } MSG("Dbi",Msg::kInfo) << *this; // Abort, if there have been any failures. if ( fail ) { MSG("Dbi",Msg::kFatal) << "Aborting due to above errors" << endl; exit(1); } }

DbiCascader::~DbiCascader (   )  [private, virtual]

Definition at line 158 of file DbiCascader.cxx. References fConnections, GetNumDb(), LEA_DTOR, and MSG. { // // // Purpose: Destructor // LEA_DTOR //Leak Checker MSG("Dbi", Msg::kVerbose) << "Destroying DbiCascader" << endl; for (Int_t dbNo = this->GetNumDb()-1; dbNo >= 0; --dbNo) delete fConnections[dbNo]; }

DbiCascader::DbiCascader (  const DbiCascader &   )  [private]

---

Member Function Documentation

Int_t DbiCascader::AllocateSeqNo (  const string &  tableName, Int_t  requireGlobal = 0, Int_t  dbNo = 0 )  const

Definition at line 212 of file DbiCascader.cxx. References fGlobalSeqNoDbNo, IsTemporaryTable(), MSG, and ReserveNextSeqNo(). Referenced by DbiWriter< T >::Close(), DbmModule::ExportTable(), DbmModule::GlobaliseSeqNo(), DbiLogEntry::Write(), and DbiConfigStream::Write(). { // // // Purpose: Allocate a unique (either locally or globally) SEQNO. // // Arguments: // tableName in The table for which the SEQNO is required. // requireGlobal in The type of SEQNO required:- // > 0 Must be global // = 0 Must be global if supplied dbNo is authorising // and table isn't temporary otherwise local // < 0 Must be local // dbNo in The entry in the cascade for which the SEQNO is required // // Return: The allocated SEQNO or 0 if failure. // // Contact: N. West // Program Notes:- // ============= // Requests for SEQNOs take account of any pre-existing entries; local entries // should only be used for development and this allows for the LOCALSEQNO table // and the local data to be wiped at different times without causing conflicts. // Global entries should not be a problem as the GLOBALSEQNO table isn't wiped // but it provides protection in case the table is damaged (which has happened!). bool isTemporary = IsTemporaryTable(tableName,dbNo); // Deal with global requests. if ( requireGlobal > 0 || ( requireGlobal == 0 && dbNo == fGlobalSeqNoDbNo && ! isTemporary ) ) { if ( fGlobalSeqNoDbNo < 0 ) { MSG("Dbi",Msg::kWarning) << "Unable to issue global SEQNO - no authorising DB in cascade\n" << " will issue local one instead" << endl; } else if ( isTemporary ) { MSG("Dbi",Msg::kWarning) << "Unable to issue global SEQNO - " << tableName << " is temporary\n" << " will issue local one instead" << endl; } else return this->ReserveNextSeqNo(tableName,true,fGlobalSeqNoDbNo); } // Deal with local requests return this->ReserveNextSeqNo(tableName,false,dbNo); }

DbiStatement * DbiCascader::CreateStatement (  UInt_t  dbNo  )  const

Create a DbiStatement. Caller must delete. Definition at line 266 of file DbiCascader.cxx. References fConnections, GetStatus(), and DbiStatement::PrintExceptions(). Referenced by DbuDaqFileModule::BeginJob(), createSpillTables(), PhotonStatSummarizer::CreateTables(), CreateTables(), DbmValidate::DbmValidate(), DTFtest(), DbiDBProxy::FindTimeBoundaries(), DbmModule::Import(), DbuDaqMonitorModule::InitTSQLConnection(), DbmModule::ListTables(), DbiDBProxy::QueryAllValidities(), DbiDBProxy::QuerySeqNo(), DbiDBProxy::QuerySeqNos(), DbiDBProxy::QueryValidity(), DbiDBProxy::RemoveSeqNo(), DbiDBProxy::ReplaceInsertDate(), DbiDBProxy::ReplaceSeqNo(), and DbiDBProxy::ReplaceSeqNoOracle(). { // // // Purpose: Return a Statement to caller. // // Arguments: // dbNo in Database no. in cascade for which statement // is required. // // Return: Created statement (or 0 if creation failed). // User must delete. // Program Notes:- // ============= // As the caller is responsible for destroying the statement after use // consider:- // // #include <memory> // using std::auto_ptr; // // ... // // auto_ptr<DbiStatement> stmt(cascader.CreateStatement(dbNo)); if ( this->GetStatus(dbNo) == kFailed ) return 0; DbiConnection& conDb = *fConnections[dbNo]; DbiStatement* stmtDb = new DbiStatement(conDb); stmtDb->PrintExceptions(); return stmtDb; }

Int_t DbiCascader::CreateTemporaryTable (  const string &  tableName, const string &  tableDescr )

Definition at line 300 of file DbiCascader.cxx. References DbiStatement::ExecuteUpdate(), fConnections, fTemporaryTables, GetConnection(), DbiConnection::GetUrl(), Dbi::GetVldDescr(), MsgService::Instance(), MsgService::IsActive(), DbiConnection::IsTemporary(), MAXMSG, MSG, DbiConnection::SetPermanent(), DbiConnection::SetTableExists(), and UtilString::ToUpper(). Referenced by DetailedTimeCal(), load_better_mipcal(), load_mc_mipcal(), LoadBeamMomentum(), LoadCERRange(), LoadCERTimeWin(), LoadOverlapWin(), LoadTOFRange(), main(), MakeFilterChannelList(), UgliGeometryReroot::MakeTempDbiGeometry(), UgliGeometryReroot::MakeTempDbiPosInfo(), UgliGeometryReroot::MakeTempDbiScintStruct(), MakeTimeCal(), AutoPIDMaker::Reco(), FillSpillServerMon::WriteToDatabase(), FillNearRunQuality::WriteToDatabase(), FillHvFromSingles::WriteToDatabase(), and FillFarRunQuality::WriteToDatabase(). { // // // Purpose: Creat temporary table with associated validity table // // Arguments: // tableNameMc in Table name // tableDescr in Table description as parenthesised comma // separated list e.g.:- // "(MyInt int, MyFloat float, MyString text)" // // Return: The database cascade number on which the table was // created or = -1 if unable to create. // // Contact: N. West // // Specification:- // ============= // // o Loop over all databases in cascade, starting at the highest // priority i.e. entry 0 and find the first that will accept create // temporary table requests. Return -1 if none will. // // o Make connection permanent so that temporary data won't be lost. // // o Generate and submit requests to create temporary table with // associated validity table and return the cascade number of // the database that has accepted the tables, recording table // name in fTemporaryTables. // // Check that input args look plausible. string tableName = UtilString::ToUpper(tableNameMc); if ( tableName == "" || tableDescr[0] != '(' || tableDescr[tableDescr.size()-1] != ')' ) { MAXMSG("Dbi",Msg::kError,20) << "Illegal input args:-" << endl << " Table Name: " << tableName << " Table Description: " << tableDescr <<endl; return -1; } // Find a DB that will accept the command. string sqlMakeTable; Int_t dbNoAcc = -1; auto_ptr<DbiStatement> stmtDb; for (UInt_t dbNoTry = 0; dbNoTry < fConnections.size(); ++dbNoTry ) { stmtDb.reset(this->CreateStatement(dbNoTry)); if ( stmtDb.get() ) { sqlMakeTable = " create temporary table "; sqlMakeTable += tableName; sqlMakeTable += " "; sqlMakeTable += tableDescr; sqlMakeTable += ";"; stmtDb->ExecuteUpdate(sqlMakeTable.c_str()); if ( stmtDb->GetExceptionLog().IsEmpty() ) { dbNoAcc = dbNoTry; this->GetConnection(dbNoAcc)->SetTableExists(tableName); break; } if ( MsgService::Instance()->IsActive("Dbi",Msg::kSynopsis) )stmtDb->PrintExceptions(); } } if ( dbNoAcc < 0 ) { if ( stmtDb.get()) stmtDb->PrintExceptions(); return -1; } // Make connection permanent if not already. DbiConnection& conDb = *fConnections[dbNoAcc]; if ( conDb.IsTemporary() ) { conDb.SetPermanent(); MSG("Dbi",Msg::kInfo) << "Making connection: " << conDb.GetUrl() << " permanent to preserve temporary tables." << endl; } // Create SQL to create auxillary validity table and write to same Db. sqlMakeTable = Dbi::GetVldDescr(tableName.c_str(),true); MSG("Dbi",Msg::kSynopsis) << "Validity Table creation: " << " Database: " << dbNoAcc << " " << sqlMakeTable << endl; stmtDb->ExecuteUpdate(sqlMakeTable.c_str()); if ( stmtDb->PrintExceptions() ) return -1; this->GetConnection(dbNoAcc)->SetTableExists(tableName+"VLD"); fTemporaryTables[tableName] = dbNoAcc; return dbNoAcc; }

Int_t DbiCascader::GetAuthorisingDbNo (   )  const [inline]

Definition at line 91 of file DbiCascader.h. Referenced by DbmModule::GlobaliseSeqNo(), and DbiWriter< T >::WritingToMaster(). { return fGlobalSeqNoDbNo; }

DbiConnection * DbiCascader::GetConnection (  UInt_t  dbNo  )

Definition at line 410 of file DbiCascader.cxx. References fConnections, and GetStatus(). { // // // Purpose: Return a connection to caller (DbiCascader retains ownership) if ( this->GetStatus(dbNo) == kFailed ) return 0; return fConnections[dbNo]; }

const DbiConnection * DbiCascader::GetConnection (  UInt_t  dbNo  )  const

Return associated DbiConnection. DbiCascader retains ownership. Definition at line 398 of file DbiCascader.cxx. References fConnections, and GetStatus(). Referenced by CreateTemporaryTable(), DTFtest(), GetTableDbNo(), DbiDBProxy::ReplaceSeqNo(), and DbiDBProxy::StoreMetaData(). { // // // Purpose: Return a connection to caller (DbiCascader retains ownership) if ( this->GetStatus(dbNo) == kFailed ) return 0; return fConnections[dbNo]; }

string DbiCascader::GetDbName (  UInt_t  dbNo  )  const

Definition at line 424 of file DbiCascader.cxx. References fConnections, DbiConnection::GetDbName(), GetNumDb(), and MSG. { // // // Purpose: Return Database Name for cascade entry number. string dbName; if ( dbNo < this->GetNumDb() ) dbName = fConnections[dbNo]->GetDbName(); else MSG("Dbi",Msg::kWarning) << "Database does not contain entry " << dbNo << endl; return dbName; }

Int_t DbiCascader::GetDbNo (  const string &  dbName  )  const

Definition at line 439 of file DbiCascader.cxx. References fConnections, GetNumDb(), and MSG. Referenced by DbiWriter< T >::SetDbName(). { // // // Purpose: Return number of first DB in cascade with name dbName. // // Return: Database number corresponding to dbName or -1 if none. for ( unsigned dbNo = 0; dbNo < this->GetNumDb(); ++dbNo) { if ( dbName == fConnections[dbNo]->GetDbName() ) return dbNo; } MSG("Dbi",Msg::kWarning) << "Database does not contain entry " << dbName << endl; return -1; }

UInt_t DbiCascader::GetNumDb (   )  const [inline]

Definition at line 92 of file DbiCascader.h. Referenced by DbiTableProxyRegistry::Config(), GetDbName(), GetDbNo(), DbiDBProxy::GetNumDb(), main(), operator<<(), DbiDBProxy::StoreMetaData(), and ~DbiCascader(). {return fConnections.size();}

Int_t DbiCascader::GetStatus (  UInt_t  dbNo  )  const [inline]

Definition at line 78 of file DbiCascader.h. Referenced by CreateStatement(), GetConnection(), and GetStatusAsString(). { if ( dbNo >= GetNumDb() || ! fConnections[dbNo] ) return kFailed; return fConnections[dbNo]->IsClosed() ? kClosed : kOpen; }

string DbiCascader::GetStatusAsString (  UInt_t  dbNo  )  const

Definition at line 457 of file DbiCascader.cxx. References GetStatus(), kClosed, and kOpen. Referenced by operator<<(). { // // // Purpose: Return DB connection status as a string. // // Arguments: // dbNo in Database number (0..GetNumDb()-1) Int_t status = GetStatus(dbNo); switch ( status ) { case kClosed: return "Closed"; case kOpen: return "Open "; default: return "Failed"; } }

Int_t DbiCascader::GetTableDbNo (  const string &  tableName, Int_t  selectDbNo = -1 )  const

Definition at line 476 of file DbiCascader.cxx. References fConnections, GetConnection(), and DbiConnection::TableExists(). Referenced by DbmModule::LogEntry(), and DbiSqlValPacket::SetMetaData(). { // // // Purpose: Return cascade number of first database that holds table // or -1 if none. // If selectDbNo >= 0 only look in this entry in the cascade. // If table name has any lower case letters then fail. // Lower case are not allowed by ORACLE which kindly // converts to upper case so SQL would pass if upper case version // exists. string::const_iterator itr = tableName.begin(); string::const_iterator itrEnd = tableName.end(); while ( itr != itrEnd ) if ( islower(*itr++) ) return -1; // Loop over cascade looking for table. for (UInt_t dbNoTry = 0; dbNoTry < fConnections.size(); ++dbNoTry ) { if ( selectDbNo >= 0 && (UInt_t) selectDbNo != dbNoTry ) continue; const DbiConnection* con = this->GetConnection(dbNoTry); if ( con && con->TableExists(tableName) ) return dbNoTry; } return -1; }

string DbiCascader::GetURL (  UInt_t  dbNo  )  const [inline]

Definition at line 82 of file DbiCascader.h. Referenced by operator<<(), and DbiLogEntry::SetServerName(). { return ( dbNo < GetNumDb() ) ? fConnections[dbNo]-> GetUrl(): ""; }

void DbiCascader::HoldConnections (   )

Definition at line 506 of file DbiCascader.cxx. References DbiConnection::ConnectStatement(), and fConnections. { // // // Purpose: Hold temporary connections open // Specification:- // ============= // Hold all connections open by telling them that they have a // connected statement. // Program Notes:- // ============= // See DbiConnectionMaintainer for use. for (UInt_t dbNo = 0; dbNo < fConnections.size(); ++dbNo ) fConnections[dbNo]->ConnectStatement(); }

Bool_t DbiCascader::IsTemporaryTable (  const string &  tableName, Int_t  dbNo )  const

Definition at line 528 of file DbiCascader.cxx. References fTemporaryTables. Referenced by AllocateSeqNo(), ReserveNextSeqNo(), and DbiWriter< T >::WritingToMaster(). { // // // Purpose: Return kTRUE if tableName is temporary in cascade member dbNo map<string,Int_t>::const_iterator itr = fTemporaryTables.find(tableName); return ( itr != fTemporaryTables.end() && (*itr).second == dbNo ); }

void DbiCascader::ReleaseConnections (   )

Definition at line 626 of file DbiCascader.cxx. References fConnections. Referenced by DbiConnectionMaintainer::~DbiConnectionMaintainer(). { // // // Purpose: Release temporary connections held open by HoldConnections. // Specification:- // ============= // Undo HoldConnections() by telling all connections that they no longer // have a connected statement. // Program Notes:- // ============= // See DbiConnectionMaintainer for use. for (UInt_t dbNo = 0; dbNo < fConnections.size(); ++dbNo ) fConnections[dbNo]->DisConnectStatement(); }

Int_t DbiCascader::ReserveNextSeqNo (  const string &  tableName, Bool_t  isGlobal, UInt_t  dbNo )  const [private]

Definition at line 648 of file DbiCascader.cxx. References DbiString::c_str(), DbiString::Clear(), IsTemporaryTable(), MAXMSG, MSG, and TableExists(). Referenced by AllocateSeqNo(). { // // // Purpose: Reserve the next higher available unique (either locally or globally) SEQNO. // in the appropriate SEQNO table. // // Arguments: // tableName in The table for which the SEQNO is required. // isGlobal in = true - reserve in GLOBALSEQNO table(dbNo must be authorizing) // = false - reserve in LOCALSEQNO table (creating if required) // dbNo in The entry in the cascade holding the SEQNO table. // // Return: The allocated SEQNO or 0 if failure. // // Contact: N. West // Program Notes:- // ============= // Requests for local SEQNOs may result in the creation of a LOCALSEQNO table. DbiString sql; string seqnoTableName = isGlobal ? "GLOBALSEQNO" : "LOCALSEQNO"; bool seqnoTableNameExists = this->TableExists(seqnoTableName,dbNo); bool tableNameExists = this->TableExists(tableName,dbNo); auto_ptr<DbiStatement> stmtDb(this->CreateStatement(dbNo) ); if ( ! stmtDb.get() ) return 0; // Check that required SEQNO table exists. if ( isGlobal ) { if ( ! seqnoTableNameExists ) { MAXMSG("Dbi",Msg::kError,20) << "Unable to issue global SEQNO - " << dbNo << " is not an authorising DB" << endl; return 0; } } else { if ( ! seqnoTableNameExists ) { sql.Clear(); sql << "CREATE TABLE " << seqnoTableName << "(TABLENAME CHAR(64) NOT NULL PRIMARY KEY,\n" << " LASTUSEDSEQNO INT )"; MSG("Dbi",Msg::kSynopsis) << "Database: " << dbNo << " create local SEQNO table query: " << sql.c_str() << endl; stmtDb->ExecuteUpdate(sql.c_str()); if ( stmtDb->PrintExceptions() ) return 0; sql.Clear(); sql << "INSERT INTO " << seqnoTableName << " VALUES ('*',0)"; MSG("Dbi",Msg::kSynopsis) << "Database: " << dbNo << " prime local SEQNO table query: " << sql.c_str() << endl; stmtDb->ExecuteUpdate(sql.c_str()); if ( stmtDb->PrintExceptions() ) return 0; } } // Lock seqno table by creating a lock object on the stack. // Table will be unlocked when lock object destroyed. string dataTable; // Only pass in table name if it's not temporary and exists in // the selected DB otherwise Lock will try to lock a non-existent table. if ( ! this->IsTemporaryTable(tableName,dbNo) && tableNameExists ) dataTable = tableName; Lock lock(this->CreateStatement(dbNo),seqnoTableName,dataTable); if ( ! lock.IsLocked() ) { MAXMSG("Dbi",Msg::kError,20) << "Unable to lock " << seqnoTableName << endl; return 0; } // Find row containing last used SeqNo for this table. // Not that comparison is case insensitive. sql.Clear(); sql << "select * from " << seqnoTableName << " where TABLENAME = '*' or TABLENAME = '"; sql << tableName + "' order by TABLENAME"; MSG("Dbi",Msg::kSynopsis) << seqnoTableName << " query: " << sql.c_str() << endl; TSQLStatement* stmt = stmtDb->ExecuteQuery(sql.c_str()); stmtDb->PrintExceptions(Msg::kDebug); Int_t seqNoDefault = 0; if ( stmt && stmt->NextResultRow() ) { seqNoDefault = stmt->GetInt(1); } else { MAXMSG("Dbi",Msg::kError,20) << "Unable to find default SeqNo" << " due to above error" << endl; delete stmt; stmt = 0; return 0; } Int_t seqNoTable = seqNoDefault; if ( stmt->NextResultRow() ) { seqNoTable = stmt->GetInt(1); } delete stmt; stmt = 0; MSG("Dbi",Msg::kSynopsis) << " query returned last used seqno: " << seqNoTable << endl; // If the table exists, make sure that the seqNo hasn't already been used. // This is paranoia code and expensive, so only do the check once for // each tableName/isGlobal/dbNo combination. static std::string checkedCombinations; ostringstream combination; combination << ":" << tableName << isGlobal << dbNo << ":"; bool notChecked = checkedCombinations.find(combination.str()) == std::string::npos; if ( notChecked ) checkedCombinations += combination.str(); if ( tableNameExists && notChecked ) { Int_t seqNoMin = seqNoDefault; Int_t seqNoMax = seqNoDefault + Dbi::kMAXLOCALSEQNO; sql.Clear(); sql << "select max(SEQNO) from " << tableName << "VLD" << " where SEQNO between " << seqNoMin << " and " << seqNoMax; MSG("Dbi",Msg::kSynopsis) << "Database: " << dbNo << " max SEQNO query: " << sql.c_str() << endl; stmt = stmtDb->ExecuteQuery(sql.c_str()); if ( stmtDb->PrintExceptions() ) return 0; Int_t minValue = 0; // Queries returning group function results can be null. if ( stmt && stmt->NextResultRow() && ! stmt->IsNull(0) ) { minValue = stmt->GetInt(0); if ( minValue <= 0 ) minValue = 0; // Should never happen. } delete stmt; stmt = 0; if ( minValue > seqNoTable ) { MAXMSG("Dbi",Msg::kError,20) << "Database: " << dbNo << " " << seqnoTableName << " has last used SEQNO of " << seqNoTable << " for table " << tableName << ",\n but the highest SEQNO in the band " << seqNoMin << " to " << seqNoMax << " is " << minValue << " for that table\n " << seqnoTableName << " is out of date! It will be updated for " << tableName << endl; seqNoTable = minValue; } } // Update last used SeqNo and record in table. sql.Clear(); sql << "delete from " << seqnoTableName << " where TABLENAME='"; sql << tableName + "'"; MSG("Dbi",Msg::kSynopsis) << "SEQNO entry removal: " << sql.c_str() << endl; stmtDb->ExecuteUpdate(sql.c_str()); if ( stmtDb->PrintExceptions() ) return 0; seqNoTable++; sql.Clear(); sql << "insert into " << seqnoTableName << " values('"; sql << tableName + "'," << seqNoTable << ")"; MSG("Dbi",Msg::kSynopsis) << "SEQNO entry add: " << sql.c_str() << endl; stmtDb->ExecuteUpdate(sql.c_str()); if ( stmtDb->PrintExceptions() ) return 0; return seqNoTable; }

void DbiCascader::SetAuthorisingEntry (  Int_t  entry  )  [inline, private]

Definition at line 112 of file DbiCascader.h. {fGlobalSeqNoDbNo = entry;}

void DbiCascader::SetPermanent (  UInt_t  dbNo, Bool_t  permanent = true )

Definition at line 813 of file DbiCascader.cxx. References fConnections. Referenced by DbiTableProxyRegistry::Config(), and main(). { // // // Purpose: Set connection permanent. if ( dbNo < fConnections.size() ) fConnections[dbNo]->SetPermanent(permanent); }

Bool_t DbiCascader::TableExists (  const string &  tableName, Int_t  selectDbNo = -1 )  const [inline]

Definition at line 94 of file DbiCascader.h. Referenced by FillSpillServerMon::ReadFromDatabase(), FillNearRunQuality::ReadFromDatabase(), FillHvFromSingles::ReadFromDatabase(), FillFarRunQuality::ReadFromDatabase(), DbiSqlValPacket::Recreate(), ReserveNextSeqNo(), DbiDBProxy::TableExists(), FillSpillServerMon::WriteToDatabase(), FillNearRunQuality::WriteToDatabase(), FillHvFromSingles::WriteToDatabase(), and FillFarRunQuality::WriteToDatabase(). { return this->GetTableDbNo(tableName,selectDbNo) >= 0; }

---

Friends And Related Function Documentation

friend class DbiTableProxyRegistry [friend]

Definition at line 54 of file DbiCascader.h.

friend class DbiValidate [friend]

Definition at line 59 of file DbiCascader.h.

ostream& operator<< (  ostream &  s, const DbiCascader &  cascader )  [friend]

Definition at line 174 of file DbiCascader.cxx. { // // // Purpose: Output DbiCascader status to message stream. // // Arguments: // os in ostream to output on // cascader in Cascader to be output // // Return: ostream // // Contact: N. West // // Specification:- // ============= // // o Output DbiCascader status to ostream. // Program Notes:- // ============= // None. os << "DbiCascader Status:- " << endl << "Status URL" << endl << endl; int maxDb = cascader.GetNumDb(); for (Int_t dbNo = 0; dbNo < maxDb; ++dbNo) os << cascader.GetStatusAsString(dbNo) << " " << ( ( dbNo == cascader.fGlobalSeqNoDbNo ) ? "(auth) " : " ") << cascader.GetURL(dbNo) << endl; os << endl; return os; }

---

Member Data Documentation

vector<DbiConnection*> DbiCascader::fConnections [private]

Vector of DbiConnections, one for each DB. Definition at line 125 of file DbiCascader.h. Referenced by CreateStatement(), CreateTemporaryTable(), GetConnection(), GetDbName(), GetDbNo(), GetTableDbNo(), HoldConnections(), ReleaseConnections(), SetPermanent(), and ~DbiCascader().

Int_t DbiCascader::fGlobalSeqNoDbNo [private]

1st db in cascade with GlobalSeqNo table Definition at line 122 of file DbiCascader.h. Referenced by AllocateSeqNo(), and operator<<().

std::map<string,Int_t> DbiCascader::fTemporaryTables [private]

Mapping Name->DbNo for temporary tables. Definition at line 128 of file DbiCascader.h. Referenced by CreateTemporaryTable(), and IsTemporaryTable().

---

The documentation for this class was generated from the following files:

• DbiCascader.h
• DbiCascader.cxx

---