DbmValidate.cxx

Go to the documentation of this file.

// DbmValidate                                                        //
//                                                                    //
// Package: Dbm (Database Maintenance).                               //
//                                                                    //
// N. West 08/2001                                                    //
//                                                                    //
// Concept: Internal validation            .                          //
//                                                                    //
// Purpose: This forms the internal validation of Dbm.                //
//                                                                    //

#include <fstream>
#include <memory>

#include "DatabaseInterface/Dbi.h"
#include "DatabaseInterface/DbiCascader.h"
#include "DatabaseInterface/DbiTableProxyRegistry.h"
#include "DatabaseInterface/DbiValRecSet.h"

#include "DatabaseMaintenance/DbmModule.h"
#include "DatabaseMaintenance/DbmValidate.h"

#include "JobControl/JobCommand.h"
#include "LeakChecker/Lea.h"
#include "MessageService/MsgService.h"

#include "TSQLStatement.h"

ClassImp(DbmValidate)


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

CVSID("$Id: DbmValidate.cxx,v 1.10 2007/04/26 14:20:43 west Exp $");

// Definition of member functions (alphabetical order)
// ***************************************************


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

DbmValidate::DbmValidate(DbmModule* module) :
fModule(module),
fStatement0(0),
fStatement1(0)
{
//
//
//  Purpose:  Constructor
//
//  Arguments:
//     module     in  Module to be tested..  
//
//  Return:    n/a
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o  Create validation object and run tests..


//  Program Notes:-
//  =============

//  None.

  LEA_CTOR    //Leak Checker

  MSG("Dbi", Msg::kVerbose) << "Creating DbmValidate" << endl;

  fStatement0  =   DbiTableProxyRegistry::Instance()  
                    .GetCascader()
                       .CreateStatement(0);
  fStatement1  =   DbiTableProxyRegistry::Instance()  
                    .GetCascader()
                       .CreateStatement(1);

  if ( ! fStatement0 || ! fStatement1 ) {
    MSG("Dbi", Msg::kInfo) 
      << "Cannot get DbiStatement for cascade entries 0,1 "
      << "unable to validate Dbm." << endl;
  }
  else {
    if ( ! PrepareDb() ) {
      MSG("Dbi", Msg::kInfo) << "Cannot run validation!" << endl;
    }
    else {
      if ( RunAllTests() ) {
        MSG("Dbi", Msg::kInfo) << "All tests passed" << endl;
      }
      else {
        MSG("Dbi", Msg::kInfo) << "Validation failed!" << endl;
      }
    }
  }   

}  


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

DbmValidate::~DbmValidate() {
//
//
//  Purpose: Destructor
//
//  Arguments: 
//    None.
//
//  Return:    n/a
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o  Destroy validation object.


//  Program Notes:-
//  =============

//  None.

  LEA_DTOR    //Leak Checker

  MSG("Dbi", Msg::kVerbose) << "Destroying DbmValidate" << endl;

  delete fStatement0;
  fStatement0 = 0;
  delete fStatement1;
  fStatement0 = 0;

}


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

Bool_t DbmValidate::PrepareDb() {
//
//
//  Purpose:  Prepare database for validation tests.
//
//  Arguments: None
//
//  Return:    
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Prepare database for validation tests.


//  Program Notes:-
//  =============

//  None.

  Bool_t ok = kTRUE;

  if ( ! fStatement0 || ! fStatement1 ) {
    MSG("Dbm",Msg::kInfo) 
       << "Cannot prepare  for tests (no database access)" << endl;
    return kFALSE;
  }

  string prepareDBFileName 
     = fFileLocater.Find("DatabaseMaintenance/test/PrepareDB.mysql");
  ifstream prepareDBFile(prepareDBFileName.c_str());

  if ( ! prepareDBFile.is_open() ) {
    MSG("Dbm",Msg::kInfo)
       << "Cannot prepare  for tests (no validation data file)" << endl;
    return kFALSE;
  }

  // Loop processing SQL commands.

  while ( ! prepareDBFile.eof() ) {
    string sql;
    string line;
    while ( ! prepareDBFile.eof() ) {
      getline(prepareDBFile,line);
      // Remove trailing spaces.
      int last = line.size()-1;
      while ( last >= 0 && line[last] == ' ') line.erase(last--);
      // Ignore blank and comment lines
      if ( last < 0 || line[0] == '#' ) continue;
      // Append and look for terminating ";".
      sql += line;
      if ( line[last] == ';' ) {
        MSG("Dbm",Msg::kDebug) << "SQL " << sql << endl;
        fStatement0->ExecuteUpdate(sql.c_str());
        if ( fStatement0->PrintExceptions() ) ok = kFALSE;
        fStatement1->ExecuteUpdate(sql.c_str());
        if ( fStatement1->PrintExceptions() ) ok = kFALSE;
        sql = "";
        break;
      }
    }
    if ( sql != "" 
       ) MSG("Dbm",Msg::kInfo)
                << "File ends with incomplete SQL "<< sql << endl;
  }
  
  return ok;
  
}

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

