TDbiStatement.cxx

Go to the documentation of this file.

//////////////////////////////////////////////////////////////////////////
////////////////////////////     ROOT API     ////////////////////////////
//////////////////////////////////////////////////////////////////////////


#include <iostream>
#include <sstream>
#include <string>
#include <vector>

#include "TString.h"

#include "TDbiStatement.hxx"
#include "TDbiTableMetaData.hxx"
#include <TSK_DBI_Log.hxx>
#include <MsgFormat.h>
using std::endl;
#include "UtilString.hxx"

ClassImp(TDbiStatement)


//   Definition of static data members
//   *********************************


//    Definition of all member functions (static or otherwise)
//    *******************************************************
//
//    -  ordered: ctors, dtor, operators then in alphabetical order.

//.....................................................................

TDbiStatement::TDbiStatement(TDbiConnection& conDb) :
fConDb(conDb)
{
//
//
//  Purpose:  Constructor
//
//  Arguments:  None.
//
//  Return:
//
//  conDb    in    The connection associated with the statement.
//


  SK_DBI_Trace( "Creating TDbiStatement" << "  ");
  fConDb.ConnectStatement();

}

//.....................................................................

TDbiStatement::~TDbiStatement() {
//
//
//  Purpose: Destructor

  SK_DBI_Trace( "Destroying TDbiStatement" << "  ");

  fConDb.DisConnectStatement();
}

//.....................................................................

TSQLStatement* TDbiStatement::CreateProcessedStatement(const TString& sql /* ="" */) {

// Attempt to create a processed statement (caller must delete).  Return 0 if failure.

  TSQLStatement* stmt = fConDb.CreatePreparedStatement(sql.Data());
  if ( ! stmt ) {
    this->AppendExceptionLog(fConDb);
    return 0;
  }
  if ( stmt->Process() ) return stmt;
  this->AppendExceptionLog(stmt);
  delete stmt;
  stmt = 0;
  return 0;

}


//.....................................................................

TSQLStatement* TDbiStatement::ExecuteQuery( const TString& sql) {
//
//
//  Purpose:  Execute SQL.
//  Return:   TSQLStatement with Process() and StoreResult() already performed.

  this->ClearExceptionLog();

  SK_DBI_Info( "SQL:" << fConDb.GetDbName() << ":" << sql << "  ");
  TSQLStatement* stmt = this->CreateProcessedStatement(sql);
  if ( ! stmt ) return 0;
  if ( ! stmt->StoreResult() ) {
    this->AppendExceptionLog(stmt);
    delete stmt;
    stmt = 0;
  }

  // Final sanity check: If there is a statement then the exception log should still
  // be clear otherwise it should not be.
  if ( stmt ) {
    if ( ! fExceptionLog.IsEmpty() ) {
      delete stmt;
      stmt = 0;
    }
  }
  else if ( fExceptionLog.IsEmpty() ) {
    ostringstream oss;
    oss << "Unknown failure (no execption but no TSQLStatement either executing " << sql;
    fExceptionLog.AddEntry(oss.str().c_str());
  }
  return stmt;

}

//.....................................................................

Bool_t TDbiStatement::ExecuteUpdate( const TString& sql) {
//
//
//  Purpose:  Translate SQL if required and Execute.
//
//  Return true if all updates successful.


  this->ClearExceptionLog();

  SK_DBI_Info( "SQL:" << fConDb.GetDbName() << ":" << sql << "  ");
  bool ok = fConDb.GetServer()->Exec(sql.Data());
  if ( ! ok ) {
    fConDb.RecordException();
    this->AppendExceptionLog(fConDb);
    return false;
  }

  return fExceptionLog.IsEmpty();

}

//.....................................................................

Bool_t TDbiStatement::PrintExceptions(Int_t level) const {

//  Purpose:  Print accumulated exceptions at supplied Msg level,
//            add them to the Global Exception Log if level >= kWarning
//            and return true if there are any.

  const TDbiExceptionLog& el(this->GetExceptionLog());
  if ( el.IsEmpty() ) return false;

  return true;

}