QwParityDB Class Reference

#include <QwParityDB.h>

Inheritance diagram for QwParityDB:

Collaboration diagram for QwParityDB:

Public Member Functions
	QwParityDB ()
	Simple constructor. More...
	QwParityDB (QwOptions &options)
	Constructor with QwOptions object. More...
virtual	~QwParityDB ()
	Destructor. More...
void	SetupOneRun (QwEventBuffer &qwevt)
void	FillParameterFiles (QwSubsystemArrayParity &subsys)
UInt_t	GetMonitorID (const string &name, Bool_t zero_id_is_error=kTRUE)
UInt_t	GetMainDetectorID (const string &name, Bool_t zero_id_is_error=kTRUE)
UInt_t	GetLumiDetectorID (const string &name, Bool_t zero_id_is_error=kTRUE)
const string	GetMeasurementID (const Int_t index)
UInt_t	GetSlowControlDetectorID (const string &name)
UInt_t	GetErrorCodeID (const string &name)
UInt_t	GetRunNumber ()
UInt_t	GetSegmentNumber ()
UInt_t	GetRunID ()
UInt_t	GetRunletID ()
UInt_t	GetAnalysisID ()
UInt_t	GetRunID (QwEventBuffer &qwevt)
UInt_t	GetRunletID (QwEventBuffer &qwevt)
UInt_t	GetAnalysisID (QwEventBuffer &qwevt)
Bool_t	SetRunNumber (const UInt_t runnum)
Bool_t	SetSegmentNumber (const UInt_t segment)
void	ProcessAdditionalOptions (QwOptions &options)
	Processes the options contained in the QwOptions object. More...
Public Member Functions inherited from QwDatabase
	QwDatabase (const string &major="00", const string &minor="00", const string &point="0000")
	Simple constructor. More...
	QwDatabase (QwOptions &options, const string &major="00", const string &minor="00", const string &point="0000")
	Constructor with QwOptions object. More...
virtual	~QwDatabase ()
	Destructor. More...
void	SetAccessLevel (string accesslevel)
	Sets the access level flag based on string labels: "off", "ro", "rw". More...
Bool_t	AllowsReadAccess ()
Bool_t	AllowsWriteAccess ()
Bool_t	Connect ()
	Open a connection to the database using the predefined parameters. More...
void	Disconnect ()
Bool_t	Connected ()
const string	GetServerVersion ()
void	ProcessOptions (QwOptions &options)
	Processes the options contained in the QwOptions object. More...
void	ProcessOptions (const TString &dbname, const TString &username, const TString &passwd, const TString &dbhost="localhost", const Int_t dbport=0, const TString &accesslevel="ro")
	Processes database options. More...
mysqlpp::Query	Query (const char *qstr=0)
mysqlpp::Query	Query (const std::string &qstr)
const string	GetVersion ()
const string	GetVersionMajor ()
	Return a full version string for the DB schema. More...
const string	GetVersionMinor ()
const string	GetVersionPoint ()
const string	GetValidVersion ()
void	PrintServerInfo ()

Static Public Member Functions
static void	DefineAdditionalOptions (QwOptions &options)
	Defines QwParityDB-specific class options for QwOptions. More...
Static Public Member Functions inherited from QwDatabase
static void	DefineOptions (QwOptions &options)
	Defines available class options for QwOptions. More...

Private Member Functions
UInt_t	SetRunID (QwEventBuffer &qwevt)
UInt_t	SetRunletID (QwEventBuffer &qwevt)
UInt_t	SetAnalysisID (QwEventBuffer &qwevt)
void	StoreMonitorIDs ()
void	StoreMainDetectorIDs ()
void	StoreLumiDetectorIDs ()
void	StoreMeasurementIDs ()
void	StoreSlowControlDetectorIDs ()
void	StoreErrorCodeIDs ()

Private Attributes
UInt_t	fRunNumber
	Run number of current run. More...
Int_t	fSegmentNumber
	CODA file segment number of current run. More...
UInt_t	fRunID
	run_id of current run More...
UInt_t	fRunletID
	runlet_id of current run More...
UInt_t	fAnalysisID
	analysis_id of current analysis pass More...
bool	fDisableAnalysisCheck
	Flag to disable pre-existing analysis_id check. More...

Static Private Attributes
static std::map< string, unsigned int >	fMonitorIDs
	Associative array of beam monitor IDs. This declaration will be a problem if QwDatabase is used to connect to two databases simultaneously. More...
static std::map< string, unsigned int >	fMainDetectorIDs
	Associative array of main detector IDs. This declaration will be a problem if QwDatabase is used to connect to two databases simultaneously. More...
static std::map< string, unsigned int >	fLumiDetectorIDs
	Associative array of LUMI detector IDs. This declaration will be a problem if QwDatabase is used to connect to two databases simultaneously. More...
static std::map< string, unsigned int >	fSlowControlDetectorIDs
	Associative array of slow controls data IDs. This declaration will be a problem if QwDatabase is used to connect to two databases simultaneously. More...
static std::map< string, unsigned char >	fErrorCodeIDs
	Associative array of error code IDs. This declaration will be a problem if QwDatabase is used to connect to two databases simultaneously. More...
static std::vector< string >	fMeasurementIDs

Friends
class	StoreMonitorID
class	StoreMainDetectorID
class	StoreLumiDetectorID
class	StoreMeasurementID
class	StoreSlowControlDetectorID
class	StoreErrorCodeID

Detailed Description

Definition at line 49 of file QwParityDB.h.

Constructor & Destructor Documentation

QwParityDB::QwParityDB

(

)

Simple constructor.

The simple constructor initializes member fields. This class is not used to establish the database connection. It sets up a mysqlpp::Connection() object that has exception throwing disabled.

Definition at line 90 of file QwParityDB.cc.

