TDbiCascader Class Reference

Concept A cascade (prioritorised list) of TDbiConnection s, one for each database in the cascade. More...

#include <TDbiCascader.hxx>

Collaboration diagram for TDbiCascader:

[legend]

List of all members.

Classes
class	Lock
	Private Locker object used by TDbiCascader. More...
Public Types
enum	Status { kFailed, kClosed, kOpen }
Public Member Functions
TDbiStatement *	CreateStatement (UInt_t dbNo) const
	Create a TDbiStatement. Caller must delete.
const TDbiConnection *	GetConnection (UInt_t dbNo) const
	Return associated TDbiConnection. TDbiCascader retains ownership.
TDbiConnection *	GetConnection (UInt_t dbNo)
string	GetDbName (UInt_t dbNo) const
	Purpose: Return Database Name for cascade entry number.
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
	Purpose: Return kTRUE if tableName is temporary in cascade member dbNo.
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)
	Purpose: Set connection permanent.
Static Public Member Functions
static bool	canConnect ()
Private Member Functions
Int_t	ReserveNextSeqNo (const string &tableName, Bool_t isGlobal, UInt_t dbNo) const
void	SetAuthorisingEntry (Int_t entry)
	TDbiCascader (bool beQuiet=false)
virtual	~TDbiCascader ()
	TDbiCascader (const TDbiCascader &)
Private Attributes
Int_t	fGlobalSeqNoDbNo
	1st db in cascade with GlobalSeqNo table
vector< TDbiConnection * >	fConnections
	Vector of TDbiConnections, one for each DB.
std::map< string, Int_t >	fTemporaryTables
	Mapping Name->DbNo for temporary tables.
Friends
class	TDbiDatabaseManager
class	TDbiValidate
ostream &	operator<< (ostream &s, const TDbiCascader &cascader)

---

Detailed Description

Concept A cascade (prioritorised list) of TDbiConnection s, 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. Contact: A.Finch@lancaster.ac.uk

Definition at line 48 of file TDbiCascader.hxx.

---

Member Enumeration Documentation

enum TDbiCascader::Status

Enumerator:

kFailed
kClosed
kOpen

Definition at line 62 of file TDbiCascader.hxx.

{ kFailed, kClosed, kOpen };

---

Constructor & Destructor Documentation

TDbiCascader::TDbiCascader

(

bool

beQuiet = false

)

[private]

TDbiCascader::~TDbiCascader

(

)

[private, virtual]

Definition at line 174 of file TDbiCascader.cxx.

References fConnections, GetNumDb(), and SK_DBI_Trace.

                            {
//
//
//  Purpose: Destructor
//


  SK_DBI_Trace( "Destroying TDbiCascader" << "  ");

  for (Int_t dbNo = this->GetNumDb()-1; dbNo >= 0; --dbNo) delete fConnections[dbNo];

}

Here is the call graph for this function:

TDbiCascader::TDbiCascader

(

const TDbiCascader &

)

[private]

---

Member Function Documentation

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

   
     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!).
   

Definition at line 269 of file TDbiCascader.cxx.

References fGlobalSeqNoDbNo, IsTemporaryTable(), ReserveNextSeqNo(), and SK_DBI_Warn.

Referenced by TSeqNoAllocator::GetSeqNo(), TDbiLogEntry::Write(), and TDbiConfigStream::Write().

                                                              {



  bool isTemporary = IsTemporaryTable(tableName,dbNo);

  //  Deal with global requests.

  if (     requireGlobal > 0
      || ( requireGlobal == 0 && dbNo == fGlobalSeqNoDbNo && ! isTemporary ) ) {
    if ( fGlobalSeqNoDbNo < 0 ) {
      SK_DBI_Warn( "Unable to issue global SEQNO - no authorising DB in cascade\n"
                               << "  will issue local one instead" << "  ");
    }
    else if ( isTemporary ) {
      SK_DBI_Warn( "Unable to issue global SEQNO - " << tableName << " is temporary\n"
                               << "  will issue local one instead" << "  ");
    }
    else return this->ReserveNextSeqNo(tableName,true,fGlobalSeqNoDbNo);
  }

  // Deal with local requests

  return this->ReserveNextSeqNo(tableName,false,dbNo);

}

Here is the call graph for this function:

Here is the caller graph for this function:

bool TDbiCascader::canConnect

(

)

[static]

