TDbiConnection.cxx File Reference

#include <cctype>
#include <cstdlib>
#include <list>
#include <sstream>
#include <string>
#include "TList.h"
#include "TString.h"
#include "TSystem.h"
#include "TDbi.hxx"
#include "TDbiAsciiDbImporter.hxx"
#include "TDbiConnection.hxx"
#include "TDbiExceptionLog.hxx"
#include "TDbiServices.hxx"
#include <TSK_DBI_Log.hxx>
#include <MsgFormat.h>

Include dependency graph for TDbiConnection.cxx:

Go to the source code of this file.

Functions
	ClassImp (TDbiConnection) TDbiConnection

---

Function Documentation

ClassImp

(

TDbiConnection

)

Definition at line 27 of file TDbiConnection.cxx.

References SK_DBI_Info, SK_DBI_Severe, and SK_DBI_Trace.

                : ctors, dtor, operators then in alphabetical order.

//.....................................................................
//      Throws EBadConnection() if can not make connection
TDbiConnection::TDbiConnection(const std::string& url      /* = "" */,
                             const std::string& user     /* = "" */,
                             const std::string& password /* = "" */,
                             int maxConnects) :

fUrl(url.c_str()),
fUser(user),
fPassword(password),
fUrlValidated(false),
fNumConnectedStatements(0),
fIsTemporary(true),
fServer(0)
{
//
//
//  Purpose:  Default constructor

  fMaxConnectionAttempts = maxConnects;

  SK_DBI_Trace( "Creating TDbiConnection" << "  ");

  if ( this->Open() ) {
    SK_DBI_Info(  "Successfully opened connection to: " << this->GetUrl() << "  ");
    fUrlValidated =  true;

    // Initialise the list existing supported tables.
    this->SetTableExists();

    //  If URL looks O.K., check that both client and server support prepared statements.
    if ( fUrlValidated ) {
#if ROOT_VERSION_CODE >= ROOT_VERSION(5,15,9)
      if ( ! fServer->HasStatement() ) {
#else
      if ( ! fServer->IsSupportStatement() ) {
#endif
        SK_DBI_Severe( "  This client does not support prepared statements." << "  ");
        fUrlValidated = false;
        #if ROOT_VERSION_CODE >= ROOT_VERSION(5,15,9)
      }
#else
      }
#endif
      
      std::string serverInfo(fServer->ServerInfo());
      if ( serverInfo < "4.1" ) {
        SK_DBI_Severe( "This MySQL server (" << serverInfo
                             << ") does NOT support prepared statements." << "  ");
        fUrlValidated = false;
      }
      if ( fUrlValidated ) {
        SK_DBI_Info( "This client, and MySQL server (" << serverInfo
                             << ") supports prepared statements." << "  ");
      }
      else {

        SK_DBI_Severe( "\n"
           << "This version of MySQL does not support prepared statements.\n"
           << "\n"
           << "Please upgrade to MySQL (client and server) version 4.1 or greater \n"
           << "\n"
           << "  ");
      }

    }
  }
    if ( ! fUrlValidated ) {
      SK_DBI_Severe( "FATAL: " << "Aborting due to above errors" << "  ");
      throw EBadConnection();
    }
   fDbName = fUrl.GetFile();
  

}