DbiRollbackDates.cxx

Go to the documentation of this file.

// $Id: DbiRollbackDates.cxx,v 1.4 2008/01/30 16:42:35 nwest Exp $
//
// DbiRollbackDates

#include <cstring>

#include "TString.h"

#include "DatabaseInterface/Dbi.h"
#include "DatabaseInterface/DbiRollbackDates.h"
#include "LeakChecker/Lea.h"
#include "MessageService/MsgService.h"
#include "Registry/Registry.h"
#include "Util/UtilString.h"
#include "Validity/VldTimeStamp.h"

ClassImp(DbiRollbackDates)

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

CVSID("$Id: DbiRollbackDates.cxx,v 1.4 2008/01/30 16:42:35 nwest Exp $");

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


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

DbiRollbackDates::DbiRollbackDates()
{
//
//
//  Purpose:  Default constructor
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Create DbiRollbackDates.


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

//  None.

  LEA_CTOR    //Leak Checker

    MSG("Dbi", Msg::kVerbose) << "Creating DbiRollbackDates" << endl;
}
//.....................................................................

DbiRollbackDates::~DbiRollbackDates() {
//
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o  Destroy DbiRollbackDates.


  LEA_DTOR    //Leak Checker

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

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

const std::string& DbiRollbackDates::GetDate(const std::string& tableName) const {
//
//
//  Purpose:  Return rollback date associated with named table.
//
//  Contact:   N. West

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

//  Search in reverse order so that specific entries are processed
//  before generic (i.e. ones that end in wildcard *).

  static std::string date;

  name_map_t::const_reverse_iterator itr    = fTableToDate.rbegin(); 
  name_map_t::const_reverse_iterator itrEnd = fTableToDate.rend();
  for (; itr != itrEnd; ++itr)
    if ( ! UtilString::cmp_wildcard(tableName,itr->first)
       ) return itr->second;
  return date;
}
//.....................................................................

const std::string& DbiRollbackDates::GetType(const std::string& tableName) const {
//
//
//  Purpose:  Return rollback time type associated with named table.
//
//  Contact:   N. West

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

//  Search in reverse order so that specific entries are processed
//  before generic (i.e. ones that end in wildcard *).

  static std::string type("INSERTDATE");  // The default type

  name_map_t::const_reverse_iterator itr    = fTableToType.rbegin(); 
  name_map_t::const_reverse_iterator itrEnd = fTableToType.rend();
  for (; itr != itrEnd; ++itr)
    if ( ! UtilString::cmp_wildcard(tableName,itr->first)
       ) return itr->second;
  return type;
}
//.....................................................................

void DbiRollbackDates::Set(Registry& reg) {
//
//
//  Purpose:  Extract Rollback dates from Registry.
//
//  Arguments: 
//    reg          in    Registry containing "Rollback:" and "RollbackType:" keys.
//                 out   Updated Registry with these keys removed.
//
//  Contact:   N. West
//
//  Specification:-
//  =============
//
//  o Extract Rollback dates from Registry.

  Registry::RegistryKey keyItr(&reg);
 
  Bool_t  hasChanged = kFALSE;

  const char* key = keyItr();
  while ( key ) {

    const char* nextKey =  keyItr();

    // Process Rollback keys

    if ( ! strncmp("Rollback:",key,9) ) {
      std::string tableName = key+9;
      std::string date;
      const char* dateChars = 0;
      bool  ok = reg.Get(key,dateChars);
      if ( ok ) {
        date = dateChars;
        VldTimeStamp ts(Dbi::MakeTimeStamp(date,&ok));
        date = Dbi::MakeDateTimeString(ts);
      }
      if ( ok ) {

        // Prune away any trailing spaces - they cause SQL
        // to fail expressions involving the date.
        int loc = date.size()-1;
        while ( loc && date[loc] == ' ' ) date.erase(loc--);

        fTableToDate[tableName] = date;
        hasChanged = kTRUE;
 
      }
      else MSG("Dbi",Msg::kWarning) 
        << "Illegal Rollback registry item: " << key
        << " = " << dateChars << endl;
      reg.RemoveKey(key);
    }

    // Process RollbackType keys

    else if ( ! strncmp("RollbackType:",key,13) ) {
      std::string tableName = key+13;
      TString type;
      const char* typeChars = 0;
      bool  ok = reg.Get(key,typeChars);
      if ( ok ) {
        // Convert to upper case and remove any leading or trailing spaces
        type = typeChars;
        type.ToUpper();
        type = type.Strip(TString::kBoth);
        ok = ! type.CompareTo("INSERTDATE") || ! type.CompareTo("CREATIONDATE");
      }
      if ( ok ) {
        fTableToType[tableName] = type.Data();
        hasChanged = kTRUE;
      }
      else MSG("Dbi",Msg::kWarning) 
        << "Illegal RollbackType registry item: " << key
        << " = " << typeChars << endl;
      reg.RemoveKey(key);
    }
    key = nextKey;
  }

  if ( hasChanged ) this->Show();
}
//.....................................................................

void DbiRollbackDates::Show() const {
//
//
//  Purpose:  Print out the current Rollback date status.
//
//
//  Contact:   N. West
//

  MsgStream msg = MSGSTREAM("Dbi",Msg::kInfo);
  msg << "\n\nRollback Status:  ";
  if ( fTableToDate.size() == 0 ) msg <<"Not enabled" << endl;
  else {
    msg << "\n\n  Dates:- " << endl;
    name_map_t::const_reverse_iterator itr    = fTableToDate.rbegin(); 
    name_map_t::const_reverse_iterator itrEnd = fTableToDate.rend();
    for (; itr != itrEnd; ++itr) {
      std::string name = itr->first;
      if ( name.size() < 30 ) name.append(30-name.size(),' ');
      msg <<"    " << name << "  " << itr->second << endl;
    }
    msg << "\n  Rollback Type is 'INSERTDATE'";
    if ( fTableToType.size() ) {
      msg << " except as follows:- " << endl;
      itr    = fTableToType.rbegin(); 
      itrEnd = fTableToType.rend();
      for (; itr != itrEnd; ++itr) {
        std::string name = itr->first;
        if ( name.size() < 30 ) name.append(30-name.size(),' ');
        msg <<"    " << name << "  " << itr->second << endl;
      }
    }
    msg << endl;
  } 
}


/*    Template for New Member Function

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

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

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

//  None.


}

*/

---