Check we can connect to the database defined in the environment variables. Allows a user program to skip using the database if it doesn't need to and it is not there, or if it does need it then die in a civilised manner.

Definition at line 225 of file TDbiCascader.cxx.

References SK_DBI_Trace.

{
  SK_DBI_Trace(" bool TDbiCascader::canConnect() started");

  try
    {
      TDbiCascader test(false);
      //   test.NOOP();
      SK_DBI_Trace(" bool TDbiCascader::canConnect() return true");
      return true;
    }
  catch(...)
    {
      SK_DBI_Trace(" bool TDbiCascader::canConnect() return false");
      return false;
    }
}

TDbiStatement * TDbiCascader::CreateStatement

(

UInt_t

dbNo

)

const

Create a TDbiStatement. Caller must delete.

   
     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<TDbiStatement> stmt(cascader.CreateStatement(dbNo));
   

Definition at line 322 of file TDbiCascader.cxx.

References fConnections, GetStatus(), kFailed, and TDbiStatement::PrintExceptions().

Referenced by CreateTemporaryTable(), TDbiDBProxy::FindTimeBoundaries(), TDbiDBProxy::QueryAllValidities(), TDbiDBProxy::QuerySeqNo(), TDbiDBProxy::QuerySeqNos(), TDbiDBProxy::QueryValidity(), TDbiDBProxy::RemoveSeqNo(), TDbiDBProxy::ReplaceInsertDate(), TDbiDBProxy::ReplaceSeqNo(), and ReserveNextSeqNo().

                                                              {


  if ( this->GetStatus(dbNo) == kFailed ) return 0;
  TDbiConnection& conDb = *fConnections[dbNo];
  TDbiStatement* stmtDb = new TDbiStatement(conDb);
  stmtDb->PrintExceptions();
  return stmtDb;

}

Here is the call graph for this function:

Here is the caller graph for this function:

Int_t TDbiCascader::CreateTemporaryTable	(	const string &	tableNameMc,
		const string &	tableDescr
	)

   
     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.
   
   

Definition at line 363 of file TDbiCascader.cxx.

References CreateStatement(), fConnections, fTemporaryTables, GetConnection(), TDbiConnection::GetUrl(), TDbi::GetVldDescr(), TDbiConnection::IsTemporary(), TDbiConnection::SetPermanent(), TDbiConnection::SetTableExists(), SK_DBI_Info, SK_DBI_Log, SK_DBI_Severe, and UtilString::ToUpper().

                                                                 {


//  Check that input args look plausible.

  string tableName = UtilString::ToUpper(tableNameMc);
  if (    tableName == ""
       || tableDescr[0] != '('
       || tableDescr[tableDescr.size()-1] != ')' ) {
       SK_DBI_Severe( "Illegal input args:-" << "  "
                           << "     Table Name: " << tableName
                           << "  Table Description: " << tableDescr
                           <<"  ");
    return -1;
  }

// Find a DB that will accept the command.
  string sqlMakeTable;

  Int_t dbNoAcc       = -1;
  auto_ptr<TDbiStatement> 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;
      }
        stmtDb->PrintExceptions();
   }
  }

  if ( dbNoAcc < 0 ) {
    if ( stmtDb.get()) stmtDb->PrintExceptions();
    return -1;
  }

// Make connection permanent if not already.
  TDbiConnection& conDb = *fConnections[dbNoAcc];
  if ( conDb.IsTemporary() ) {
    conDb.SetPermanent();
    SK_DBI_Info( "Making connection: " << conDb.GetUrl()
                           << " permanent to preserve temporary tables." << "  ");
  }

// Create SQL to create auxillary validity table and write to same Db.
  sqlMakeTable = TDbi::GetVldDescr(tableName.c_str(),true);

  SK_DBI_Log( "Validity Table creation: "
                         << " Database: " << dbNoAcc << " "
                         << sqlMakeTable << "  ");
  stmtDb->ExecuteUpdate(sqlMakeTable.c_str());
  if ( stmtDb->PrintExceptions() ) return -1;
  this->GetConnection(dbNoAcc)->SetTableExists(tableName+"VLD");
  fTemporaryTables[tableName] = dbNoAcc;
  return dbNoAcc;

}

Here is the call graph for this function:

Int_t TDbiCascader::GetAuthorisingDbNo

(

)

const [inline]

Definition at line 92 of file TDbiCascader.hxx.

References fGlobalSeqNoDbNo.

