---

cConnection.h

Go to the documentation of this file.

/******************************************************************************/
/*                                                                            */
/* POLiTe - Persistent Object Library Test                                    */
/*                                        Ph.D. Thesis by Mgr. Michal Kopecky */
/*                                                                            */
/* Charles University Prague                                                  */
/*                                                                            */
/******************************************************************************/
/*                                                                            */
/* File name: ...                                                             */
/* Module: ......                                                             */
/*                                                                            */
/******************************************************************************/

#ifndef __C_CONNECTION_H__
#define __C_CONNECTION_H__

// Common POLiTe Header(s)
#include <lTypes.h>
#include <lExceptions.h>

class DLL_External Connection
{
#ifdef POLITE_TEST_FRIEND
        friend POLITE_TEST_FRIEND;
#endif // POLITE_TEST_FRIEND

friend class Database;
friend class Cursor;
friend class RefBase;
friend class Object;
friend class ProtoBase;
friend class PersistentObject;
friend class ObjectBuffer;
friend class ResultBase;
friend class Relation;
friend class OneToOneRelationBase;
friend class OneToManyRelationBase;
friend class ManyToOneRelationBase;
friend class ManyToManyRelationBase;
friend class ChainedRelationBase;

protected:
        unsigned short _Strategies;
        char *_UserName;                                        //user's login name
        char *_Password;             //user's password
        class Database *_Database;      //the database this connection is
                                                                                        //connected to
        int _Handle;                                            //order in the global table of connections
        int _LocalHandle;                               //order in the local table of connections
        class Cursor *_DefaultCursor;//default cursor;

        virtual bool _Sql(const char * const SqlCommand) = 0;
        virtual bool _Commit() = 0;
        virtual bool _Rollback() = 0;
        virtual bool _Savepoint(const char * const Name) = 0;
        virtual bool _RollbackToSavepoint(const char * const Name) = 0;

        virtual bool _NextOID(long int &nxtoid, long int &nxtsn) = 0;
        // generates new OID and Serial Number for new object
        virtual bool _NextSN(long int curoid, long int &nxtsn) = 0;
        // generates new Serial Number for object

        Connection(
                class Database *DB,
                const char *UserName,
                const char *Password,
                const int LocHandle,
                const int GlobHandle
                );

public:
        ~Connection();


public:
        virtual bool Sql(const char *SqlCommand);
        virtual bool Commit();
        virtual bool Rollback();
        virtual bool Savepoint(const char *Name);
        virtual bool RollbackToSavepoint(const char *Name);
        virtual bool Disconnect();
        virtual bool Abort();
        virtual bool Autocommit(bool ac) = 0;
        virtual Connection &operator << (
                const char *SqlCommand
                );
        Connection &operator << (
                const class Cmd &Command
                );
        //Tests, if the Database connections are the same
        bool operator == (const class Connection &DbConn) const;
        //Tests, if the Database connections are not the same
        bool operator != (const class Connection &DbConn) const;

        // Get and set corresponging patrs of attribute _Strategies
        // that holds all concurency strategies
        virtual enum UpdatingStrategy CurrentUpdatingStrategy() const
        // Returns Update Strategy part of attribute _Strategies
        {
                return (enum UpdatingStrategy)(_Strategies & US_MASK);
        };
        virtual bool SetUpdatingStrategy(enum UpdatingStrategy anUpdateStrategy);
        virtual enum WaitingStrategy CurrentWaitingStrategy() const
        {
                return (enum WaitingStrategy)(_Strategies & WS_MASK);
        };
        virtual bool SetWaitingStrategy(enum WaitingStrategy aWaitingStrategy);
        virtual enum LockingStrategy CurrentLockingStrategy() const
        {
                return (enum LockingStrategy)(_Strategies & LS_MASK);
        };
        virtual bool SetLockingStrategy(enum LockingStrategy aLockingStrategy);
        virtual enum ReadingStrategy CurrentReadingStrategy() const
        {
                return (enum ReadingStrategy)(_Strategies & RS_MASK);
        };
        virtual bool SetReadingStrategy(enum ReadingStrategy aReadingStrategy);

protected:
        char *_GetUserName() {return _UserName;};
        char *_GetPassword() {return _Password;};
        //Obtaining of the new cursor
        virtual class Cursor *_GetNewCursor() = 0;
        //Manipulating with the default cursor
        virtual bool _Open();
        virtual bool _Prepare(const char *SqlCommand);
        virtual bool _PreExecBind(
                const char *const VarName,
                const void *VarAddr,
                const int VarLen,
                const char VarType,
                const short *VarInd = NULL
                );
        virtual bool _Execute();
        virtual bool _PreFetchBind(
                const int Position,
                const void *VarAddr,
                const int VarLen,
                const char VarType,
                const short *VarInd = NULL
                );
        virtual bool _FetchNext();
        virtual bool _FetchPrev();
        virtual bool _Close();
};

#endif //__C_CONNECTION_H__

---