DbuRunSummary.cxx

Go to the documentation of this file.

// $Id: DbuRunSummary.cxx,v 1.13 2007/02/15 14:15:48 rhatcher Exp $
//
// DbuRunSummary
//
// Package: DatabaseUpdater
//
// R. Hatcher  2002-04-19
//
// Concept:
//
// Purpose:
//

#include "DatabaseUpdater/DbuRunSummary.h"
#include "DatabaseUpdater/DbuSignalHandler.h"

#include "MessageService/MsgService.h"

#include "DatabaseInterface/DbiOutRowStream.h"
#include "DatabaseInterface/DbiResultSet.h"
#include "DatabaseInterface/DbiValidityRec.h"
#include "DatabaseInterface/DbiString.h"

#include "DatabaseUpdater/DbuDaqConfigFilesText.h"
#include "DatabaseUpdater/DbuDaqFileSummary.h"

#include "TMath.h"

#include <iostream>
#include <cassert>

#include "DatabaseUpdater/RunTypeName.h"
#include "OnlineUtil/msgLogLib/msgLog.h"
#include "Util/UtilString.h"

ClassImp(DbuRunSummary)

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

CVSID("$Id: DbuRunSummary.cxx,v 1.13 2007/02/15 14:15:48 rhatcher Exp $ CVSID_DBIRESULTPTR ");

const std::string DbuRunSummary::kNoComment    = "<<No Comment>>";
const std::string DbuRunSummary::kNoRunPrepare = "<<No RunPrepare>>";
const std::string DbuRunSummary::kNoAuxConfig  = "<<No AuxConfig>>";
const std::string DbuRunSummary::kUnfilled     = "<<Unfilled>>";

UInt_t DbuRunSummary::fgFmtFlag = 0xffff;

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

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

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

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

std::ostream& operator<<(std::ostream& os, const DbuRunSummary& drs)
{

  const char* countMatchMsg = "[consistent]";
  bool rmatch = 
    ( drs.fRunEndSnarls    == drs.CalcSnarls()    ) &&
    ( drs.fRunEndNonSnarls == drs.CalcNonSnarls() );
  if ( !rmatch ) {
    countMatchMsg = "[MISMATCH]";
    // the DAQ RawRunEndBlock sometimes doesn't count the monitor record
    // that contains itself so their count is off by one
    bool rmatchClose = 
      ( drs.fRunEndSnarls      == drs.CalcSnarls()      ) &&
      ( drs.fRunEndNonSnarls+1 == drs.CalcNonSnarls() );
    if ( rmatchClose) countMatchMsg = "[DAQ off-by-one error]";
  }

   os << drs.GetName()
      << " " << Detector::AsString(drs.fDetector)
      << " Run " << drs.fRun
      << " LastSubRun " << drs.fLastSubRun
      << " RunType " << RunTypeName(drs.fRunType,drs.fDetector,drs.fRun)
      << " (0x" << hex << drs.fRunType << dec << ")"
      << endl
      << " {" << drs.fStartTime << "} {" << drs.fEndTime << "}"
      << endl
      << " Snarls " << drs.fRunEndSnarls << " (" << drs.CalcSnarls() << ") "
      << " NonSnarls " << drs.fRunEndNonSnarls << " (" << drs.CalcNonSnarls() << ") "
      << countMatchMsg
      << endl
      << " TermCode " << drs.fTermCode
      << " Errors " << drs.fNErrs
      << " TimeFrames " << drs.fTimeFrames
      << " Dropped " << drs.fDroppedFrames
      << " Consistency 0x" << hex << drs.fConsistency << dec
      << endl;

   if ( DbuRunSummary::fgFmtFlag & DbuRunSummary::fmt_RunComment ) {
     os << " RunComment: \"" << drs.fRunComment << "\"" << endl;
   }
   if ( DbuRunSummary::fgFmtFlag & DbuRunSummary::fmt_RunPrepare ) {
     os << " RunPrepare: \"" << drs.fRunPrepare << "\"" << endl;
   }
   if ( DbuRunSummary::fgFmtFlag & DbuRunSummary::fmt_AuxConfigText ) {
     os << " AuxConfigFiles: \"" << drs.fAuxConfigText << "\"" << endl;
   }
   if ( DbuRunSummary::fgFmtFlag & DbuRunSummary::fmt_ConfigFilesText ) {
     os << " ConfigFilesText:" << endl << *drs.fDbuDaqConfigFilesText;
   }
   else {
     const DbuDaqConfigFilesText* ddcft = drs.fDbuDaqConfigFilesText;
     os << " ConfigFilesText:" << endl 
        << ddcft->GetName() << " SeqNo " << ddcft->fSeqNo
        << " MD5 \"" << ddcft->fMD5  << "\" " << endl
        << " Text [actual text suppressed]" << endl;
   }

   if ( DbuRunSummary::fgFmtFlag & DbuRunSummary::fmt_DaqFiles ) {
     for (size_t k=0; k < drs.fDbuDaqFiles.size(); ++k) {
       const DbuDaqFileSummary* fs = drs.fDbuDaqFiles[k];
       if (fs) os << " [" << setw(2) << k << "] " << *fs;
     }
   }

   return os;
}

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

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

