1 #ifndef RNPCLIENTCOMM_HH
2 #define RNPCLIENTCOMM_HH
55 bool effectivTypeIsRNP()
throw();
62 int openDB(
const char* database );
66 int createDB(
const char* name )
throw(r_Error);
68 int destroyDB(
const char* name )
throw(r_Error);
78 int openTA(
unsigned short readOnly = 0 )
throw(r_Error);
80 int commitTA()
throw(r_Error);
92 void insertMDD(
const char* collName, r_GMarray* mar )
throw( r_Error );
94 r_Ref_Any getMDDByOId(
const r_OId& oid )
throw( r_Error );
104 void insertColl(
const char* collName,
const char* typeName,
const r_OId& oid )
throw( r_Error );
106 void deleteCollByName(
const char* collName )
throw( r_Error );
108 void deleteObjByOId(
const r_OId& oid )
throw( r_Error );
110 void removeObjFromColl(
const char* name,
const r_OId& oid )
throw ( r_Error );
112 r_Ref_Any getCollByName(
const char* name )
throw( r_Error );
114 r_Ref_Any getCollByOId (
const r_OId& oid )
throw( r_Error );
116 r_Ref_Any getCollOIdsByName(
const char* name )
throw( r_Error );
118 r_Ref_Any getCollOIdsByOId (
const r_OId& oid )
throw( r_Error );
128 void executeQuery(
const r_OQL_Query& query, r_Set< r_Ref_Any >& result )
throw( r_Error );
136 void executeQuery(
const r_OQL_Query& query )
throw( r_Error );
150 r_OId getNewOId(
unsigned short objType )
throw(r_Error);
153 unsigned short getObjectType(
const r_OId& oid )
throw(r_Error);
157 char* getTypeStructure(
const char* typeName, r_Type_Type typeType )
throw(r_Error);
163 unsigned long getClientID()
const;
166 int setTransferFormat( r_Data_Format format,
const char* formatParams=NULL );
169 int setStorageFormat( r_Data_Format format,
const char *formatParams=NULL );
173 const char* getServerName();
176 void setUserIdentification(
const char *userName,
const char *plainTextPassword);
179 void setMaxRetry(
unsigned int newMaxRetry);
182 unsigned int getMaxRetry();
184 void setTurbo(
bool turbo);
190 void triggerAliveSignal();
191 void sendAliveSignal();
192 const char *getExtendedErrorInfo()
throw(r_Error);
194 void setTimeoutInterval(
int seconds);
195 int getTimeoutInterval();
199 r_OId createCollection(
const char *collName,
const char *collTypeName)
throw(r_Error);
201 r_OId createMDD(
const char* collName,
const char* mddTypeName,
const char* definitionDomain,
const char *tileDomain,
bool rcindex =
false)
throw(r_Error);
203 void extendMDD(r_OId mddOId,
const char *stripeDomain,
const char* tileDomain)
throw(r_Error);
205 vector<r_OId> getOIdsFromCollection(
const char* name )
throw( r_Error );
207 vector<r_OId> getOIdsFromCollection(
const r_OId& oid )
throw( r_Error );
209 vector<r_Minterval> getTileDomains(r_OId mddOId,
const char *stripeDomain)
throw( r_Error );
212 void preloadTiles(r_OId mddOId,
const char *tileDomain)
throw(r_Error);
214 int getTileData(r_OId mddOId,
const char *tileDomain,
char *&data,
bool preallocated =
false)
throw(r_Error);
216 void replaceTileData(r_OId mddOId,
const char *tileDomain,
const char *newData,
int dataLength,
const char *alfaData,
int alfaLength)
throw(r_Error);
230 char serverHost[100];
235 char databaseName[100];
238 char capability[100];
241 char identificationString[100];
244 int getFreeServer(
bool readwrite,
bool openDB);
247 int executeGetFreeServer(
bool readwrite,
bool openDB);
249 int readWholeMessage(
int socket,
char *destBuffer,
int buffSize);
251 int writeWholeMessage(
int socket,
char *destBuffer,
int buffSize);
254 int messageDigest(
const char *input,
char *output,
const char *mdName);
257 void getElementCollection( r_Set< r_Ref_Any >& result )
throw(r_Error);
260 void getMDDCollection( r_Set< r_Ref_Any >& result,
unsigned int isQuery )
throw(r_Error);
263 unsigned short getMDDCore( r_Ref<r_GMarray> &mdd,
GetMDDRes *thisResult,
unsigned int isQuery )
throw( r_Error );
266 int concatArrayData(
const char *source,
unsigned long srcSize,
char *&dest,
267 unsigned long &destSize,
unsigned long &destLevel );
270 void getMarRpcRepresentation(
const r_GMarray* mar,
RPCMarray*& rpcMarray,
271 r_Data_Format initStorageFormat = r_Array,
272 const r_Base_Type *bt = NULL);
275 void freeMarRpcRepresentation(
const r_GMarray* mar,
RPCMarray* rpcMarray );
282 r_Data_Format transferFormat;
284 r_Data_Format storageFormat;
286 char* transferFormatParams;
288 char *storageFormatParams;
290 r_Parse_Params *clientParams;
293 int serverCompresses;
298 void executeConnect();
299 void executeDisconnect();
300 void executeOpenDB(
const char*);
301 void executeCloseDB();
302 void executeBeginTA(
bool rw);
303 void executeCommitTA();
304 void executeAbortTA();
305 int executeExecuteQuery(
const char* query, r_Set< r_Ref_Any >& result )
throw( r_Error );
307 int executeEndTransfer();
310 void executeExecuteUpdateQuery(
const char *query)
throw(r_Error);
311 int executeStartInsertTransMDD(r_GMarray* mdd);
312 int executeInsertTile(
bool persistent,
RPCMarray* tile);
313 void executeEndInsertMDD(
bool persistent);
314 int executeInitUpdate();
315 int executeStartInsertPersMDD(
const char* collName, r_GMarray* mar );
316 int executeInsertMDD(
const char* collName, r_GMarray* mar,
RPCMarray *rpcMarray);
317 int executeInsertCollection(
const char* collName,
const char* typeName,
const r_OId& oid );
318 r_Ref_Any executeGetCollByNameOrOId (
const char* collName,
const r_OId& oid )
throw( r_Error );
319 r_Ref_Any executeGetCollOIdsByNameOrOId (
const char* collName,
const r_OId& oid )
throw( r_Error );
320 int executeSetFormat(
bool transferFormat, r_Data_Format format,
const char* formatParams);
321 r_OId executeGetNewOId(
unsigned short objType )
throw(r_Error);
322 unsigned short executeGetObjectType(
const r_OId& oid )
throw(r_Error);
323 char* executeGetTypeStructure(
const char* typeName, r_Type_Type typeType )
throw(r_Error);
325 vector<r_OId> executeGetOIdsFromCollection (
const char* collName,
const r_OId& oid )
throw( r_Error );
327 void turboOpenDB(
const char*);
328 void turboBeginTA(
bool rw);
329 void turboCommitTA();
335 void checkForRwTransaction()
throw (r_Error);
338 void sendRequestGetAnswer()
throw (r_Error);
340 int sendAndReturnStatus()
throw (r_Error);
344 void reassemble_r_Error()
throw (r_Error);
347 void helper012d(
const char* caller)
throw (r_Error);
Definition: rnpclientcomm.hh:47
const int RASMGRPORT
Definition: rminit.hh:59
Definition: rnpcommunication.hh:117