rasdaman complete source
|
#include <rnpclientcomm.hh>
Public Member Functions | |
RnpClientComm (const char *rasmgrHost, int rasmgrPort=RASMGRPORT) throw ( r_Error ) | |
constructor getting the host name of the rasmgr host and it's listening port (default 7001). More... | |
~RnpClientComm () throw () | |
bool | effectivTypeIsRNP () throw () |
unsigned long | getClientID () const |
provides read access to my clientID More... | |
int | setTransferFormat (r_Data_Format format, const char *formatParams=NULL) |
set the preferred transfer format More... | |
int | setStorageFormat (r_Data_Format format, const char *formatParams=NULL) |
set the preferred storage format More... | |
const char * | getServerName () |
get real server name (the dinamic one, assigned by the RasMGR) More... | |
void | setUserIdentification (const char *userName, const char *plainTextPassword) |
user identification for RasMGR More... | |
void | setMaxRetry (unsigned int newMaxRetry) |
set maximum retry to get a server More... | |
unsigned int | getMaxRetry () |
get maximum retry to get a server More... | |
void | setTurbo (bool turbo) |
void | triggerAliveSignal () |
void | sendAliveSignal () |
const char * | getExtendedErrorInfo () throw (r_Error) |
void | setTimeoutInterval (int seconds) |
int | getTimeoutInterval () |
r_OId | createCollection (const char *collName, const char *collTypeName) throw (r_Error) |
r_OId | createMDD (const char *collName, const char *mddTypeName, const char *definitionDomain, const char *tileDomain, bool rcindex=false) throw (r_Error) |
void | extendMDD (r_OId mddOId, const char *stripeDomain, const char *tileDomain) throw (r_Error) |
vector< r_OId > | getOIdsFromCollection (const char *name) throw ( r_Error ) |
vector< r_OId > | getOIdsFromCollection (const r_OId &oid) throw ( r_Error ) |
vector< r_Minterval > | getTileDomains (r_OId mddOId, const char *stripeDomain) throw ( r_Error ) |
void | preloadTiles (r_OId mddOId, const char *tileDomain) throw (r_Error) |
int | getTileData (r_OId mddOId, const char *tileDomain, char *&data, bool preallocated=false) throw (r_Error) |
void | replaceTileData (r_OId mddOId, const char *tileDomain, const char *newData, int dataLength, const char *alfaData, int alfaLength) throw (r_Error) |
int | openDB (const char *database) |
open database More... | |
int | closeDB () |
close current database More... | |
int | createDB (const char *name) throw (r_Error) |
create a database More... | |
int | destroyDB (const char *name) throw (r_Error) |
destroy a database More... | |
int | openTA (unsigned short readOnly=0) throw (r_Error) |
begin transaction More... | |
int | commitTA () throw (r_Error) |
commit current transaction More... | |
int | abortTA () |
abort current transaction More... | |
void | insertMDD (const char *collName, r_GMarray *mar) throw ( r_Error ) |
inserts a MDD object in an existing MDD collection on the server More... | |
r_Ref_Any | getMDDByOId (const r_OId &oid) throw ( r_Error ) |
gets MDD object by oid More... | |
void | insertColl (const char *collName, const char *typeName, const r_OId &oid) throw ( r_Error ) |
creates an empty MDD collection on the server More... | |
void | deleteCollByName (const char *collName) throw ( r_Error ) |
deletes an MDD collection by name More... | |
void | deleteObjByOId (const r_OId &oid) throw ( r_Error ) |
deletes an object by oid (right now, objects are collection only) More... | |
void | removeObjFromColl (const char *name, const r_OId &oid) throw ( r_Error ) |
removes an object from a collection More... | |
r_Ref_Any | getCollByName (const char *name) throw ( r_Error ) |
gets collection by name More... | |
r_Ref_Any | getCollByOId (const r_OId &oid) throw ( r_Error ) |
gets collection by oid More... | |
r_Ref_Any | getCollOIdsByName (const char *name) throw ( r_Error ) |
gets collection references by name More... | |
r_Ref_Any | getCollOIdsByOId (const r_OId &oid) throw ( r_Error ) |
gets collection references by oid More... | |
void | executeQuery (const r_OQL_Query &query, r_Set< r_Ref_Any > &result) throw ( r_Error ) |
query execution More... | |
void | executeQuery (const r_OQL_Query &query) throw ( r_Error ) |
update execution More... | |
r_OId | getNewOId (unsigned short objType) throw (r_Error) |
get new oid More... | |
unsigned short | getObjectType (const r_OId &oid) throw (r_Error) |
get oid type More... | |
char * | getTypeStructure (const char *typeName, r_Type_Type typeType) throw (r_Error) |
RnpClientComm::RnpClientComm | ( | const char * | rasmgrHost, |
int | rasmgrPort = RASMGRPORT |
||
) | |||
throw | ( | r_Error | |
) |
constructor getting the host name of the rasmgr host and it's listening port (default 7001).
RnpClientComm::~RnpClientComm | ( | ) | ||
throw | ( | |||
) |
int RnpClientComm::abortTA | ( | ) |
abort current transaction
int RnpClientComm::closeDB | ( | ) |
close current database
int RnpClientComm::commitTA | ( | ) | ||
throw | ( | r_Error | ||
) |
commit current transaction
r_OId RnpClientComm::createCollection | ( | const char * | collName, |
const char * | collTypeName | ||
) | |||
throw | ( | r_Error | |
) |
int RnpClientComm::createDB | ( | const char * | name | ) | |
throw | ( | r_Error | |||
) |
create a database
r_OId RnpClientComm::createMDD | ( | const char * | collName, |
const char * | mddTypeName, | ||
const char * | definitionDomain, | ||
const char * | tileDomain, | ||
bool | rcindex = false |
||
) | |||
throw | ( | r_Error | |
) |
void RnpClientComm::deleteCollByName | ( | const char * | collName | ) | |
throw | ( | r_Error | |||
) |
deletes an MDD collection by name
void RnpClientComm::deleteObjByOId | ( | const r_OId & | oid | ) | |
throw | ( | r_Error | |||
) |
deletes an object by oid (right now, objects are collection only)
int RnpClientComm::destroyDB | ( | const char * | name | ) | |
throw | ( | r_Error | |||
) |
destroy a database
bool RnpClientComm::effectivTypeIsRNP | ( | ) | ||
throw | ( | |||
) |
void RnpClientComm::executeQuery | ( | const r_OQL_Query & | query, |
r_Set< r_Ref_Any > & | result | ||
) | |||
throw | ( | r_Error | |
) |
query execution
void RnpClientComm::executeQuery | ( | const r_OQL_Query & | query | ) | |
throw | ( | r_Error | |||
) |
update execution
void RnpClientComm::extendMDD | ( | r_OId | mddOId, |
const char * | stripeDomain, | ||
const char * | tileDomain | ||
) | |||
throw | ( | r_Error | |
) |
unsigned long RnpClientComm::getClientID | ( | ) | const |
provides read access to my clientID
r_Ref_Any RnpClientComm::getCollByName | ( | const char * | name | ) | |
throw | ( | r_Error | |||
) |
gets collection by name
r_Ref_Any RnpClientComm::getCollByOId | ( | const r_OId & | oid | ) | |
throw | ( | r_Error | |||
) |
gets collection by oid
r_Ref_Any RnpClientComm::getCollOIdsByName | ( | const char * | name | ) | |
throw | ( | r_Error | |||
) |
gets collection references by name
r_Ref_Any RnpClientComm::getCollOIdsByOId | ( | const r_OId & | oid | ) | |
throw | ( | r_Error | |||
) |
gets collection references by oid
const char* RnpClientComm::getExtendedErrorInfo | ( | ) | ||
throw | ( | r_Error | ||
) |
unsigned int RnpClientComm::getMaxRetry | ( | ) |
get maximum retry to get a server
r_Ref_Any RnpClientComm::getMDDByOId | ( | const r_OId & | oid | ) | |
throw | ( | r_Error | |||
) |
gets MDD object by oid
r_OId RnpClientComm::getNewOId | ( | unsigned short | objType | ) | |
throw | ( | r_Error | |||
) |
get new oid
unsigned short RnpClientComm::getObjectType | ( | const r_OId & | oid | ) | |
throw | ( | r_Error | |||
) |
get oid type
vector<r_OId> RnpClientComm::getOIdsFromCollection | ( | const char * | name | ) | |
throw | ( | r_Error | |||
) |
vector<r_OId> RnpClientComm::getOIdsFromCollection | ( | const r_OId & | oid | ) | |
throw | ( | r_Error | |||
) |
const char* RnpClientComm::getServerName | ( | ) |
get real server name (the dinamic one, assigned by the RasMGR)
int RnpClientComm::getTileData | ( | r_OId | mddOId, |
const char * | tileDomain, | ||
char *& | data, | ||
bool | preallocated = false |
||
) | |||
throw | ( | r_Error | |
) |
vector<r_Minterval> RnpClientComm::getTileDomains | ( | r_OId | mddOId, |
const char * | stripeDomain | ||
) | |||
throw | ( | r_Error | |
) |
int RnpClientComm::getTimeoutInterval | ( | ) |
char* RnpClientComm::getTypeStructure | ( | const char * | typeName, |
r_Type_Type | typeType | ||
) | |||
throw | ( | r_Error | |
) |
get type structure dallocate using delete []
void RnpClientComm::insertColl | ( | const char * | collName, |
const char * | typeName, | ||
const r_OId & | oid | ||
) | |||
throw | ( | r_Error | |
) |
creates an empty MDD collection on the server
void RnpClientComm::insertMDD | ( | const char * | collName, |
r_GMarray * | mar | ||
) | |||
throw | ( | r_Error | |
) |
inserts a MDD object in an existing MDD collection on the server
int RnpClientComm::openDB | ( | const char * | database | ) |
open database
int RnpClientComm::openTA | ( | unsigned short | readOnly = 0 | ) | |
throw | ( | r_Error | |||
) |
begin transaction
void RnpClientComm::preloadTiles | ( | r_OId | mddOId, |
const char * | tileDomain | ||
) | |||
throw | ( | r_Error | |
) |
void RnpClientComm::removeObjFromColl | ( | const char * | name, |
const r_OId & | oid | ||
) | |||
throw | ( | r_Error | |
) |
removes an object from a collection
void RnpClientComm::replaceTileData | ( | r_OId | mddOId, |
const char * | tileDomain, | ||
const char * | newData, | ||
int | dataLength, | ||
const char * | alfaData, | ||
int | alfaLength | ||
) | |||
throw | ( | r_Error | |
) |
void RnpClientComm::sendAliveSignal | ( | ) |
void RnpClientComm::setMaxRetry | ( | unsigned int | newMaxRetry | ) |
set maximum retry to get a server
int RnpClientComm::setStorageFormat | ( | r_Data_Format | format, |
const char * | formatParams = NULL |
||
) |
set the preferred storage format
void RnpClientComm::setTimeoutInterval | ( | int | seconds | ) |
int RnpClientComm::setTransferFormat | ( | r_Data_Format | format, |
const char * | formatParams = NULL |
||
) |
set the preferred transfer format
void RnpClientComm::setTurbo | ( | bool | turbo | ) |
void RnpClientComm::setUserIdentification | ( | const char * | userName, |
const char * | plainTextPassword | ||
) |
user identification for RasMGR
void RnpClientComm::triggerAliveSignal | ( | ) |