DbuRunSummary::DbuRunSummary(const DbuRunSummary& from)
  : DbiTableRow(from), 
    fDbuDaqConfigFilesText(0)  // make sure this pointer gets initialized
{
  // deep copy using deep assignment
  LEA_CTOR;
  *this = from;
}

DbuRunSummary& DbuRunSummary::operator=(const DbuRunSummary& rhs)
{
  // deep assignment

  if (this == &rhs) return *this;  // do nothing if asked to self-assign

  DbiTableRow::operator=(rhs);
  this->fDetector        = rhs.fDetector;
  this->fSimFlag         = rhs.fSimFlag;
  this->fRun             = rhs.fRun;
  this->fLastSubRun      = rhs.fLastSubRun;
  this->fRunType         = rhs.fRunType;
  this->fStartTime       = rhs.fStartTime;
  this->fEndTime         = rhs.fEndTime;
  this->fTermCode        = rhs.fTermCode;
  this->fRunEndSnarls    = rhs.fRunEndSnarls;
  this->fRunEndNonSnarls = rhs.fRunEndNonSnarls;
  this->fNErrs           = rhs.fNErrs;
  this->fTimeFrames      = rhs.fTimeFrames;
  this->fDroppedFrames   = rhs.fDroppedFrames;
  this->fConsistency     = rhs.fConsistency;
  this->fRunComment      = rhs.fRunComment;
  this->fRunPrepare      = rhs.fRunPrepare;
  this->fAuxConfigText  = rhs.fAuxConfigText;

  if (this->fDbuDaqConfigFilesText) delete this->fDbuDaqConfigFilesText;
  if ( ! rhs.fDbuDaqConfigFilesText ) {
    MSG("Dbu",Msg::kError)
      << "DbuRunSummary::operator= rhs has no fDbuDaqConfigFilesText"
      << endl;
  }
  this->fDbuDaqConfigFilesText = 
    new DbuDaqConfigFilesText(*(rhs.fDbuDaqConfigFilesText));

  // delete any DbuDaqFileSummary objects that we currently have
  for (size_t j=0; j < this->fDbuDaqFiles.size(); ++j) 
    { delete this->fDbuDaqFiles[j]; this->fDbuDaqFiles[j] = 0; }

  // make new copies of DbuDaqFileSummary objects
  if (rhs.fLastSubRun >= 0) {
    size_t mxsize = TMath::Max( rhs.fLastSubRun+1,
                                (int)rhs.fDbuDaqFiles.size() );
    this->fDbuDaqFiles.resize(mxsize);
    for (size_t k=0; k < rhs.fDbuDaqFiles.size(); ++k) {
      const DbuDaqFileSummary* fs = rhs.fDbuDaqFiles[k];
      if (fs) AddDaqFileEntry(*fs);
    }
  }

  return *this;
}

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

Int_t DbuRunSummary::CalcSnarls() const
{
  // Calculate # of snarls from sum of those recorded in DbuDaqFileSummary's
  Int_t snarls = 0;
  for (size_t k=0; k < fDbuDaqFiles.size(); ++k) {
    const DbuDaqFileSummary* fs = fDbuDaqFiles[k];
    if (fs) snarls += fs->fSnarlRecs;
  }
  return snarls;
}

