DbuDaqConfigFilesText.cxx

Go to the documentation of this file.

// $Id: DbuDaqConfigFilesText.cxx,v 1.9 2007/04/26 14:21:39 west Exp $
//
// DbuDaqConfigFilesText
//
// Package: DatabaseUpdater
//
// R. Hatcher  2002-04-19
//
// Concept:
//   
// Purpose:
//

#include "DatabaseInterface/DbiExceptionLog.h"
#include "DatabaseUpdater/DbuDaqConfigFilesText.h"
#include "MessageService/MsgService.h"
#include "DatabaseInterface/DbiOutRowStream.h"
#include "DatabaseInterface/DbiResultSet.h"
#include "DatabaseInterface/DbiStatement.h"
#include "DatabaseInterface/DbiValidityRec.h"
#include <iostream>
#include <cassert>

#include "TMD5.h"
#include "TSQLStatement.h"

#include "DatabaseUpdater/RunTypeName.h"

ClassImp(DbuDaqConfigFilesText)

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

CVSID("$Id: DbuDaqConfigFilesText.cxx,v 1.9 2007/04/26 14:21:39 west Exp $ CVSID_DBIRESULTPTR ");

const std::string DbuDaqConfigFilesText::kNoText = "<<No ConfigFileText>>";
const std::string DbuDaqConfigFilesText::kNoMD5  = "<<No MD5 value>>";

//  Instantiate associated Result Pointer class.
//  *******************************************

#include "DatabaseInterface/DbiResultPtr.tpl"
template class  DbiResultPtr<DbuDaqConfigFilesText>;

#include "DatabaseInterface/DbiWriter.tpl"
template class  DbiWriter<DbuDaqConfigFilesText>;

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

std::ostream& operator<<(std::ostream& os, const DbuDaqConfigFilesText& dcft)
{
   os << dcft.GetName() 
      << " SeqNo " << dcft.fSeqNo
      << " MD5 \"" << dcft.fMD5 << "\""
      << endl
      << " Text \"" << dcft.fText << "\""
      << endl;

   return os;
}

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

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

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

void DbuDaqConfigFilesText::Fill(DbiResultSet& rs,
                             const DbiValidityRec* vrec ) {
//
//
//  Purpose:  Fill object from Result Set
//
//  Arguments: 
//    rs           in    Result Set used to fill object
//    vrec         in    Associated validity record (or 0 if filling
//                                                    DbiValidityRec)
//
//  Return:    
//
//  Contact:   R. Hatcher
//
//  Specification:-
//  =============
//
//  o Fill object from current row of Result Set.

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

//  None.

   rs >> fMD5
      >> fText;

   fSeqNo = ((vrec) ? vrec->GetSeqNo() : 0 );
}

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

void DbuDaqConfigFilesText::Store(DbiOutRowStream& ors,
                             const DbiValidityRec* /* vrec */) const {
//
//
//  Purpose:  Stream object to output row stream
//
//  Arguments: 
//    ors          in     Output row stream.
//    vrec         in     Associated validity record (or 0 if filling
//                                                    DbiValidityRec)
//
//  Return:    
//
//  Contact:   R. Hatcher
//
//  Specification:-
//  =============
//
//  o  Stream object to output row stream.

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

//  None.

   ors << fMD5
       << fText;
   
}

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

#ifdef RWH_OLD
Int_t DbuDaqConfigFilesText::CalcUniqueSeqNo(Detector::Detector_t det,
                                        Int_t run, Short_t subrun)
{
//
//
//  Purpose:  Calculate unique SeqNo
//
//  Return:   an integer
//
//  Contact:   R. Hatcher
//
//  Specification:-
//  =============
//

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

//  None.

// similar to file naming convention
//   Char_t detchar = Detector::AsString(det)[0];
//   string fname = Form("%c%8.8d_%4.4d",detchar,run,subrun);
// take care since can overflow int
//  use two fewers places for sub and two fewer for run
//  "drrrrrrss"

   return subrun + 100*(run + 1000000*det);
}

//.....................................................................
#endif

std::string& DbuDaqConfigFilesText::CalcMD5()
{
//
//
//  Purpose:  Calculate and record MD5 value
//
//  Return:   nothing
//
//  Contact:   R. Hatcher
//
//  Specification:-
//  =============
//

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

//  None.

  TMD5 md5;
  md5.Update((const UChar_t*)fText.c_str(),(UInt_t)fText.size());
  md5.Final();
  fMD5 = md5.AsString();
  return fMD5;
}

//.....................................................................
Int_t DbuDaqConfigFilesText::LookupSeqNo(DbiStatement* stmt) const
{
//
//
//  Purpose:  Lookup the SeqNo for this MD5
//
//  Return:   the SEQNO (or 0 if no match exists)
//
//  Contact:   R. Hatcher
//
//  Specification:-
//  =============
//

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

//  None.

  // ensure MD5 is up-to-date
  // CalcMD5(); ... not const
  const char* sqlbase = 
    "select SEQNO from DBUDAQCONFIGFILESTEXT where CONFIGFILES_MD5='%s';\0";
  TString sqlquery = Form(sqlbase,fMD5.c_str());

  TSQLStatement* tsqlstmt = stmt->ExecuteQuery(sqlquery);
  
  Int_t nrows = 0, seqno = 0;
  while ( 1 ) {
    if ( ! tsqlstmt->NextResultRow() ) break;
    nrows++;
    seqno = tsqlstmt->GetInt(0);
  }
  // accept the last one
  
  if (nrows>1) {
    MSG("Dbu",Msg::kWarning) 
      << "DbuDaqConfigFilesText saw " << nrows << " that statisfied '"
      << sqlquery
      << "'" << endl;
  }
  return seqno;
}

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

const char* DbuDaqConfigFilesText::GetTableDescr()
{
//
//
//  Purpose:  Return a string describing rows in the table
//            Used in creating temporary tables
//
//  Return:   const char* to parenthesized comma separated list
//            of column name and type pairs
//
//  Contact:   R. Hatcher
//
//  Specification:-
//  =============
//

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

//  None.

   const char* const_tabledescr = "( \
       SEQNO             int,        \
       ROW_COUNTER       int,        \
       CONFIGFILES_MD5   char(32),   \
       CONFIGFILES_TEXT  mediumtext, \
       primary key (SEQNO,ROW_COUNTER) \
       )";

   return const_tabledescr;
}

/*    Template for New Member Function

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

DbuDaqConfigFilesText:: {
//
//
//  Purpose:  
//
//  Arguments: 
//    xxxxxxxxx    in    yyyyyy
//
//  Return:    
//
//  Contact:   R. Hatcher
//
//  Specification:-
//  =============
//
//  o 

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

//  None.


}

*/

---