1 |
#ifndef _MANAGER_H_
|
2 |
#define _MANAGER_H_
|
3 |
///Class that creates a manager
|
4 |
///parent class of all managers
|
5 |
/// creates DBManager
|
6 |
|
7 |
|
8 |
#define USERDSN "mydsnvijay"
|
9 |
//#define USERDSN "thinservertest"
|
10 |
#define USERNAME "ggraham"
|
11 |
//#define USERNAME "anzar"
|
12 |
|
13 |
#include "DBManagement.hpp"
|
14 |
#include "TableInterface.hpp"
|
15 |
#include "ObjectLayerTables.hpp"
|
16 |
#include "Message.hpp"
|
17 |
#include "TableInterface.hpp"
|
18 |
#include "Util.hpp"
|
19 |
#include <string>
|
20 |
#include "RowInterface.hpp"
|
21 |
#include <log4cxx/logger.h>
|
22 |
|
23 |
|
24 |
typedef vector<RowInterface*> Rows;
|
25 |
typedef Rows::iterator RowIter;
|
26 |
|
27 |
class Manager {
|
28 |
|
29 |
public:
|
30 |
|
31 |
Manager();
|
32 |
Manager(std::string, std::string);
|
33 |
|
34 |
int doInsert(TableInterface* inTable, Message& msgReturned);
|
35 |
//int doSelect(TableInterface* inTable, std::string whereClause, Message& msgReturned);
|
36 |
int makeMessage(TableInterface* inTable, RowIter b, RowIter e, Message& msgReturned);
|
37 |
int setRowValues(TableInterface* inTable, RowInterface* rowPtr, Message* message, std::string listName, int index);
|
38 |
string findKeyMakeQuery(Message* msgReceived);
|
39 |
|
40 |
std::string getElementValue(std::string name, Message*);
|
41 |
virtual ~Manager();
|
42 |
//virtual ~Manager(){};
|
43 |
void cleanup();
|
44 |
//virtual int read(Message*, Message&){};
|
45 |
//virtual void write(Message*, Message&);
|
46 |
|
47 |
protected:
|
48 |
DBManagement* dbManager;
|
49 |
Util util;
|
50 |
Dictionary* schema;
|
51 |
log4cxx::LoggerPtr logger;
|
52 |
};
|
53 |
|
54 |
|
55 |
|
56 |
class DatasetProvcManagerParent: public Manager {
|
57 |
public:
|
58 |
DatasetProvcManagerParent();
|
59 |
int read(Message*, Message&);
|
60 |
~DatasetProvcManagerParent();
|
61 |
|
62 |
private:
|
63 |
DatasetprovenenceevparentMultiTable* dspTable;
|
64 |
};
|
65 |
|
66 |
|
67 |
|
68 |
class DatasetProvcManagerChild: public Manager {
|
69 |
public:
|
70 |
DatasetProvcManagerChild();
|
71 |
int read(Message*, Message&);
|
72 |
~DatasetProvcManagerChild();
|
73 |
|
74 |
private:
|
75 |
DatasetprovenenceevchildMultiTable* dspTable;
|
76 |
};
|
77 |
|
78 |
|
79 |
class ECReadManager : public Manager {
|
80 |
public:
|
81 |
ECReadManager();
|
82 |
int read(Message*, Message&);
|
83 |
~ECReadManager();
|
84 |
|
85 |
private:
|
86 |
EvcollviewMultiTable* ecTable;
|
87 |
};
|
88 |
|
89 |
|
90 |
class CRABECReadManager : public Manager {
|
91 |
public:
|
92 |
CRABECReadManager();
|
93 |
int read(Message*, Message&);
|
94 |
~CRABECReadManager();
|
95 |
|
96 |
private:
|
97 |
CrabevcollviewMultiTable* ecTable;
|
98 |
};
|
99 |
|
100 |
|
101 |
class PrimaryDatasetManager : public Manager {
|
102 |
public:
|
103 |
PrimaryDatasetManager();
|
104 |
int write(Message*, Message&);
|
105 |
int read(Message*, Message&);
|
106 |
~PrimaryDatasetManager();
|
107 |
|
108 |
private:
|
109 |
PrimarydatasetMultiTable* priDatasetTable;
|
110 |
};
|
111 |
|
112 |
|
113 |
|
114 |
class ProcessedDatasetManager : public Manager {
|
115 |
public:
|
116 |
ProcessedDatasetManager();
|
117 |
int write(Message*, Message&);
|
118 |
int read(Message* , Message& );
|
119 |
~ProcessedDatasetManager();
|
120 |
|
121 |
private:
|
122 |
ProcessingpathMultiTable* processedDatasetTable;
|
123 |
};
|
124 |
|
125 |
/*
|
126 |
class GenParamManager : public Manager {
|
127 |
public:
|
128 |
GenParamManager();
|
129 |
int write(Message*, Message&);
|
130 |
~GenParamManager();
|
131 |
|
132 |
private:
|
133 |
GenparametersetsMultiTable* genparametersetsTable;
|
134 |
};
|
135 |
*/
|
136 |
|
137 |
class AppConfigManager : public Manager {
|
138 |
public:
|
139 |
AppConfigManager();
|
140 |
int write(Message*, Message&);
|
141 |
~AppConfigManager();
|
142 |
|
143 |
private:
|
144 |
InsertappsMultiTable* appsConfigTable;
|
145 |
};
|
146 |
|
147 |
|
148 |
class FileManager : public Manager {
|
149 |
public:
|
150 |
FileManager();
|
151 |
int write(Message*, Message&);
|
152 |
int read(Message*, Message&);
|
153 |
~FileManager();
|
154 |
|
155 |
private:
|
156 |
FileviewMultiTable* fileTable;
|
157 |
};
|
158 |
|
159 |
|
160 |
class ECWriteManager : public Manager {
|
161 |
public:
|
162 |
ECWriteManager();
|
163 |
int write(Message*, Message&);
|
164 |
~ECWriteManager();
|
165 |
|
166 |
private:
|
167 |
EvcollviewMultiTable* ecTable;
|
168 |
};
|
169 |
|
170 |
/*
|
171 |
class AssignRoleManager : public Manager {
|
172 |
public:
|
173 |
AssignRoleManager();
|
174 |
int write(Message*, Message&);
|
175 |
~AssignRoleManager();
|
176 |
|
177 |
private:
|
178 |
AdministrativeMultiTable* assignRoleTable;
|
179 |
};
|
180 |
|
181 |
*/
|
182 |
class PersonManager : public Manager {
|
183 |
public:
|
184 |
PersonManager();
|
185 |
int write(Message*, Message&);
|
186 |
~PersonManager();
|
187 |
|
188 |
private:
|
189 |
PersonMultiTable* personTable;
|
190 |
};
|
191 |
/*
|
192 |
class RoleManager : public Manager {
|
193 |
public:
|
194 |
RoleManager();
|
195 |
int write(Message*, Message&);
|
196 |
~RoleManager();
|
197 |
|
198 |
private:
|
199 |
RoleMultiTable* roleTable;
|
200 |
};
|
201 |
*/
|
202 |
|
203 |
class AnalysisDatasetManager : public Manager {
|
204 |
public:
|
205 |
AnalysisDatasetManager();
|
206 |
int write(Message*, Message&);
|
207 |
~AnalysisDatasetManager();
|
208 |
|
209 |
private:
|
210 |
AnalysisdatasetMultiTable* analysisDatasetTable;
|
211 |
};
|
212 |
|
213 |
class PhysicsGroupManager : public Manager {
|
214 |
public:
|
215 |
PhysicsGroupManager();
|
216 |
int write(Message*, Message&);
|
217 |
~PhysicsGroupManager();
|
218 |
|
219 |
private:
|
220 |
PhysicsgroupMultiTable* physicsgroupTable;
|
221 |
};
|
222 |
|
223 |
class BlockManager : public Manager {
|
224 |
public:
|
225 |
BlockManager();
|
226 |
int write(Message*, Message&);
|
227 |
~BlockManager();
|
228 |
|
229 |
private:
|
230 |
BlockviewMultiTable* blockTable;
|
231 |
};
|
232 |
|
233 |
|
234 |
#endif
|