Int_t DbuRunSummary::CalcNonSnarls() const
{
  // Calculate # of non-snarls from sum of those recorded in DbuDaqFileSummary's
  Int_t nonsnarls = 0;
  for (size_t k=0; k < fDbuDaqFiles.size(); ++k) {
    const DbuDaqFileSummary* fs = fDbuDaqFiles[k];
    if (fs) nonsnarls += ( fs->fMonitorRecs + fs->fLightInjRecs);
  }
  return nonsnarls;
}

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

void DbuRunSummary::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.

   Detector::Detector_t det =
      (Detector::Detector_t)
      ((vrec) ? vrec->GetVldRange().GetDetectorMask() : 0);

   SimFlag::SimFlag_t simflag =
     (SimFlag::SimFlag_t)
     ((vrec) ? vrec->GetVldRange().GetSimMask() : 0);

   string detname, runtypename, config_md5;
   Int_t config_seqno;

   // count of data columns (not including SEQNO and ROW_COUNTER)
   Int_t numDataCol = rs.NumCols() - (rs.HasRowCounter() ? 1 : 0) - 1;
   if ( 19 == numDataCol ) {
       rs >> detname
          >> fRun
          >> fLastSubRun
          >> fRunType
          >> runtypename
          >> fStartTime
          >> fEndTime
          >> fTermCode
          >> fRunEndSnarls
          >> fRunEndNonSnarls
          >> fNErrs
          >> fTimeFrames
          >> fDroppedFrames
          >> fConsistency
          >> fRunComment
          >> fRunPrepare
          >> fAuxConfigText
          >> config_md5
          >> config_seqno;
   }
   else if ( 18 == numDataCol ) {  // before fAuxConfigText
       rs >> detname
          >> fRun
          >> fLastSubRun
          >> fRunType
          >> runtypename
          >> fStartTime
          >> fEndTime
          >> fTermCode
          >> fRunEndSnarls
          >> fRunEndNonSnarls
          >> fNErrs
          >> fTimeFrames
          >> fDroppedFrames
          >> fConsistency
          >> fRunComment
          >> fRunPrepare
          >> config_md5
          >> config_seqno;
   }
   else {
       MAXMSG("Dbu",Msg::kWarning,25)
           << "Table " << GetName() << " has " << numDataCol
           << ", but we only know how to handle 19 or 18."
           << endl;
   }

   fDetector = Detector::CharToEnum(detname.c_str()[0]);
   if (fDetector != det)
      MSG("Dbu",Msg::kWarning)
         << "Detector column '" << detname << "' (" << (int)fDetector
         << ") did not match DetectorMask (" << (int)det << ")" << endl;
   fSimFlag  = simflag;

   // make a extended query to get ConfigFileText
   VldTimeStamp tsStart(1970, 1, 1, 0, 0, 0);
   VldTimeStamp   tsEnd(2038, 1,18,19,14, 7);

   DbiSqlContext extContextConfig(DbiSqlContext::kStarts,tsStart,tsEnd,
                                  (Detector::Detector_t)127,   // any
                                  (SimFlag::SimFlag_t)127   ); // any
   //kUnknown,SimFlag::kUnknown);
   //fDetector,simflag);
                            
   string seqSelectConfig = Form("SEQNO=%d",config_seqno);

   DbiResultPtr<DbuDaqConfigFilesText> 
     rsConfig("DBUDAQCONFIGFILESTEXT",extContextConfig,Dbi::kAnyTask,
              seqSelectConfig.c_str());

   Int_t nConfig = rsConfig.GetNumRows();
   if (nConfig == 1) {
     *fDbuDaqConfigFilesText = *rsConfig.GetRow(0);
   }
   else
     MSG("Dbu",Msg::kWarning)
       << "Found " << nConfig << " matching DbuDaqConfigFilesText entries"
       << endl;

   VldTimeStamp tsLower(fStartTime.GetSec()-1,0);
   VldTimeStamp tsUpper(fEndTime.GetSec()+1,0);
   // make a extended query to get DaqFileSummary's
   DbiSqlContext extContextFile(DbiSqlContext::kStarts,
                                tsLower,tsUpper, // was fStartTime,fEndTime,
                                fDetector,simflag); // yes, these are important
                            
   string seqSelectFile = Form("RUN=%d",fRun);

   DbiResultPtr<DbuDaqFileSummary> 
     rsFiles("DBUDAQFILESUMMARY",extContextFile,Dbi::kAnyTask,
             seqSelectFile.c_str());

   // clear any existing DaqFileSummary's
   for (size_t j=0; j < fDbuDaqFiles.size(); ++j) 
     { delete fDbuDaqFiles[j]; fDbuDaqFiles[j] = 0; }

   // make sure vector has enough entries
   Int_t nFile = rsFiles.GetNumRows();
   Int_t lastSubRunSeen = -1;
   for (Int_t k=0; k < nFile; ++k) {
     const DbuDaqFileSummary* fs = rsFiles.GetRow(k);
     if ( fs->fSubRun > lastSubRunSeen ) lastSubRunSeen = fs->fSubRun;
   }
   size_t mxsize = TMath::Max( nFile, lastSubRunSeen+1 );

   MSG("Dbu",Msg::kDebug)
     << " " << Detector::AsString(fDetector) << " Run " << fRun 
     << " Found " << nFile << " matching DbuDaqFileSummary entries "
     << " LastSubRun " << fLastSubRun 
     << " lastSubRunSeen is " << lastSubRunSeen
     << endl;

   fDbuDaqFiles.resize(mxsize);
   if (mxsize > (size_t)(fLastSubRun+1)) {
     MSG("Dbu",Msg::kWarning)
       << "LastSubRun was " << fLastSubRun
       << " but there are " << nFile << " DbuDaqFileSummary entries "
       << " and lastSubRunSeen is " << lastSubRunSeen
       << endl;
     fLastSubRun = mxsize-1;
   }

   // make copies
   for (int iFile = 0; iFile < nFile; ++iFile) {
     const DbuDaqFileSummary* fs = rsFiles.GetRow(iFile);
     if (fs) AddDaqFileEntry(*fs);
   }

   if ( fLastSubRun != nFile-1 ) {
     MAXMSG("Dbu",Msg::kInfo,20)
       << "  ! fLastSubRun is " << fLastSubRun
       << " but there are " << nFile 
       << " DbuDaqFileSummary entries" << endl;
   }

}