Bool_t DbmValidate::RunAllTests() {
//
//
//  Purpose: Run suite of validation tests. 
//
//  Arguments: None.
//
//  Return:    
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Run suite of validation tests. 

//  Program Notes:-
//  =============

//  None.

  Bool_t ok = kTRUE;

  if ( ! TestGlobaliseSeqNo() ) ok = kFALSE;
  if ( ! TestExportImport()   ) ok = kFALSE;

  return ok;

}
//.....................................................................

Bool_t DbmValidate::TestExportImport() {
//
//
//  Purpose: Test Export and Import.
//
//  Arguments: None.
//
//  Return:    
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Export data from database 0  and import into database 1.

//  Program Notes:-
//  =============

//  None.

  MSG("Dbm",Msg::kInfo) << "Testing Export/Import       ..." << endl;

  Bool_t ok = kTRUE;


  if ( ! ok ) {
    MSG("Dbm",Msg::kError) << "  Cannot prepare test" << endl;
    return kFALSE;
  }


  //  Export data
  JobCommand jcExport("/Export --Table DBMVALIDATEDATA1 --File DbmValidateData1.dat");
  fModule->HandleCommand(&jcExport);

  //  Force Dbm to load DbiValidityRecs from cascade number 1.
  fModule->ClearCache();
  fModule->fValRecSet = new DbiValRecSet("DBMVALIDATEDATA1",1);

  //  Import data
  JobCommand jcImport("/Import --DatabaseNumber 1 --File DbmValidateData1.dat");
  fModule->HandleCommand(&jcImport);

  return ok;

}

Bool_t DbmValidate::TestGlobaliseSeqNo() {
//
//
//  Purpose: Test Globalisation of SeqNos.
//
//  Arguments: None.
//
//  Return:    
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Count no.of local SeqNos, convert and count again.

//  Program Notes:-
//  =============

//  None.

  MSG("Dbm",Msg::kInfo) << "Testing SeqNo globalisation ..." << endl;

  string sqlLocalMain =
  "select SeqNo from DBMVALIDATEDATA1 where SeqNo < 100000000;";
  string sqlLocalVal =
  "select SeqNo from DBMVALIDATEDATA1VLD where SeqNo < 100000000;";

  TSQLStatement* stmt = 0;

  //  Count number before
  Int_t numBefore = 0;
  stmt = fStatement0->ExecuteQuery(sqlLocalMain.c_str());
  fStatement0->PrintExceptions();
  if ( stmt ) while ( stmt->NextResultRow() ) ++numBefore;
  delete stmt;
  stmt = fStatement0->ExecuteQuery(sqlLocalVal.c_str());
  fStatement0->PrintExceptions();
  if ( stmt ) while ( stmt->NextResultRow() ) ++numBefore;
  delete stmt;

  //  Globalise
  JobCommand jc("/GlobaliseSeqNo DBMVALIDATEDATA1");
  fModule->HandleCommand(&jc);

  //  Count number after
  Int_t numAfter = 0;
  stmt = fStatement0->ExecuteQuery(sqlLocalMain.c_str());
  fStatement0->PrintExceptions();
  if ( stmt ) while ( stmt->NextResultRow() ) ++numAfter;
  delete stmt;
  stmt = fStatement0->ExecuteQuery(sqlLocalVal.c_str());
  fStatement0->PrintExceptions();
  if ( stmt ) while ( stmt->NextResultRow() ) ++numAfter;
  delete stmt;

  Bool_t ok = numBefore == 9 &&  numAfter == 0;
  MSG("Dbm",Msg::kInfo) 
    << "    Before there should be 9 local Seqno, found " 
    << numBefore << endl  
    << "    After there should be 0 local Seqno, found " 
    << numAfter << endl
    << "Test has " << (ok ? "passed" : "failed!!") << endl;

  return ok;

}
/*    Template for New Member Function

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

DbmValidate:: {
//
//
//  Purpose:  
//
//  Arguments: 
//    xxxxxxxxx    in    yyyyyy
//
//  Return:    
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o 

//  Program Notes:-
//  =============

//  None.


}

*/

---