{ return fGlobalSeqNoDbNo; }

TDbiConnection * TDbiCascader::GetConnection

(

UInt_t

dbNo

)

Purpose: Return a connection to caller (TDbiCascader retains ownership)

Definition at line 447 of file TDbiCascader.cxx.

References fConnections, GetStatus(), and kFailed.

                                                       {


  if ( this->GetStatus(dbNo) == kFailed ) return 0;
  return fConnections[dbNo];

}

Here is the call graph for this function:

const TDbiConnection * TDbiCascader::GetConnection

(

UInt_t

dbNo

)

const

Return associated TDbiConnection. TDbiCascader retains ownership.

Purpose: Return a connection to caller (TDbiCascader retains ownership)

Definition at line 435 of file TDbiCascader.cxx.

References fConnections, GetStatus(), and kFailed.

Referenced by CreateTemporaryTable(), GetTableDbNo(), TDbiDBProxy::ReplaceSeqNo(), and TDbiDBProxy::StoreMetaData().

                                                                  {


  if ( this->GetStatus(dbNo) == kFailed ) return 0;
  return fConnections[dbNo];

}

Here is the call graph for this function:

Here is the caller graph for this function:

string TDbiCascader::GetDbName

(

UInt_t

dbNo

)

const

Purpose: Return Database Name for cascade entry number.

Definition at line 458 of file TDbiCascader.cxx.

References fConnections, GetNumDb(), and SK_DBI_Warn.

Referenced by GetDbNo().

                                                {
//
//

  string dbName;

  if ( dbNo < this->GetNumDb() ) dbName = fConnections[dbNo]->GetDbName();
  else SK_DBI_Warn( "Database does not contain entry " << dbNo << "  ");
  return dbName;

}

Here is the call graph for this function:

Here is the caller graph for this function:

Int_t TDbiCascader::GetDbNo

(

const string &

dbName

)

const

Purpose: Return number of first DB in cascade with name dbName.

Return: Database number corresponding to dbName or -1 if none.

Definition at line 476 of file TDbiCascader.cxx.

References fConnections, GetDbName(), GetNumDb(), and SK_DBI_Warn.

                                                      {


  for ( unsigned dbNo = 0; dbNo < this->GetNumDb(); ++dbNo) {
    if ( dbName == fConnections[dbNo]->GetDbName() ) return dbNo;
  }

  SK_DBI_Warn( "Database does not contain entry " << dbName << "  ");
  return -1;

}

Here is the call graph for this function:

UInt_t TDbiCascader::GetNumDb

(

)

const [inline]

Definition at line 93 of file TDbiCascader.hxx.

References fConnections.

Referenced by TDbiDatabaseManager::Config(), GetDbName(), GetDbNo(), TDbiDBProxy::GetNumDb(), GetStatus(), GetURL(), operator<<(), TDbiDBProxy::StoreMetaData(), and ~TDbiCascader().

{return fConnections.size();}

Here is the caller graph for this function:

Int_t TDbiCascader::GetStatus

(

UInt_t

dbNo

)

const [inline]

Definition at line 79 of file TDbiCascader.hxx.

References fConnections, GetNumDb(), kClosed, kFailed, and kOpen.

Referenced by CreateStatement(), GetConnection(), and GetStatusAsString().

                                            {
                 if ( dbNo >= GetNumDb() || ! fConnections[dbNo]  ) return kFailed;
                 return fConnections[dbNo]->IsClosed() ? kClosed : kOpen; }

Here is the call graph for this function:

Here is the caller graph for this function:

string TDbiCascader::GetStatusAsString

(

UInt_t

dbNo

)

const

Purpose: Return DB connection status as a string.

Arguments: dbNo in Database number (0..GetNumDb()-1)

Definition at line 495 of file TDbiCascader.cxx.

References GetStatus(), kClosed, and kOpen.

Referenced by operator<<().

                                                        {


  Int_t status = GetStatus(dbNo);

  switch ( status ) {
  case kClosed:  return "Closed";
  case kOpen:    return "Open  ";
  default:       return "Failed";
  }

}

Here is the call graph for this function:

Here is the caller graph for this function:

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

Purpose: Return cascade number of first database that holds table or -1 if none.

Definition at line 512 of file TDbiCascader.cxx.

References fConnections, GetConnection(), and TDbiConnection::TableExists().