//.....................................................................
void DbuRunSummary::AddDaqFileEntry(const DbuDaqFileSummary& fs)
{
  // copy DbuDaqFileSummary into DbuRunSummary's owned list

  Short_t subrun = fs.fSubRun;
  if (subrun < 0) {
    MSG("Dbu",Msg::kWarning) 
      << "DbuDaqFileSummary had SubRun=" << subrun << "?!"
      << endl;
    return;
  }
  if ( fDbuDaqFiles[subrun] ) {
    MSG("Dbu",Msg::kWarning) 
      << "DbuDaqFileSummary had previous entry for SubRun=" 
      << subrun << "?!"
      << endl;
    return;
  }
  if ( fDbuDaqFiles.size() < (size_t)subrun+1 ) {
    MSG("Dbu",Msg::kWarning) 
      << "DbuDaqFileSummary allocated " << fDbuDaqFiles.size()
      << ", saw " << subrun << "?!"
      << endl;
    fDbuDaqFiles.resize(subrun+1);  // expand if necessary
  }
  fDbuDaqFiles[subrun] = new DbuDaqFileSummary(fs);\
}

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

void DbuRunSummary::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 << Detector::AsString(fDetector)
       << fRun
       << fLastSubRun
       << fRunType
       << RunTypeName(fRunType,fDetector,fRun)
       << fStartTime
       << fEndTime
       << fTermCode
       << fRunEndSnarls
       << fRunEndNonSnarls
       << fNErrs
       << fTimeFrames
       << fDroppedFrames
       << fConsistency
       << fRunComment;

}

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

Int_t DbuRunSummary::CalcUniqueSeqNo(Detector::Detector_t det, Int_t run)
{
//
//
//  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 99 + 100*(run + 1000000*det);
}

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

