AEMDBInterface.h

Go to the documentation of this file.

////////////////////////////////////////////////////////////////////////
/// $Id: AEMDBInterface.h,v 1.5 2005/08/15 17:31:32 hmeyer Exp $
/// 
/// Class which defines interface to database, taken from RunControl
///
/// hmeyer@fnal.gov
////////////////////////////////////////////////////////////////////////

#ifndef AEM_DB_INTERFACE_H
#define AEM_DB_INTERFACE_H

extern "C" {
#include <libpq-fe.h>
}
#include <string>
#include <vector>

//----------------------------------------------------------------------

class DBRunEntry {
 public:
  DBRunEntry();
  //DBRunEntry(fRun);
  ~DBRunEntry() {}

  void dump();
  int    Run() {return run;}
  
  long   RunTime() {return fRunTime;}
  double SpillLength() {return fSpillLength;}
  double Spills() {return fSpills;}
  double SpillTime() {return fSpillTime;}
  int    SpillEvents() {return fSpillEvents;}
  double DAQRate() {return fDAQRate;}


  int run;
  int nsubrun;
  int nevent;
  std::string target;
  double momentum;
  std::string datestart, dateend;
  long epochstart, epochend; // as epoch, seconds since 1-jan-1970 GMT
  // We are at CST, GMT+6: select DATE_PART('epoch','1-jan-1970'::date)/60/60; returns 6.
  // daylight savings and other complications apply

  int nspill, nemptyspill, nbeamspill;
  int trigcount[20];
  int goodrun;

  long   fRunTime;    //Run clock-time (start-end)
  double fSpillLength;//Spill length in seconds
  int    fSpills;     //Number of beam-spills
  double fSpillTime;  //Beam-spills times spill-length (seconds)
  int    fSpillEvents;//Number of events 
  double fDAQRate;    //Events per second
};

typedef std::vector<DBRunEntry> DBRunEntries;

class AEMDBInterface {
 public:
  AEMDBInterface(std::string const Host);
  ~AEMDBInterface();

  int  GetRunNumber();             //return current run number
  int  GetnSubrun(int const fRun); //return number of subruns for run
  int  GetnSpill(int const fRun);  //return number of spills with beam for run
  int  GetnEvent(int const fRun);  //return number of in-spill events for run
  DBRunEntry GetRunEntry(int const fRun);
  DBRunEntries GetRunEntry(int const fRunMin, int const fRunMax);
  long GetRunEntry(std::string const fDateStart, DBRunEntries& fDBRuns);
  void GetRunEntry(DBRunEntries& fDBRuns);

 private:
  void Open();

  PGresult* ExecQuery(const char* query);
  void      ExecCommand(const char* command);

  void PutQueryToVector(PGresult* res, DBRunEntries& vec);

 private:
  // Object through which we interface to DB
  PGconn      *fDBConn;  
  std::string fDBHost;

};

#endif // AEM_DB_INTERFACE_H

////////////////////////////////////////////////////////////////////////

---