Referenced by TDbiSqlValPacket::SetMetaData(), and TableExists().

                                                                 {


// If selectDbNo >= 0 only look in this entry in the cascade.

// If table name has any lower case letters then fail.
  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 TDbiConnection* con =  this->GetConnection(dbNoTry);
    if ( con && con->TableExists(tableName) ) return dbNoTry;
  }

  return -1;

}

Here is the call graph for this function:

Here is the caller graph for this function:

string TDbiCascader::GetURL

(

UInt_t

dbNo

)

const [inline]

Definition at line 83 of file TDbiCascader.hxx.

References fConnections, and GetNumDb().

Referenced by operator<<(), and TDbiLogEntry::SetServerName().

                                         {
                      return ( dbNo < GetNumDb() ) ? fConnections[dbNo]-> GetUrl(): ""; }

Here is the call graph for this function:

Here is the caller graph for this function:

void TDbiCascader::HoldConnections

(

)

   
     Purpose: Hold temporary connections open
   
     Specification:-
     =============
   
     Hold all connections open by telling them that they have a
     connected statement.
   
     Program Notes:-
     =============
   
     See TDbiConnectionMaintainer for use.
   

Definition at line 550 of file TDbiCascader.cxx.

References fConnections.

                                   {


  for (UInt_t dbNo = 0; dbNo < fConnections.size(); ++dbNo )
    fConnections[dbNo]->ConnectStatement();
}

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

Purpose: Return kTRUE if tableName is temporary in cascade member dbNo.

Definition at line 559 of file TDbiCascader.cxx.

References fTemporaryTables.

Referenced by AllocateSeqNo(), and ReserveNextSeqNo().

                                                       {
//
//


  map<string,Int_t>::const_iterator itr
                                     = fTemporaryTables.find(tableName);
  return (     itr != fTemporaryTables.end()
           &&  (*itr).second == dbNo );

}

Here is the caller graph for this function:

void TDbiCascader::ReleaseConnections

(

)

   
     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 TDbiConnectionMaintainer for use.
   

Definition at line 665 of file TDbiCascader.cxx.

References fConnections.

Referenced by TDbiConnectionMaintainer::~TDbiConnectionMaintainer().

                                      {


  for (UInt_t dbNo = 0; dbNo < fConnections.size(); ++dbNo )
    fConnections[dbNo]->DisConnectStatement();
}

Here is the caller graph for this function:

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

   
     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.
   

Definition at line 692 of file TDbiCascader.cxx.

References TDbiString::c_str(), TDbiString::Clear(), CreateStatement(), TDbiCascader::Lock::IsLocked(), IsTemporaryTable(), TDbi::kMAXLOCALSEQNO, SK_DBI_Log, SK_DBI_Severe, and TableExists().