Bool_t DbuRunSummary::IsSameRun(Detector::Detector_t det, Int_t run)
{
//
//
//  Purpose:  Same characteristics?
//
//  Return:   a bool
//
//  Contact:   R. Hatcher
//
//  Specification:-
//  =============
//

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

//  None.

   return (fDetector == det) && (fRun == run);
}

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

const char* DbuRunSummary::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,        \
       DETECTOR          tinytext,   \
       RUN               int,        \
       LAST_SUBRUN       smallint,   \
       RUNTYPE           smallint,   \
       RUNTYPE_NAME      varchar(24),\
       STARTTIME         datetime,   \
       ENDTIME           datetime,   \
       TERMCODE          int,        \
       RUNEND_SNARLS     int,        \
       RUNEND_NONSNARLS  int,        \
       NERRS             int,        \
       NTIMEFRAMES       int,        \
       NDROPPEDFRAMES    int,        \
       CONSISTENCY_BITS  int,        \
       RUN_COMMENT       text,       \
       RUNPREPARE_STRING text,       \
       AUX_CONFIG_TEXT   text,       \
       CONFIGFILES_MD5   text,       \
       CONFIGFILES_SEQNO int,        \
       primary key (SEQNO,ROW_COUNTER), \
       index (RUN) )";

   return const_tabledescr;
}

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

Bool_t DbuRunSummary::Commit(DbiStatement* stmt, 
                             std::string cft_md5, int cft_seqno)
{
//
//
//  Purpose:  
//
//  Arguments: 
//    xxxxxxxxx    in    yyyyyy
//
//  Return:    
//
//  Contact:   R. Hatcher
//
//  Specification:-
//  =============
//
//  o 

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

//  None.

  if (!stmt) return false; 

  // protect ODBC code against signals
  DbuSignalHandler::Instance().Delay();
  
  Int_t seqno = GetSeqNo();
  string tbl  = "DBURUNSUMMARY";
  string tblv = "DBURUNSUMMARYVLD";
  
  // just blast away any existing entry

  DbiString sqlrm, sqlrmv;
  
  sqlrm  << "delete from " << tbl  << " where SEQNO=" << seqno << ";\0";
  Int_t nrm  = stmt->ExecuteUpdate(sqlrm.c_str());
  stmt->PrintExceptions();

  sqlrmv << "delete from " << tblv << " where SEQNO=" << seqno << ";\0";
  Int_t nrmv = stmt->ExecuteUpdate(sqlrmv.c_str());
  stmt->PrintExceptions();

  // prepare to fill table

  string printableRunComment;
  UtilString::MakePrintable(fRunComment.c_str(),printableRunComment);
  string printableRunPrepare;
  UtilString::MakePrintable(fRunPrepare.c_str(),printableRunPrepare);
  string printableAuxConfigText;
  UtilString::MakePrintable(fAuxConfigText.c_str(),printableAuxConfigText);

  DbiString sqlcol, sqlval;
  sqlcol << " SEQNO ";
  sqlval << seqno;
  sqlcol << ", DETECTOR ";
  sqlval << ",'" << Detector::AsString(fDetector) << "'";
  sqlcol << ", RUN ";
  sqlval << "," << fRun;
  sqlcol << ", LAST_SUBRUN ";
  sqlval << "," << fLastSubRun;
  sqlcol << ", RUNTYPE ";
  sqlval << "," << fRunType;
  sqlcol << ", RUNTYPE_NAME ";
  sqlval << ",'" << RunTypeName(fRunType,fDetector,fRun) << "'";
  sqlcol << ", STARTTIME ";
  sqlval << ",'" << fStartTime.AsString("s") << "'";
  sqlcol << ", ENDTIME ";
  sqlval << ",'" << fEndTime.AsString("s") << "'";
  sqlcol << ", TERMCODE ";
  sqlval << "," << fTermCode;
  sqlcol << ", RUNEND_SNARLS ";
  sqlval << "," << fRunEndSnarls;
  sqlcol << ", RUNEND_NONSNARLS ";
  sqlval << "," << fRunEndNonSnarls;
  sqlcol << ", NERRS ";
  sqlval << "," << fNErrs;
  sqlcol << ", NTIMEFRAMES ";
  sqlval << "," << fTimeFrames;
  sqlcol << ", NDROPPEDFRAMES ";
  sqlval << "," << fDroppedFrames;
  sqlcol << ", CONSISTENCY_BITS ";
  sqlval << "," << fConsistency;
  sqlcol << ", RUN_COMMENT ";
  sqlval << ",'" << printableRunComment << "'";
  sqlcol << ", RUNPREPARE_STRING ";
  sqlval << ",'" << printableRunPrepare << "'";
  sqlcol << ", AUX_CONFIG_TEXT ";
  sqlval << ",'" << printableAuxConfigText << "'";
  sqlcol << ", CONFIGFILES_MD5 ";
  sqlval << ",'" << cft_md5 << "'";
  sqlcol << ", CONFIGFILES_SEQNO ";
  sqlval << "," << cft_seqno;
    
  DbiString sqlinsert;
  sqlinsert << "insert into " << tbl
            << " ( " << sqlcol.c_str() << " ) "
            << " values ( " << sqlval.c_str() << " ) ;\0";
  
  MSG("Dbu",Msg::kDebug) << sqlinsert.c_str() << endl;
  
  VldTimeStamp now;
  
  const Int_t task = 0;
  
  DbiString sqlcolv, sqlvalv;
  sqlcolv << " SEQNO";
  sqlvalv << seqno;
  sqlcolv << ", TIMESTART ";
  sqlvalv << ",'" << fStartTime.AsString("s") << "'";
  sqlcolv << ", TIMEEND ";
  sqlvalv << ",'" << fEndTime.AsString("s") << "'";
  sqlcolv << ", DETECTORMASK ";
  sqlvalv << "," << fDetector;
  sqlcolv << ", SIMMASK ";
  sqlvalv << "," << fSimFlag;
  sqlcolv << ", TASK ";
  sqlvalv << "," << task;
  sqlcolv << ", AGGREGATENO ";
  sqlvalv << "," << GetAggregateNo();
  sqlcolv << ", CREATIONDATE ";
  sqlvalv << ",'" << now.AsString("s") << "'" ;
  sqlcolv << ", INSERTDATE ";
  sqlvalv << ",'" << now.AsString("s") << "'";
  
  DbiString sqlinsertv;
  sqlinsertv << "insert into " << tblv
             << " ( " << sqlcolv.c_str() << " ) "
             << " VALUES ( " << sqlvalv.c_str() << " ) ;\0";
  
  MSG("Dbu",Msg::kDebug) 
    << "insert into " << tblv
    << " ( " << sqlcolv.c_str() << " ) "
    << " VALUES ( " << sqlvalv.c_str() << " ) ;"
    << endl;
  
  Int_t ninsert = stmt->ExecuteUpdate(sqlinsert.c_str());
  stmt->PrintExceptions();
  
  Int_t ninsertv = stmt->ExecuteUpdate(sqlinsertv.c_str());
  stmt->PrintExceptions();
  
  MSG("Dbu",Msg::kVerbose)
    << sqlinsert.c_str() << endl;
  MSG("Dbu",Msg::kVerbose)
    << sqlinsertv.c_str() << endl;
  
  char tmpbuf[1024];
  sprintf(tmpbuf,"Commit DbuRunSummary %c%8.8d",
          Detector::AsString(fDetector)[0],fRun);

  MSG("Dbu",Msg::kDebug) 
    << tmpbuf
    //<< " Cbits " << fCurrentSubRun->fConsistency 
    << " rm/in " 
    << nrm << "," << nrmv << "/"
    << ninsert << "," << ninsertv 
    << endl;

  logDebug(1,"%s rm=%d,%d in=%d,%d @ %s",
           tmpbuf,nrm,nrmv,ninsert,ninsertv,now.AsString("s"));
  
  bool success = (ninsert==1) && (ninsertv==1);
  
  // done protecting ODBC code against signals
  DbuSignalHandler::Instance().HandleDelayedSignal();


  return success;
}

/*    Template for New Member Function

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

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

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

//  None.


}

*/

---