References QwLog::endl(), fAnalysisID, fDisableAnalysisCheck, fRunID, fRunletID, fRunNumber, fSegmentNumber, and QwDebug.

                       : QwDatabase("01", "04", "0000")
{
  QwDebug << "Greetings from QwParityDB simple constructor." << QwLog::endl;
  // Initialize member fields

  fRunNumber         = 0;
  fRunID             = 0;
  fRunletID          = 0;
  fAnalysisID        = 0;
  fSegmentNumber     = -1;
  fDisableAnalysisCheck = false;
  
}

Here is the call graph for this function:

QwParityDB::QwParityDB

(

QwOptions &

options

)

Constructor with QwOptions object.

The constructor initializes member fields using the values in the QwOptions object.

Parameters

options

The QwOptions object.

Definition at line 108 of file QwParityDB.cc.

References QwLog::endl(), fAnalysisID, fDisableAnalysisCheck, fRunID, fRunletID, fRunNumber, fSegmentNumber, ProcessAdditionalOptions(), and QwDebug.

                                         : QwDatabase(options, "01", "04", "0000")
{
  QwDebug << "Greetings from QwParityDB extended constructor." << QwLog::endl;

  // Initialize member fields
  fRunNumber         = 0;
  fRunID             = 0;
  fRunletID          = 0;
  fAnalysisID        = 0;
  fSegmentNumber     = -1;
  fDisableAnalysisCheck = false;
  
  ProcessAdditionalOptions(options);

}

Here is the call graph for this function:

QwParityDB::~QwParityDB ( )

virtual

Destructor.

The destructor says "Good-bye World!"

Definition at line 126 of file QwParityDB.cc.

References QwDatabase::Connected(), QwDatabase::Disconnect(), QwLog::endl(), and QwDebug.

{
  QwDebug << "QwParityDB::~QwParityDB() : Good-bye World from QwParityDB destructor!" << QwLog::endl;
  if( Connected() ) Disconnect();
}

Here is the call graph for this function:

Member Function Documentation

void QwParityDB::DefineAdditionalOptions ( QwOptions &  options )

static

Defines QwParityDB-specific class options for QwOptions.

Defines configuration options for QwParityDB class using QwOptions functionality.

Should apparently by called by QwOptions::DefineOptions() in QwParityOptions.h

Definition at line 877 of file QwParityDB.cc.

References QwOptions::AddOptions(), and default_bool_value.

Referenced by DefineOptionsParity().

{
  // Specify command line options for use by QwParityDB
  options.AddOptions("Parity Analyzer Database options")
    ("QwParityDB.disable-analysis-check", 
     po::value<bool>()->default_bool_value(false),
     "disable check of pre-existing analysis_id");
}

Here is the call graph for this function:

Here is the caller graph for this function:

void QwParityDB::FillParameterFiles

(

QwSubsystemArrayParity &

subsys

)

Definition at line 563 of file QwParityDB.cc.

References QwDatabase::Connect(), QwDatabase::Disconnect(), QwLog::endl(), GetAnalysisID(), QwSubsystemArray::GetParamFileNameList(), QwDatabase::Query(), and QwError.

