72 virtual ~ClientComm() throw();
75 static ClientComm* createObject(const
char* rasmgrName,
int rasmgrPort);
91 static
void useRNP() throw();
92 static
void useRPC() throw();
93 static
bool internalSettingIsRNP() throw();
95 virtual
bool effectivTypeIsRNP() throw() = 0;
103 virtual
int openDB( const
char* database ) = 0;
105 virtual
int closeDB() = 0;
107 virtual
int createDB( const
char* name ) throw(r_Error) = 0;
109 virtual
int destroyDB( const
char* name ) throw(r_Error) = 0;
119 virtual
int openTA(
unsigned short readOnly = 0 ) throw(r_Error) =0;
121 virtual
int commitTA() throw(r_Error) =0;
123 virtual
int abortTA() =0;
133 virtual
void insertMDD( const
char* collName, r_GMarray* mar ) throw( r_Error ) =0;
135 virtual r_Ref_Any getMDDByOId( const r_OId& oid ) throw( r_Error ) =0;
145 virtual
void insertColl( const
char* collName, const
char* typeName, const r_OId& oid ) throw( r_Error ) =0;
147 virtual
void deleteCollByName( const
char* collName ) throw( r_Error ) =0;
149 virtual
void deleteObjByOId( const r_OId& oid ) throw( r_Error ) =0;
151 virtual
void removeObjFromColl( const
char* name, const r_OId& oid ) throw ( r_Error ) =0;
153 virtual r_Ref_Any getCollByName( const
char* name ) throw( r_Error ) =0;
155 virtual r_Ref_Any getCollByOId ( const r_OId& oid ) throw( r_Error ) =0;
157 virtual r_Ref_Any getCollOIdsByName( const
char* name ) throw( r_Error ) =0;
159 virtual r_Ref_Any getCollOIdsByOId ( const r_OId& oid ) throw( r_Error ) =0;
169 virtual
void executeQuery( const r_OQL_Query& query, r_Set< r_Ref_Any >& result ) throw( r_Error ) =0;
177 virtual
void executeQuery( const r_OQL_Query& query ) throw( r_Error ) =0;
191 virtual r_OId getNewOId(
unsigned short objType ) throw(r_Error) = 0;
194 virtual
unsigned short getObjectType( const r_OId& oid ) throw(r_Error) = 0;
204 virtual char* getTypeStructure(
const char* typeName, r_Type_Type typeType )
throw(r_Error) =0;
210 static int changeEndianness( r_GMarray* mdd,
const r_Base_Type* bt=NULL );
212 static int changeEndianness(
const r_GMarray* mdd,
void *newData,
const r_Base_Type* bt=NULL );
215 virtual unsigned long getClientID()
const = 0;
222 virtual void triggerAliveSignal() = 0;
229 virtual void sendAliveSignal() = 0;
237 virtual int setTransferFormat( r_Data_Format format,
const char* formatParams=NULL ) =0;
241 virtual int setStorageFormat( r_Data_Format format,
const char *formatParams=NULL ) =0;
244 virtual const char *getExtendedErrorInfo() throw(r_Error) =0;
247 const
char* getServerName();
250 virtual
void setUserIdentification(const
char *userName, const
char *plainTextPassword) =0;
253 virtual
void setMaxRetry(
unsigned int newMaxRetry) = 0;
256 virtual
unsigned int getMaxRetry() = 0;
259 virtual
void setTimeoutInterval(
int seconds) = 0;
260 virtual
int getTimeoutInterval() = 0;
267 ClientComm() throw( r_Error );
271 static
bool currentProtocolIsRNP;