yodaUtility/YodaProfiler/PamelaDBOperations.h

#ifndef PAMELA_DB_OPERATIONS_H
#define PAMELA_DB_OPERATIONS_H

#include <RegistryEvent.h>
#include <TSQLServer.h>
#include <YException.h>
#include <iostream>
#include <list>
#include <cOrbit.h>

using namespace yngn::YException;
using namespace pamela;


        /**
         * Collections of Pamela specific operations over a database
         */
        class PamelaDBOperations {
        private:

        
            typedef std::list<const char*> pcksList;

            static void getPacketsNames(pcksList &pcksNames){
                pcksNames.push_back("PhysEndRun");
                pcksNames.push_back("CalibCalPulse1");
                pcksNames.push_back("CalibCalPulse2");
                pcksNames.push_back("Physics");
                pcksNames.push_back("CalibTrkBoth");
                pcksNames.push_back("CalibTrk1");
                pcksNames.push_back("CalibTrk2");
                pcksNames.push_back("CalibTof");
                pcksNames.push_back("CalibS4");
                pcksNames.push_back("CalibCalPed");
                pcksNames.push_back("Calib1_Ac1");
                pcksNames.push_back("Calib2_Ac1");
                pcksNames.push_back("Calib1_Ac2");
                pcksNames.push_back("Calib2_Ac2");
                pcksNames.push_back("CalibCal");
                pcksNames.push_back("RunHeader");
                pcksNames.push_back("RunTrailer");
                pcksNames.push_back("CalibHeader");
                pcksNames.push_back("CalibTrailer");
                pcksNames.push_back("InitHeader");
                pcksNames.push_back("InitTrailer");
                pcksNames.push_back("EventTrk");
                pcksNames.push_back("Log");
                pcksNames.push_back("VarDump");
                pcksNames.push_back("ArrDump");
                pcksNames.push_back("TabDump");
                pcksNames.push_back("Tmtc");
                pcksNames.push_back("Mcmd");
                pcksNames.push_back("ForcedFECmd");
                pcksNames.push_back("Ac1Init");
                pcksNames.push_back("CalInit");
                pcksNames.push_back("TrkInit");
                pcksNames.push_back("TofInit");
                pcksNames.push_back("TrgInit");
                pcksNames.push_back("NdInit");
                pcksNames.push_back("S4Init");
                pcksNames.push_back("Ac2Init");
                pcksNames.push_back("CalAlarm");
                pcksNames.push_back("Ac1Alarm");
                pcksNames.push_back("TrkAlarm");
                pcksNames.push_back("TrgAlarm");
                pcksNames.push_back("TofAlarm");
                pcksNames.push_back("S4Alarm");
                pcksNames.push_back("Ac2Alarm");                
                pcksNames.push_back("TsbT");
                pcksNames.push_back("TsbB");
            }

            static const char* getID_RAW(TSQLServer *conn, const char *rawPathName, const char *rawFileName) 
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static const char* setGeo(cOrbit *orbit, RegistryEvent* &reg) 
                      throw (YSQLNotConnectedException, YSQLQueryException);
                      
            static int rootFilesWalker(TSQLServer *conn, const char *dirPath, const char *idRaw) 
                      throw (YSQLNotConnectedException, YSQLQueryException);
                      
            static int insertPamelaRootFiles(TSQLServer *conn, const char *pathName, const char *fileName, const char *idPath)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static int insertPamelaTM_HEADER(TSQLServer *conn, const char *idRaw)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static int insertPamelaGL_TIMESYNC(TSQLServer *conn, const char *idRaw)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static int insertPamelaTM_TIMESYNC(TSQLServer *conn, const char *idRaw)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static int deletePamelaDuplicate(TSQLServer *conn, const char *idRaw)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static int assignPamelaTIMESYNC(TSQLServer *conn, const char *idRaw)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static int insertPamelaPacket(TSQLServer *conn, const char *pathName, const char *eventFileName, const char *headerFileName)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static int createPamelaRegistry(TSQLServer *conn, const char *idRaw, bool overwrite)
                      throw (YSQLNotConnectedException, YSQLQueryException, YNotExistingFileException, YExistingFileException);

            static int insertPamelaRUN(TSQLServer *conn, const char *idRaw)
                      throw (YSQLNotConnectedException, YSQLQueryException, YNotExistingFileException, YEmptyObjectException);

            static int populateTM_CALO_CALIB(TSQLServer *conn, const char *idRaw)
                      throw (YSQLNotConnectedException, YSQLQueryException, YEmptyObjectException);

            static int populateTM_S4_CALIB(TSQLServer *conn, const char *idRaw)
                      throw (YSQLNotConnectedException, YSQLQueryException, YEmptyObjectException);

            static int populateTM_TRK_CALIB(TSQLServer *conn, const char *idRaw)
                      throw (YSQLNotConnectedException, YSQLQueryException, YEmptyObjectException);

            static int insertNEW_CALO_CALIB(TSQLServer *conn, ULong64_t time, int section, unsigned long reg_ev, unsigned long id_reg, unsigned long tm_id)
                      throw (YSQLNotConnectedException, YSQLQueryException, YEmptyObjectException, YProcessErrorException);

            static int insertNEW_S4_CALIB(TSQLServer *conn, float paramfit0, float paramfit1, ULong64_t time, unsigned long reg_ev, unsigned long id_reg, unsigned long tm_id)
                      throw (YSQLNotConnectedException, YSQLQueryException, YEmptyObjectException, YProcessErrorException);

            static int insertNEW_TRK_CALIB(TSQLServer *conn, unsigned long id_reg, unsigned long reg_ev1, unsigned long reg_ev2, ULong64_t time, const char* tm_id1, const char* tm_id2)
                      throw (YSQLNotConnectedException, YSQLQueryException, YEmptyObjectException, YProcessErrorException);

        public: 
            static const char *PamelaDBOperations::TM_CALO_CALIB;
            static const char *PamelaDBOperations::TM_S4_CALIB;
            static const char *PamelaDBOperations::TM_TRK_CALIB;
            static const char *PamelaDBOperations::TM_REGISTRY;
            static const char *PamelaDBOperations::TM_HEADER;
            static const char *PamelaDBOperations::TM_TIMESYNC;

            static int insertPamelaRootFiles(TSQLServer *conn, const char *pathName, const char *fileName, const char *rawPathName, const char *rawFileName)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static bool insertPamelaRawFile(TSQLServer *conn, const char *pathName, const char *fileName)
                      throw (YSQLNotConnectedException, YSQLQueryException, YSQLDuplicateRowException);

            static int insertPamelaUnpacking(TSQLServer *conn, const char *pathName, const char *rawPathName, const char *rawFileName)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static int insertPamelaGL_TIMESYNC(TSQLServer *conn, const char *rawPathName, const char *rawFileName)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static int createPamelaRegistry(TSQLServer *conn, const char *rawPathName, const char *rawFileName, bool overwrite)
                      throw (YSQLNotConnectedException, YSQLQueryException, YNotExistingFileException, YExistingFileException);

            static int insertPamelaRUN(TSQLServer *conn, const char *rawPathName, const char *rawFileName)
                      throw (YSQLNotConnectedException, YSQLQueryException, YNotExistingFileException, YEmptyObjectException);

            static int assignBOOT_NUMBER(TSQLServer *conn, const char *idRaw)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static int assignBOOT_NUMBER(TSQLServer *conn, const char *rawPathName, const char *rawFileName)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static int insertNEW_CALO_CALIB(TSQLServer *conn, const char *rawPathName, const char *rawFileName)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static int insertNEW_CALO_CALIB(TSQLServer *conn, const char *idRaw)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static int insertNEW_S4_CALIB(TSQLServer *conn, const char *rawPathName, const char *rawFileName)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static int insertNEW_S4_CALIB(TSQLServer *conn, const char *idRaw)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static int insertNEW_TRK_CALIB(TSQLServer *conn, const char *rawPathName, const char *rawFileName)
                      throw (YSQLNotConnectedException, YSQLQueryException);

            static int insertNEW_TRK_CALIB(TSQLServer *conn, const char *idRaw)
                      throw (YSQLNotConnectedException, YSQLQueryException);
        };
#endif /* PAMELA_DB_OPERATIONS_H */
1	#ifndef PAMELA_DB_OPERATIONS_H
2	#define PAMELA_DB_OPERATIONS_H
3
4	#include <RegistryEvent.h>
5	#include <TSQLServer.h>
6	#include <YException.h>
7	#include <iostream>
8	#include <list>
9	#include <cOrbit.h>
10
11	using namespace yngn::YException;
12	using namespace pamela;
13
14
15	/**
16	* Collections of Pamela specific operations over a database
17	*/
18	class PamelaDBOperations {
19	private:
20
21
22	typedef std::list<const char*> pcksList;
23
24	static void getPacketsNames(pcksList &pcksNames){
25	pcksNames.push_back("PhysEndRun");
26	pcksNames.push_back("CalibCalPulse1");
27	pcksNames.push_back("CalibCalPulse2");
28	pcksNames.push_back("Physics");
29	pcksNames.push_back("CalibTrkBoth");
30	pcksNames.push_back("CalibTrk1");
31	pcksNames.push_back("CalibTrk2");
32	pcksNames.push_back("CalibTof");
33	pcksNames.push_back("CalibS4");
34	pcksNames.push_back("CalibCalPed");
35	pcksNames.push_back("Calib1_Ac1");
36	pcksNames.push_back("Calib2_Ac1");
37	pcksNames.push_back("Calib1_Ac2");
38	pcksNames.push_back("Calib2_Ac2");
39	pcksNames.push_back("CalibCal");
40	pcksNames.push_back("RunHeader");
41	pcksNames.push_back("RunTrailer");
42	pcksNames.push_back("CalibHeader");
43	pcksNames.push_back("CalibTrailer");
44	pcksNames.push_back("InitHeader");
45	pcksNames.push_back("InitTrailer");
46	pcksNames.push_back("EventTrk");
47	pcksNames.push_back("Log");
48	pcksNames.push_back("VarDump");
49	pcksNames.push_back("ArrDump");
50	pcksNames.push_back("TabDump");
51	pcksNames.push_back("Tmtc");
52	pcksNames.push_back("Mcmd");
53	pcksNames.push_back("ForcedFECmd");
54	pcksNames.push_back("Ac1Init");
55	pcksNames.push_back("CalInit");
56	pcksNames.push_back("TrkInit");
57	pcksNames.push_back("TofInit");
58	pcksNames.push_back("TrgInit");
59	pcksNames.push_back("NdInit");
60	pcksNames.push_back("S4Init");
61	pcksNames.push_back("Ac2Init");
62	pcksNames.push_back("CalAlarm");
63	pcksNames.push_back("Ac1Alarm");
64	pcksNames.push_back("TrkAlarm");
65	pcksNames.push_back("TrgAlarm");
66	pcksNames.push_back("TofAlarm");
67	pcksNames.push_back("S4Alarm");
68	pcksNames.push_back("Ac2Alarm");
69	pcksNames.push_back("TsbT");
70	pcksNames.push_back("TsbB");
71	}
72
73	static const char* getID_RAW(TSQLServer conn, const char rawPathName, const char *rawFileName)
74	throw (YSQLNotConnectedException, YSQLQueryException);
75
76	static const char* setGeo(cOrbit orbit, RegistryEvent &reg)
77	throw (YSQLNotConnectedException, YSQLQueryException);
78
79	static int rootFilesWalker(TSQLServer conn, const char dirPath, const char *idRaw)
80	throw (YSQLNotConnectedException, YSQLQueryException);
81
82	static int insertPamelaRootFiles(TSQLServer conn, const char pathName, const char fileName, const char idPath)
83	throw (YSQLNotConnectedException, YSQLQueryException);
84
85	static int insertPamelaTM_HEADER(TSQLServer conn, const char idRaw)
86	throw (YSQLNotConnectedException, YSQLQueryException);
87
88	static int insertPamelaGL_TIMESYNC(TSQLServer conn, const char idRaw)
89	throw (YSQLNotConnectedException, YSQLQueryException);
90
91	static int insertPamelaTM_TIMESYNC(TSQLServer conn, const char idRaw)
92	throw (YSQLNotConnectedException, YSQLQueryException);
93
94	static int deletePamelaDuplicate(TSQLServer conn, const char idRaw)
95	throw (YSQLNotConnectedException, YSQLQueryException);
96
97	static int assignPamelaTIMESYNC(TSQLServer conn, const char idRaw)
98	throw (YSQLNotConnectedException, YSQLQueryException);
99
100	static int insertPamelaPacket(TSQLServer conn, const char pathName, const char eventFileName, const char headerFileName)
101	throw (YSQLNotConnectedException, YSQLQueryException);
102
103	static int createPamelaRegistry(TSQLServer conn, const char idRaw, bool overwrite)
104	throw (YSQLNotConnectedException, YSQLQueryException, YNotExistingFileException, YExistingFileException);
105
106	static int insertPamelaRUN(TSQLServer conn, const char idRaw)
107	throw (YSQLNotConnectedException, YSQLQueryException, YNotExistingFileException, YEmptyObjectException);
108
109	static int populateTM_CALO_CALIB(TSQLServer conn, const char idRaw)
110	throw (YSQLNotConnectedException, YSQLQueryException, YEmptyObjectException);
111
112	static int populateTM_S4_CALIB(TSQLServer conn, const char idRaw)
113	throw (YSQLNotConnectedException, YSQLQueryException, YEmptyObjectException);
114
115	static int populateTM_TRK_CALIB(TSQLServer conn, const char idRaw)
116	throw (YSQLNotConnectedException, YSQLQueryException, YEmptyObjectException);
117
118	static int insertNEW_CALO_CALIB(TSQLServer *conn, ULong64_t time, int section, unsigned long reg_ev, unsigned long id_reg, unsigned long tm_id)
119	throw (YSQLNotConnectedException, YSQLQueryException, YEmptyObjectException, YProcessErrorException);
120
121	static int insertNEW_S4_CALIB(TSQLServer *conn, float paramfit0, float paramfit1, ULong64_t time, unsigned long reg_ev, unsigned long id_reg, unsigned long tm_id)
122	throw (YSQLNotConnectedException, YSQLQueryException, YEmptyObjectException, YProcessErrorException);
123
124	static int insertNEW_TRK_CALIB(TSQLServer conn, unsigned long id_reg, unsigned long reg_ev1, unsigned long reg_ev2, ULong64_t time, const char tm_id1, const char* tm_id2)
125	throw (YSQLNotConnectedException, YSQLQueryException, YEmptyObjectException, YProcessErrorException);
126
127	public:
128	static const char *PamelaDBOperations::TM_CALO_CALIB;
129	static const char *PamelaDBOperations::TM_S4_CALIB;
130	static const char *PamelaDBOperations::TM_TRK_CALIB;
131	static const char *PamelaDBOperations::TM_REGISTRY;
132	static const char *PamelaDBOperations::TM_HEADER;
133	static const char *PamelaDBOperations::TM_TIMESYNC;
134
135	static int insertPamelaRootFiles(TSQLServer conn, const char pathName, const char fileName, const char rawPathName, const char *rawFileName)
136	throw (YSQLNotConnectedException, YSQLQueryException);
137
138	static bool insertPamelaRawFile(TSQLServer conn, const char pathName, const char *fileName)
139	throw (YSQLNotConnectedException, YSQLQueryException, YSQLDuplicateRowException);
140
141	static int insertPamelaUnpacking(TSQLServer conn, const char pathName, const char rawPathName, const char rawFileName)
142	throw (YSQLNotConnectedException, YSQLQueryException);
143
144	static int insertPamelaGL_TIMESYNC(TSQLServer conn, const char rawPathName, const char *rawFileName)
145	throw (YSQLNotConnectedException, YSQLQueryException);
146
147	static int createPamelaRegistry(TSQLServer conn, const char rawPathName, const char *rawFileName, bool overwrite)
148	throw (YSQLNotConnectedException, YSQLQueryException, YNotExistingFileException, YExistingFileException);
149
150	static int insertPamelaRUN(TSQLServer conn, const char rawPathName, const char *rawFileName)
151	throw (YSQLNotConnectedException, YSQLQueryException, YNotExistingFileException, YEmptyObjectException);
152
153	static int assignBOOT_NUMBER(TSQLServer conn, const char idRaw)
154	throw (YSQLNotConnectedException, YSQLQueryException);
155
156	static int assignBOOT_NUMBER(TSQLServer conn, const char rawPathName, const char *rawFileName)
157	throw (YSQLNotConnectedException, YSQLQueryException);
158
159	static int insertNEW_CALO_CALIB(TSQLServer conn, const char rawPathName, const char *rawFileName)
160	throw (YSQLNotConnectedException, YSQLQueryException);
161
162	static int insertNEW_CALO_CALIB(TSQLServer conn, const char idRaw)
163	throw (YSQLNotConnectedException, YSQLQueryException);
164
165	static int insertNEW_S4_CALIB(TSQLServer conn, const char rawPathName, const char *rawFileName)
166	throw (YSQLNotConnectedException, YSQLQueryException);
167
168	static int insertNEW_S4_CALIB(TSQLServer conn, const char idRaw)
169	throw (YSQLNotConnectedException, YSQLQueryException);
170
171	static int insertNEW_TRK_CALIB(TSQLServer conn, const char rawPathName, const char *rawFileName)
172	throw (YSQLNotConnectedException, YSQLQueryException);
173
174	static int insertNEW_TRK_CALIB(TSQLServer conn, const char idRaw)
175	throw (YSQLNotConnectedException, YSQLQueryException);
176	};
177	#endif /* PAMELA_DB_OPERATIONS_H */