Referenced by AllocateSeqNo().

                                                       {


  TDbiString sql;

  string seqnoTableName = isGlobal ? "GLOBALSEQNO" : "LOCALSEQNO";
  bool seqnoTableNameExists = this->TableExists(seqnoTableName,dbNo);
  bool tableNameExists      = this->TableExists(tableName,dbNo);

  auto_ptr<TDbiStatement> stmtDb(this->CreateStatement(dbNo) );
  if ( ! stmtDb.get() ) return 0;

  // Check that required SEQNO table exists.

  if ( isGlobal ) {
    if ( ! seqnoTableNameExists ) {
         SK_DBI_Severe( "Unable to issue global SEQNO - " << dbNo
                               << " is not an authorising DB" << "  ");
      return 0;
    }
  }
  else {
    if ( ! seqnoTableNameExists ) {
      sql.Clear();
      sql << "CREATE TABLE " << seqnoTableName
          << "(TABLENAME      CHAR(64) NOT NULL PRIMARY KEY,\n"
          << " LASTUSEDSEQNO  INT )";

      SK_DBI_Log( "Database: " << dbNo
                             << " create local SEQNO table query: " << sql.c_str() << "  ");
      stmtDb->ExecuteUpdate(sql.c_str());
      if ( stmtDb->PrintExceptions() ) return 0;
      sql.Clear();
      sql << "INSERT INTO " <<  seqnoTableName << " VALUES ('*',0)";
      SK_DBI_Log( "Database: " << dbNo
                             << " prime local SEQNO table query: " << sql.c_str() << "  ");
      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() ) {
       SK_DBI_Severe( "Unable to lock " << seqnoTableName << "  ");
    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";
  SK_DBI_Log( " query: " << sql.c_str() << "  ");
  TSQLStatement* stmt = stmtDb->ExecuteQuery(sql.c_str());

  Int_t seqNoDefault = 0;
  if ( stmt && stmt->NextResultRow() ) {
    seqNoDefault = stmt->GetInt(1);
  }
  else {
       SK_DBI_Severe( "Unable to find default SeqNo"
                           << " due to above error" << "  ");
    delete stmt;
    stmt = 0;
    return 0;
  }
  Int_t seqNoTable = seqNoDefault;
  if ( stmt->NextResultRow() ) {
    seqNoTable = stmt->GetInt(1);
  }
  delete stmt;
  stmt = 0;
  SK_DBI_Log( "  query returned last used seqno: " << seqNoTable << "  ");

//  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 + TDbi::kMAXLOCALSEQNO;
    sql.Clear();
    sql << "select max(SEQNO) from " << tableName << "VLD"
        << " where SEQNO between " << seqNoMin << " and " << seqNoMax;
    SK_DBI_Log( "Database: " << dbNo
                         << " max  SEQNO query: " << sql.c_str() << "  ");
    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 ) {
         SK_DBI_Severe(  "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 << "  ");
        seqNoTable = minValue;
    }
  }


//  Update last used SeqNo and record in table.
  sql.Clear();
  sql << "delete from " << seqnoTableName << " where TABLENAME='";
  sql << tableName + "'";
  SK_DBI_Log( "SEQNO entry removal: " << sql.c_str() << "  ");
  stmtDb->ExecuteUpdate(sql.c_str());
  if ( stmtDb->PrintExceptions() ) return 0;

  seqNoTable++;

  sql.Clear();
  sql << "insert into  " << seqnoTableName << " values('";
  sql << tableName + "'," << seqNoTable << ")";
  SK_DBI_Log( "SEQNO entry add: " << sql.c_str() << "  ");
  stmtDb->ExecuteUpdate(sql.c_str());
  if ( stmtDb->PrintExceptions() ) return 0;

  return seqNoTable;

}

Here is the call graph for this function:

Here is the caller graph for this function:

void TDbiCascader::SetAuthorisingEntry

(

Int_t

entry

)

[inline, private]

Definition at line 113 of file TDbiCascader.hxx.

References fGlobalSeqNoDbNo.

{fGlobalSeqNoDbNo = entry;}

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

Purpose: Set connection permanent.

Definition at line 838 of file TDbiCascader.cxx.

References fConnections.

Referenced by TDbiDatabaseManager::Config().

                                                               {
//
//


  if ( dbNo < fConnections.size() ) fConnections[dbNo]->SetPermanent(permanent);

}

Here is the caller graph for this function:

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

Definition at line 95 of file TDbiCascader.hxx.

References GetTableDbNo().

Referenced by TDbiSqlValPacket::Recreate(), ReserveNextSeqNo(), and TDbiDBProxy::TableExists().

                                                                                 {
                            return this->GetTableDbNo(tableName,selectDbNo) >= 0; }

Here is the call graph for this function:

Here is the caller graph for this function:

---

Friends And Related Function Documentation

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

friend class TDbiDatabaseManager [friend]

Definition at line 51 of file TDbiCascader.hxx.

friend class TDbiValidate [friend]

Definition at line 60 of file TDbiCascader.hxx.

---

Member Data Documentation

vector<TDbiConnection*> TDbiCascader::fConnections [private]

Vector of TDbiConnections, one for each DB.

Definition at line 126 of file TDbiCascader.hxx.

Referenced by CreateStatement(), CreateTemporaryTable(), GetConnection(), GetDbName(), GetDbNo(), GetNumDb(), GetStatus(), GetTableDbNo(), GetURL(), HoldConnections(), ReleaseConnections(), SetPermanent(), and ~TDbiCascader().

Int_t TDbiCascader::fGlobalSeqNoDbNo [private]

1st db in cascade with GlobalSeqNo table

Definition at line 123 of file TDbiCascader.hxx.

Referenced by AllocateSeqNo(), GetAuthorisingDbNo(), operator<<(), and SetAuthorisingEntry().

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

Mapping Name->DbNo for temporary tables.

Definition at line 129 of file TDbiCascader.hxx.

Referenced by CreateTemporaryTable(), and IsTemporaryTable().

---

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

• src/TDbiCascader.hxx
• src/TDbiCascader.cxx