St_db_Maker.h

// $Id: St_db_Maker.h,v 1.46 2015/05/05 21:05:52 dmitry Exp $
// $Log: St_db_Maker.h,v $
// Revision 1.46  2015/05/05 21:05:52  dmitry
// Updated db disconnect handling. Keep connection if less than 30 sec passed since last data retrieval
//
// Revision 1.45  2015/05/05 20:42:14  dmitry
// dynamic db disconnects handling
//
// Revision 1.44  2014/08/06 11:43:54  jeromel
// Suffix on literals need to be space (later gcc compiler makes it an error) - first wave of fixes
//
// Revision 1.43  2013/07/18 14:00:32  fisyak
// expand no. of possible databases from 4 to 10
//
// Revision 1.42  2012/03/16 19:36:18  dmitry
// converted dangled char pointers to std::string objects + fixed typo
//
// Revision 1.41  2011/11/28 17:03:09  dmitry
// dbv override support in StDbLib,StDbBroker,St_db_Maker
//
// Revision 1.40  2011/03/19 02:50:57  perev
// blacklist added
//
// Revision 1.38  2010/05/05 18:35:04  dmitry
// addon: single datasets also saved
//
// Revision 1.37  2010/05/05 15:25:51  dmitry
// refactored snapshot code, to include Valeri's patch (save .root files)
//
// Revision 1.36  2010/04/28 07:23:40  dmitry
// =new method to save snapshot+one subsequent dataset for each table in db
//
// Revision 1.35  2010/04/17 02:07:19  perev
// Method Drop added
//
// Revision 1.34  2010/01/27 21:34:20  perev
// GetValidity now is static
//
// Revision 1.33  2009/11/16 20:16:23  fine
// Make the TDatime const interfaces
//
// Revision 1.32  2008/04/02 20:22:33  perev
// WarnOff
//
// Revision 1.31  2008/01/09 20:44:52  perev
// Improve printout in Finish()
//
// Revision 1.30  2007/12/29 01:43:24  perev
// More dbStat
//
// Revision 1.29  2007/09/10 02:20:10  perev
// StDbBroker::Release used
//
// Revision 1.28  2007/07/02 19:36:40  fisyak
// Add parameter currenTime (== requested time) in FindLeft
//
// Revision 1.27  2007/03/09 20:01:03  perev
// Request by user defined time now allowed
//
// Revision 1.26  2006/08/15 21:42:21  jeromel
// Fix rhic -> rhic.bnl.gov
//
// Revision 1.25  2005/07/20 17:41:44  perev
// Cleanup
//
// Revision 1.24  2004/08/18 20:33:56  perev
// Timers added for MySQL and maker itself
//
// Revision 1.23  2004/07/23 17:06:58  perev
// AliasDate & AliasTime moved fro db maker to StMaker
//
// Revision 1.22  2004/04/08 00:28:53  perev
// AliasDate & AliasTime now static methods
//
// Revision 1.21  2002/12/20 03:28:37  perev
// Save method improved
//
// Revision 1.20  2002/11/26 02:24:45  perev
// new ROOT adoptation
//
// Revision 1.19  2001/10/27 21:48:32  perev
// SetRunNumber added
//
// Revision 1.18  2001/10/13 20:23:25  perev
// SetFlavor  working before and after Init()
//
// Revision 1.17  2001/09/26 23:24:05  perev
// SetFlavor for table added
//
// Revision 1.16  2001/04/13 21:21:34  perev
// small fix (fine) + cons's
//
// Revision 1.15  2000/07/14 02:39:21  perev
// SetMaxEntryTime method added
//
// Revision 1.14  2000/06/26 20:58:41  perev
// multiple DBs
//
// Revision 1.13  2000/05/20 01:00:43  perev
// SetFlavor() added
//
// Revision 1.12  2000/04/13 02:58:47  perev
// Method Save is added & default CintDB loaded if exists
//
// Revision 1.11  2000/03/23 14:55:56  fine
// Adjusted to libSTAR and ROOT 2.24
//
// Revision 1.10  2000/02/26 01:45:04  fine
// CVS id has been introduced
//
//
#ifndef STAR_St_db_Maker
#define STAR_St_db_Maker

//                                                                      //
// St_db_Maker virtual base class for Maker                          //
//                                                                      //
// This class is C++ implementation of the Begin_html <a href="http://www.rhic.bnl.gov/afs/rhic.bnl.gov/star/doc/www/packages_l/pro/pams/db/sdb/doc/index.html">Simple Database Manager</a> End_html    //
//                                                                      //
#ifndef StMaker_H
#include "StMaker.h"
#endif
#include "TTable.h"

#include "TDatime.h"
#include "StDbBroker/dbConfig.h"

#include <map>
#include <utility>
#include <list>

class TFileSet;
class TList;
class TBrowser;
class StDbBroker;
class St_dbConfig;
class StValiSet;

class St_db_Maker : public StMaker {
private:

  TDataSet    *fDataBase;       
  StDbBroker  *fDBBroker;       
  St_dbConfig *fHierarchy;      
  TString     fDirs[10];        
  Int_t       fIsDBTime;        
  TDatime     fDBTime;          
  Int_t       fUpdateMode;      
  UInt_t      fMaxEntryTime;    
  std::map<std::pair<std::string,std::string>,UInt_t> fMaxEntryTimeOverride; // DBV override for specific subsystems
  TStopwatch  fTimer[6];        
  int         fEvents[2];       // [0]=nEvents [1]=events with mysql request
  int         fDataSize[2];     // [0]=mysql data this event; [1]=total
  time_t      fQueryTs;         // timestamps of recent db fetch

//  static Char_t fVersionCVS = "$Id: St_db_Maker.h,v 1.46 2015/05/05 21:05:52 dmitry Exp $";
 protected:
 public:
                   St_db_Maker(const char *name
                              ,const char *dir0
                              ,const char *dir1 = ""
                              ,const char *dir2 = ""
                              ,const char *dir3 = ""
                              ,const char *dir4 = ""
                              ,const char *dir5 = ""
                              ,const char *dir6 = ""
                              ,const char *dir7 = ""
                              ,const char *dir8 = ""
                              ,const char *dir9 = ""
                   );
   virtual        ~St_db_Maker();
   virtual TDataSet *GetDataBase(const char* logInput, const TDatime *td=0);
   virtual const TDatime &GetDateTime() const;
   static  Int_t   GetValidity(const TTable *tb, TDatime *const val);
   virtual void    SetDateTime(int idat,int itim);
   virtual void    SetDateTime(const char *datalias);
   virtual Int_t   InitRun(int runumber);
   virtual Int_t   Init();
   virtual Int_t   Make();
   virtual Int_t   Save(const char *path,const TDatime *newtime=0);
   virtual Int_t   SaveSnapshotPlus(char* path, int type = 0);      // snapshot mode, type: 0 = .root, 1 = .C 
   virtual void    SetOff(const Char_t *path);
   virtual void    SetOn (const Char_t *path);
   virtual void    SetFlavor(const char *flav,const char *tabname=".all");
   virtual void    OnOff();
   virtual void    Clear(Option_t *opt="");
   virtual Int_t   Finish();
           void    SetMaxEntryTime(Int_t idate,Int_t itime);
           void    AddMaxEntryTimeOverride(Int_t idate,Int_t itime, char* dbType = 0, char* dbDomain = 0);
private:
   virtual TDataSet* UpdateDB (TDataSet* ds);
   virtual int UpdateTable(UInt_t parId, TTable* dat, const TDatime &req, TDatime val[2]);
   virtual TDataSet *LoadTable(TDataSet* left);
   virtual TDataSet *FindLeft(StValiSet *val, TDatime vals[2], const TDatime &currenTime);
   virtual TDataSet *OpenMySQL(const char* dbname);
   virtual Int_t   SaveDataSet(TDataSet* ds, int type, bool savenext); // prepares directory and calls appropriate save method
   virtual Int_t   SaveDataSetAsCMacro(TTable* tb, TString ds_name, bool savenext);   // creates [dataset_name].[beginTime].[endTime].C file 
   virtual Int_t   SaveDataSetAsRootFile(TTable* tb, TString ds_name, bool savenext); // creates [dataset_name].[beginTime].[endTime].root file 
   static  Int_t     Drop(TDataSet *ds);
           int       Snapshot (int flag);

   static EDataSetPass UpdateDB (TDataSet* ds,void *user );
   static EDataSetPass PrepareDB(TDataSet* ds,void *user );
          int UpdateValiSet(StValiSet *val,const TDatime &currenTime);
public:
   static TDatime  Time(const char *filename);
   static int      Kind(const char *filename);

   virtual const char *GetCVS() const
  {static const char cvs[]="Tag $Name:  $ $Id: St_db_Maker.h,v 1.46 2015/05/05 21:05:52 dmitry Exp $ built " __DATE__ " " __TIME__ ; return cvs;}

   ClassDef(St_db_Maker, 0)
};

class St_dbConfig : public TTable
{
  ClassDefTable(St_dbConfig,dbConfig_st)
  ClassDef(St_dbConfig,2)
};

#endif