clientcomm.hh

Go to the documentation of this file.

/*
* This file is part of rasdaman community.
*
* Rasdaman community is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* Rasdaman community is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with rasdaman community.  If not, see <http://www.gnu.org/licenses/>.
*
* Copyright 2003, 2004, 2005, 2006, 2007, 2008, 2009 Peter Baumann /
rasdaman GmbH.
*
* For more information please see <http://www.rasdaman.org>
* or contact Peter Baumann via <baumann@rasdaman.com>.
*/
 
#ifndef CLIENTCOMM_HH_
#define CLIENTCOMM_HH_
 
#include "raslib/mddtypes.hh"
 
class r_Database;
class r_Transaction;
class r_OId;
class r_OQL_Query;
class r_GMarray;
template <class T>
class r_Set;
class r_Ref_Any;
class r_Base_Type;
class r_Parse_Params;
 
class ClientComm
{
public:
    virtual ~ClientComm() = default;
 
 
    virtual int openDB(const char *database) = 0;
    virtual int closeDB() = 0;
    virtual int createDB(const char *name) = 0;
    virtual int destroyDB(const char *name) = 0;
 
 
 
    virtual int openTA(unsigned short readOnly = 0) = 0;
    virtual int commitTA() = 0;
    virtual int abortTA() = 0;
 
 
 
    virtual void insertMDD(const char *collName, r_GMarray *mar) = 0;
    virtual r_Ref_Any getMDDByOId(const r_OId &oid) = 0;
 
 
 
    virtual void insertColl(const char *collName, const char *typeName, const r_OId &oid) = 0;
    virtual void deleteCollByName(const char *collName) = 0;
    virtual void deleteObjByOId(const r_OId &oid) = 0;
    virtual void removeObjFromColl(const char *name, const r_OId &oid) = 0;
    virtual r_Ref_Any getCollByName(const char *name) = 0;
    virtual r_Ref_Any getCollByOId(const r_OId &oid) = 0;
    virtual r_Ref_Any getCollOIdsByName(const char *name) = 0;
    virtual r_Ref_Any getCollOIdsByOId(const r_OId &oid) = 0;
 
 
 
    virtual void executeQuery(const r_OQL_Query &query, r_Set<r_Ref_Any> &result) = 0;
 
    virtual void executeQuery(const r_OQL_Query &query) = 0;
 
    virtual void executeQuery(const r_OQL_Query &query, r_Set<r_Ref_Any> &result, int dummy) = 0;
 
 
 
    virtual r_OId getNewOId(unsigned short objType) = 0;
 
    virtual unsigned short getObjectType(const r_OId &oid) = 0;
 
    enum r_Type_Type
    {
        r_SetType_Type = 1,
        r_MDDType_Type = 2
    };
 
    virtual char *getTypeStructure(const char *typeName, r_Type_Type typeType) = 0;
 
 
 
    virtual int setTransferFormat(r_Data_Format format, const char *formatParams = NULL) = 0;
 
    virtual int setStorageFormat(r_Data_Format format, const char *formatParams = NULL) = 0;
 
    virtual void setUserIdentification(const char *userName, const char *plainTextPassword) = 0;
 
    virtual void setMaxRetry(unsigned int newMaxRetry) = 0;
    virtual unsigned int getMaxRetry() = 0;
 
    virtual void setTimeoutInterval(int seconds) = 0;
    virtual int getTimeoutInterval() = 0;
 
    void setDatabase(r_Database *database);
    void setTransaction(r_Transaction *transaction);
    virtual void updateTransaction();
 
 
protected:
    ClientComm() = default;
 
    r_Database *database;
 
    r_Transaction *transaction;
};
 
 
#endif