Referenced by main().

                                                                 {
  TList* param_file_list = subsys.GetParamFileNameList("mapfiles");
  try {
    this->Connect();
    mysqlpp::Query query = this->Query();
    parameter_files parameter_file_row(0);
    parameter_file_row.analysis_id = GetAnalysisID();

    param_file_list->Print();
    TIter next(param_file_list);
    TList *pfl_elem;
    while ((pfl_elem = (TList *) next())) {
      parameter_file_row.filename = pfl_elem->GetName();
      query.insert(parameter_file_row);
      query.execute();
    }

    this->Disconnect();

    delete param_file_list;
  }
  catch (const mysqlpp::Exception& er) {
    QwError << er.what() << QwLog::endl;
    this->Disconnect();
    delete param_file_list;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

UInt_t QwParityDB::GetAnalysisID ( )

inline

Definition at line 71 of file QwParityDB.h.

References fAnalysisID.

Referenced by QwRegression::FillDB(), QwBlinder::FillDB(), QwMainCerenkovDetector::FillDB(), QwBeamLine::FillDB(), QwIntegratedRaster::FillDB(), QwLumi::FillDB(), QwBeamMod::FillDB_MPS(), QwBlinder::FillErrDB(), QwMainCerenkovDetector::FillErrDB(), QwBeamLine::FillErrDB(), QwIntegratedRaster::FillErrDB(), QwLumi::FillErrDB(), FillParameterFiles(), main(), SetupOneRun(), QwBlinder::WriteChecksum(), and QwBlinder::WriteTestValues().

{return fAnalysisID;};    //<! Get analysis ID

Here is the caller graph for this function:

UInt_t QwParityDB::GetAnalysisID

(

QwEventBuffer &

qwevt

)

This is a getter for analysis_id in the analysis table. Required by all queries on cerenkov, beam, etc. tables. Will return 0 if fRunID has not been successfully set. If fAnalysisID is not set, then calls code to insert into analysis table and retrieve analysis_id.

Definition at line 594 of file QwParityDB.cc.

References QwEventBuffer::AreRunletsSplit(), QwLog::endl(), fAnalysisID, fRunletID, fRunNumber, fSegmentNumber, QwEventBuffer::GetRunNumber(), QwEventBuffer::GetSegmentNumber(), QwDebug, QwError, and SetAnalysisID().

{
  // Sanity check to make sure not calling this before runlet_id has been retrieved.
  if (fRunletID == 0) {
    QwDebug << "QwParityDB::GetAnalysisID() : fRunletID must be set before proceeding.  Check to make sure run exists in database." << QwLog::endl;
    return 0;
  }

  if (fAnalysisID == 0 || fRunNumber != (UInt_t) qwevt.GetRunNumber()
      || (qwevt.AreRunletsSplit() && fSegmentNumber!=qwevt.GetSegmentNumber())) {
    QwDebug << "QwParityDB::GetAnalysisID() set fAnalysisID to " << SetAnalysisID(qwevt) << QwLog::endl;
    if (fAnalysisID==0) {
      QwError << "QwParityDB::SetAnalysisID() unable to set valid fAnalysisID for this run.  Exiting." <<QwLog::endl;
      exit(1);
    }
  }

  return fAnalysisID;
}

Here is the call graph for this function:

UInt_t QwParityDB::GetErrorCodeID

(

const string &

name

)

Definition at line 725 of file QwParityDB.cc.

References QwLog::endl(), fErrorCodeIDs, QwError, and StoreErrorCodeIDs().

{
  if (fErrorCodeIDs.size() == 0) {
    StoreErrorCodeIDs();
  }

  UInt_t error_code_id = fErrorCodeIDs[name];

  if (error_code_id==0) {
    QwError << "QwParityDB::GetErrorCodeID() => Unable to determine valid ID for the error code " << name << QwLog::endl;
  }

  return error_code_id;

}

Here is the call graph for this function:

UInt_t QwParityDB::GetLumiDetectorID	(	const string &	name,
		Bool_t	zero_id_is_error = kTRUE
	)

Definition at line 790 of file QwParityDB.cc.

References QwLog::endl(), fLumiDetectorIDs, QwError, and StoreLumiDetectorIDs().

Referenced by main(), QwDBInterface::SetDetectorID(), QwDBInterface::SetLumiDetectorID(), and QwErrDBInterface::SetLumiDetectorID().

{
  if (fLumiDetectorIDs.size() == 0) {
    StoreLumiDetectorIDs();
  }

  UInt_t lumi_detector_id = fLumiDetectorIDs[name];

  if (zero_id_is_error && lumi_detector_id==0) {
     QwError << "QwParityDB::GetLumiDetectorID() => Unable to determine valid ID for beam lumi_detector " << name << QwLog::endl;
  }

  return lumi_detector_id;
}

Here is the call graph for this function:

Here is the caller graph for this function:

UInt_t QwParityDB::GetMainDetectorID	(	const string &	name,
		Bool_t	zero_id_is_error = kTRUE
	)

Definition at line 661 of file QwParityDB.cc.

References QwLog::endl(), fMainDetectorIDs, QwError, and StoreMainDetectorIDs().

Referenced by main(), QwDBInterface::SetDetectorID(), QwDBInterface::SetMainDetectorID(), and QwErrDBInterface::SetMainDetectorID().

{
  if (fMainDetectorIDs.size() == 0) {
    StoreMainDetectorIDs();
  }

  UInt_t main_detector_id = fMainDetectorIDs[name];

  if (zero_id_is_error && main_detector_id==0) {
    //    main_detector_id = 19; // only for QwMockDataAnalysis
    QwError << "QwParityDB::GetMainDetectorID() => Unable to determine valid ID for beam main_detector " << name << QwLog::endl;
  }

  return main_detector_id;

}

Here is the call graph for this function:

Here is the caller graph for this function:

const string QwParityDB::GetMeasurementID

(

const Int_t

index

)

Definition at line 833 of file QwParityDB.cc.

References QwLog::endl(), fMeasurementIDs, QwError, and StoreMeasurementIDs().

{
  if (fMeasurementIDs.size() == 0) {
    StoreMeasurementIDs();
  }

  string measurement_type = fMeasurementIDs[index];

  if (measurement_type.empty()) {
    QwError << "QwParityDB::GetMeasurementID() => Unable to determine valid ID for measurement type with " << index << QwLog::endl;
  }

  return measurement_type;
}

Here is the call graph for this function:

UInt_t QwParityDB::GetMonitorID	(	const string &	name,
		Bool_t	zero_id_is_error = kTRUE
	)

Definition at line 618 of file QwParityDB.cc.

References QwLog::endl(), fMonitorIDs, QwError, and StoreMonitorIDs().

Referenced by QwBeamMod::FillDB_MPS(), main(), QwDBInterface::SetDetectorID(), QwDBInterface::SetMonitorID(), and QwErrDBInterface::SetMonitorID().

{
  if (fMonitorIDs.size() == 0) {
    StoreMonitorIDs();
  }

  UInt_t monitor_id = fMonitorIDs[name];

  if (zero_id_is_error && monitor_id==0) {
    //    monitor_id = 6; // only for QwMockDataAnalysis
    QwError << "QwParityDB::GetMonitorID() => Unable to determine valid ID for beam monitor " << name << QwLog::endl;
  }

  return monitor_id;

}

Here is the call graph for this function:

Here is the caller graph for this function:

UInt_t QwParityDB::GetRunID ( )

inline

Definition at line 69 of file QwParityDB.h.

References fRunID.

Referenced by main(), and SetupOneRun().

{return fRunID;}           //<! Run ID getter

Here is the caller graph for this function:

UInt_t QwParityDB::GetRunID

(

QwEventBuffer &

qwevt

)

This is a getter for run_id in the run table. Should be used in subsequent queries to retain key relationships between tables.

Definition at line 290 of file QwParityDB.cc.

References QwLog::endl(), fAnalysisID, fRunID, fRunletID, fRunNumber, QwEventBuffer::GetRunNumber(), QwDebug, and SetRunID().

{
  // If the stored run number does not agree with the CODA run number
  // or if fRunID is not set, then retrieve data from database and update if necessary.

  // GetRunNumber() in QwEventBuffer returns Int_t, thus
  // we should convert it to UInt_t here. I think, it is OK.

  if (fRunID == 0 || fRunNumber != (UInt_t) qwevt.GetRunNumber() ) {
     QwDebug << "QwParityDB::GetRunID() set fRunID to " << SetRunID(qwevt) << QwLog::endl;
     fRunletID = 0;
     fAnalysisID = 0;
  }

  return fRunID;

}

Here is the call graph for this function:

UInt_t QwParityDB::GetRunletID ( )

inline

Definition at line 70 of file QwParityDB.h.

References fRunletID.

Referenced by QwEPICSEvent::FillDB(), QwEPICSEvent::FillSlowControlsData(), QwEPICSEvent::FillSlowControlsSettings(), QwEPICSEvent::FillSlowControlsStrigs(), SetAnalysisID(), and SetupOneRun().

{return fRunletID;}           //<! Runlet ID getter

Here is the caller graph for this function:

UInt_t QwParityDB::GetRunletID

(

QwEventBuffer &

qwevt

)

This is a getter for runlet_id in the runlet table. Should be used in subsequent queries to retain key relationships between tables.

Definition at line 412 of file QwParityDB.cc.

References QwEventBuffer::AreRunletsSplit(), QwLog::endl(), fAnalysisID, fRunletID, fRunNumber, fSegmentNumber, QwEventBuffer::GetRunNumber(), QwEventBuffer::GetSegmentNumber(), QwDebug, and SetRunletID().

{
  // If the stored run number does not agree with the CODA run number
  // or if fRunID is not set, then retrieve data from database and update if necessary.

  if (fRunletID == 0 || (qwevt.AreRunletsSplit() && fSegmentNumber!=qwevt.GetSegmentNumber()) || fRunNumber != (UInt_t) qwevt.GetRunNumber() ) {
     QwDebug << "QwParityDB::GetRunletID() set fRunletID to " << SetRunletID(qwevt) << QwLog::endl;
     fAnalysisID = 0;
  }

  return fRunletID;

}

Here is the call graph for this function:

UInt_t QwParityDB::GetRunNumber ( )

inline

Definition at line 67 of file QwParityDB.h.

References fRunNumber.

Referenced by QwBlinder::ReadSeed().

{return fRunNumber;}       //<! Run number getter

Here is the caller graph for this function:

UInt_t QwParityDB::GetSegmentNumber ( )

inline

Definition at line 68 of file QwParityDB.h.

References fSegmentNumber.

{return fSegmentNumber;}       //<! CODA File segment number getter

UInt_t QwParityDB::GetSlowControlDetectorID

(

const string &

name

)

Definition at line 706 of file QwParityDB.cc.

References QwLog::endl(), fSlowControlDetectorIDs, QwError, and StoreSlowControlDetectorIDs().

Referenced by QwEPICSEvent::FillSlowControlsData(), and QwEPICSEvent::FillSlowControlsStrigs().

{
  if (fSlowControlDetectorIDs.size() == 0) {
    StoreSlowControlDetectorIDs();
  }

  UInt_t sc_detector_id = fSlowControlDetectorIDs[name];

  if (sc_detector_id==0) {
    QwError << "QwParityDB::GetSlowControlDetectorID() => Unable to determine valid ID for the epics variable " << name << QwLog::endl;
  }

  return sc_detector_id;

}

Here is the call graph for this function:

Here is the caller graph for this function:

void QwParityDB::ProcessAdditionalOptions

(

QwOptions &

options

)

Processes the options contained in the QwOptions object.

Loads the configuration options for QwParityDB class into this instance of QwParityDB from the QwOptions object.

Parameters

options

Options object

Definition at line 891 of file QwParityDB.cc.

References fDisableAnalysisCheck, and QwOptions::GetValue().

Referenced by QwParityDB().

{
  if (options.GetValue<bool>("QwParityDB.disable-analysis-check"))  
    fDisableAnalysisCheck=true;

  return;
}

Here is the call graph for this function:

Here is the caller graph for this function:

UInt_t QwParityDB::SetAnalysisID ( QwEventBuffer &  qwevt )

private

This is used to set the appropriate analysis_id for this run. Must be a valid runlet_id in the runlet table before proceeding. Will insert an entry into the analysis table if necessary.

Definition at line 429 of file QwParityDB.cc.

References QwDatabase::Connect(), QwDatabase::Disconnect(), QwLog::endl(), fAnalysisID, fDisableAnalysisCheck, QwRunCondition::Get(), QwOptions::GetArgc(), QwOptions::GetArgv(), QwEventBuffer::GetEventRange(), GetRunletID(), gQwOptions, QwDatabase::Query(), QwError, QwMessage, and QwWarning.

Referenced by GetAnalysisID().

{

  // If there is already an analysis_id for this run, then let's bomb out.

  try {
    this->Connect();
    mysqlpp::Query query= this->Query();
    query << "SELECT analysis_id FROM analysis WHERE beam_mode=" << mysqlpp::quote << "nbm";
    query << " AND slope_calculation=" << mysqlpp::quote << "off";
    query << " AND slope_correction=" << mysqlpp::quote << "off";
    query << " AND runlet_id = " << mysqlpp::quote << this->GetRunletID(qwevt); 

    mysqlpp::StoreQueryResult res = query.store();

    if (res.num_rows() != 0) {
      QwError << "This runlet has already been analyzed by the engine!" << QwLog::endl;
      QwError << "The following analysis_id values already exist in the database:  ";
      for (size_t i=0; i<res.num_rows(); i++) {
        QwError << res[i][0] << " ";
      }
      QwError << QwLog::endl;

      if (fDisableAnalysisCheck==false) {
        QwError << "Analysis of this run will now be terminated."  << QwLog::endl;

        return 0;
      } else {
        QwWarning << "Analysis will continue.  A duplicate entry with new analysis_id will be added to the analysis table." << QwLog::endl;
      }
    }

    this->Disconnect();
  }
  catch (const mysqlpp::Exception& er) {
    QwError << er.what() << QwLog::endl;
    QwError << "Unable to determine if there are other database entries for this run.  Exiting." << QwLog::endl;
    this->Disconnect();
    return 0;
  }


  try {

    analysis analysis_row(0);

    analysis_row.runlet_id  = GetRunletID(qwevt);
    analysis_row.seed_id = 1;

    std::pair<UInt_t, UInt_t> event_range;
    event_range = qwevt.GetEventRange();

    analysis_row.time        = mysqlpp::DateTime::now();
    analysis_row.bf_checksum = "empty"; // we will match this as a real one later
    analysis_row.beam_mode   = "nbm";   // we will match this as a real one later
    analysis_row.n_mps       = 0;       // we will match this as a real one later
    analysis_row.n_qrt       = 4;       // we will match this as a real one later
    analysis_row.first_event = event_range.first;
    analysis_row.last_event  = event_range.second;
    analysis_row.segment     = 0;       // we will match this as a real one later
    analysis_row.slope_calculation = "off";  // we will match this as a real one later
    analysis_row.slope_correction  = "off"; // we will match this as a real one later

    // Analyzer Information Parsing 
    QwRunCondition run_condition(
      gQwOptions.GetArgc(),
      gQwOptions.GetArgv(),
      "run_condition"
    );

    run_condition.Get()->Print();

    TIter next(run_condition.Get());
    TObjString *obj_str;
    TString str_val, str_var;
    Ssiz_t location;

    // Iterate over each entry in run_condition
    while ((obj_str = (TObjString *) next())) {
      QwMessage << obj_str->GetName() << QwLog::endl; 

      // Store string contents for parsing
      str_var = str_val = obj_str->GetString();
      location = str_val.First(":"); // The first : separates variable from value
      location = location + 2; // Value text starts two characters after :
      str_val.Remove(0,location); //str_val stores value to go in DB

      // Decision tree to figure out which variable to store in
      if (str_var.BeginsWith("ROOT Version")) { 
        analysis_row.root_version = str_val;
      } else if (str_var.BeginsWith("ROOT file creating time")) {
        analysis_row.root_file_time = str_val;
      } else if (str_var.BeginsWith("ROOT file created on Hostname")) {
        analysis_row.root_file_host = str_val;
      } else if (str_var.BeginsWith("ROOT file created by the user")) {
        analysis_row.root_file_user = str_val;
      } else if (str_var.BeginsWith("QwAnalyzer Name")) {
        analysis_row.analyzer_name = str_val;
      } else if (str_var.BeginsWith("QwAnalyzer Options")) {
        analysis_row.analyzer_argv = str_val;
      } else if (str_var.BeginsWith("QwAnalyzer SVN Revision")) {
        analysis_row.analyzer_svn_rev = str_val;
      } else if (str_var.BeginsWith("QwAnalyzer SVN Last Changed Revision")) {
        analysis_row.analyzer_svn_lc_rev = str_val;
      } else if (str_var.BeginsWith("QwAnalyzer SVN URL")) {
        analysis_row.analyzer_svn_url = str_val;
      } else if (str_var.BeginsWith("DAQ ROC flags when QwAnalyzer runs")) {
        analysis_row.roc_flags = str_val;
      } else {
      }
    }
    this->Connect();
    mysqlpp::Query query= this->Query();
    query.insert(analysis_row);
    //QwMessage << "\nQwParityDB::SetAnalysisID() => Analysis Insert Query = " << query.str() << QwLog::endl<< QwLog::endl;
    query.execute();

    if (query.insert_id()!=0)
      {
  fAnalysisID = query.insert_id();
      }

    this->Disconnect();
    return fAnalysisID;
  }
  catch (const mysqlpp::Exception& er) {
    QwError << er.what() << QwLog::endl;
    this->Disconnect();
    return 0;
  }


}

Here is the call graph for this function:

Here is the caller graph for this function:

UInt_t QwParityDB::SetRunID ( QwEventBuffer &  qwevt )

private

This function sets the fRunID for the run being replayed as determined by the QwEventBuffer class.

Definition at line 200 of file QwParityDB.cc.

References QwDatabase::Connect(), QwDatabase::Disconnect(), QwLog::endl(), fRunID, fRunNumber, MQwCodaControlEvent::GetEndUnixTime(), QwEventBuffer::GetRunNumber(), MQwCodaControlEvent::GetStartUnixTime(), QwDatabase::Query(), QwDebug, and QwError.

Referenced by GetRunID().

{

  // Check to see if run is already in database.  If so retrieve run ID and exit.
  try
    {
      this->Connect();
      mysqlpp::Query query = this->Query();

      query << "SELECT * FROM run WHERE run_number = " << qwevt.GetRunNumber();
      std::vector<run> res;
      query.storein(res);
      QwDebug << "QwParityDB::SetRunID => Number of rows returned:  " << res.size() << QwLog::endl;

      // If there is more than one run in the DB with the same run number, then there will be trouble later on.  Catch and bomb out.
      if (res.size()>1)
  {
    QwError << "Unable to find unique run number " << qwevt.GetRunNumber() << " in database." << QwLog::endl;
    QwError << "Run number query returned " << res.size() << "rows." << QwLog::endl;
    QwError << "Please make sure that the database contains one unique entry for this run." << QwLog::endl;
    this->Disconnect();
    return 0;
  }

      // Run already exists in database.  Pull run_id and move along.
      if (res.size()==1)
  {
    QwDebug << "QwParityDB::SetRunID => Run ID = " << res.at(0).run_id << QwLog::endl;

    fRunNumber = qwevt.GetRunNumber();
    fRunID     = res.at(0).run_id;
    this->Disconnect();
    return fRunID;
  }
      this->Disconnect();
    }
  catch (const mysqlpp::Exception& er)
    {

      QwError << er.what() << QwLog::endl;
      this->Disconnect();
      return 0;
    }

  // Run is not in database so insert pertinent data and retrieve run ID
  // Right now this does not insert start/stop times or info on number of events.
  try
    {

      this->Connect();
      run row(0);
      row.run_number      = qwevt.GetRunNumber();
      row.run_type        = "good"; // qwevt.GetRunType(); RunType is the confused name because we have also a CODA run type.
      row.start_time      = mysqlpp::DateTime(qwevt.GetStartUnixTime());
      row.end_time        = mysqlpp::DateTime(qwevt.GetEndUnixTime());
      row.n_mps = 0;
      row.n_qrt = 0;
      // Set following quantities to 9999 as "uninitialized value".  DTS 8/3/2012
      row.slug = 9999;
      row.wien_slug = 9999;
      row.injector_slug = 9999;
//    row.n_mps=10; // This works
      //    row.start_time = mysqlpp::null; // This works
      //    row.start_time = qwevt.GetStartSQLTime().Data(); // This does not work
        mysqlpp::Query query=this->Query();
        query.insert(row);
       QwDebug<< "QwParityDB::SetRunID() => Run Insert Query = " << query.str() << QwLog::endl;

      query.execute();

      if (query.insert_id()!=0)
  {
    fRunNumber = qwevt.GetRunNumber();
    fRunID     = query.insert_id();
  }
      this->Disconnect();
      return fRunID;
    }
  catch (const mysqlpp::Exception& er)
    {
      QwError << er.what() << QwLog::endl;
      this->Disconnect();
      return 0;
    }

}

Here is the call graph for this function:

Here is the caller graph for this function:

UInt_t QwParityDB::SetRunletID ( QwEventBuffer &  qwevt )

private

This function sets the fRunletID for the run being replayed as determined by the QwEventBuffer class.

Runlets are differentiated by file segment number at the moment, not by event range or start/stop time. This function will need to be altered if we opt to differentiate between runlets in a different way.

Definition at line 313 of file QwParityDB.cc.

References QwEventBuffer::AreRunletsSplit(), QwDatabase::Connect(), QwDatabase::Disconnect(), QwLog::endl(), fRunID, fRunletID, fSegmentNumber, QwEventBuffer::GetRunNumber(), QwEventBuffer::GetSegmentNumber(), QwDatabase::Query(), QwDebug, and QwError.

Referenced by GetRunletID().

{

  // Make sure 'run' table has been populated and retrieve run_id
  //  UInt_t runid = this->GetRunID(qwevt);

  // Check to see if runlet is already in database.  If so retrieve runlet_id and exit.
  try
    {
      this->Connect();
      mysqlpp::Query query = this->Query();

      // Query is slightly different if file segments are being chained together for replay or not.
      if (qwevt.AreRunletsSplit()) {
        fSegmentNumber = qwevt.GetSegmentNumber();
        query << "SELECT * FROM runlet WHERE run_id = " << fRunID << " AND full_run = 'false' AND segment_number = " << fSegmentNumber;
      } else {
  query << "SELECT * FROM runlet WHERE run_id = " << fRunID << " AND full_run = 'true'";
      }

      std::vector<runlet> res;
      query.storein(res);
      QwDebug << "QwParityDB::SetRunletID => Number of rows returned:  " << res.size() << QwLog::endl;

      // If there is more than one run in the DB with the same runlet number, then there will be trouble later on.  Catch and bomb out.
      if (res.size()>1)
  {
    QwError << "Unable to find unique runlet number " << qwevt.GetRunNumber() << " in database." << QwLog::endl;
    QwError << "Run number query returned " << res.size() << "rows." << QwLog::endl;
    QwError << "Please make sure that the database contains one unique entry for this run." << QwLog::endl;
    this->Disconnect();
    return 0;
  }

      // Run already exists in database.  Pull runlet_id and move along.
      if (res.size()==1)
  {
    QwDebug << "QwParityDB::SetRunletID => Runlet ID = " << res.at(0).runlet_id << QwLog::endl;

    fRunletID     = res.at(0).runlet_id;
    this->Disconnect();
    return fRunletID;
  }
      this->Disconnect();
    }
  catch (const mysqlpp::Exception& er)
    {

      QwError << er.what() << QwLog::endl;
      this->Disconnect();
      return 0;
    }

  // Runlet is not in database so insert pertinent data and retrieve run ID
  // Right now this does not insert start/stop times or info on number of events.
  try
    {

      this->Connect();
      runlet row(0);
      row.run_id      = fRunID;
      row.run_number      = qwevt.GetRunNumber();
      row.start_time      = mysqlpp::null;
      row.end_time        = mysqlpp::null;
      row.first_mps = 0;
      row.last_mps  = 0;
      if (qwevt.AreRunletsSplit()) {
        row.segment_number = fSegmentNumber;
        row.full_run = "false";
      } else {
        row.segment_number  = mysqlpp::null;
        row.full_run = "true";
      }

        mysqlpp::Query query=this->Query();
        query.insert(row);
       QwDebug<< "QwParityDB::SetRunletID() => Run Insert Query = " << query.str() << QwLog::endl;

      query.execute();

      if (query.insert_id()!=0)
  {
    fRunletID     = query.insert_id();
  }
      this->Disconnect();
      return fRunletID;
    }
  catch (const mysqlpp::Exception& er)
    {
      QwError << er.what() << QwLog::endl;
      this->Disconnect();
      return 0;
    }

}

Here is the call graph for this function:

Here is the caller graph for this function:

bool QwParityDB::SetRunNumber

(

const UInt_t

runnum

)

Sets run number for subsequent database interactions. Makes sure correct entry exists in run table and retrieves run_id.

Definition at line 158 of file QwParityDB.cc.

References QwDatabase::Connect(), QwDatabase::Disconnect(), QwLog::endl(), fRunID, fRunNumber, QwDatabase::Query(), QwDebug, and QwError.

{

  QwDebug << "Made it into QwParityDB::SetRunNumber()" << QwLog::endl;

  try {

    this->Connect();

    mysqlpp::Query query= this->Query();
    query << "SELECT * FROM run WHERE run_number = " << runnum;
    std::vector<run> res;
    query.storein(res);

    QwDebug << "Number of rows returned:  " << res.size() << QwLog::endl;

    if (res.size()!=1) {
      QwError << "Unable to find unique run number " << runnum << " in database." << QwLog::endl;
      QwError << "Run number query returned " << res.size() << "rows." << QwLog::endl;
      QwError << "Please make sure that the database contains one unique entry for this run." << QwLog::endl;
      return false;
    }

    QwDebug << "Run ID = " << res.at(0).run_id << QwLog::endl;

    fRunNumber = runnum;
    fRunID = res.at(0).run_id;

    this->Disconnect();
  }
  catch (const mysqlpp::Exception& er) {
    QwError << er.what() << QwLog::endl;
    return false;
  }

  return true;

}

Here is the call graph for this function:

Bool_t QwParityDB::SetSegmentNumber

(

const UInt_t

segment

)

void QwParityDB::SetupOneRun

(

QwEventBuffer &

qwevt

)

Sets run number for subsequent database interactions. Makes sure correct entry exists in run table and retrieves run_id.

Definition at line 136 of file QwParityDB.cc.

References QwDatabase::AllowsReadAccess(), QwLog::endl(), GetAnalysisID(), GetRunID(), GetRunletID(), QwEventBuffer::GetRunNumber(), Qw::kBoldMagenta, Qw::kNormal, and QwMessage.

Referenced by main().

{
  if (this->AllowsReadAccess()) {
    UInt_t run_id      = this->GetRunID(qwevt);
    UInt_t runlet_id   = this->GetRunletID(qwevt);
    UInt_t analysis_id = this->GetAnalysisID(qwevt);
    
    //  Write from the datebase
    QwMessage << "QwParityDB::SetupOneRun::"
        << " Run Number "  << QwColor(Qw::kBoldMagenta) << qwevt.GetRunNumber() << QwColor(Qw::kNormal)
        << " Run ID "      << QwColor(Qw::kBoldMagenta) << run_id << QwColor(Qw::kNormal)
        << " Runlet ID "   << QwColor(Qw::kBoldMagenta) << runlet_id << QwColor(Qw::kNormal)
        << " Analysis ID " << QwColor(Qw::kBoldMagenta) << analysis_id 
        << QwColor(Qw::kNormal)
        << QwLog::endl;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void QwParityDB::StoreErrorCodeIDs ( )

private

Definition at line 767 of file QwParityDB.cc.

References QwDatabase::Connect(), QwDatabase::Disconnect(), QwLog::endl(), QwDatabase::Query(), QwError, and StoreErrorCodeID.

Referenced by GetErrorCodeID().

{

  try {
    this->Connect();
    mysqlpp::Query query=this->Query();
    query.for_each(error_code(), StoreErrorCodeID());

//    QwDebug<< "QwParityDB::SetAnalysisID() => Analysis Insert Query = " << query.str() << QwLog::endl;

    this->Disconnect();
  }
  catch (const mysqlpp::Exception& er) {
    QwError << er.what() << QwLog::endl;
    Disconnect();
    exit(1);
  }
  return;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void QwParityDB::StoreLumiDetectorIDs ( )

private

Definition at line 808 of file QwParityDB.cc.

References QwDatabase::Connect(), QwDatabase::Disconnect(), QwLog::endl(), QwDatabase::Query(), QwError, and StoreLumiDetectorID.

Referenced by GetLumiDetectorID().

{

  try {
    this->Connect();

    mysqlpp::Query query=this->Query();
    query.for_each(lumi_detector(), StoreLumiDetectorID());

//    QwDebug<< "QwParityDB::SetAnalysisID() => Analysis Insert Query = " << query.str() << QwLog::endl;

    this->Disconnect();

  }
  catch (const mysqlpp::Exception& er) {
    QwError << er.what() << QwLog::endl;
    Disconnect();
    exit(1);
  }
  return;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void QwParityDB::StoreMainDetectorIDs ( )

private

Definition at line 682 of file QwParityDB.cc.

References QwDatabase::Connect(), QwDatabase::Disconnect(), QwLog::endl(), QwDatabase::Query(), QwError, and StoreMainDetectorID.

Referenced by GetMainDetectorID().

{

  try {
    this->Connect();
    mysqlpp::Query query=this->Query();
    query.for_each(main_detector(), StoreMainDetectorID());

//    QwDebug<< "QwParityDB::SetAnalysisID() => Analysis Insert Query = " << query.str() << QwLog::endl;

    this->Disconnect();
  }
  catch (const mysqlpp::Exception& er) {
    QwError << er.what() << QwLog::endl;
    Disconnect();
    exit(1);
  }
  return;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void QwParityDB::StoreMeasurementIDs ( )

private

Definition at line 848 of file QwParityDB.cc.

References QwDatabase::Connect(), QwDatabase::Disconnect(), QwLog::endl(), QwDatabase::Query(), QwError, and StoreMeasurementID.

Referenced by GetMeasurementID().

{

  try {
    this->Connect();

    mysqlpp::Query query=this->Query();
    query.for_each(measurement_type(), StoreMeasurementID());

    // QwDebug<< "QwParityDB::SetAnalysisID() => Analysis Insert Query = " << query.str() << QwLog::endl;

    this->Disconnect();

  }
  catch (const mysqlpp::Exception& er) {
    QwError << er.what() << QwLog::endl;
    Disconnect();
    exit(1);
  }
  return;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void QwParityDB::StoreMonitorIDs ( )

private

Definition at line 638 of file QwParityDB.cc.

References QwDatabase::Connect(), QwDatabase::Disconnect(), QwLog::endl(), QwDatabase::Query(), QwError, and StoreMonitorID.

Referenced by GetMonitorID().

{
  try {

    this->Connect();
    mysqlpp::Query query=this->Query();
    query.for_each(monitor(), StoreMonitorID());

//    QwDebug<< "QwParityDB::SetAnalysisID() => Analysis Insert Query = " << query.str() << QwLog::endl;
    this->Disconnect();
  }

  catch (const mysqlpp::Exception& er) {
    QwError << er.what() << QwLog::endl;
    Disconnect();
    exit(1);
  }
  return;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void QwParityDB::StoreSlowControlDetectorIDs ( )

private

Definition at line 744 of file QwParityDB.cc.

References QwDatabase::Connect(), QwDatabase::Disconnect(), QwLog::endl(), QwDatabase::Query(), QwError, and StoreSlowControlDetectorID.

Referenced by GetSlowControlDetectorID().

{

  try {
    this->Connect();
    mysqlpp::Query query=this->Query();
    query.for_each(sc_detector(), StoreSlowControlDetectorID());

//    QwDebug<< "QwParityDB::SetAnalysisID() => Analysis Insert Query = " << query.str() << QwLog::endl;

    this->Disconnect();
  }
  catch (const mysqlpp::Exception& er) {
    QwError << er.what() << QwLog::endl;
    Disconnect();
    exit(1);
  }
  return;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Friends And Related Function Documentation

friend class StoreErrorCodeID

friend

Definition at line 113 of file QwParityDB.h.

Referenced by StoreErrorCodeIDs().

friend class StoreLumiDetectorID

friend

Definition at line 110 of file QwParityDB.h.

Referenced by StoreLumiDetectorIDs().

friend class StoreMainDetectorID

friend

Definition at line 109 of file QwParityDB.h.

Referenced by StoreMainDetectorIDs().

friend class StoreMeasurementID

friend

Definition at line 111 of file QwParityDB.h.

Referenced by StoreMeasurementIDs().

friend class StoreMonitorID

friend

Definition at line 108 of file QwParityDB.h.

Referenced by StoreMonitorIDs().

friend class StoreSlowControlDetectorID

friend

Definition at line 112 of file QwParityDB.h.

Referenced by StoreSlowControlDetectorIDs().

Field Documentation

UInt_t QwParityDB::fAnalysisID

private

analysis_id of current analysis pass

Definition at line 98 of file QwParityDB.h.

Referenced by GetAnalysisID(), GetRunID(), GetRunletID(), QwParityDB(), and SetAnalysisID().

bool QwParityDB::fDisableAnalysisCheck

private

Flag to disable pre-existing analysis_id check.

Definition at line 99 of file QwParityDB.h.

Referenced by ProcessAdditionalOptions(), QwParityDB(), and SetAnalysisID().

std::map< string, unsigned char > QwParityDB::fErrorCodeIDs

staticprivate

Associative array of error code IDs. This declaration will be a problem if QwDatabase is used to connect to two databases simultaneously.

Definition at line 105 of file QwParityDB.h.

Referenced by GetErrorCodeID(), and StoreErrorCodeID::operator()().

std::map< string, unsigned int > QwParityDB::fLumiDetectorIDs

staticprivate

Associative array of LUMI detector IDs. This declaration will be a problem if QwDatabase is used to connect to two databases simultaneously.

Definition at line 103 of file QwParityDB.h.

Referenced by GetLumiDetectorID(), and StoreLumiDetectorID::operator()().

std::map< string, unsigned int > QwParityDB::fMainDetectorIDs

staticprivate

Associative array of main detector IDs. This declaration will be a problem if QwDatabase is used to connect to two databases simultaneously.

Definition at line 102 of file QwParityDB.h.

Referenced by GetMainDetectorID(), and StoreMainDetectorID::operator()().

std::vector< string > QwParityDB::fMeasurementIDs

staticprivate

Definition at line 106 of file QwParityDB.h.

Referenced by GetMeasurementID(), and StoreMeasurementID::operator()().

std::map< string, unsigned int > QwParityDB::fMonitorIDs

staticprivate

Associative array of beam monitor IDs. This declaration will be a problem if QwDatabase is used to connect to two databases simultaneously.

Definition at line 101 of file QwParityDB.h.

Referenced by GetMonitorID(), and StoreMonitorID::operator()().

UInt_t QwParityDB::fRunID

private

run_id of current run

Definition at line 96 of file QwParityDB.h.

Referenced by GetRunID(), QwParityDB(), SetRunID(), SetRunletID(), and SetRunNumber().

UInt_t QwParityDB::fRunletID

private

runlet_id of current run

Definition at line 97 of file QwParityDB.h.

Referenced by GetAnalysisID(), GetRunID(), GetRunletID(), QwParityDB(), and SetRunletID().

UInt_t QwParityDB::fRunNumber

private

Run number of current run.

Definition at line 94 of file QwParityDB.h.

Referenced by GetAnalysisID(), GetRunID(), GetRunletID(), GetRunNumber(), QwParityDB(), SetRunID(), and SetRunNumber().

Int_t QwParityDB::fSegmentNumber

private

CODA file segment number of current run.

Definition at line 95 of file QwParityDB.h.

Referenced by GetAnalysisID(), GetRunletID(), GetSegmentNumber(), QwParityDB(), and SetRunletID().

std::map< string, unsigned int > QwParityDB::fSlowControlDetectorIDs

staticprivate

Associative array of slow controls data IDs. This declaration will be a problem if QwDatabase is used to connect to two databases simultaneously.

Definition at line 104 of file QwParityDB.h.

Referenced by GetSlowControlDetectorID(), and StoreSlowControlDetectorID::operator()().

---

The documentation for this class was generated from the following files:

• QwParityDB.h
• QwParityDB.cc