TDbiCascader.cxx File Reference

#include <cstdlib>
#include <memory>
#include <sstream>
#include "TList.h"
#include "TROOT.h"
#include "TSQLStatement.h"
#include "TSystem.h"
#include "TDbi.hxx"
#include "TDbiCascader.hxx"
#include "TDbiString.hxx"
#include <TSK_DBI_Log.hxx>
#include <MsgFormat.h>
#include "UtilString.hxx"

Include dependency graph for TDbiCascader.cxx:

Go to the source code of this file.

Functions
	ClassImp (TDbiCascader) TDbiCascader
ostream &	operator<< (ostream &os, const TDbiCascader &cascader)

---

Function Documentation

ClassImp

(

TDbiCascader

)

   
     Purpose:  Default constructor
   
     Arguments: beQuiet - If true, fail quietly. If not be more verbose.
   
     Return:    n/a
   
     Throws:  ENoEnvironment(); if there is no environment defined
                  throw EBadDatabase(); if any other error occured
     Contact:   N. West
   
     Specification:-
     =============
   
     o  Create Cascader.
   
   
     Program Notes:-
     =============
   
     Current cascader configuration comes from 3 environmental
     variables:-
   
       SK_TSQL_URL             a semi-colon separated list of URLs
       SK_TSQL_USER            user name (one or a semi-colon separated list)
       SK_TSQL_PSWD            password (one or a semi-colon separated list)
   
       or the _UPDATE alternatives e.g. SK_TSQL_UPDATE_USER
   
    The _UPDATE versions take priority.
   

Definition at line 26 of file TDbiCascader.cxx.

References TDbiConnection::Open(), SK_DBI_Info, SK_DBI_Severe, SK_DBI_Trace, and UtilString::StringTok().

                : ctors, dtor, operators then in alphabetical order.

//.....................................................................
///\verbatim
///
///  Purpose:  Default constructor
///
///  Arguments: beQuiet - If true, fail quietly. If not be more verbose.
///
///  Return:    n/a
///
///  Throws:  ENoEnvironment(); if there is no environment defined
///               throw EBadDatabase(); if any other error occured
///  Contact:   N. West
///
///  Specification:-
///  =============
///
///  o  Create Cascader.
///
///
///  Program Notes:-
///  =============
///
///  Current cascader configuration comes from 3 environmental
///  variables:-
///
///    SK_TSQL_URL             a semi-colon separated list of URLs
///    SK_TSQL_USER            user name (one or a semi-colon separated list)
///    SK_TSQL_PSWD            password (one or a semi-colon separated list)
///
///    or the _UPDATE alternatives e.g. SK_TSQL_UPDATE_USER
///
/// The _UPDATE versions take priority.
///\endverbatim
TDbiCascader::TDbiCascader(bool beQuiet):
fGlobalSeqNoDbNo(-1)
{


  SK_DBI_Trace( "Creating TDbiCascader" << "  ");

// Extract args from  SK_TSQL environmental variables
  const char*      strUser = gSystem->Getenv("SK_TSQL_UPDATE_USER");
  if ( ! strUser ) strUser = gSystem->Getenv("SK_TSQL_USER");
  const char*      strPswd = gSystem->Getenv("SK_TSQL_UPDATE_PSWD");
  if ( ! strPswd ) strPswd = gSystem->Getenv("SK_TSQL_PSWD");
  const char*       strUrl = gSystem->Getenv("SK_TSQL_UPDATE_URL");
  if ( !strUrl )    strUrl = gSystem->Getenv("SK_TSQL_URL");
  string userList     = ( strUser ) ? strUser : "";
  string pswdList     = ( strPswd ) ? strPswd : "";
  string urlList      = ( strUrl  ) ? strUrl  : "";

  
  if ( urlList == "" || userList == "" || pswdList == "" ) {
    /*
       If beQuiet is true be mute about why we are failing, leave it to the caller to deal with.
    */
    if(!beQuiet)
    {
       std::cout<<"error!"<<std::endl;
        SK_DBI_Severe("Cannnot open a Database cascade;\n"
        << "   the environmental variables SK_TSQL_*:-" << endl
        << "USER: \"" << userList << "\" PSWD:\"" << pswdList
        << "\" URL:\"" << urlList << endl
        << " are either not defined or empty.\n"
        << "   Please check your settings of SK_TSQL_USER,"
                << " SK_TSQL_PSWD and SK_TSQL_URL\n" );

    throw ENoEnvironment();
   }
  }

  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 = "";

    std::cout << "Make connection " << url << " " << user << " " << pswd << std::endl;
    TDbiConnection* con;
    // If we are testing the cascade for validity, just try connecting once, otherwise use defaults.
    if(!beQuiet)
      con  = new TDbiConnection(url,user,pswd,1);
    else
      con  = new TDbiConnection(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<TDbiStatement>  stmtDb(new TDbiStatement(*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 ) {
      if(!beQuiet)  SK_DBI_Severe("  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;
    }
  }

  SK_DBI_Info( *this);

//  Abort, if there have been any failures.
  if ( fail ) {
    throw EBadDatabase();
  }

}

Here is the call graph for this function:

ostream& operator<<	(	ostream &	os,
		const TDbiCascader &	cascader
	)

   
     Purpose:  Output TDbiCascader 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 TDbiCascader status to ostream.
   
     Program Notes:-
     =============
   
     None.
   

Definition at line 210 of file TDbiCascader.cxx.

References TDbiCascader::fGlobalSeqNoDbNo, TDbiCascader::GetNumDb(), TDbiCascader::GetStatusAsString(), and TDbiCascader::GetURL().

                                                               {


  os << "TDbiCascader 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;

}

Here is the call graph for this function: