00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033
00034
00035
00036
00037
00038
00039
00040
00041
00042
00043
00044
00045
00046
00047
00048
00049
00050
00051
00052
00053
00054
00055
00056
00057
00058
00059
00060
00061
00062
00063
00064
00065
00066
00067
00068
00069
00070
00071
00072
00073
00074
00075
00076
00077
00078
00079
00080
00081
00082
00083
00084
00085
00086
00087
00088
00089
00090
00091
00092
00093
00094
00095
00096
00097
00098
00099
00100 #ifndef STAR_St_db_Maker
00101 #define STAR_St_db_Maker
00102
00104
00105
00106
00107
00108
00110 #ifndef StMaker_H
00111 #include "StMaker.h"
00112 #endif
00113 #include "TTable.h"
00114
00115 #include "TDatime.h"
00116 #include "StDbBroker/dbConfig.h"
00117
00118 #include <map>
00119 #include <utility>
00120
00121 class TFileSet;
00122 class TList;
00123 class TBrowser;
00124 class StDbBroker;
00125 class St_dbConfig;
00126 class StValiSet;
00127
00128 class St_db_Maker : public StMaker {
00129 private:
00130
00131 TDataSet *fDataBase;
00132 StDbBroker *fDBBroker;
00133 St_dbConfig *fHierarchy;
00134 TString fDirs[10];
00135 Int_t fIsDBTime;
00136 TDatime fDBTime;
00137 Int_t fUpdateMode;
00138 UInt_t fMaxEntryTime;
00139 std::map<std::pair<std::string,std::string>,UInt_t> fMaxEntryTimeOverride;
00140 TStopwatch fTimer[6];
00141 int fEvents[2];
00142 int fDataSize[2];
00143
00144
00145 protected:
00146 public:
00147 St_db_Maker(const char *name
00148 ,const char *dir0
00149 ,const char *dir1 = ""
00150 ,const char *dir2 = ""
00151 ,const char *dir3 = ""
00152 );
00153 virtual ~St_db_Maker();
00154 virtual TDataSet *GetDataBase(const char* logInput, const TDatime *td=0);
00155 virtual const TDatime &GetDateTime() const;
00156 static Int_t GetValidity(const TTable *tb, TDatime *const val);
00157 virtual void SetDateTime(int idat,int itim);
00158 virtual void SetDateTime(const char *datalias);
00159 virtual Int_t InitRun(int runumber);
00160 virtual Int_t Init();
00161 virtual Int_t Make();
00162 virtual Int_t Save(const char *path,const TDatime *newtime=0);
00163 virtual Int_t SaveSnapshotPlus(char* path, int type = 0);
00164 virtual void SetOff(const Char_t *path);
00165 virtual void SetOn (const Char_t *path);
00166 virtual void SetFlavor(const char *flav,const char *tabname=".all");
00167 virtual void OnOff();
00168 virtual void Clear(Option_t *opt="");
00169 virtual Int_t Finish();
00170 void SetMaxEntryTime(Int_t idate,Int_t itime);
00171 void AddMaxEntryTimeOverride(Int_t idate,Int_t itime, char* dbType = 0, char* dbDomain = 0);
00172 private:
00173 virtual TDataSet* UpdateDB (TDataSet* ds);
00174 virtual int UpdateTable(UInt_t parId, TTable* dat, const TDatime &req, TDatime val[2]);
00175 virtual TDataSet *LoadTable(TDataSet* left);
00176 virtual TDataSet *FindLeft(StValiSet *val, TDatime vals[2], const TDatime ¤Time);
00177 virtual TDataSet *OpenMySQL(const char* dbname);
00178 virtual Int_t SaveDataSet(TDataSet* ds, int type, bool savenext);
00179 virtual Int_t SaveDataSetAsCMacro(TTable* tb, TString ds_name, bool savenext);
00180 virtual Int_t SaveDataSetAsRootFile(TTable* tb, TString ds_name, bool savenext);
00181 static Int_t Drop(TDataSet *ds);
00182 int Snapshot (int flag);
00183
00184 static EDataSetPass UpdateDB (TDataSet* ds,void *user );
00185 static EDataSetPass PrepareDB(TDataSet* ds,void *user );
00186 int UpdateValiSet(StValiSet *val,const TDatime ¤Time);
00187 public:
00188 static TDatime Time(const char *filename);
00189 static int Kind(const char *filename);
00190
00191 virtual const char *GetCVS() const
00192 {static const char cvs[]="Tag $Name: $ $Id: St_db_Maker.h,v 1.42 2012/03/16 19:36:18 dmitry Exp $ built "__DATE__" "__TIME__ ; return cvs;}
00193
00194 ClassDef(St_db_Maker, 0)
00195 };
00196
00197 class St_dbConfig : public TTable
00198 {
00199 ClassDefTable(St_dbConfig,dbConfig_st)
00200 ClassDef(St_dbConfig,2)
00201 };
00202
00203 #endif